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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StreamAuthorizeInterceptor ¶
func StreamAuthorizeInterceptor(authenticator *auth.Authenticator) grpc.StreamServerInterceptor
func StreamCrashInterceptor ¶
func StreamCrashInterceptor(srv interface{}, stream grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) (err error)
func UnaryAuthorizeInterceptor ¶
func UnaryAuthorizeInterceptor(authenticator *auth.Authenticator) grpc.UnaryServerInterceptor
func UnaryCrashInterceptor ¶
func UnaryCrashInterceptor() grpc.UnaryServerInterceptor
func UnaryPrometheusInterceptor ¶
func UnaryPrometheusInterceptor() grpc.UnaryServerInterceptor
func UnaryStatInterceptor ¶
func UnaryStatInterceptor(metrics *stat.Metrics) grpc.UnaryServerInterceptor
func UnaryTimeoutInterceptor ¶
func UnaryTimeoutInterceptor(timeout time.Duration) grpc.UnaryServerInterceptor
func UnaryTracingInterceptor ¶
func UnaryTracingInterceptor(serviceName string) grpc.UnaryServerInterceptor
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.