middleware

Documentation

Index

• func AttachServerNameInterceptor(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• func InterceptorLogger(l *zerolog.Logger) logging.Logger
• func ServerNameStreamingInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
• type ErrorInterceptor
  • func NewErrorInterceptor(a errors.Alerter, l *zerolog.Logger) *ErrorInterceptor
  • func (e *ErrorInterceptor) ErrorStreamServerInterceptor() grpc.StreamServerInterceptor
  • func (e *ErrorInterceptor) ErrorUnaryServerInterceptor() grpc.UnaryServerInterceptor
• type GRPCAuthN
  • func NewAuthN(config *server.ServerConfig) *GRPCAuthN
  • func (a *GRPCAuthN) Middleware(ctx context.Context) (context.Context, error)
• type HatchetApiTokenRateLimiter
• type HatchetRateLimiter
  • func NewHatchetRateLimiter(r rate.Limit, b int, l *zerolog.Logger) *HatchetRateLimiter
  • func (rl *HatchetRateLimiter) GetOrCreateTenantRateLimiter(rateLimitToken string) *HatchetApiTokenRateLimiter
  • func (r *HatchetRateLimiter) Limit(ctx context.Context) error

Functions

func AttachServerNameInterceptor

func AttachServerNameInterceptor(
	ctx context.Context,
	req interface{},
	info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler,
) (interface{}, error)

func InterceptorLogger

func InterceptorLogger(l *zerolog.Logger) logging.Logger

InterceptorLogger adapts zerolog logger to interceptor logger. This code is simple enough to be copied and not imported.

func ServerNameStreamingInterceptor

func ServerNameStreamingInterceptor(
	srv interface{},
	ss grpc.ServerStream,
	info *grpc.StreamServerInfo,
	handler grpc.StreamHandler,
) error

Types

type ErrorInterceptor

type ErrorInterceptor struct {
	// contains filtered or unexported fields
}

func NewErrorInterceptor

func NewErrorInterceptor(a errors.Alerter,
	l *zerolog.Logger) *ErrorInterceptor

func (*ErrorInterceptor) ErrorStreamServerInterceptor

func (e *ErrorInterceptor) ErrorStreamServerInterceptor() grpc.StreamServerInterceptor

StreamServerInterceptor returns a new streaming server interceptor for panic recovery.

func (*ErrorInterceptor) ErrorUnaryServerInterceptor

func (e *ErrorInterceptor) ErrorUnaryServerInterceptor() grpc.UnaryServerInterceptor

UnaryServerInterceptor returns a new unary server interceptor for panic recovery.

type GRPCAuthN

type GRPCAuthN struct {
	// contains filtered or unexported fields
}

func NewAuthN

func NewAuthN(config *server.ServerConfig) *GRPCAuthN

func (*GRPCAuthN) Middleware

func (a *GRPCAuthN) Middleware(ctx context.Context) (context.Context, error)

type HatchetApiTokenRateLimiter

type HatchetApiTokenRateLimiter struct {
	// contains filtered or unexported fields
}

type HatchetRateLimiter

type HatchetRateLimiter struct {
	// contains filtered or unexported fields
}

func NewHatchetRateLimiter

func NewHatchetRateLimiter(r rate.Limit, b int, l *zerolog.Logger) *HatchetRateLimiter

func (*HatchetRateLimiter) GetOrCreateTenantRateLimiter

func (rl *HatchetRateLimiter) GetOrCreateTenantRateLimiter(rateLimitToken string) *HatchetApiTokenRateLimiter

func (*HatchetRateLimiter) Limit

func (r *HatchetRateLimiter) Limit(ctx context.Context) error

Limit is called before each request is processed. It should return an error if rate-limited.