Package com.linkedin.venice.controller.grpc.server

Class ClusterAdminOpsGrpcServiceImpl

java.lang.Object

com.linkedin.venice.protocols.controller.ClusterAdminOpsGrpcServiceGrpc.ClusterAdminOpsGrpcServiceImplBase

com.linkedin.venice.controller.grpc.server.ClusterAdminOpsGrpcServiceImpl

All Implemented Interfaces:

ClusterAdminOpsGrpcServiceGrpc.AsyncService, io.grpc.BindableService

public class ClusterAdminOpsGrpcServiceImpl
extends ClusterAdminOpsGrpcServiceGrpc.ClusterAdminOpsGrpcServiceImplBase

Constructor Summary

Constructors

Constructor	Description
ClusterAdminOpsGrpcServiceImpl(ClusterAdminOpsRequestHandler requestHandler, VeniceControllerAccessManager accessManager)

Method Summary

Modifier and Type	Method	Description
void	getAdminCommandExecutionStatus(AdminCommandExecutionStatusGrpcRequest request, io.grpc.stub.StreamObserver<AdminCommandExecutionStatusGrpcResponse> responseObserver)	AdminCommandExecution
void	getAdminTopicMetadata(AdminTopicMetadataGrpcRequest request, io.grpc.stub.StreamObserver<AdminTopicMetadataGrpcResponse> responseObserver)	AdminTopicMetadata
void	getLastSuccessfulAdminCommandExecutionId(LastSuccessfulAdminCommandExecutionGrpcRequest request, io.grpc.stub.StreamObserver<LastSuccessfulAdminCommandExecutionGrpcResponse> responseObserver)
void	updateAdminOperationProtocolVersion(UpdateAdminOperationProtocolVersionGrpcRequest request, io.grpc.stub.StreamObserver<AdminTopicMetadataGrpcResponse> responseObserver)
void	updateAdminTopicMetadata(UpdateAdminTopicMetadataGrpcRequest request, io.grpc.stub.StreamObserver<AdminTopicMetadataGrpcResponse> responseObserver)

Methods inherited from class com.linkedin.venice.protocols.controller.ClusterAdminOpsGrpcServiceGrpc.ClusterAdminOpsGrpcServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Details

ClusterAdminOpsGrpcServiceImpl

public ClusterAdminOpsGrpcServiceImpl(ClusterAdminOpsRequestHandler requestHandler,
 VeniceControllerAccessManager accessManager)

Method Details

getAdminCommandExecutionStatus

public void getAdminCommandExecutionStatus(AdminCommandExecutionStatusGrpcRequest request,
 io.grpc.stub.StreamObserver<AdminCommandExecutionStatusGrpcResponse> responseObserver)

Description copied from interface: ClusterAdminOpsGrpcServiceGrpc.AsyncService

 AdminCommandExecution
 

getLastSuccessfulAdminCommandExecutionId

public void getLastSuccessfulAdminCommandExecutionId(LastSuccessfulAdminCommandExecutionGrpcRequest request,
 io.grpc.stub.StreamObserver<LastSuccessfulAdminCommandExecutionGrpcResponse> responseObserver)

getAdminTopicMetadata

public void getAdminTopicMetadata(AdminTopicMetadataGrpcRequest request,
 io.grpc.stub.StreamObserver<AdminTopicMetadataGrpcResponse> responseObserver)

Description copied from interface: ClusterAdminOpsGrpcServiceGrpc.AsyncService

 AdminTopicMetadata
 

updateAdminTopicMetadata

public void updateAdminTopicMetadata(UpdateAdminTopicMetadataGrpcRequest request,
 io.grpc.stub.StreamObserver<AdminTopicMetadataGrpcResponse> responseObserver)

updateAdminOperationProtocolVersion

public void updateAdminOperationProtocolVersion(UpdateAdminOperationProtocolVersionGrpcRequest request,
 io.grpc.stub.StreamObserver<AdminTopicMetadataGrpcResponse> responseObserver)