Versions in this module Expand all Collapse all v0 v0.0.2 Jun 5, 2022 Changes in this version + func SetSlowThreshold(threshold time.Duration) + func StreamAuthorizeInterceptor(authenticator *auth.Authenticator) grpc.StreamServerInterceptor + func StreamBreakerInterceptor(svr interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, ...) (err error) + func StreamCrashInterceptor(svr interface{}, stream grpc.ServerStream, _ *grpc.StreamServerInfo, ...) (err error) + func StreamTracingInterceptor(svr interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error + func UnaryAuthorizeInterceptor(authenticator *auth.Authenticator) grpc.UnaryServerInterceptor + func UnaryBreakerInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (resp interface{}, err error) + func UnaryCrashInterceptor(ctx context.Context, req interface{}, _ *grpc.UnaryServerInfo, ...) (resp interface{}, err error) + func UnaryPrometheusInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error) + 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(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)