Package io.deephaven.proto.routing.grpc

Class RoutingApiGrpc.RoutingApiBlockingStub

java.lang.Object

io.grpc.stub.AbstractStub<S>

io.grpc.stub.AbstractBlockingStub<RoutingApiGrpc.RoutingApiBlockingStub>

io.deephaven.proto.routing.grpc.RoutingApiGrpc.RoutingApiBlockingStub

Enclosing class:

RoutingApiGrpc

public static final class RoutingApiGrpc.RoutingApiBlockingStub
extends io.grpc.stub.AbstractBlockingStub<RoutingApiGrpc.RoutingApiBlockingStub>

A stub to allow clients to do limited synchronous 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
AboutReply	about(AboutRequest request)	========== DataRoutingService metadata ====================================
protected RoutingApiGrpc.RoutingApiBlockingStub	build(io.grpc.Channel channel, io.grpc.CallOptions callOptions)
Iterator<DataImportServiceDestinationConfigResponse>	getAllDataImportServiceDestinationConfigs(AllDataImportServiceDestinationConfigsRequest request)	Implements Collection<? extends DataImportServiceEndpointConfig> getAllDataImportServiceDestinationConfigs();
Iterator<LogAggregatorConfigResponse>	getAllLogAggregatorServiceConfigs(AllLogAggregatorConfigRequest request)	Implements Collection<? extends LogAggregatorConfig> getAllLogAggregatorServiceConfigs();
CollectedClaimsResponse	getCollectedClaims(CollectedClaimsRequest request)
DataImportServiceConfigsResponse	getDataImportServiceConfigs(DataImportServiceConfigsRequest request)	Implements DataImportServiceConfig getDataImportServiceConfig(@NotNull String name);
Iterator<DataImportServiceDestinationConfigResponse>	getDataImportServiceDestinationConfigs(DataImportServiceDestinationConfigsRequest request)	Implements Collection<? extends DataImportServiceEndpointConfig> getDataImportServiceDestinations(@NotNull TableIdentifier tableIdentifier);
com.google.protobuf.StringValue	getFile(DataRoutingFileRequest request)	this is just a workaround pending more TDS serialization work
DataRoutingConfigurationResponse	getFullConfiguration(DataRoutingConfigurationRequest request)
LogAggregatorConfigResponse	getLogAggregatorConfig(LogAggregatorConfigRequest request)	Implements Config getLogAggregatorConfig(@NotNull String configName);
LogAggregatorDestinationConfigResponse	getLogAggregatorDestinationConfig(LogAggregatorDestinationConfigRequest request)	Implements LogAggregatorEndpoint getLogAggregatorDestinationConfig(@NotNull TableIdentifier tableIdentifier);
TableDataServiceConfigResponse	getTableDataServiceConfig(TableDataServiceConfigRequest request)	Implements TableDataServiceConfig getTableDataServiceConfig(@NotNull String name);
TableDataServiceConfigsResponse	getTableDataServiceConfigs(AllTableDataServiceConfigRequest request)	Implements Collection<? extends TableDataServiceConfig> getTableDataServiceConfigs();
Iterator<DataRoutingConfigurationChangeMessage>	subscribeToDataRoutingChangeNotifications(DataRoutingConfigurationChangeNotificationRequest request)	========== change notification =======================================
DataRoutingFileUpdateResponse	updateDises(DataRoutingUpdateDataImportServiceConfigsMessage request)	Update one or more items comprising the data routing configuration.
DataRoutingFileUpdateResponse	updateFile(DataRoutingFileUpdateRequest request)	Update the contents of the data routing file

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

Specified by:

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

about

public AboutReply about(AboutRequest request)

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

getFile

public com.google.protobuf.StringValue getFile(DataRoutingFileRequest request)

 this is just a workaround pending more TDS serialization work 
 

getFullConfiguration

public DataRoutingConfigurationResponse getFullConfiguration(DataRoutingConfigurationRequest request)

getCollectedClaims

public CollectedClaimsResponse getCollectedClaims(CollectedClaimsRequest request)

getDataImportServiceConfigs

public DataImportServiceConfigsResponse getDataImportServiceConfigs(DataImportServiceConfigsRequest request)

 Implements DataImportServiceConfig getDataImportServiceConfig(@NotNull String name); 
 

getDataImportServiceDestinationConfigs

public Iterator<DataImportServiceDestinationConfigResponse> getDataImportServiceDestinationConfigs(DataImportServiceDestinationConfigsRequest request)

 Implements Collection<? extends DataImportServiceEndpointConfig> getDataImportServiceDestinations(@NotNull TableIdentifier tableIdentifier); 
 

getAllDataImportServiceDestinationConfigs

public Iterator<DataImportServiceDestinationConfigResponse> getAllDataImportServiceDestinationConfigs(AllDataImportServiceDestinationConfigsRequest request)

 Implements Collection<? extends DataImportServiceEndpointConfig> getAllDataImportServiceDestinationConfigs(); 
 

getLogAggregatorConfig

public LogAggregatorConfigResponse getLogAggregatorConfig(LogAggregatorConfigRequest request)

 Implements Config getLogAggregatorConfig(@NotNull String configName); 
 

getAllLogAggregatorServiceConfigs

public Iterator<LogAggregatorConfigResponse> getAllLogAggregatorServiceConfigs(AllLogAggregatorConfigRequest request)

 Implements Collection<? extends LogAggregatorConfig> getAllLogAggregatorServiceConfigs(); 
 

getLogAggregatorDestinationConfig

public LogAggregatorDestinationConfigResponse getLogAggregatorDestinationConfig(LogAggregatorDestinationConfigRequest request)

 Implements LogAggregatorEndpoint getLogAggregatorDestinationConfig(@NotNull TableIdentifier tableIdentifier); 
 

getTableDataServiceConfig

public TableDataServiceConfigResponse getTableDataServiceConfig(TableDataServiceConfigRequest request)

 Implements TableDataServiceConfig getTableDataServiceConfig(@NotNull String name); 
 

getTableDataServiceConfigs

public TableDataServiceConfigsResponse getTableDataServiceConfigs(AllTableDataServiceConfigRequest request)

 Implements Collection<? extends TableDataServiceConfig> getTableDataServiceConfigs(); 
 

updateFile

public DataRoutingFileUpdateResponse updateFile(DataRoutingFileUpdateRequest request)

 Update the contents of the data routing file 
 

updateDises

public 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. 
 

subscribeToDataRoutingChangeNotifications

public Iterator<DataRoutingConfigurationChangeMessage> subscribeToDataRoutingChangeNotifications(DataRoutingConfigurationChangeNotificationRequest request)

 ========== change notification =======================================