interceptor

Documentation

Index

• type ACLConfig
• type AccessControlInterceptor
  • func NewAccessControlInterceptor(logger log.Logger, adminServiceAllowedMethods []string, ...) *AccessControlInterceptor
  • func (i *AccessControlInterceptor) Intercept(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (any, error)
  • func (i *AccessControlInterceptor) StreamIntercept(service interface{}, serverStream grpc.ServerStream, ...) error
• type TranslationInterceptor
  • func NewTranslationInterceptor(logger log.Logger, translators []Translator) *TranslationInterceptor
  • func (i *TranslationInterceptor) Intercept(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (any, error)
  • func (i *TranslationInterceptor) InterceptStream(srv any, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
• type Translator
  • func NewNamespaceNameTranslator(logger log.Logger, reqMap, respMap map[string]string) Translator
  • func NewSearchAttributeTranslator(logger log.Logger, reqMap, respMap map[string]map[string]string) Translator

Types

type ACLConfig

type ACLConfig interface {
	AllowedNamespaces() []string
	AdminServiceAllowedMethods() []string
}

type AccessControlInterceptor

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

func NewAccessControlInterceptor

func NewAccessControlInterceptor(
	logger log.Logger,
	adminServiceAllowedMethods []string,
	allowedNamespaces []string,
) *AccessControlInterceptor

func (*AccessControlInterceptor) Intercept

func (i *AccessControlInterceptor) Intercept(
	ctx context.Context,
	req any,
	info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler,
) (any, error)

func (*AccessControlInterceptor) StreamIntercept

func (i *AccessControlInterceptor) StreamIntercept(
	service interface{},
	serverStream grpc.ServerStream,
	info *grpc.StreamServerInfo,
	handler grpc.StreamHandler,
) error

type TranslationInterceptor

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

func NewTranslationInterceptor

func NewTranslationInterceptor(
	logger log.Logger,
	translators []Translator,
) *TranslationInterceptor

func (*TranslationInterceptor) Intercept

func (i *TranslationInterceptor) Intercept(
	ctx context.Context,
	req any,
	info *grpc.UnaryServerInfo,
	handler grpc.UnaryHandler,
) (any, error)

func (*TranslationInterceptor) InterceptStream

func (i *TranslationInterceptor) InterceptStream(
	srv any,
	ss grpc.ServerStream,
	info *grpc.StreamServerInfo,
	handler grpc.StreamHandler,
) error

type Translator

type Translator interface {
	MatchMethod(string) bool
	TranslateRequest(any) (bool, error)
	TranslateResponse(any) (bool, error)
	Kind() string
}

func NewNamespaceNameTranslator

func NewNamespaceNameTranslator(logger log.Logger, reqMap, respMap map[string]string) Translator

func NewSearchAttributeTranslator

func NewSearchAttributeTranslator(logger log.Logger, reqMap, respMap map[string]map[string]string) Translator