clientinterceptors

Documentation

Index

• Constants
• func BreakerStream(opts ...grpc_hystrix.Option) grpc.StreamClientInterceptor
• func BreakerUnary(opts ...grpc_hystrix.Option) grpc.UnaryClientInterceptor
• func DefaultRecovery() grpc_recovery.RecoveryHandlerFuncContext
• func OpenTracingStream(opts ...grpc_opentracing.Option) grpc.StreamClientInterceptor
• func OpenTracingUnary(opts ...grpc_opentracing.Option) grpc.UnaryClientInterceptor
• func RecoveryStream(f grpc_recovery.RecoveryHandlerFuncContext) grpc.StreamClientInterceptor
• func RecoveryUnary(f grpc_recovery.RecoveryHandlerFuncContext) grpc.UnaryClientInterceptor
• func ShrinkDeadline(ctx context.Context, timeout time.Duration) (context.Context, func())
• func TimeoutStream(t time.Duration) grpc.StreamClientInterceptor
• func TimeoutUnary(t time.Duration) grpc.UnaryClientInterceptor

Constants

const (
	DefaultUnaryTimeout  = 10 * time.Second
	DefaultStreamTimeout = 10 * time.Second
)

Functions

func BreakerStream

func BreakerStream(opts ...grpc_hystrix.Option) grpc.StreamClientInterceptor

func BreakerUnary

func BreakerUnary(opts ...grpc_hystrix.Option) grpc.UnaryClientInterceptor

func DefaultRecovery

func DefaultRecovery() grpc_recovery.RecoveryHandlerFuncContext

func OpenTracingStream

func OpenTracingStream(opts ...grpc_opentracing.Option) grpc.StreamClientInterceptor

func OpenTracingUnary

func OpenTracingUnary(opts ...grpc_opentracing.Option) grpc.UnaryClientInterceptor

func RecoveryStream

func RecoveryStream(f grpc_recovery.RecoveryHandlerFuncContext) grpc.StreamClientInterceptor

func RecoveryUnary

func RecoveryUnary(f grpc_recovery.RecoveryHandlerFuncContext) grpc.UnaryClientInterceptor

func ShrinkDeadline

func ShrinkDeadline(ctx context.Context, timeout time.Duration) (context.Context, func())

func TimeoutStream

func TimeoutStream(t time.Duration) grpc.StreamClientInterceptor

TimeoutStream returns a new streaming server interceptor for panic recovery.

func TimeoutUnary

func TimeoutUnary(t time.Duration) grpc.UnaryClientInterceptor

TimeoutUnary returns a new unary server interceptor for OpenTracing.