clientinterceptors

package
v1.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 14, 2023 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

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

Variables

This section is empty.

Functions

func BreakerStreamByService added in v1.3.0

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

func BreakerUnaryByService added in v1.3.0

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

Types

This section is empty.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL