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

Class ControllerGrpcServerUtils

java.lang.Object

com.linkedin.venice.controller.grpc.server.ControllerGrpcServerUtils

public class ControllerGrpcServerUtils
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ControllerGrpcServerUtils.GrpcRequestHandler<T>

Constructor Summary

Constructors

Constructor	Description
ControllerGrpcServerUtils()

Method Summary

Modifier and Type	Method	Description
protected static GrpcControllerClientDetails	getClientDetails(io.grpc.Context context)
static <T> void	handleRequest(io.grpc.MethodDescriptor<?,?> methodDescriptor, ControllerGrpcServerUtils.GrpcRequestHandler<T> handler, io.grpc.stub.StreamObserver<T> responseObserver, ClusterStoreGrpcInfo storeGrpcInfo)
static <T> void	handleRequest(io.grpc.MethodDescriptor<?,?> methodDescriptor, ControllerGrpcServerUtils.GrpcRequestHandler<T> handler, io.grpc.stub.StreamObserver<T> responseObserver, String clusterName, String storeName)
static boolean	isAllowListUser(VeniceControllerAccessManager accessManager, String resourceName, io.grpc.Context context)

Methods inherited from class java.lang.Object

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

Constructor Details

ControllerGrpcServerUtils

public ControllerGrpcServerUtils()

Method Details

handleRequest

public static <T> void handleRequest(io.grpc.MethodDescriptor<?,?> methodDescriptor,
 ControllerGrpcServerUtils.GrpcRequestHandler<T> handler,
 io.grpc.stub.StreamObserver<T> responseObserver,
 ClusterStoreGrpcInfo storeGrpcInfo)

handleRequest

public static <T> void handleRequest(io.grpc.MethodDescriptor<?,?> methodDescriptor,
 ControllerGrpcServerUtils.GrpcRequestHandler<T> handler,
 io.grpc.stub.StreamObserver<T> responseObserver,
 String clusterName,
 String storeName)

getClientDetails

protected static GrpcControllerClientDetails getClientDetails(io.grpc.Context context)

isAllowListUser

public static boolean isAllowListUser(VeniceControllerAccessManager accessManager,
 String resourceName,
 io.grpc.Context context)