Class ConsoleServiceGrpc.ConsoleServiceBlockingV2Stub
java.lang.Object
io.grpc.stub.AbstractStub<S>
io.grpc.stub.AbstractBlockingStub<ConsoleServiceGrpc.ConsoleServiceBlockingV2Stub>
io.deephaven.proto.backplane.script.grpc.ConsoleServiceGrpc.ConsoleServiceBlockingV2Stub
- Enclosing class:
- ConsoleServiceGrpc
public static final class ConsoleServiceGrpc.ConsoleServiceBlockingV2Stub
extends io.grpc.stub.AbstractBlockingStub<ConsoleServiceGrpc.ConsoleServiceBlockingV2Stub>
A stub to allow clients to do synchronous rpc calls to service ConsoleService.
Console interaction service
-
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 TypeMethodDescriptionio.grpc.stub.BlockingClientCall<AutoCompleteRequest,AutoCompleteResponse> Starts a stream for autocomplete on the current session.build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) cancelCommand(CancelCommandRequest request) executeCommand(ExecuteCommandRequest request) getConsoleTypes(GetConsoleTypesRequest request) getHeapInfo(GetHeapInfoRequest request) Other half of the browser-based implementation for AutoCompleteStream.io.grpc.stub.BlockingClientCall<?,AutoCompleteResponse> Half of the browser-based (browser's can't do bidirectional streams without websockets) implementation for AutoCompleteStream.startConsole(StartConsoleRequest request) io.grpc.stub.BlockingClientCall<?,LogSubscriptionData> subscribeToLogs(LogSubscriptionRequest request) Methods inherited from class io.grpc.stub.AbstractBlockingStub
newStub, newStubMethods inherited from class io.grpc.stub.AbstractStub
getCallOptions, getChannel, withCallCredentials, withChannel, withCompression, withDeadline, withDeadlineAfter, withDeadlineAfter, withExecutor, withInterceptors, withMaxInboundMessageSize, withMaxOutboundMessageSize, withOnReadyThreshold, withOption, withWaitForReady
-
Method Details
-
build
protected ConsoleServiceGrpc.ConsoleServiceBlockingV2Stub build(io.grpc.Channel channel, io.grpc.CallOptions callOptions) - Specified by:
buildin classio.grpc.stub.AbstractStub<ConsoleServiceGrpc.ConsoleServiceBlockingV2Stub>
-
getConsoleTypes
public GetConsoleTypesResponse getConsoleTypes(GetConsoleTypesRequest request) throws io.grpc.StatusException - Throws:
io.grpc.StatusException
-
startConsole
public StartConsoleResponse startConsole(StartConsoleRequest request) throws io.grpc.StatusException - Throws:
io.grpc.StatusException
-
getHeapInfo
- Throws:
io.grpc.StatusException
-
subscribeToLogs
@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918") public io.grpc.stub.BlockingClientCall<?,LogSubscriptionData> subscribeToLogs(LogSubscriptionRequest request) -
executeCommand
public ExecuteCommandResponse executeCommand(ExecuteCommandRequest request) throws io.grpc.StatusException - Throws:
io.grpc.StatusException
-
cancelCommand
public CancelCommandResponse cancelCommand(CancelCommandRequest request) throws io.grpc.StatusException - Throws:
io.grpc.StatusException
-
bindTableToVariable
public BindTableToVariableResponse bindTableToVariable(BindTableToVariableRequest request) throws io.grpc.StatusException - Throws:
io.grpc.StatusException
-
autoCompleteStream
@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918") public io.grpc.stub.BlockingClientCall<AutoCompleteRequest,AutoCompleteResponse> autoCompleteStream()Starts a stream for autocomplete on the current session. More than one console, more than one document can be edited at a time using this, and they can separately be closed as well. A given document should only be edited within one stream at a time.
-
cancelAutoComplete
public CancelAutoCompleteResponse cancelAutoComplete(CancelAutoCompleteRequest request) throws io.grpc.StatusException - Throws:
io.grpc.StatusException
-
openAutoCompleteStream
@ExperimentalApi("https://github.com/grpc/grpc-java/issues/10918") public io.grpc.stub.BlockingClientCall<?,AutoCompleteResponse> openAutoCompleteStream(AutoCompleteRequest request) Half of the browser-based (browser's can't do bidirectional streams without websockets) implementation for AutoCompleteStream.
-
nextAutoCompleteStream
public BrowserNextResponse nextAutoCompleteStream(AutoCompleteRequest request) throws io.grpc.StatusException Other half of the browser-based implementation for AutoCompleteStream.
- Throws:
io.grpc.StatusException
-