interceptor

Documentation

Index

• Constants
• Variables
• func GetNamespace(req interface{}) string
• func MetricsScope(ctx context.Context, logger log.Logger) metrics.Scope
• type NamespaceCountLimitInterceptor
  • func NewNamespaceCountLimitInterceptor(countFn func(namespace string) int, tokens map[string]int) *NamespaceCountLimitInterceptor
  • func (ni *NamespaceCountLimitInterceptor) Intercept(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• type NamespaceGetter
• type NamespaceRateLimitInterceptor
  • func NewNamespaceRateLimitInterceptor(rateFn func(namespace string) float64, tokens map[string]int) *NamespaceRateLimitInterceptor
  • func (ni *NamespaceRateLimitInterceptor) Intercept(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• type RateLimitInterceptor
  • func NewRateLimitInterceptor(rate quotas.RateFn, tokens map[string]int) *RateLimitInterceptor
  • func (i *RateLimitInterceptor) Intercept(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• type TelemetryInterceptor
  • func NewTelemetryInterceptor(metricsClient metrics.Client, scopes map[string]int, logger log.Logger) *TelemetryInterceptor
  • func (ti *TelemetryInterceptor) Intercept(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)

Constants

const (
	NamespaceRateLimitDefaultToken = 1
)

const (
	RateLimitDefaultToken = 1
)

Variables

var (
	ErrNamespaceCountLimitServerBusy = serviceerror.NewResourceExhausted("namespace count limit exceeded")
)

var (
	ErrNamespaceRateLimitServerBusy = serviceerror.NewResourceExhausted("namespace rate limit exceeded")
)

var (
	RateLimitServerBusy = serviceerror.NewResourceExhausted("service rate limit exceeded")
)

Functions

func GetNamespace

func GetNamespace(req interface{}) string

func MetricsScope

func MetricsScope(
	ctx context.Context,
	logger log.Logger,
) metrics.Scope

Types

type NamespaceCountLimitInterceptor

type NamespaceCountLimitInterceptor struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewNamespaceCountLimitInterceptor

func NewNamespaceCountLimitInterceptor(
	countFn func(namespace string) int,
	tokens map[string]int,
) *NamespaceCountLimitInterceptor

func (*NamespaceCountLimitInterceptor) Intercept

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

type NamespaceGetter

type NamespaceGetter interface {
	GetNamespace() string
}

type NamespaceRateLimitInterceptor

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

func NewNamespaceRateLimitInterceptor

func NewNamespaceRateLimitInterceptor(
	rateFn func(namespace string) float64,
	tokens map[string]int,
) *NamespaceRateLimitInterceptor

func (*NamespaceRateLimitInterceptor) Intercept

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

type RateLimitInterceptor

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

func NewRateLimitInterceptor

func NewRateLimitInterceptor(
	rate quotas.RateFn,
	tokens map[string]int,
) *RateLimitInterceptor

func (*RateLimitInterceptor) Intercept

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

type TelemetryInterceptor

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

func NewTelemetryInterceptor

func NewTelemetryInterceptor(
	metricsClient metrics.Client,
	scopes map[string]int,
	logger log.Logger,
) *TelemetryInterceptor

func (*TelemetryInterceptor) Intercept

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