filtermanager

Documentation

Index

• func FilterManagerFactory(c interface{}, cb capi.FilterCallbackHandler) (streamFilter capi.StreamFilter)
• func InternalErrorFactoryForCAPI(cfg interface{}, callbacks capi.FilterCallbackHandler) capi.StreamFilter
• func NewDebugFilter(name string, internal api.Filter, callbacks api.FilterCallbackHandler) api.Filter
• func NewDecoderFilterCallbackHandlerWrapper(h capi.DecoderFilterCallbacks) api.DecoderFilterCallbacks
• func NewEncoderFilterCallbackHandlerWrapper(h capi.EncoderFilterCallbacks) api.EncoderFilterCallbacks
• func NewInternalErrorFactory(plugin string, err error) api.FilterFactory
• func NewLogExecutionFilter(name string, internal api.Filter, callbacks api.FilterCallbackHandler) api.Filter
• func PassThroughFactory(interface{}, api.FilterCallbackHandler) api.Filter
• type FilterManagerConfig
• type FilterManagerConfigParser
  • func (p *FilterManagerConfigParser) Merge(parent interface{}, child interface{}) interface{}
  • func (p *FilterManagerConfigParser) Parse(any *anypb.Any, callbacks capi.ConfigCallbackHandler) (interface{}, error)

Functions

func FilterManagerFactory

func FilterManagerFactory(c interface{}, cb capi.FilterCallbackHandler) (streamFilter capi.StreamFilter)

func InternalErrorFactoryForCAPI

func InternalErrorFactoryForCAPI(cfg interface{}, callbacks capi.FilterCallbackHandler) capi.StreamFilter

func NewDebugFilter

func NewDebugFilter(name string, internal api.Filter, callbacks api.FilterCallbackHandler) api.Filter

func NewDecoderFilterCallbackHandlerWrapper

func NewDecoderFilterCallbackHandlerWrapper(h capi.DecoderFilterCallbacks) api.DecoderFilterCallbacks

func NewEncoderFilterCallbackHandlerWrapper

func NewEncoderFilterCallbackHandlerWrapper(h capi.EncoderFilterCallbacks) api.EncoderFilterCallbacks

func NewInternalErrorFactory

func NewInternalErrorFactory(plugin string, err error) api.FilterFactory

func NewLogExecutionFilter

func NewLogExecutionFilter(name string, internal api.Filter, callbacks api.FilterCallbackHandler) api.Filter

func PassThroughFactory

func PassThroughFactory(interface{}, api.FilterCallbackHandler) api.Filter

Types

type FilterManagerConfig

type FilterManagerConfig struct {
	Namespace string `json:"namespace,omitempty"`

	Plugins []*model.FilterConfig `json:"plugins"`
}

type FilterManagerConfigParser

type FilterManagerConfigParser struct {
}

func (*FilterManagerConfigParser) Merge

func (p *FilterManagerConfigParser) Merge(parent interface{}, child interface{}) interface{}

func (*FilterManagerConfigParser) Parse

func (p *FilterManagerConfigParser) Parse(any *anypb.Any, callbacks capi.ConfigCallbackHandler) (interface{}, error)