serverinterceptors

package
v0.0.0-...-ccf4dff Latest Latest
Warning

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

Go to latest
Published: Oct 11, 2022 License: MIT Imports: 28 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DontLogContentForMethod

func DontLogContentForMethod(method string)

DontLogContentForMethod disable logging content for given method.

func SetSlowThreshold

func SetSlowThreshold(threshold time.Duration)

SetSlowThreshold sets the slow threshold.

func StreamAuthorizeInterceptor

func StreamAuthorizeInterceptor(authenticator *auth.Authenticator) grpc.StreamServerInterceptor

StreamAuthorizeInterceptor returns a func that uses given authenticator in processing stream requests.

func StreamBreakerInterceptor

func StreamBreakerInterceptor(svr interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo,
	handler grpc.StreamHandler) (err error)

StreamBreakerInterceptor is an interceptor that acts as a circuit breaker.

func StreamCrashInterceptor

func StreamCrashInterceptor(svr interface{}, stream grpc.ServerStream, _ *grpc.StreamServerInfo,
	handler grpc.StreamHandler) (err error)

StreamCrashInterceptor catches panics in processing stream requests and recovers.

func StreamTracingInterceptor

func StreamTracingInterceptor(svr interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo,
	handler grpc.StreamHandler) error

StreamTracingInterceptor returns a grpc.StreamServerInterceptor for opentelemetry.

func UnaryAuthorizeInterceptor

func UnaryAuthorizeInterceptor(authenticator *auth.Authenticator) grpc.UnaryServerInterceptor

UnaryAuthorizeInterceptor returns a func that uses given authenticator in processing unary requests.

func UnaryBreakerInterceptor

func UnaryBreakerInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler) (resp interface{}, err error)

UnaryBreakerInterceptor is an interceptor that acts as a circuit breaker.

func UnaryCrashInterceptor

func UnaryCrashInterceptor(ctx context.Context, req interface{}, _ *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler) (resp interface{}, err error)

UnaryCrashInterceptor catches panics in processing unary requests and recovers.

func UnaryPrometheusInterceptor

func UnaryPrometheusInterceptor(ctx context.Context, req interface{},
	info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (interface{}, error)

UnaryPrometheusInterceptor reports the statistics to the prometheus server.

func UnarySheddingInterceptor

func UnarySheddingInterceptor(shedder load.Shedder, metrics *stat.Metrics) grpc.UnaryServerInterceptor

UnarySheddingInterceptor returns a func that does load shedding on processing unary requests.

func UnaryStatInterceptor

func UnaryStatInterceptor(metrics *stat.Metrics) grpc.UnaryServerInterceptor

UnaryStatInterceptor returns a func that uses given metrics to report stats.

func UnaryTimeoutInterceptor

func UnaryTimeoutInterceptor(timeout time.Duration) grpc.UnaryServerInterceptor

UnaryTimeoutInterceptor returns a func that sets timeout to incoming unary requests.

func UnaryTracingInterceptor

func UnaryTracingInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler) (interface{}, error)

UnaryTracingInterceptor is a grpc.UnaryServerInterceptor for opentelemetry.

Types

This section is empty.

Jump to

Keyboard shortcuts

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