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

Class ConsoleServiceGrpc.ConsoleServiceStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractAsyncStub<ConsoleServiceGrpc.ConsoleServiceStub>

io.deephaven.proto.backplane.script.grpc.ConsoleServiceGrpc.ConsoleServiceStub

Enclosing class:

ConsoleServiceGrpc

public static final class ConsoleServiceGrpc.ConsoleServiceStub
extends io.grpc.stub.AbstractAsyncStub<ConsoleServiceGrpc.ConsoleServiceStub>

A stub to allow clients to do asynchronous 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.StreamObserver<AutoCompleteRequest>	autoCompleteStream(io.grpc.stub.StreamObserver<AutoCompleteResponse> responseObserver)	Starts a stream for autocomplete on the current session.
void	bindTableToVariable(BindTableToVariableRequest request, io.grpc.stub.StreamObserver<BindTableToVariableResponse> responseObserver)
protected ConsoleServiceGrpc.ConsoleServiceStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
void	cancelAutoComplete(CancelAutoCompleteRequest request, io.grpc.stub.StreamObserver<CancelAutoCompleteResponse> responseObserver)
void	cancelCommand(CancelCommandRequest request, io.grpc.stub.StreamObserver<CancelCommandResponse> responseObserver)
void	executeCommand(ExecuteCommandRequest request, io.grpc.stub.StreamObserver<ExecuteCommandResponse> responseObserver)
void	getConsoleTypes(GetConsoleTypesRequest request, io.grpc.stub.StreamObserver<GetConsoleTypesResponse> responseObserver)
void	getHeapInfo(GetHeapInfoRequest request, io.grpc.stub.StreamObserver<GetHeapInfoResponse> responseObserver)
void	nextAutoCompleteStream(AutoCompleteRequest request, io.grpc.stub.StreamObserver<BrowserNextResponse> responseObserver)	Other half of the browser-based implementation for AutoCompleteStream.
void	openAutoCompleteStream(AutoCompleteRequest request, io.grpc.stub.StreamObserver<AutoCompleteResponse> responseObserver)	Half of the browser-based (browser's can't do bidirectional streams without websockets) implementation for AutoCompleteStream.
void	startConsole(StartConsoleRequest request, io.grpc.stub.StreamObserver<StartConsoleResponse> responseObserver)
void	subscribeToLogs(LogSubscriptionRequest request, io.grpc.stub.StreamObserver<LogSubscriptionData> responseObserver)

Methods inherited from class io.grpc.stub.AbstractAsyncStub

newStub, newStub

Methods inherited from class io.grpc.stub.AbstractStub

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

Specified by:

build in class io.grpc.stub.AbstractStub<ConsoleServiceGrpc.ConsoleServiceStub>

getConsoleTypes

public void getConsoleTypes(GetConsoleTypesRequest request,
 io.grpc.stub.StreamObserver<GetConsoleTypesResponse> responseObserver)

startConsole

public void startConsole(StartConsoleRequest request,
 io.grpc.stub.StreamObserver<StartConsoleResponse> responseObserver)

getHeapInfo

public void getHeapInfo(GetHeapInfoRequest request,
 io.grpc.stub.StreamObserver<GetHeapInfoResponse> responseObserver)

subscribeToLogs

public void subscribeToLogs(LogSubscriptionRequest request,
 io.grpc.stub.StreamObserver<LogSubscriptionData> responseObserver)

executeCommand

public void executeCommand(ExecuteCommandRequest request,
 io.grpc.stub.StreamObserver<ExecuteCommandResponse> responseObserver)

cancelCommand

public void cancelCommand(CancelCommandRequest request,
 io.grpc.stub.StreamObserver<CancelCommandResponse> responseObserver)

bindTableToVariable

public void bindTableToVariable(BindTableToVariableRequest request,
 io.grpc.stub.StreamObserver<BindTableToVariableResponse> responseObserver)

autoCompleteStream

public io.grpc.stub.StreamObserver<AutoCompleteRequest> autoCompleteStream(io.grpc.stub.StreamObserver<AutoCompleteResponse> responseObserver)

 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 void cancelAutoComplete(CancelAutoCompleteRequest request,
 io.grpc.stub.StreamObserver<CancelAutoCompleteResponse> responseObserver)

openAutoCompleteStream

public void openAutoCompleteStream(AutoCompleteRequest request,
 io.grpc.stub.StreamObserver<AutoCompleteResponse> responseObserver)

 Half of the browser-based (browser's can't do bidirectional streams without websockets)
 implementation for AutoCompleteStream.
 

nextAutoCompleteStream

public void nextAutoCompleteStream(AutoCompleteRequest request,
 io.grpc.stub.StreamObserver<BrowserNextResponse> responseObserver)

 Other half of the browser-based implementation for AutoCompleteStream.