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

Class StoreGrpcServiceImpl

java.lang.Object

com.linkedin.venice.protocols.controller.StoreGrpcServiceGrpc.StoreGrpcServiceImplBase

com.linkedin.venice.controller.grpc.server.StoreGrpcServiceImpl

All Implemented Interfaces:

StoreGrpcServiceGrpc.AsyncService, io.grpc.BindableService

public class StoreGrpcServiceImpl
extends StoreGrpcServiceGrpc.StoreGrpcServiceImplBase

Constructor Summary

Constructors

Constructor	Description
StoreGrpcServiceImpl(StoreRequestHandler storeRequestHandler, VeniceControllerAccessManager accessManager)

Method Summary

Modifier and Type	Method	Description
void	checkResourceCleanupForStoreCreation(ClusterStoreGrpcInfo request, io.grpc.stub.StreamObserver<ResourceCleanupCheckGrpcResponse> responseObserver)
void	createStore(CreateStoreGrpcRequest grpcRequest, io.grpc.stub.StreamObserver<CreateStoreGrpcResponse> responseObserver)
void	deleteAclForStore(DeleteAclForStoreGrpcRequest request, io.grpc.stub.StreamObserver<DeleteAclForStoreGrpcResponse> responseObserver)
void	getAclForStore(GetAclForStoreGrpcRequest request, io.grpc.stub.StreamObserver<GetAclForStoreGrpcResponse> responseObserver)
void	updateAclForStore(UpdateAclForStoreGrpcRequest request, io.grpc.stub.StreamObserver<UpdateAclForStoreGrpcResponse> responseObserver)

Methods inherited from class com.linkedin.venice.protocols.controller.StoreGrpcServiceGrpc.StoreGrpcServiceImplBase

bindService

Methods inherited from class java.lang.Object

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

Constructor Details

StoreGrpcServiceImpl

public StoreGrpcServiceImpl(StoreRequestHandler storeRequestHandler,
 VeniceControllerAccessManager accessManager)

Method Details

createStore

public void createStore(CreateStoreGrpcRequest grpcRequest,
 io.grpc.stub.StreamObserver<CreateStoreGrpcResponse> responseObserver)

updateAclForStore

public void updateAclForStore(UpdateAclForStoreGrpcRequest request,
 io.grpc.stub.StreamObserver<UpdateAclForStoreGrpcResponse> responseObserver)

getAclForStore

public void getAclForStore(GetAclForStoreGrpcRequest request,
 io.grpc.stub.StreamObserver<GetAclForStoreGrpcResponse> responseObserver)

deleteAclForStore

public void deleteAclForStore(DeleteAclForStoreGrpcRequest request,
 io.grpc.stub.StreamObserver<DeleteAclForStoreGrpcResponse> responseObserver)

checkResourceCleanupForStoreCreation

public void checkResourceCleanupForStoreCreation(ClusterStoreGrpcInfo request,
 io.grpc.stub.StreamObserver<ResourceCleanupCheckGrpcResponse> responseObserver)