Package io.deephaven.server.console

Class ConsoleServiceGrpcImpl

java.lang.Object

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

io.deephaven.server.console.ConsoleServiceGrpcImpl

All Implemented Interfaces:

io.grpc.BindableService

@Singleton
public class ConsoleServiceGrpcImpl
extends ConsoleServiceGrpc.ConsoleServiceImplBase

Field Summary

Fields

Modifier and Type	Field	Description
static final boolean	AUTOCOMPLETE_DISABLED
static final boolean	QUIET_AUTOCOMPLETE_ERRORS
static final boolean	REMOTE_CONSOLE_DISABLED
static final int	SUBSCRIBE_TO_LOGS_BUFFER_SIZE
static final String	SUBSCRIBE_TO_LOGS_BUFFER_SIZE_PROP
static final long	SUBSCRIBE_TO_LOGS_SEND_MILLIS

Constructor Summary

Constructors

Constructor	Description
ConsoleServiceGrpcImpl(TicketRouter ticketRouter, SessionService sessionService, javax.inject.Provider<ScriptSession> scriptSessionProvider, Scheduler scheduler, LogBuffer logBuffer, Set<CustomCompletion.Factory> customCompletionFactory)

Method Summary

Modifier and Type	Method	Description
io.grpc.stub.StreamObserver<AutoCompleteRequest>	autoCompleteStream(@NotNull io.grpc.stub.StreamObserver<AutoCompleteResponse> responseObserver)	Starts a stream for autocomplete on the current session.
void	bindTableToVariable(@NotNull BindTableToVariableRequest request, @NotNull io.grpc.stub.StreamObserver<BindTableToVariableResponse> responseObserver)
void	cancelAutoComplete(@NotNull CancelAutoCompleteRequest request, @NotNull io.grpc.stub.StreamObserver<CancelAutoCompleteResponse> responseObserver)
void	cancelCommand(@NotNull CancelCommandRequest request, @NotNull io.grpc.stub.StreamObserver<CancelCommandResponse> responseObserver)
void	executeCommand(@NotNull ExecuteCommandRequest request, @NotNull io.grpc.stub.StreamObserver<ExecuteCommandResponse> responseObserver)
void	getConsoleTypes(@NotNull GetConsoleTypesRequest request, @NotNull io.grpc.stub.StreamObserver<GetConsoleTypesResponse> responseObserver)
void	getHeapInfo(@NotNull GetHeapInfoRequest request, @NotNull io.grpc.stub.StreamObserver<GetHeapInfoResponse> responseObserver)
void	startConsole(@NotNull StartConsoleRequest request, @NotNull io.grpc.stub.StreamObserver<StartConsoleResponse> responseObserver)
void	subscribeToLogs(@NotNull LogSubscriptionRequest request, @NotNull io.grpc.stub.StreamObserver<LogSubscriptionData> responseObserver)

Methods inherited from class io.deephaven.proto.backplane.script.grpc.ConsoleServiceGrpc.ConsoleServiceImplBase

bindService, nextAutoCompleteStream, openAutoCompleteStream

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

REMOTE_CONSOLE_DISABLED

public static final boolean REMOTE_CONSOLE_DISABLED

AUTOCOMPLETE_DISABLED

public static final boolean AUTOCOMPLETE_DISABLED

QUIET_AUTOCOMPLETE_ERRORS

public static final boolean QUIET_AUTOCOMPLETE_ERRORS

SUBSCRIBE_TO_LOGS_SEND_MILLIS

public static final long SUBSCRIBE_TO_LOGS_SEND_MILLIS

SUBSCRIBE_TO_LOGS_BUFFER_SIZE_PROP

public static final String SUBSCRIBE_TO_LOGS_BUFFER_SIZE_PROP

See Also:

• Constant Field Values

SUBSCRIBE_TO_LOGS_BUFFER_SIZE

public static final int SUBSCRIBE_TO_LOGS_BUFFER_SIZE

Constructor Details

ConsoleServiceGrpcImpl

@Inject
public ConsoleServiceGrpcImpl(TicketRouter ticketRouter,
 SessionService sessionService,
 javax.inject.Provider<ScriptSession> scriptSessionProvider,
 Scheduler scheduler,
 LogBuffer logBuffer,
 Set<CustomCompletion.Factory> customCompletionFactory)

Method Details

getConsoleTypes

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

Overrides:

getConsoleTypes in class ConsoleServiceGrpc.ConsoleServiceImplBase

startConsole

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

Overrides:

startConsole in class ConsoleServiceGrpc.ConsoleServiceImplBase

subscribeToLogs

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

Overrides:

subscribeToLogs in class ConsoleServiceGrpc.ConsoleServiceImplBase

executeCommand

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

Overrides:

executeCommand in class ConsoleServiceGrpc.ConsoleServiceImplBase

getHeapInfo

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

Overrides:

getHeapInfo in class ConsoleServiceGrpc.ConsoleServiceImplBase

cancelCommand

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

Overrides:

cancelCommand in class ConsoleServiceGrpc.ConsoleServiceImplBase

bindTableToVariable

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

Overrides:

bindTableToVariable in class ConsoleServiceGrpc.ConsoleServiceImplBase

autoCompleteStream

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

Description copied from class: ConsoleServiceGrpc.ConsoleServiceImplBase

 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.
 

Overrides:

autoCompleteStream in class ConsoleServiceGrpc.ConsoleServiceImplBase

cancelAutoComplete

public void cancelAutoComplete(@NotNull
 @NotNull CancelAutoCompleteRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<CancelAutoCompleteResponse> responseObserver)

Overrides:

cancelAutoComplete in class ConsoleServiceGrpc.ConsoleServiceImplBase