clientinterceptors

Documentation

Index

• func HystrixStreamClientInterceptor(...) grpc.StreamClientInterceptor
• func HystrixUnaryClientIntercept(...) grpc.UnaryClientInterceptor
• func PrometheusStreamClientInterceptor(name string) ...
• func PrometheusUnaryClientInterceptor(name string) func(ctx context.Context, method string, req, reply interface{}, ...) error
• func XAidUnaryClientInterceptor() grpc.UnaryClientInterceptor
• func XLoggerUnaryClientInterceptor(name string) grpc.UnaryClientInterceptor
• func XTimeoutUnaryClientInterceptor(timeout time.Duration, slowThreshold time.Duration) grpc.UnaryClientInterceptor
• func XTraceUnaryClientInterceptor() grpc.UnaryClientInterceptor
• type XAid

Functions

func HystrixStreamClientInterceptor

func HystrixStreamClientInterceptor(timeout, maxConcurrentRequests, requestVolumeThreshold, errorPercentThreshold, sleepWindow int,
	fallback func(context.Context, error) error) grpc.StreamClientInterceptor

func HystrixUnaryClientIntercept

func HystrixUnaryClientIntercept(timeout, maxConcurrentRequests, requestVolumeThreshold, errorPercentThreshold, sleepWindow int,
	fallback func(context.Context, error) error) grpc.UnaryClientInterceptor

func PrometheusStreamClientInterceptor

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

func PrometheusUnaryClientInterceptor

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

func XAidUnaryClientInterceptor

func XAidUnaryClientInterceptor() grpc.UnaryClientInterceptor

func XLoggerUnaryClientInterceptor

func XLoggerUnaryClientInterceptor(name string) grpc.UnaryClientInterceptor

func XTimeoutUnaryClientInterceptor

func XTimeoutUnaryClientInterceptor(timeout time.Duration, slowThreshold time.Duration) grpc.UnaryClientInterceptor

func XTraceUnaryClientInterceptor

func XTraceUnaryClientInterceptor() grpc.UnaryClientInterceptor

Types

type XAid

type XAid struct {
	AppName  string `json:"app_name"`
	HostName string `json:"host_name"`
	AppId    string `json:"app_id"`
	HostIP   string `json:"host_ip"`
}