Package io.deephaven.dhservice.grpc

Class ServiceRegistryServiceImpl

java.lang.Object

io.deephaven.proto.serviceregistry.grpc.ServiceRegistryApiGrpc.ServiceRegistryApiImplBase

io.deephaven.dhservice.grpc.ServiceRegistryServiceImpl

All Implemented Interfaces:

ServiceRegistryApiGrpc.AsyncService, io.grpc.BindableService

public final class ServiceRegistryServiceImpl
extends ServiceRegistryApiGrpc.ServiceRegistryApiImplBase

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

Method Summary

Modifier and Type	Method	Description
String	about()	Returns the description of the class for logging purposes.
void	about(AboutRequest request, io.grpc.stub.StreamObserver<AboutReply> responseObserver)
void	getAllEndpointConfigs(@NotNull GetAllConfigsRequest request, @NotNull io.grpc.stub.StreamObserver<GetAllConfigsResponse> responseObserver)
void	getEndpointConfig(@NotNull RoutingEndpointConfigRequest request, @NotNull io.grpc.stub.StreamObserver<RoutingEndpointConfigResponse> responseObserver)
void	getEndpointConfigs(@NotNull GetConfigsRequest request, @NotNull io.grpc.stub.StreamObserver<GetConfigsResponse> responseObserver)
static ServiceRegistryServiceImpl	make(@NotNull com.fishlib.io.logger.Logger log, @NotNull ServiceRegistryService registryService, @NotNull IrisGroupProvider irisGroupProvider, ConfigurationServer.ConfigurationAuditEventLogger ael)	Factory: create a new ServiceRegistryServiceImpl with the given ServiceRegistryService
void	registerEndpointConfig(@NotNull RegisterRoutingEndpointConfigRequest request, @NotNull io.grpc.stub.StreamObserver<RegisterRoutingEndpointConfigResponse> responseObserver)
void	renewLease(@NotNull RenewLeaseRequest request, @NotNull io.grpc.stub.StreamObserver<RenewLeaseResponse> responseObserver)
void	revokeLease(@NotNull RevokeLeaseRequest request, @NotNull io.grpc.stub.StreamObserver<RevokeLeaseResponse> responseObserver)

Methods inherited from class io.deephaven.proto.serviceregistry.grpc.ServiceRegistryApiGrpc.ServiceRegistryApiImplBase

bindService

Methods inherited from class java.lang.Object

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

Method Details

make

public static ServiceRegistryServiceImpl make(@NotNull
 @NotNull com.fishlib.io.logger.Logger log,
 @NotNull
 @NotNull ServiceRegistryService registryService,
 @NotNull
 @NotNull IrisGroupProvider irisGroupProvider,
 @NotNull
 ConfigurationServer.ConfigurationAuditEventLogger ael)

Factory: create a new ServiceRegistryServiceImpl with the given ServiceRegistryService

Parameters:

log - The passed in logger

registryService - The backing service implementation

irisGroupProvider - The constructed group provider to use for permission checks

ael - Logger for audit events

Returns:

A new instance

about

public String about()

Returns the description of the class for logging purposes.

Returns:

the description of the class.

about

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

registerEndpointConfig

public void registerEndpointConfig(@NotNull
 @NotNull RegisterRoutingEndpointConfigRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<RegisterRoutingEndpointConfigResponse> responseObserver)

revokeLease

public void revokeLease(@NotNull
 @NotNull RevokeLeaseRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<RevokeLeaseResponse> responseObserver)

renewLease

public void renewLease(@NotNull
 @NotNull RenewLeaseRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<RenewLeaseResponse> responseObserver)

getEndpointConfig

public void getEndpointConfig(@NotNull
 @NotNull RoutingEndpointConfigRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<RoutingEndpointConfigResponse> responseObserver)

getEndpointConfigs

public void getEndpointConfigs(@NotNull
 @NotNull GetConfigsRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<GetConfigsResponse> responseObserver)

getAllEndpointConfigs

public void getAllEndpointConfigs(@NotNull
 @NotNull GetAllConfigsRequest request,
 @NotNull
 @NotNull io.grpc.stub.StreamObserver<GetAllConfigsResponse> responseObserver)