Package io.deephaven.proto.controller.grpc

Class ControllerApiGrpc.ControllerApiFutureStub

java.lang.Object

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

io.deephaven.shadow.core.io.grpc.stub.AbstractFutureStub<ControllerApiGrpc.ControllerApiFutureStub>

io.deephaven.proto.controller.grpc.ControllerApiGrpc.ControllerApiFutureStub

Enclosing class:

ControllerApiGrpc

public static final class ControllerApiGrpc.ControllerApiFutureStub
extends io.deephaven.shadow.core.io.grpc.stub.AbstractFutureStub<ControllerApiGrpc.ControllerApiFutureStub>

A stub to allow clients to do ListenableFuture-style 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
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<AddQueryResponse>	addQuery(AddQueryRequest request)	These are for query management
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<AuthenticationResponse>	authenticate(AuthenticationRequest request)	Authentication
protected ControllerApiGrpc.ControllerApiFutureStub	build(io.deephaven.shadow.core.io.grpc.Channel channel, io.deephaven.shadow.core.io.grpc.CallOptions callOptions)
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<DetermineDispatcherResponse>	determineDispatcher(DetermineDispatcherRequest request)
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<GetConfigurationResponse>	getConfiguration(GetConfigurationRequest request)
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<GetScriptResponse>	getScript(GetScriptRequest request)
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<GetScriptPathsResponse>	getScriptPaths(GetScriptPathsRequest request)	Script commands
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<InvalidateCookieResponse>	invalidateCookie(InvalidateCookieRequest request)
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<ModifyQueryResponse>	modifyQuery(ModifyQueryRequest request)
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<PingResponse>	ping(PingRequest request)	Heartbeating
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<ReloadConfigResponse>	reloadConfig(ReloadConfigRequest request)
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<RemoveQueryResponse>	removeQuery(RemoveQueryRequest request)
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<RestartQueryResponse>	restartQuery(RestartQueryRequest request)
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<RestartReplicaResponse>	restartReplica(RestartReplicaRequest request)
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<ServerSelectionAdminResponse>	selectionProviderAdmin(ServerSelectionAdminRequest request)
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<ServerSelectionStatusResponse>	selectionProviderStatus(ServerSelectionStatusRequest request)
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<StatusUpdateResponse>	statusUpdate(StatusUpdateRequest request)	Configuration commands
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<StopQueryResponse>	stopQuery(StopQueryRequest request)
io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<StopReplicaResponse>	stopReplica(StopReplicaRequest request)

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

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.ControllerApiFutureStub 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.ControllerApiFutureStub>

authenticate

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<AuthenticationResponse> authenticate(AuthenticationRequest request)

 Authentication
 

addQuery

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<AddQueryResponse> addQuery(AddQueryRequest request)

 These are for query management
 

removeQuery

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<RemoveQueryResponse> removeQuery(RemoveQueryRequest request)

modifyQuery

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<ModifyQueryResponse> modifyQuery(ModifyQueryRequest request)

restartQuery

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<RestartQueryResponse> restartQuery(RestartQueryRequest request)

stopQuery

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<StopQueryResponse> stopQuery(StopQueryRequest request)

restartReplica

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<RestartReplicaResponse> restartReplica(RestartReplicaRequest request)

stopReplica

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<StopReplicaResponse> stopReplica(StopReplicaRequest request)

determineDispatcher

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<DetermineDispatcherResponse> determineDispatcher(DetermineDispatcherRequest request)

selectionProviderStatus

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<ServerSelectionStatusResponse> selectionProviderStatus(ServerSelectionStatusRequest request)

selectionProviderAdmin

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<ServerSelectionAdminResponse> selectionProviderAdmin(ServerSelectionAdminRequest request)

getConfiguration

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<GetConfigurationResponse> getConfiguration(GetConfigurationRequest request)

getScriptPaths

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<GetScriptPathsResponse> getScriptPaths(GetScriptPathsRequest request)

 Script commands
 

getScript

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<GetScriptResponse> getScript(GetScriptRequest request)

statusUpdate

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<StatusUpdateResponse> statusUpdate(StatusUpdateRequest request)

 Configuration commands
 

reloadConfig

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<ReloadConfigResponse> reloadConfig(ReloadConfigRequest request)

ping

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<PingResponse> ping(PingRequest request)

 Heartbeating
 

invalidateCookie

public io.deephaven.shadow.core.com.google.common.util.concurrent.ListenableFuture<InvalidateCookieResponse> invalidateCookie(InvalidateCookieRequest request)