alluxio.grpc

Class ServiceVersionClientServiceHandler

java.lang.Object

alluxio.grpc.ServiceVersionClientServiceGrpc.ServiceVersionClientServiceImplBase

alluxio.grpc.ServiceVersionClientServiceHandler

All Implemented Interfaces:

ServiceVersionClientServiceGrpc.AsyncService, io.grpc.BindableService

public final class ServiceVersionClientServiceHandler
extends ServiceVersionClientServiceGrpc.ServiceVersionClientServiceImplBase

This class is a gRPC handler that serves Alluxio service versions.

Constructor Summary

Constructors

Constructor and Description
ServiceVersionClientServiceHandler(Set<ServiceType> services, java.util.function.Supplier<NodeState> nodeStateSupplier) Creates service version handler that allows given services.

Method Summary

Modifier and Type	Method and Description
void	getServiceVersion(GetServiceVersionPRequest request, io.grpc.stub.StreamObserver<GetServiceVersionPResponse> responseObserver) Returns the version of the master service.

Methods inherited from class alluxio.grpc.ServiceVersionClientServiceGrpc.ServiceVersionClientServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Detail

ServiceVersionClientServiceHandler

public ServiceVersionClientServiceHandler(Set<ServiceType> services,
                                          @Nullable
                                          java.util.function.Supplier<NodeState> nodeStateSupplier)

Creates service version handler that allows given services.

Parameters:

services - services to allow

nodeStateSupplier - the supplier to get the node state

Method Detail

getServiceVersion

public void getServiceVersion(GetServiceVersionPRequest request,
                              io.grpc.stub.StreamObserver<GetServiceVersionPResponse> responseObserver)

Description copied from interface: ServiceVersionClientServiceGrpc.AsyncService

 Returns the version of the master service.
 NOTE: The version should be updated every time a backwards incompatible API change occurs.