Package io.deephaven.proto.controller.grpc

Class ControllerApiGrpc.ControllerApiFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<ControllerApiGrpc.ControllerApiFutureStub>

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

Enclosing class:

ControllerApiGrpc

public static final class ControllerApiGrpc.ControllerApiFutureStub
extends 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.grpc.stub.AbstractStub

io.grpc.stub.AbstractStub.StubFactory<T extends io.grpc.stub.AbstractStub<T>>

Method Summary

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

Methods inherited from class io.grpc.stub.AbstractFutureStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, 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.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

build in class io.grpc.stub.AbstractStub<ControllerApiGrpc.ControllerApiFutureStub>

authenticate

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

 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

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

 These are for query management
 

removeQuery

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

modifyQuery

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

restartQuery

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

stopQuery

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

restartReplica

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

stopReplica

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

determineDispatcher

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

selectionProviderStatus

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

selectionProviderAdmin

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

getConfiguration

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

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

getScriptPaths

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

 Script commands
 

getScript

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

statusUpdate

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

 Configuration commands
 

reloadConfig

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

ping

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

 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.
 

invalidateCookie

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

serializeQueryConfiguration

public com.google.common.util.concurrent.ListenableFuture<SerializeQueryConfigurationResponse> serializeQueryConfiguration(SerializeQueryConfigurationRequest request)

 XML import and export
 

deserializeQueryConfiguration

public com.google.common.util.concurrent.ListenableFuture<DeserializeQueryConfigurationResponse> deserializeQueryConfiguration(DeserializeQueryConfigurationRequest request)