serverinterceptors

Documentation

Index

• func StreamAuthorizeInterceptor(authenticator *auth.Authenticator) grpc.StreamServerInterceptor
• func StreamCrashInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) (err error)
• func UnaryAuthorizeInterceptor(authenticator *auth.Authenticator) grpc.UnaryServerInterceptor
• func UnaryCrashInterceptor() grpc.UnaryServerInterceptor
• func UnaryPrometheusInterceptor() grpc.UnaryServerInterceptor
• func UnarySheddingInterceptor(shedder load.Shedder, metrics *stat.Metrics) grpc.UnaryServerInterceptor
• func UnaryStatInterceptor(metrics *stat.Metrics) grpc.UnaryServerInterceptor
• func UnaryTimeoutInterceptor(timeout time.Duration) grpc.UnaryServerInterceptor
• func UnaryTracingInterceptor(serviceName string) grpc.UnaryServerInterceptor

Functions

func StreamAuthorizeInterceptor

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

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

func StreamCrashInterceptor

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

StreamCrashInterceptor catches panics in processing stream requests and recovers.

func UnaryAuthorizeInterceptor

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

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

func UnaryCrashInterceptor

func UnaryCrashInterceptor() grpc.UnaryServerInterceptor

UnaryCrashInterceptor catches panics in processing unary requests and recovers.

func UnaryPrometheusInterceptor

func UnaryPrometheusInterceptor() grpc.UnaryServerInterceptor

UnaryPrometheusInterceptor returns a func that reports 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(serviceName string) grpc.UnaryServerInterceptor

UnaryTracingInterceptor returns a func that handles tracing with given service name.