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.deephaven.shadow.core.io.grpc.stub.StreamObserver<AddQueryResponse> responseObserver)	These are for query management
default void	authenticate(AuthenticationRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<AuthenticationResponse> responseObserver)	Authentication
default void	determineDispatcher(DetermineDispatcherRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<DetermineDispatcherResponse> responseObserver)
default void	getConfiguration(GetConfigurationRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<GetConfigurationResponse> responseObserver)
default void	getScript(GetScriptRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<GetScriptResponse> responseObserver)
default void	getScriptPaths(GetScriptPathsRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<GetScriptPathsResponse> responseObserver)	Script commands
default void	invalidateCookie(InvalidateCookieRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<InvalidateCookieResponse> responseObserver)
default void	modifyQuery(ModifyQueryRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<ModifyQueryResponse> responseObserver)
default void	ping(PingRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<PingResponse> responseObserver)	Heartbeating
default void	reloadConfig(ReloadConfigRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<ReloadConfigResponse> responseObserver)
default void	removeQuery(RemoveQueryRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<RemoveQueryResponse> responseObserver)
default void	restartQuery(RestartQueryRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<RestartQueryResponse> responseObserver)
default void	restartReplica(RestartReplicaRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<RestartReplicaResponse> responseObserver)
default void	selectionProviderAdmin(ServerSelectionAdminRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<ServerSelectionAdminResponse> responseObserver)
default void	selectionProviderStatus(ServerSelectionStatusRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<ServerSelectionStatusResponse> responseObserver)
default void	statusUpdate(StatusUpdateRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<StatusUpdateResponse> responseObserver)	Configuration commands
default void	stopQuery(StopQueryRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<StopQueryResponse> responseObserver)
default void	stopReplica(StopReplicaRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<StopReplicaResponse> responseObserver)
default void	subscribe(SubscribeRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<SubscribeResponse> responseObserver)

Method Details

authenticate

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

 Authentication
 

addQuery

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

 These are for query management
 

removeQuery

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

modifyQuery

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

restartQuery

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

stopQuery

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

restartReplica

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

stopReplica

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

determineDispatcher

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

selectionProviderStatus

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

selectionProviderAdmin

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

getConfiguration

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

getScriptPaths

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

 Script commands
 

getScript

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

statusUpdate

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

 Configuration commands
 

reloadConfig

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

ping

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

 Heartbeating
 

subscribe

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

invalidateCookie

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