Package io.deephaven.proto.backplane.grpc

Class SessionServiceGrpc

java.lang.Object

io.deephaven.proto.backplane.grpc.SessionServiceGrpc

@Generated(value="by gRPC proto compiler (version 1.63.1)",
           comments="Source: deephaven/proto/session.proto")
public final class SessionServiceGrpc
extends Object

 User supplied Flight.Ticket(s) should begin with 'e' byte followed by an signed little-endian int. The client is only
 allowed to use the positive exportId key-space (client generated exportIds should be greater than 0). The client is
 encouraged to use a packed ranges of ids as this yields the smallest footprint server side for long running sessions.
 The client is responsible for releasing all Flight.Tickets that they create or that were created for them via a gRPC
 call. The documentation for the gRPC call will indicate that the exports must be released. Exports that need to be
 released will always be communicated over the session's ExportNotification stream.
 When a session ends, either explicitly or due to timeout, all exported objects in that session are released
 automatically.
 Some parts of the API return a Flight.Ticket that does not need to be released. It is not an error to attempt to
 release them.
 

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	SessionServiceGrpc.AsyncService	User supplied Flight.Ticket(s) should begin with 'e' byte followed by an signed little-endian int.
static final class	SessionServiceGrpc.SessionServiceBlockingStub	A stub to allow clients to do synchronous rpc calls to service SessionService.
static final class	SessionServiceGrpc.SessionServiceFutureStub	A stub to allow clients to do ListenableFuture-style rpc calls to service SessionService.
static class	SessionServiceGrpc.SessionServiceImplBase	Base class for the server implementation of the service SessionService.
static final class	SessionServiceGrpc.SessionServiceStub	A stub to allow clients to do asynchronous rpc calls to service SessionService.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	SERVICE_NAME

Method Summary

Modifier and Type	Method	Description
static final io.grpc.ServerServiceDefinition	bindService(SessionServiceGrpc.AsyncService service)
static io.grpc.MethodDescriptor<HandshakeRequest,CloseSessionResponse>	getCloseSessionMethod()
static io.grpc.MethodDescriptor<ExportRequest,ExportResponse>	getExportFromTicketMethod()
static io.grpc.MethodDescriptor<ExportNotificationRequest,ExportNotification>	getExportNotificationsMethod()
static io.grpc.MethodDescriptor<HandshakeRequest,HandshakeResponse>	getNewSessionMethod()
static io.grpc.MethodDescriptor<PublishRequest,PublishResponse>	getPublishFromTicketMethod()
static io.grpc.MethodDescriptor<HandshakeRequest,HandshakeResponse>	getRefreshSessionTokenMethod()
static io.grpc.MethodDescriptor<ReleaseRequest,ReleaseResponse>	getReleaseMethod()
static io.grpc.ServiceDescriptor	getServiceDescriptor()
static io.grpc.MethodDescriptor<TerminationNotificationRequest,TerminationNotificationResponse>	getTerminationNotificationMethod()
static SessionServiceGrpc.SessionServiceBlockingStub	newBlockingStub(io.grpc.Channel channel)	Creates a new blocking-style stub that supports unary and streaming output calls on the service
static SessionServiceGrpc.SessionServiceFutureStub	newFutureStub(io.grpc.Channel channel)	Creates a new ListenableFuture-style stub that supports unary calls on the service
static SessionServiceGrpc.SessionServiceStub	newStub(io.grpc.Channel channel)	Creates a new async stub that supports all call types for the service

Methods inherited from class java.lang.Object

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

Field Details

SERVICE_NAME

public static final String SERVICE_NAME

See Also:

• Constant Field Values

Method Details

getNewSessionMethod

public static io.grpc.MethodDescriptor<HandshakeRequest,HandshakeResponse> getNewSessionMethod()

getRefreshSessionTokenMethod

public static io.grpc.MethodDescriptor<HandshakeRequest,HandshakeResponse> getRefreshSessionTokenMethod()

getCloseSessionMethod

public static io.grpc.MethodDescriptor<HandshakeRequest,CloseSessionResponse> getCloseSessionMethod()

getReleaseMethod

public static io.grpc.MethodDescriptor<ReleaseRequest,ReleaseResponse> getReleaseMethod()

getExportFromTicketMethod

public static io.grpc.MethodDescriptor<ExportRequest,ExportResponse> getExportFromTicketMethod()

getPublishFromTicketMethod

public static io.grpc.MethodDescriptor<PublishRequest,PublishResponse> getPublishFromTicketMethod()

getExportNotificationsMethod

public static io.grpc.MethodDescriptor<ExportNotificationRequest,ExportNotification> getExportNotificationsMethod()

getTerminationNotificationMethod

public static io.grpc.MethodDescriptor<TerminationNotificationRequest,TerminationNotificationResponse> getTerminationNotificationMethod()

newStub

public static SessionServiceGrpc.SessionServiceStub newStub(io.grpc.Channel channel)

Creates a new async stub that supports all call types for the service

newBlockingStub

public static SessionServiceGrpc.SessionServiceBlockingStub newBlockingStub(io.grpc.Channel channel)

Creates a new blocking-style stub that supports unary and streaming output calls on the service

newFutureStub

public static SessionServiceGrpc.SessionServiceFutureStub newFutureStub(io.grpc.Channel channel)

Creates a new ListenableFuture-style stub that supports unary calls on the service

bindService

public static final io.grpc.ServerServiceDefinition bindService(SessionServiceGrpc.AsyncService service)

getServiceDescriptor

public static io.grpc.ServiceDescriptor getServiceDescriptor()