clientinterceptors

Documentation

Index

• Constants
• func BreakerStream(cc hystrix.CommandConfig, cfgs ...ghystrix.HystrixCfg) grpc.StreamClientInterceptor
• func BreakerStreamByService(serviceName string, cc hystrix.CommandConfig) grpc.StreamClientInterceptor
• func BreakerUnary(cc hystrix.CommandConfig, cfgs ...ghystrix.HystrixCfg) grpc.UnaryClientInterceptor
• func BreakerUnaryByService(serviceName string, cc hystrix.CommandConfig) 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(cc hystrix.CommandConfig, cfgs ...ghystrix.HystrixCfg) grpc.StreamClientInterceptor

func BreakerStreamByService

func BreakerStreamByService(serviceName string, cc hystrix.CommandConfig) grpc.StreamClientInterceptor

func BreakerUnary

func BreakerUnary(cc hystrix.CommandConfig, cfgs ...ghystrix.HystrixCfg) grpc.UnaryClientInterceptor

func BreakerUnaryByService

func BreakerUnaryByService(serviceName string, cc hystrix.CommandConfig) 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.