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
- type GRPCAuthN
- type HatchetApiTokenRateLimiter
- type HatchetRateLimiter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AttachServerNameInterceptor ¶
func AttachServerNameInterceptor( ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler, ) (interface{}, error)
func InterceptorLogger ¶
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
type HatchetApiTokenRateLimiter ¶
type HatchetApiTokenRateLimiter struct {
// contains filtered or unexported fields
}
type HatchetRateLimiter ¶
type HatchetRateLimiter struct {
// contains filtered or unexported fields
}
func NewHatchetRateLimiter ¶
func (*HatchetRateLimiter) GetOrCreateTenantRateLimiter ¶
func (rl *HatchetRateLimiter) GetOrCreateTenantRateLimiter(rateLimitToken string) *HatchetApiTokenRateLimiter
Source Files
Click to show internal directories.
Click to hide internal directories.