Package io.deephaven.proto.controller.grpc

Interface ControllerApiGrpc.AsyncService

All Known Implementing Classes:

ControllerApiGrpc.ControllerApiImplBase

Enclosing class:

ControllerApiGrpc

public static interface ControllerApiGrpc.AsyncService

Method Summary

Modifier and Type	Method	Description
default void	addQuery(AddQueryRequest request, io.grpc.stub.StreamObserver<AddQueryResponse> responseObserver)	These are for query management
default void	authenticate(AuthenticationRequest request, io.grpc.stub.StreamObserver<AuthenticationResponse> responseObserver)	Given a token and client ID from the auth service, authenticate and return a cookie for future use on this service.
default void	deserializeQueryConfiguration(DeserializeQueryConfigurationRequest request, io.grpc.stub.StreamObserver<DeserializeQueryConfigurationResponse> responseObserver)
default void	determineDispatcher(DetermineDispatcherRequest request, io.grpc.stub.StreamObserver<DetermineDispatcherResponse> responseObserver)
default void	getConfiguration(GetConfigurationRequest request, io.grpc.stub.StreamObserver<GetConfigurationResponse> responseObserver)	Simple unary to request the current configuration, as an alternative to having it pushed via subscribe, or requesting it on authenticate.
default void	getScript(GetScriptRequest request, io.grpc.stub.StreamObserver<GetScriptResponse> responseObserver)
default void	getScriptPaths(GetScriptPathsRequest request, io.grpc.stub.StreamObserver<GetScriptPathsResponse> responseObserver)	Script commands
default void	invalidateCookie(InvalidateCookieRequest request, io.grpc.stub.StreamObserver<InvalidateCookieResponse> responseObserver)
default void	modifyQuery(ModifyQueryRequest request, io.grpc.stub.StreamObserver<ModifyQueryResponse> responseObserver)
default void	ping(PingRequest request, io.grpc.stub.StreamObserver<PingResponse> responseObserver)	Simple no-op to verify connectivity.
default void	reloadConfig(ReloadConfigRequest request, io.grpc.stub.StreamObserver<ReloadConfigResponse> responseObserver)
default void	removeQuery(RemoveQueryRequest request, io.grpc.stub.StreamObserver<RemoveQueryResponse> responseObserver)
default void	restartQuery(RestartQueryRequest request, io.grpc.stub.StreamObserver<RestartQueryResponse> responseObserver)
default void	restartReplica(RestartReplicaRequest request, io.grpc.stub.StreamObserver<RestartReplicaResponse> responseObserver)
default void	selectionProviderAdmin(ServerSelectionAdminRequest request, io.grpc.stub.StreamObserver<ServerSelectionAdminResponse> responseObserver)
default void	selectionProviderStatus(ServerSelectionStatusRequest request, io.grpc.stub.StreamObserver<ServerSelectionStatusResponse> responseObserver)
default void	serializeQueryConfiguration(SerializeQueryConfigurationRequest request, io.grpc.stub.StreamObserver<SerializeQueryConfigurationResponse> responseObserver)	XML import and export
default void	statusUpdate(StatusUpdateRequest request, io.grpc.stub.StreamObserver<StatusUpdateResponse> responseObserver)	Configuration commands
default void	stopQuery(StopQueryRequest request, io.grpc.stub.StreamObserver<StopQueryResponse> responseObserver)
default void	stopReplica(StopReplicaRequest request, io.grpc.stub.StreamObserver<StopReplicaResponse> responseObserver)
default void	subscribe(SubscribeRequest request, io.grpc.stub.StreamObserver<SubscribeResponse> responseObserver)	Subscribes to a stream of query configuration/state changes, as well as controller configuration changes.

Method Details

authenticate

default void authenticate(AuthenticationRequest request,
 io.grpc.stub.StreamObserver<AuthenticationResponse> responseObserver)

 Given a token and client ID from the auth service, authenticate and return a cookie for future use on this
 service. Optionally will send controller configuration.
 

addQuery

default void addQuery(AddQueryRequest request,
 io.grpc.stub.StreamObserver<AddQueryResponse> responseObserver)

 These are for query management
 

removeQuery

default void removeQuery(RemoveQueryRequest request,
 io.grpc.stub.StreamObserver<RemoveQueryResponse> responseObserver)

modifyQuery

default void modifyQuery(ModifyQueryRequest request,
 io.grpc.stub.StreamObserver<ModifyQueryResponse> responseObserver)

restartQuery

default void restartQuery(RestartQueryRequest request,
 io.grpc.stub.StreamObserver<RestartQueryResponse> responseObserver)

stopQuery

default void stopQuery(StopQueryRequest request,
 io.grpc.stub.StreamObserver<StopQueryResponse> responseObserver)

restartReplica

default void restartReplica(RestartReplicaRequest request,
 io.grpc.stub.StreamObserver<RestartReplicaResponse> responseObserver)

stopReplica

default void stopReplica(StopReplicaRequest request,
 io.grpc.stub.StreamObserver<StopReplicaResponse> responseObserver)

determineDispatcher

default void determineDispatcher(DetermineDispatcherRequest request,
 io.grpc.stub.StreamObserver<DetermineDispatcherResponse> responseObserver)

selectionProviderStatus

default void selectionProviderStatus(ServerSelectionStatusRequest request,
 io.grpc.stub.StreamObserver<ServerSelectionStatusResponse> responseObserver)

selectionProviderAdmin

default void selectionProviderAdmin(ServerSelectionAdminRequest request,
 io.grpc.stub.StreamObserver<ServerSelectionAdminResponse> responseObserver)

getConfiguration

default void getConfiguration(GetConfigurationRequest request,
 io.grpc.stub.StreamObserver<GetConfigurationResponse> responseObserver)

 Simple unary to request the current configuration, as an alternative to having it pushed via subscribe, or
 requesting it on authenticate.
 

getScriptPaths

default void getScriptPaths(GetScriptPathsRequest request,
 io.grpc.stub.StreamObserver<GetScriptPathsResponse> responseObserver)

 Script commands
 

getScript

default void getScript(GetScriptRequest request,
 io.grpc.stub.StreamObserver<GetScriptResponse> responseObserver)

statusUpdate

default void statusUpdate(StatusUpdateRequest request,
 io.grpc.stub.StreamObserver<StatusUpdateResponse> responseObserver)

 Configuration commands
 

reloadConfig

default void reloadConfig(ReloadConfigRequest request,
 io.grpc.stub.StreamObserver<ReloadConfigResponse> responseObserver)

ping

default void ping(PingRequest request,
 io.grpc.stub.StreamObserver<PingResponse> responseObserver)

 Simple no-op to verify connectivity. The server will terminate sessions after some idle time (default of one minute),
 so clients should ping at some interval less than that, such as every 10 seconds.
 

subscribe

default void subscribe(SubscribeRequest request,
 io.grpc.stub.StreamObserver<SubscribeResponse> responseObserver)

 Subscribes to a stream of query configuration/state changes, as well as controller configuration changes. As the stream
 starts, the current configuration will be sent, along with the current state of all queries.
 

invalidateCookie

default void invalidateCookie(InvalidateCookieRequest request,
 io.grpc.stub.StreamObserver<InvalidateCookieResponse> responseObserver)

serializeQueryConfiguration

default void serializeQueryConfiguration(SerializeQueryConfigurationRequest request,
 io.grpc.stub.StreamObserver<SerializeQueryConfigurationResponse> responseObserver)

 XML import and export
 

deserializeQueryConfiguration

default void deserializeQueryConfiguration(DeserializeQueryConfigurationRequest request,
 io.grpc.stub.StreamObserver<DeserializeQueryConfigurationResponse> responseObserver)