clientinterceptors

Documentation

Index

• func BreakerInterceptor(ctx context.Context, method string, req, reply interface{}, ...) error
• func DurationInterceptor(ctx context.Context, method string, req, reply interface{}, ...) error
• func PrometheusInterceptor(ctx context.Context, method string, req, reply interface{}, ...) error
• func StreamOpenTracingInterceptor() grpc.StreamClientInterceptor
• func StreamTracingInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, ...) (grpc.ClientStream, error)
• func TimeoutInterceptor(timeout time.Duration) grpc.UnaryClientInterceptor
• func UnaryOpenTracingInterceptor() grpc.UnaryClientInterceptor
• func UnaryTracingInterceptor(ctx context.Context, method string, req, reply interface{}, ...) error

Functions

func BreakerInterceptor

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

BreakerInterceptor is an interceptor that acts as a circuit breaker.

func DurationInterceptor

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

DurationInterceptor is an interceptor that logs the processing time.

func PrometheusInterceptor

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

PrometheusInterceptor is an interceptor that reports to prometheus server.

func StreamOpenTracingInterceptor

func StreamOpenTracingInterceptor() grpc.StreamClientInterceptor

StreamOpenTracingInterceptor returns a grpc.StreamClientInterceptor for opentelemetry.

func StreamTracingInterceptor

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

StreamTracingInterceptor is an interceptor that handles tracing for stream requests.

func TimeoutInterceptor

func TimeoutInterceptor(timeout time.Duration) grpc.UnaryClientInterceptor

TimeoutInterceptor is an interceptor that controls timeout.

func UnaryOpenTracingInterceptor

func UnaryOpenTracingInterceptor() grpc.UnaryClientInterceptor

UnaryOpenTracingInterceptor returns a grpc.UnaryClientInterceptor for opentelemetry.

func UnaryTracingInterceptor

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

UnaryTracingInterceptor is an interceptor that handles tracing.