Package io.deephaven.proto.routing.grpc

Interface RoutingApiGrpc.AsyncService

All Known Implementing Classes:

RoutingApiGrpc.RoutingApiImplBase, RoutingServiceImpl

Enclosing class:

RoutingApiGrpc

public static interface RoutingApiGrpc.AsyncService

 Remoting for the DataRoutingService interface.
 

Method Summary

Modifier and Type	Method	Description
default void	about(AboutRequest request, io.grpc.stub.StreamObserver<AboutReply> responseObserver)	========== DataRoutingService metadata ====================================
default void	getAllDataImportServiceDestinationConfigs(AllDataImportServiceDestinationConfigsRequest request, io.grpc.stub.StreamObserver<DataImportServiceDestinationConfigResponse> responseObserver)	Implements Collection<? extends DataImportServiceEndpointConfig> getAllDataImportServiceDestinationConfigs();
default void	getAllLogAggregatorServiceConfigs(AllLogAggregatorConfigRequest request, io.grpc.stub.StreamObserver<LogAggregatorConfigResponse> responseObserver)	Implements Collection<? extends LogAggregatorConfig> getAllLogAggregatorServiceConfigs();
default void	getCollectedClaims(CollectedClaimsRequest request, io.grpc.stub.StreamObserver<CollectedClaimsResponse> responseObserver)
default void	getDataImportServiceConfigs(DataImportServiceConfigsRequest request, io.grpc.stub.StreamObserver<DataImportServiceConfigsResponse> responseObserver)	Implements DataImportServiceConfig getDataImportServiceConfig(@NotNull String name);
default void	getDataImportServiceDestinationConfigs(DataImportServiceDestinationConfigsRequest request, io.grpc.stub.StreamObserver<DataImportServiceDestinationConfigResponse> responseObserver)	Implements Collection<? extends DataImportServiceEndpointConfig> getDataImportServiceDestinations(@NotNull TableIdentifier tableIdentifier);
default void	getFile(DataRoutingFileRequest request, io.grpc.stub.StreamObserver<com.google.protobuf.StringValue> responseObserver)	this is just a workaround pending more TDS serialization work
default void	getFullConfiguration(DataRoutingConfigurationRequest request, io.grpc.stub.StreamObserver<DataRoutingConfigurationResponse> responseObserver)
default void	getLogAggregatorConfig(LogAggregatorConfigRequest request, io.grpc.stub.StreamObserver<LogAggregatorConfigResponse> responseObserver)	Implements Config getLogAggregatorConfig(@NotNull String configName);
default void	getLogAggregatorDestinationConfig(LogAggregatorDestinationConfigRequest request, io.grpc.stub.StreamObserver<LogAggregatorDestinationConfigResponse> responseObserver)	Implements LogAggregatorEndpoint getLogAggregatorDestinationConfig(@NotNull TableIdentifier tableIdentifier);
default void	getTableDataServiceConfig(TableDataServiceConfigRequest request, io.grpc.stub.StreamObserver<TableDataServiceConfigResponse> responseObserver)	Implements TableDataServiceConfig getTableDataServiceConfig(@NotNull String name);
default void	getTableDataServiceConfigs(AllTableDataServiceConfigRequest request, io.grpc.stub.StreamObserver<TableDataServiceConfigsResponse> responseObserver)	Implements Collection<? extends TableDataServiceConfig> getTableDataServiceConfigs();
default void	subscribeToDataRoutingChangeNotifications(DataRoutingConfigurationChangeNotificationRequest request, io.grpc.stub.StreamObserver<DataRoutingConfigurationChangeMessage> responseObserver)	========== change notification =======================================
default void	updateDises(DataRoutingUpdateDataImportServiceConfigsMessage request, io.grpc.stub.StreamObserver<DataRoutingFileUpdateResponse> responseObserver)	Update one or more items comprising the data routing configuration.
default void	updateFile(DataRoutingFileUpdateRequest request, io.grpc.stub.StreamObserver<DataRoutingFileUpdateResponse> responseObserver)	Update the contents of the data routing file

Method Details

about

default void about(AboutRequest request,
 io.grpc.stub.StreamObserver<AboutReply> responseObserver)

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

getFile

default void getFile(DataRoutingFileRequest request,
 io.grpc.stub.StreamObserver<com.google.protobuf.StringValue> responseObserver)

 this is just a workaround pending more TDS serialization work 
 

getFullConfiguration

default void getFullConfiguration(DataRoutingConfigurationRequest request,
 io.grpc.stub.StreamObserver<DataRoutingConfigurationResponse> responseObserver)

getCollectedClaims

default void getCollectedClaims(CollectedClaimsRequest request,
 io.grpc.stub.StreamObserver<CollectedClaimsResponse> responseObserver)

getDataImportServiceConfigs

default void getDataImportServiceConfigs(DataImportServiceConfigsRequest request,
 io.grpc.stub.StreamObserver<DataImportServiceConfigsResponse> responseObserver)

 Implements DataImportServiceConfig getDataImportServiceConfig(@NotNull String name); 
 

getDataImportServiceDestinationConfigs

default void getDataImportServiceDestinationConfigs(DataImportServiceDestinationConfigsRequest request,
 io.grpc.stub.StreamObserver<DataImportServiceDestinationConfigResponse> responseObserver)

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

getAllDataImportServiceDestinationConfigs

default void getAllDataImportServiceDestinationConfigs(AllDataImportServiceDestinationConfigsRequest request,
 io.grpc.stub.StreamObserver<DataImportServiceDestinationConfigResponse> responseObserver)

 Implements Collection<? extends DataImportServiceEndpointConfig> getAllDataImportServiceDestinationConfigs(); 
 

getLogAggregatorConfig

default void getLogAggregatorConfig(LogAggregatorConfigRequest request,
 io.grpc.stub.StreamObserver<LogAggregatorConfigResponse> responseObserver)

 Implements Config getLogAggregatorConfig(@NotNull String configName); 
 

getAllLogAggregatorServiceConfigs

default void getAllLogAggregatorServiceConfigs(AllLogAggregatorConfigRequest request,
 io.grpc.stub.StreamObserver<LogAggregatorConfigResponse> responseObserver)

 Implements Collection<? extends LogAggregatorConfig> getAllLogAggregatorServiceConfigs(); 
 

getLogAggregatorDestinationConfig

default void getLogAggregatorDestinationConfig(LogAggregatorDestinationConfigRequest request,
 io.grpc.stub.StreamObserver<LogAggregatorDestinationConfigResponse> responseObserver)

 Implements LogAggregatorEndpoint getLogAggregatorDestinationConfig(@NotNull TableIdentifier tableIdentifier); 
 

getTableDataServiceConfig

default void getTableDataServiceConfig(TableDataServiceConfigRequest request,
 io.grpc.stub.StreamObserver<TableDataServiceConfigResponse> responseObserver)

 Implements TableDataServiceConfig getTableDataServiceConfig(@NotNull String name); 
 

getTableDataServiceConfigs

default void getTableDataServiceConfigs(AllTableDataServiceConfigRequest request,
 io.grpc.stub.StreamObserver<TableDataServiceConfigsResponse> responseObserver)

 Implements Collection<? extends TableDataServiceConfig> getTableDataServiceConfigs(); 
 

updateFile

default void updateFile(DataRoutingFileUpdateRequest request,
 io.grpc.stub.StreamObserver<DataRoutingFileUpdateResponse> responseObserver)

 Update the contents of the data routing file 
 

updateDises

default void updateDises(DataRoutingUpdateDataImportServiceConfigsMessage request,
 io.grpc.stub.StreamObserver<DataRoutingFileUpdateResponse> responseObserver)

 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

default void subscribeToDataRoutingChangeNotifications(DataRoutingConfigurationChangeNotificationRequest request,
 io.grpc.stub.StreamObserver<DataRoutingConfigurationChangeMessage> responseObserver)

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