Package io.deephaven.proto.controller.grpc

Class ControllerApiGrpc.ControllerApiBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<ControllerApiGrpc.ControllerApiBlockingStub>

io.deephaven.proto.controller.grpc.ControllerApiGrpc.ControllerApiBlockingStub

Enclosing class:

ControllerApiGrpc

public static final class ControllerApiGrpc.ControllerApiBlockingStub
extends io.grpc.stub.AbstractBlockingStub<ControllerApiGrpc.ControllerApiBlockingStub>

A stub to allow clients to do limited synchronous 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
AddQueryResponse	addQuery(AddQueryRequest request)	These are for query management
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.ControllerApiBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
DeserializeQueryConfigurationResponse	deserializeQueryConfiguration(DeserializeQueryConfigurationRequest request)
DetermineDispatcherResponse	determineDispatcher(DetermineDispatcherRequest request)
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.
GetScriptResponse	getScript(GetScriptRequest request)
GetScriptPathsResponse	getScriptPaths(GetScriptPathsRequest request)	Script commands
InvalidateCookieResponse	invalidateCookie(InvalidateCookieRequest request)
ModifyQueryResponse	modifyQuery(ModifyQueryRequest request)
PingResponse	ping(PingRequest request)	Simple no-op to verify connectivity.
ReloadConfigResponse	reloadConfig(ReloadConfigRequest request)
RemoveQueryResponse	removeQuery(RemoveQueryRequest request)
RestartQueryResponse	restartQuery(RestartQueryRequest request)
RestartReplicaResponse	restartReplica(RestartReplicaRequest request)
ServerSelectionAdminResponse	selectionProviderAdmin(ServerSelectionAdminRequest request)
ServerSelectionStatusResponse	selectionProviderStatus(ServerSelectionStatusRequest request)
SerializeQueryConfigurationResponse	serializeQueryConfiguration(SerializeQueryConfigurationRequest request)	XML import and export
StatusUpdateResponse	statusUpdate(StatusUpdateRequest request)	Configuration commands
StopQueryResponse	stopQuery(StopQueryRequest request)
StopReplicaResponse	stopReplica(StopReplicaRequest request)
Iterator<SubscribeResponse>	subscribe(SubscribeRequest request)	Subscribes to a stream of query configuration/state changes, as well as controller configuration changes.

Methods inherited from class io.grpc.stub.AbstractBlockingStub

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.ControllerApiBlockingStub build(io.grpc.Channel channel,
 io.grpc.CallOptions callOptions)

Specified by:

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

authenticate

public 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 AddQueryResponse addQuery(AddQueryRequest request)

 These are for query management
 

removeQuery

public RemoveQueryResponse removeQuery(RemoveQueryRequest request)

modifyQuery

public ModifyQueryResponse modifyQuery(ModifyQueryRequest request)

restartQuery

public RestartQueryResponse restartQuery(RestartQueryRequest request)

stopQuery

public StopQueryResponse stopQuery(StopQueryRequest request)

restartReplica

public RestartReplicaResponse restartReplica(RestartReplicaRequest request)

stopReplica

public StopReplicaResponse stopReplica(StopReplicaRequest request)

determineDispatcher

public DetermineDispatcherResponse determineDispatcher(DetermineDispatcherRequest request)

selectionProviderStatus

public ServerSelectionStatusResponse selectionProviderStatus(ServerSelectionStatusRequest request)

selectionProviderAdmin

public ServerSelectionAdminResponse selectionProviderAdmin(ServerSelectionAdminRequest request)

getConfiguration

public 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 GetScriptPathsResponse getScriptPaths(GetScriptPathsRequest request)

 Script commands
 

getScript

public GetScriptResponse getScript(GetScriptRequest request)

statusUpdate

public StatusUpdateResponse statusUpdate(StatusUpdateRequest request)

 Configuration commands
 

reloadConfig

public ReloadConfigResponse reloadConfig(ReloadConfigRequest request)

ping

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

subscribe

public Iterator<SubscribeResponse> subscribe(SubscribeRequest request)

 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

public InvalidateCookieResponse invalidateCookie(InvalidateCookieRequest request)

serializeQueryConfiguration

public SerializeQueryConfigurationResponse serializeQueryConfiguration(SerializeQueryConfigurationRequest request)

 XML import and export
 

deserializeQueryConfiguration

public DeserializeQueryConfigurationResponse deserializeQueryConfiguration(DeserializeQueryConfigurationRequest request)