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 TimeoutInterceptor(timeout time.Duration) grpc.UnaryClientInterceptor
• func TracingInterceptor(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 TimeoutInterceptor

func TimeoutInterceptor(timeout time.Duration) grpc.UnaryClientInterceptor

TimeoutInterceptor is an interceptor that controls timeout.

func TracingInterceptor

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

TracingInterceptor is an interceptor that handles tracing.