Package io.deephaven.dhservice.grpc

Class RoutingServiceImpl

java.lang.Object

io.deephaven.proto.routing.grpc.RoutingApiGrpc.RoutingApiImplBase

io.deephaven.dhservice.grpc.RoutingServiceImpl

All Implemented Interfaces:

DataRoutingConfigListener, RoutingApiGrpc.AsyncService, io.grpc.BindableService

public class RoutingServiceImpl
extends RoutingApiGrpc.RoutingApiImplBase
implements DataRoutingConfigListener

Server side implementation of DataRoutingService. For Deephaven Internal use only.

Method Summary

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

Methods inherited from class io.deephaven.proto.routing.grpc.RoutingApiGrpc.RoutingApiImplBase

bindService

Methods inherited from class java.lang.Object

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

Method Details

make

public static RoutingServiceImpl make(@NotNull
 @NotNull DataRoutingService routingService,
 @Nullable
 @Nullable IrisGroupProvider irisGroupProvider,
 @NotNull
 ConfigurationServer.ConfigurationAuditEventLogger ael)

Factory: create a new RoutingServiceImpl with the given DataRoutingService provider.

Parameters:

routingService - use this provider for DataRoutingService

irisGroupProvider - the constructed group provider to use for permission checks

ael - logger for audit events

Returns:

a new instance

about

public String about()

about

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

Description copied from interface: RoutingApiGrpc.AsyncService

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

Specified by:

about in interface RoutingApiGrpc.AsyncService

getDataImportServiceConfigs

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

Description copied from interface: RoutingApiGrpc.AsyncService

 Implements DataImportServiceConfig getDataImportServiceConfig(@NotNull String name); 
 

Specified by:

getDataImportServiceConfigs in interface RoutingApiGrpc.AsyncService

getDataImportServiceDestinationConfigs

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

Description copied from interface: RoutingApiGrpc.AsyncService

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

Specified by:

getDataImportServiceDestinationConfigs in interface RoutingApiGrpc.AsyncService

getAllDataImportServiceDestinationConfigs

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

Description copied from interface: RoutingApiGrpc.AsyncService

 Implements Collection<? extends DataImportServiceEndpointConfig> getAllDataImportServiceDestinationConfigs(); 
 

Specified by:

getAllDataImportServiceDestinationConfigs in interface RoutingApiGrpc.AsyncService

getLogAggregatorConfig

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

Description copied from interface: RoutingApiGrpc.AsyncService

 Implements Config getLogAggregatorConfig(@NotNull String configName); 
 

Specified by:

getLogAggregatorConfig in interface RoutingApiGrpc.AsyncService

getAllLogAggregatorServiceConfigs

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

Description copied from interface: RoutingApiGrpc.AsyncService

 Implements Collection<? extends LogAggregatorConfig> getAllLogAggregatorServiceConfigs(); 
 

Specified by:

getAllLogAggregatorServiceConfigs in interface RoutingApiGrpc.AsyncService

getLogAggregatorDestinationConfig

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

Description copied from interface: RoutingApiGrpc.AsyncService

 Implements LogAggregatorEndpoint getLogAggregatorDestinationConfig(@NotNull TableIdentifier tableIdentifier); 
 

Specified by:

getLogAggregatorDestinationConfig in interface RoutingApiGrpc.AsyncService

getTableDataServiceConfig

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

Description copied from interface: RoutingApiGrpc.AsyncService

 Implements TableDataServiceConfig getTableDataServiceConfig(@NotNull String name); 
 

Specified by:

getTableDataServiceConfig in interface RoutingApiGrpc.AsyncService

getTableDataServiceConfigs

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

Description copied from interface: RoutingApiGrpc.AsyncService

 Implements Collection<? extends TableDataServiceConfig> getTableDataServiceConfigs(); 
 

Specified by:

getTableDataServiceConfigs in interface RoutingApiGrpc.AsyncService

getFile

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

Description copied from interface: RoutingApiGrpc.AsyncService

 this is just a workaround pending more TDS serialization work 
 

Specified by:

getFile in interface RoutingApiGrpc.AsyncService

getFullConfiguration

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

Specified by:

getFullConfiguration in interface RoutingApiGrpc.AsyncService

getCollectedClaims

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

Specified by:

getCollectedClaims in interface RoutingApiGrpc.AsyncService

updateFile

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

Description copied from interface: RoutingApiGrpc.AsyncService

 Update the contents of the data routing file 
 

Specified by:

updateFile in interface RoutingApiGrpc.AsyncService

updateDises

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

Description copied from interface: RoutingApiGrpc.AsyncService

 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. 
 

Specified by:

updateDises in interface RoutingApiGrpc.AsyncService

subscribeToDataRoutingChangeNotifications

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

Description copied from interface: RoutingApiGrpc.AsyncService

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

Specified by:

subscribeToDataRoutingChangeNotifications in interface RoutingApiGrpc.AsyncService

onConfigChange

public void onConfigChange(long version)

Description copied from interface: DataRoutingConfigListener

Called when the configuration changes. Additional heartbeat notifications are sent periodically.

Specified by:

onConfigChange in interface DataRoutingConfigListener

Parameters:

version - the new/current version of the configuration.