clientinterceptors

package

v1.1.3 Latest Latest Go to latest Published: Apr 19, 2021 License: MIT Imports: 16 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/coder2z/g-server

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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 ¶ added in v1.0.8

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

Source Files ¶

View all Source files

interceptor.go

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