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 *base_server.FlowCountService) ...
- func GrpcFlowCountUnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GrpcAuthStreamInterceptor ¶
func GrpcAuthStreamInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error
流式RPC拦截器
func GrpcAuthUnaryInterceptor ¶
func GrpcAuthUnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)
普通RPC拦截器
func GrpcFlowCountStreamInterceptor ¶
func GrpcFlowCountStreamInterceptor(counter *base_server.FlowCountService) func(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error
流量统计
func GrpcFlowCountUnaryInterceptor ¶
func GrpcFlowCountUnaryInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)
流量统计
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.