filtermanager

Documentation

Index

• func FilterManagerFactory(c interface{}) capi.StreamFilterFactory
• func InternalErrorFactory(interface{}, api.FilterCallbackHandler) api.Filter
• func InternalErrorFactoryForCAPI(cfg interface{}, callbacks capi.FilterCallbackHandler) capi.StreamFilter
• func NewLogExecutionFilter(name string, internal api.Filter) 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{}) capi.StreamFilterFactory

func InternalErrorFactory

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

func InternalErrorFactoryForCAPI

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

func NewLogExecutionFilter

func NewLogExecutionFilter(name string, internal api.Filter) 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)