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	getStore(GetStoreGrpcRequest grpcRequest, io.grpc.stub.StreamObserver<GetStoreGrpcResponse> responseObserver)	Gets store information for a given store in a cluster.
void	listStores(ListStoresGrpcRequest grpcRequest, io.grpc.stub.StreamObserver<ListStoresGrpcResponse> responseObserver)	Lists all stores in a cluster with optional filtering.
void	updateAclForStore(UpdateAclForStoreGrpcRequest request, io.grpc.stub.StreamObserver<UpdateAclForStoreGrpcResponse> responseObserver)
void	validateStoreDeleted(ValidateStoreDeletedGrpcRequest grpcRequest, io.grpc.stub.StreamObserver<ValidateStoreDeletedGrpcResponse> 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)

validateStoreDeleted

public void validateStoreDeleted(ValidateStoreDeletedGrpcRequest grpcRequest,
 io.grpc.stub.StreamObserver<ValidateStoreDeletedGrpcResponse> responseObserver)

listStores

public void listStores(ListStoresGrpcRequest grpcRequest,
 io.grpc.stub.StreamObserver<ListStoresGrpcResponse> responseObserver)

Lists all stores in a cluster with optional filtering. No ACL check; any user can list stores.

getStore

public void getStore(GetStoreGrpcRequest grpcRequest,
 io.grpc.stub.StreamObserver<GetStoreGrpcResponse> responseObserver)

Gets store information for a given store in a cluster. No ACL check; this is a read-only operation.