Package io.deephaven.proto.routing.grpc

Class RoutingApiGrpc.RoutingApiFutureStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractFutureStub<RoutingApiGrpc.RoutingApiFutureStub>

io.deephaven.proto.routing.grpc.RoutingApiGrpc.RoutingApiFutureStub

Enclosing class:

RoutingApiGrpc

public static final class RoutingApiGrpc.RoutingApiFutureStub
extends io.grpc.stub.AbstractFutureStub<RoutingApiGrpc.RoutingApiFutureStub>

A stub to allow clients to do ListenableFuture-style rpc calls to service RoutingApi.

 Remoting for the DataRoutingService interface.
 

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
com.google.common.util.concurrent.ListenableFuture<AboutReply>	about(AboutRequest request)	========== DataRoutingService metadata ====================================
protected RoutingApiGrpc.RoutingApiFutureStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
com.google.common.util.concurrent.ListenableFuture<CollectedClaimsResponse>	getCollectedClaims(CollectedClaimsRequest request)
com.google.common.util.concurrent.ListenableFuture<DataImportServiceConfigsResponse>	getDataImportServiceConfigs(DataImportServiceConfigsRequest request)	Implements DataImportServiceConfig getDataImportServiceConfig(@NotNull String name);
com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.StringValue>	getFile(DataRoutingFileRequest request)	this is just a workaround pending more TDS serialization work
com.google.common.util.concurrent.ListenableFuture<DataRoutingConfigurationResponse>	getFullConfiguration(DataRoutingConfigurationRequest request)
com.google.common.util.concurrent.ListenableFuture<LogAggregatorConfigResponse>	getLogAggregatorConfig(LogAggregatorConfigRequest request)	Implements Config getLogAggregatorConfig(@NotNull String configName);
com.google.common.util.concurrent.ListenableFuture<LogAggregatorDestinationConfigResponse>	getLogAggregatorDestinationConfig(LogAggregatorDestinationConfigRequest request)	Implements LogAggregatorEndpoint getLogAggregatorDestinationConfig(@NotNull TableIdentifier tableIdentifier);
com.google.common.util.concurrent.ListenableFuture<TableDataServiceConfigResponse>	getTableDataServiceConfig(TableDataServiceConfigRequest request)	Implements TableDataServiceConfig getTableDataServiceConfig(@NotNull String name);
com.google.common.util.concurrent.ListenableFuture<TableDataServiceConfigsResponse>	getTableDataServiceConfigs(AllTableDataServiceConfigRequest request)	Implements Collection<? extends TableDataServiceConfig> getTableDataServiceConfigs();
com.google.common.util.concurrent.ListenableFuture<DataRoutingFileUpdateResponse>	updateDises(DataRoutingUpdateDataImportServiceConfigsMessage request)	Update one or more items comprising the data routing configuration.
com.google.common.util.concurrent.ListenableFuture<DataRoutingFileUpdateResponse>	updateFile(DataRoutingFileUpdateRequest request)	Update the contents of the data routing file

Methods inherited from class io.grpc.stub.AbstractFutureStub

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

Specified by:

build in class io.grpc.stub.AbstractStub<RoutingApiGrpc.RoutingApiFutureStub>

about

public com.google.common.util.concurrent.ListenableFuture<AboutReply> about(AboutRequest request)

 ========== DataRoutingService metadata ====================================
 

getFile

public com.google.common.util.concurrent.ListenableFuture<com.google.protobuf.StringValue> getFile(DataRoutingFileRequest request)

 this is just a workaround pending more TDS serialization work 
 

getFullConfiguration

public com.google.common.util.concurrent.ListenableFuture<DataRoutingConfigurationResponse> getFullConfiguration(DataRoutingConfigurationRequest request)

getCollectedClaims

public com.google.common.util.concurrent.ListenableFuture<CollectedClaimsResponse> getCollectedClaims(CollectedClaimsRequest request)

getDataImportServiceConfigs

public com.google.common.util.concurrent.ListenableFuture<DataImportServiceConfigsResponse> getDataImportServiceConfigs(DataImportServiceConfigsRequest request)

 Implements DataImportServiceConfig getDataImportServiceConfig(@NotNull String name); 
 

getLogAggregatorConfig

public com.google.common.util.concurrent.ListenableFuture<LogAggregatorConfigResponse> getLogAggregatorConfig(LogAggregatorConfigRequest request)

 Implements Config getLogAggregatorConfig(@NotNull String configName); 
 

getLogAggregatorDestinationConfig

public com.google.common.util.concurrent.ListenableFuture<LogAggregatorDestinationConfigResponse> getLogAggregatorDestinationConfig(LogAggregatorDestinationConfigRequest request)

 Implements LogAggregatorEndpoint getLogAggregatorDestinationConfig(@NotNull TableIdentifier tableIdentifier); 
 

getTableDataServiceConfig

public com.google.common.util.concurrent.ListenableFuture<TableDataServiceConfigResponse> getTableDataServiceConfig(TableDataServiceConfigRequest request)

 Implements TableDataServiceConfig getTableDataServiceConfig(@NotNull String name); 
 

getTableDataServiceConfigs

public com.google.common.util.concurrent.ListenableFuture<TableDataServiceConfigsResponse> getTableDataServiceConfigs(AllTableDataServiceConfigRequest request)

 Implements Collection<? extends TableDataServiceConfig> getTableDataServiceConfigs(); 
 

updateFile

public com.google.common.util.concurrent.ListenableFuture<DataRoutingFileUpdateResponse> updateFile(DataRoutingFileUpdateRequest request)

 Update the contents of the data routing file 
 

updateDises

public com.google.common.util.concurrent.ListenableFuture<DataRoutingFileUpdateResponse> updateDises(DataRoutingUpdateDataImportServiceConfigsMessage request)

 Update one or more items comprising the data routing configuration. According to the request message,
add DISes, update or remove DISes, replace all DISes, and optionally update the main routing file at the
same time for an atomic change.