Documentation
¶
Index ¶
- func StreamAuthorizeInterceptor(authenticator *auth.Authenticator) grpc.StreamServerInterceptor
- func StreamBreakerInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) (err error)
- func StreamCrashInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) (err error)
- func StreamOpenTracingInterceptor() grpc.StreamServerInterceptor
- func StreamTracingInterceptor(serviceName string) grpc.StreamServerInterceptor
- func UnaryAuthorizeInterceptor(authenticator *auth.Authenticator) grpc.UnaryServerInterceptor
- func UnaryBreakerInterceptor() grpc.UnaryServerInterceptor
- func UnaryCrashInterceptor() grpc.UnaryServerInterceptor
- func UnaryOpenTracingInterceptor() 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
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(srv 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(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo,
handler grpc.StreamHandler) (err error)
StreamCrashInterceptor catches panics in processing stream requests and recovers.
func StreamOpenTracingInterceptor ¶
func StreamOpenTracingInterceptor() grpc.StreamServerInterceptor
StreamOpenTracingInterceptor returns a grpc.StreamServerInterceptor for opentelemetry.
func StreamTracingInterceptor ¶
func StreamTracingInterceptor(serviceName string) grpc.StreamServerInterceptor
StreamTracingInterceptor returns a grpc.StreamServerInterceptor that handles tracing with given service name.
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() grpc.UnaryServerInterceptor
UnaryBreakerInterceptor is an interceptor that acts as a circuit breaker.
func UnaryCrashInterceptor ¶
func UnaryCrashInterceptor() grpc.UnaryServerInterceptor
UnaryCrashInterceptor catches panics in processing unary requests and recovers.
func UnaryOpenTracingInterceptor ¶
func UnaryOpenTracingInterceptor() grpc.UnaryServerInterceptor
UnaryOpenTracingInterceptor returns a grpc.UnaryServerInterceptor for opentelemetry.
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 grpc.UnaryServerInterceptor that handles tracing with given service name.
Types ¶
This section is empty.
Source Files