Class ClusterAdminOpsGrpcServiceImpl
java.lang.Object
com.linkedin.venice.protocols.controller.ClusterAdminOpsGrpcServiceGrpc.ClusterAdminOpsGrpcServiceImplBase
com.linkedin.venice.controller.grpc.server.ClusterAdminOpsGrpcServiceImpl
- All Implemented Interfaces:
io.grpc.BindableService
public class ClusterAdminOpsGrpcServiceImpl
extends ClusterAdminOpsGrpcServiceGrpc.ClusterAdminOpsGrpcServiceImplBase
-
Constructor Summary
ConstructorDescriptionClusterAdminOpsGrpcServiceImpl
(ClusterAdminOpsRequestHandler requestHandler, VeniceControllerAccessManager accessManager) -
Method Summary
Modifier and TypeMethodDescriptionvoid
getAdminCommandExecutionStatus
(AdminCommandExecutionStatusGrpcRequest request, io.grpc.stub.StreamObserver<AdminCommandExecutionStatusGrpcResponse> responseObserver) AdminCommandExecutionvoid
getAdminTopicMetadata
(AdminTopicMetadataGrpcRequest request, io.grpc.stub.StreamObserver<AdminTopicMetadataGrpcResponse> responseObserver) AdminTopicMetadatavoid
getLastSuccessfulAdminCommandExecutionId
(LastSuccessfulAdminCommandExecutionGrpcRequest request, io.grpc.stub.StreamObserver<LastSuccessfulAdminCommandExecutionGrpcResponse> responseObserver) void
updateAdminTopicMetadata
(UpdateAdminTopicMetadataGrpcRequest request, io.grpc.stub.StreamObserver<UpdateAdminTopicMetadataGrpcResponse> responseObserver) Methods inherited from class com.linkedin.venice.protocols.controller.ClusterAdminOpsGrpcServiceGrpc.ClusterAdminOpsGrpcServiceImplBase
bindService
-
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 class:ClusterAdminOpsGrpcServiceGrpc.ClusterAdminOpsGrpcServiceImplBase
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 class:ClusterAdminOpsGrpcServiceGrpc.ClusterAdminOpsGrpcServiceImplBase
AdminTopicMetadata
-
updateAdminTopicMetadata
public void updateAdminTopicMetadata(UpdateAdminTopicMetadataGrpcRequest request, io.grpc.stub.StreamObserver<UpdateAdminTopicMetadataGrpcResponse> responseObserver)
-