Package io.deephaven.proto.controller.grpc

Class ControllerApiGrpc.ControllerApiBlockingV2Stub

java.lang.Object

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

io.deephaven.shadow.core.io.grpc.stub.AbstractBlockingStub<ControllerApiGrpc.ControllerApiBlockingV2Stub>

io.deephaven.proto.controller.grpc.ControllerApiGrpc.ControllerApiBlockingV2Stub

Enclosing class:

ControllerApiGrpc

public static final class ControllerApiGrpc.ControllerApiBlockingV2Stub
extends io.deephaven.shadow.core.io.grpc.stub.AbstractBlockingStub<ControllerApiGrpc.ControllerApiBlockingV2Stub>

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

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

newStub, newStub

Methods inherited from class io.deephaven.shadow.core.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.ControllerApiBlockingV2Stub 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.ControllerApiBlockingV2Stub>

authenticate

public AuthenticationResponse authenticate(AuthenticationRequest request)
                                    throws io.deephaven.shadow.core.io.grpc.StatusException

 Authentication
 

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

addQuery

public AddQueryResponse addQuery(AddQueryRequest request)
                          throws io.deephaven.shadow.core.io.grpc.StatusException

 These are for query management
 

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

removeQuery

public RemoveQueryResponse removeQuery(RemoveQueryRequest request)
                                throws io.deephaven.shadow.core.io.grpc.StatusException

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

modifyQuery

public ModifyQueryResponse modifyQuery(ModifyQueryRequest request)
                                throws io.deephaven.shadow.core.io.grpc.StatusException

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

restartQuery

public RestartQueryResponse restartQuery(RestartQueryRequest request)
                                  throws io.deephaven.shadow.core.io.grpc.StatusException

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

stopQuery

public StopQueryResponse stopQuery(StopQueryRequest request)
                            throws io.deephaven.shadow.core.io.grpc.StatusException

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

restartReplica

public RestartReplicaResponse restartReplica(RestartReplicaRequest request)
                                      throws io.deephaven.shadow.core.io.grpc.StatusException

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

stopReplica

public StopReplicaResponse stopReplica(StopReplicaRequest request)
                                throws io.deephaven.shadow.core.io.grpc.StatusException

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

determineDispatcher

public DetermineDispatcherResponse determineDispatcher(DetermineDispatcherRequest request)
                                                throws io.deephaven.shadow.core.io.grpc.StatusException

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

selectionProviderStatus

public ServerSelectionStatusResponse selectionProviderStatus(ServerSelectionStatusRequest request)
                                                      throws io.deephaven.shadow.core.io.grpc.StatusException

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

selectionProviderAdmin

public ServerSelectionAdminResponse selectionProviderAdmin(ServerSelectionAdminRequest request)
                                                    throws io.deephaven.shadow.core.io.grpc.StatusException

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

getConfiguration

public GetConfigurationResponse getConfiguration(GetConfigurationRequest request)
                                          throws io.deephaven.shadow.core.io.grpc.StatusException

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

getScriptPaths

public GetScriptPathsResponse getScriptPaths(GetScriptPathsRequest request)
                                      throws io.deephaven.shadow.core.io.grpc.StatusException

 Script commands
 

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

getScript

public GetScriptResponse getScript(GetScriptRequest request)
                            throws io.deephaven.shadow.core.io.grpc.StatusException

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

statusUpdate

public StatusUpdateResponse statusUpdate(StatusUpdateRequest request)
                                  throws io.deephaven.shadow.core.io.grpc.StatusException

 Configuration commands
 

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

reloadConfig

public ReloadConfigResponse reloadConfig(ReloadConfigRequest request)
                                  throws io.deephaven.shadow.core.io.grpc.StatusException

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

ping

public PingResponse ping(PingRequest request)
                  throws io.deephaven.shadow.core.io.grpc.StatusException

 Heartbeating
 

Throws:

io.deephaven.shadow.core.io.grpc.StatusException

subscribe

@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918")
public io.deephaven.shadow.core.io.grpc.stub.BlockingClientCall<?,SubscribeResponse> subscribe(SubscribeRequest request)

invalidateCookie

public InvalidateCookieResponse invalidateCookie(InvalidateCookieRequest request)
                                          throws io.deephaven.shadow.core.io.grpc.StatusException

Throws:

io.deephaven.shadow.core.io.grpc.StatusException