Package com.google.cloud.ces.v1beta

Class SessionServiceGrpc.SessionServiceBlockingStub

java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractBlockingStub<SessionServiceGrpc.SessionServiceBlockingStub>
com.google.cloud.ces.v1beta.SessionServiceGrpc.SessionServiceBlockingStub
Enclosing class:
SessionServiceGrpc
public static final class SessionServiceGrpc.SessionServiceBlockingStub extends io.grpc.stub.AbstractBlockingStub<SessionServiceGrpc.SessionServiceBlockingStub>
A stub to allow clients to do limited synchronous rpc calls to service SessionService. 
 Session service provides APIs for interacting with CES agents.

  • Nested Class Summary

    Nested classes/interfaces inherited from class io.grpc.stub.AbstractStub

    io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

  • Method Summary

    Modifier and Type
    Method
    Description
    protected SessionServiceGrpc.SessionServiceBlockingStub
    build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
     
    RunSessionResponse
    runSession(RunSessionRequest request)
    Initiates a single-turn interaction with the CES agent within a session.
    Iterator<RunSessionResponse>
    streamRunSession(RunSessionRequest request)
    Initiates a single-turn interaction with the CES agent.

    Methods inherited from class io.grpc.stub.AbstractBlockingStub

    newStub, newStub

    Methods inherited from class io.grpc.stub.AbstractStub

    getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • build

      protected SessionServiceGrpc.SessionServiceBlockingStub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
      Specified by:
      build in class io.grpc.stub.AbstractStub<SessionServiceGrpc.SessionServiceBlockingStub>

    • runSession

      public RunSessionResponse runSession(RunSessionRequest request)
       Initiates a single-turn interaction with the CES agent within a session.

    • streamRunSession

      public Iterator<RunSessionResponse> streamRunSession(RunSessionRequest request)
       Initiates a single-turn interaction with the CES agent. Uses server-side
 streaming to deliver incremental results and partial responses as they are
 generated.
 By default, complete responses (e.g., messages from callbacks or full LLM
 responses) are sent to the client as soon as they are available. To enable
 streaming individual text chunks directly from the model, set
 [enable_text_streaming][google.cloud.ces.v1beta.SessionConfig.enable_text_streaming]
 to true.