clientinterceptors

package
v0.5.3 Latest Latest
Warning

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

Go to latest
Published: Mar 6, 2021 License: MIT Imports: 16 Imported by: 0

Documentation

Overview

* * @Author: myxy99 <myxy99@foxmail.com> * @Date: 2021/1/2 12:50

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func BreakStreamClientInterceptor

func BreakStreamClientInterceptor() grpc.StreamClientInterceptor

func BreakUnaryClientIntercept

func BreakUnaryClientIntercept() grpc.UnaryClientInterceptor

TODO 熔断限流?

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

This section is empty.

Jump to

Keyboard shortcuts

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