Package io.deephaven.proto.backplane.script.grpc

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 Type	Method	Description
io.grpc.stub.BlockingClientCall<AutoCompleteRequest,AutoCompleteResponse>	autoCompleteStream()	Starts a stream for autocomplete on the current session.
BindTableToVariableResponse	bindTableToVariable(BindTableToVariableRequest request)
protected ConsoleServiceGrpc.ConsoleServiceBlockingV2Stub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
CancelAutoCompleteResponse	cancelAutoComplete(CancelAutoCompleteRequest request)
CancelCommandResponse	cancelCommand(CancelCommandRequest request)
ExecuteCommandResponse	executeCommand(ExecuteCommandRequest request)
GetConsoleTypesResponse	getConsoleTypes(GetConsoleTypesRequest request)
GetHeapInfoResponse	getHeapInfo(GetHeapInfoRequest request)
BrowserNextResponse	nextAutoCompleteStream(AutoCompleteRequest request)	Other half of the browser-based implementation for AutoCompleteStream.
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.
StartConsoleResponse	startConsole(StartConsoleRequest request)
io.grpc.stub.BlockingClientCall<?,LogSubscriptionData>	subscribeToLogs(LogSubscriptionRequest request)

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

Specified by:

build in class io.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

public GetHeapInfoResponse getHeapInfo(GetHeapInfoRequest request)
                                throws io.grpc.StatusException

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