Package io.deephaven.proto.controller.grpc

Class ControllerApiGrpc.ControllerApiStub

java.lang.Object

io.deephaven.shadow.core.io.grpc.stub.AbstractStub<S>

io.deephaven.shadow.core.io.grpc.stub.AbstractAsyncStub<ControllerApiGrpc.ControllerApiStub>

io.deephaven.proto.controller.grpc.ControllerApiGrpc.ControllerApiStub

Enclosing class:

ControllerApiGrpc

public static final class ControllerApiGrpc.ControllerApiStub
extends io.deephaven.shadow.core.io.grpc.stub.AbstractAsyncStub<ControllerApiGrpc.ControllerApiStub>

A stub to allow clients to do asynchronous rpc calls to service ControllerApi.

Nested Class Summary

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

io.deephaven.shadow.core.io.grpc.stub.AbstractStub.StubFactory<T extends io.deephaven.shadow.core.io.grpc.stub.AbstractStub<T>>

Method Summary

Modifier and Type	Method	Description
void	addQuery(AddQueryRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<AddQueryResponse> responseObserver)	These are for query management
void	authenticate(AuthenticationRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<AuthenticationResponse> responseObserver)	Authentication
protected ControllerApiGrpc.ControllerApiStub	build(io.deephaven.shadow.core.io.grpc.Channel channel, io.deephaven.shadow.core.io.grpc.CallOptions callOptions)
void	determineDispatcher(DetermineDispatcherRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<DetermineDispatcherResponse> responseObserver)
void	getConfiguration(GetConfigurationRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<GetConfigurationResponse> responseObserver)
void	getScript(GetScriptRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<GetScriptResponse> responseObserver)
void	getScriptPaths(GetScriptPathsRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<GetScriptPathsResponse> responseObserver)	Script commands
void	invalidateCookie(InvalidateCookieRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<InvalidateCookieResponse> responseObserver)
void	modifyQuery(ModifyQueryRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<ModifyQueryResponse> responseObserver)
void	ping(PingRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<PingResponse> responseObserver)	Heartbeating
void	reloadConfig(ReloadConfigRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<ReloadConfigResponse> responseObserver)
void	removeQuery(RemoveQueryRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<RemoveQueryResponse> responseObserver)
void	restartQuery(RestartQueryRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<RestartQueryResponse> responseObserver)
void	restartReplica(RestartReplicaRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<RestartReplicaResponse> responseObserver)
void	selectionProviderAdmin(ServerSelectionAdminRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<ServerSelectionAdminResponse> responseObserver)
void	selectionProviderStatus(ServerSelectionStatusRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<ServerSelectionStatusResponse> responseObserver)
void	statusUpdate(StatusUpdateRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<StatusUpdateResponse> responseObserver)	Configuration commands
void	stopQuery(StopQueryRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<StopQueryResponse> responseObserver)
void	stopReplica(StopReplicaRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<StopReplicaResponse> responseObserver)
void	subscribe(SubscribeRequest request, io.deephaven.shadow.core.io.grpc.stub.StreamObserver<SubscribeResponse> responseObserver)

Methods inherited from class io.deephaven.shadow.core.io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.deephaven.shadow.core.io.grpc.stub.AbstractStub

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

Methods inherited from class java.lang.Object

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

Method Details

build

protected ControllerApiGrpc.ControllerApiStub build(io.deephaven.shadow.core.io.grpc.Channel channel,
 io.deephaven.shadow.core.io.grpc.CallOptions callOptions)

Specified by:

build in class io.deephaven.shadow.core.io.grpc.stub.AbstractStub<ControllerApiGrpc.ControllerApiStub>

authenticate

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

 Authentication
 

addQuery

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

 These are for query management
 

removeQuery

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

modifyQuery

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

restartQuery

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

stopQuery

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

restartReplica

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

stopReplica

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

determineDispatcher

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

selectionProviderStatus

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

selectionProviderAdmin

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

getConfiguration

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

getScriptPaths

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

 Script commands
 

getScript

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

statusUpdate

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

 Configuration commands
 

reloadConfig

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

ping

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

 Heartbeating
 

subscribe

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

invalidateCookie

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