clientinterceptors

Documentation

Overview

* * @Author: myxy99 <myxy99@foxmail.com> * @Date: 2021/1/2 12:50

Index

• func BreakStreamClientInterceptor() grpc.StreamClientInterceptor
• func BreakUnaryClientIntercept() grpc.UnaryClientInterceptor
• func PrometheusStreamClientInterceptor(name string) ...
• func PrometheusUnaryClientInterceptor(name string) func(ctx context.Context, method string, req, reply interface{}, ...) error
• func XAidUnaryClientInterceptor() grpc.UnaryClientInterceptor
• func XLoggerUnaryClientInterceptor(name string) grpc.UnaryClientInterceptor
• func XTimeoutUnaryClientInterceptor(timeout time.Duration, slowThreshold time.Duration) grpc.UnaryClientInterceptor
• func XTraceUnaryClientInterceptor() grpc.UnaryClientInterceptor

Functions

func BreakStreamClientInterceptor

func BreakStreamClientInterceptor() grpc.StreamClientInterceptor

func BreakUnaryClientIntercept

func BreakUnaryClientIntercept() grpc.UnaryClientInterceptor

TODO 熔断限流？

func PrometheusStreamClientInterceptor

func PrometheusStreamClientInterceptor(name string) func(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error)

func PrometheusUnaryClientInterceptor

func PrometheusUnaryClientInterceptor(name string) func(ctx context.Context, method string, req, reply interface{}, cc *grpc.ClientConn, invoker grpc.UnaryInvoker, opts ...grpc.CallOption) error

func XAidUnaryClientInterceptor

func XAidUnaryClientInterceptor() grpc.UnaryClientInterceptor

func XLoggerUnaryClientInterceptor

func XLoggerUnaryClientInterceptor(name string) grpc.UnaryClientInterceptor

func XTimeoutUnaryClientInterceptor

func XTimeoutUnaryClientInterceptor(timeout time.Duration, slowThreshold time.Duration) grpc.UnaryClientInterceptor

func XTraceUnaryClientInterceptor

func XTraceUnaryClientInterceptor() grpc.UnaryClientInterceptor