interceptor

Documentation

Index

• Constants
• Variables
• func GetNamespace(namespaceCache cache.NamespaceCache, req interface{}) string
• func MetricsScope(ctx context.Context, logger log.Logger) metrics.Scope
• type NamespaceCountLimitInterceptor
  • func NewNamespaceCountLimitInterceptor(namespaceCache cache.NamespaceCache, countFn func(namespace string) int, ...) *NamespaceCountLimitInterceptor
  • func (ni *NamespaceCountLimitInterceptor) Intercept(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• type NamespaceIDGetter
• type NamespaceLogInterceptor
  • func NewNamespaceLogInterceptor(namespaceCache cache.NamespaceCache, logger log.Logger) *NamespaceLogInterceptor
  • func (nli *NamespaceLogInterceptor) Intercept(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• type NamespaceNameGetter
• type NamespaceRateLimitInterceptor
  • func NewNamespaceRateLimitInterceptor(namespaceCache cache.NamespaceCache, rateLimiter quotas.RequestRateLimiter, ...) *NamespaceRateLimitInterceptor
  • func (ni *NamespaceRateLimitInterceptor) Intercept(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• type RateLimitInterceptor
  • func NewRateLimitInterceptor(rateLimiter quotas.RequestRateLimiter, tokens map[string]int) *RateLimitInterceptor
  • func (i *RateLimitInterceptor) Intercept(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, ...) (interface{}, error)
• type TelemetryInterceptor
  • func NewTelemetryInterceptor(namespaceCache cache.NamespaceCache, metricsClient metrics.Client, ...) *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(
	namespaceCache cache.NamespaceCache,
	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(
	namespaceCache cache.NamespaceCache,
	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 NamespaceIDGetter

type NamespaceIDGetter interface {
	GetNamespaceId() string
}

gRPC method request must implement either NamespaceNameGetter or NamespaceIDGetter for namespace specific metrics to be reported properly

type NamespaceLogInterceptor

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

func NewNamespaceLogInterceptor

func NewNamespaceLogInterceptor(namespaceCache cache.NamespaceCache, logger log.Logger) *NamespaceLogInterceptor

func (*NamespaceLogInterceptor) Intercept

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

type NamespaceNameGetter

type NamespaceNameGetter interface {
	GetNamespace() string
}

gRPC method request must implement either NamespaceNameGetter or NamespaceIDGetter for namespace specific metrics to be reported properly

type NamespaceRateLimitInterceptor

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

func NewNamespaceRateLimitInterceptor

func NewNamespaceRateLimitInterceptor(
	namespaceCache cache.NamespaceCache,
	rateLimiter quotas.RequestRateLimiter,
	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(
	rateLimiter quotas.RequestRateLimiter,
	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(
	namespaceCache cache.NamespaceCache,
	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)