Function grpcIsClusterAuthCall

pkg/ratelimit/grpc.go:42–44

(ctx context.Context)

}

func grpcIsClusterAuthCall(ctx context.Context) bool {
	return rpcmetadata.FromIncomingContext(ctx).AuthType == clusterauth.AuthType
}

// UnaryServerInterceptor returns a gRPC unary server interceptor that rate limits incoming gRPC requests.
func UnaryServerInterceptor(limiter Interface) grpc.UnaryServerInterceptor {