grpcinterceptor

Documentation

Index

• func GrpcAuthStreamInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
• func GrpcAuthUnaryInterCeptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• func GrpcFlowCountStreamInterceptor(counter *public.FlowCountService) ...
• func GrpcFlowCountUnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

Functions

func GrpcAuthStreamInterceptor

func GrpcAuthStreamInterceptor(srv interface{}, ss grpc.ServerStream,
	info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

GrpcAuthStreamInterceptor 流式 RPC 拦截器

func GrpcAuthUnaryInterCeptor

func GrpcAuthUnaryInterCeptor(ctx context.Context, req interface{},
	info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

GrpcAuthUnaryInterCeptor 普通 RPC 拦截器

func GrpcFlowCountStreamInterceptor

func GrpcFlowCountStreamInterceptor(counter *public.FlowCountService) func(
	srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error

GrpcFlowCountStreamInterceptor 流式 RPC 流量统计

func GrpcFlowCountUnaryInterceptor

func GrpcFlowCountUnaryInterceptor(ctx context.Context, req interface{},
	info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

GrpcFlowCountUnaryInterceptor 普通 RPC 流量统计