serverinterceptors

Documentation

Index

• Constants
• func AuthStream(authFunc grpc_auth.AuthFunc) grpc.StreamServerInterceptor
• func AuthUnary(authFunc grpc_auth.AuthFunc) grpc.UnaryServerInterceptor
• func DefaultRecovery() grpc_recovery.RecoveryHandlerFuncContext
• func HystrixRateLimitStream(cc hystrix.CommandConfig, cfgs ...ghystrix.HystrixCfg) grpc.StreamServerInterceptor
• func HystrixRateLimitUnary(cc hystrix.CommandConfig, cfgs ...ghystrix.HystrixCfg) grpc.UnaryServerInterceptor
• func OpenTracingStream(opts ...grpc_opentracing.Option) grpc.StreamServerInterceptor
• func OpenTracingUnary(opts ...grpc_opentracing.Option) grpc.UnaryServerInterceptor
• func RateLimitStream(limiter ratelimit.Limiter) grpc.StreamServerInterceptor
• func RateLimitUnary(limiter ratelimit.Limiter) grpc.UnaryServerInterceptor
• func RecoveryStream(f grpc_recovery.RecoveryHandlerFuncContext) grpc.StreamServerInterceptor
• func RecoveryUnary(f grpc_recovery.RecoveryHandlerFuncContext) grpc.UnaryServerInterceptor
• func SetLog(log logger.Logger)
• func TimeoutStream(t time.Duration) grpc.StreamServerInterceptor
• func TimeoutUnary(t time.Duration) grpc.UnaryServerInterceptor
• type RateLimit
  • func (r RateLimit) Limit() bool

Constants

const (
	DefaultUnaryTimeout  = 10 * time.Second
	DefaultStreamTimeout = 10 * time.Second
)

Functions

func AuthStream

func AuthStream(authFunc grpc_auth.AuthFunc) grpc.StreamServerInterceptor

func AuthUnary

func AuthUnary(authFunc grpc_auth.AuthFunc) grpc.UnaryServerInterceptor

func DefaultRecovery

func DefaultRecovery() grpc_recovery.RecoveryHandlerFuncContext

func HystrixRateLimitStream

func HystrixRateLimitStream(cc hystrix.CommandConfig, cfgs ...ghystrix.HystrixCfg) grpc.StreamServerInterceptor

func HystrixRateLimitUnary

func HystrixRateLimitUnary(cc hystrix.CommandConfig, cfgs ...ghystrix.HystrixCfg) grpc.UnaryServerInterceptor

func OpenTracingStream

func OpenTracingStream(opts ...grpc_opentracing.Option) grpc.StreamServerInterceptor

func OpenTracingUnary

func OpenTracingUnary(opts ...grpc_opentracing.Option) grpc.UnaryServerInterceptor

func RateLimitStream

func RateLimitStream(limiter ratelimit.Limiter) grpc.StreamServerInterceptor

func RateLimitUnary

func RateLimitUnary(limiter ratelimit.Limiter) grpc.UnaryServerInterceptor

func RecoveryStream

func RecoveryStream(f grpc_recovery.RecoveryHandlerFuncContext) grpc.StreamServerInterceptor

func RecoveryUnary

func RecoveryUnary(f grpc_recovery.RecoveryHandlerFuncContext) grpc.UnaryServerInterceptor

func SetLog

func SetLog(log logger.Logger)

func TimeoutStream

func TimeoutStream(t time.Duration) grpc.StreamServerInterceptor

TimeoutStream returns a new streaming server interceptor for panic recovery.

func TimeoutUnary

func TimeoutUnary(t time.Duration) grpc.UnaryServerInterceptor

TimeoutUnary returns a new unary server interceptor for OpenTracing.

Types

type RateLimit

type RateLimit struct{}

func (RateLimit) Limit

func (r RateLimit) Limit() bool