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:

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)

Overrides:

createStore in class StoreGrpcServiceGrpc.StoreGrpcServiceImplBase

updateAclForStore

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

Overrides:

updateAclForStore in class StoreGrpcServiceGrpc.StoreGrpcServiceImplBase

getAclForStore

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

Overrides:

getAclForStore in class StoreGrpcServiceGrpc.StoreGrpcServiceImplBase

deleteAclForStore

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

Overrides:

deleteAclForStore in class StoreGrpcServiceGrpc.StoreGrpcServiceImplBase

checkResourceCleanupForStoreCreation

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

Overrides:

checkResourceCleanupForStoreCreation in class StoreGrpcServiceGrpc.StoreGrpcServiceImplBase