filters

May 22, 2024

Changes in this version

type Filter

+ func NewJSONFilter(p map[string]string) (Filter, error)

+ func NewRateLimitFilter(p map[string]string) (Filter, error)

+ func NewXLSFilter(p map[string]string) (Filter, error)

+ type JSON struct

+ func (f *JSON) DoFilter(msg *data.Message) (bool, error)

+ func (f *JSON) OnEvent(event *data.Event)

+ type RateLimit struct

+ func (f *RateLimit) DoFilter(msg *data.Message) (bool, error)

+ func (f *RateLimit) OnEvent(event *data.Event)

+ type XLS struct

+ func (f *XLS) DoFilter(msg *data.Message) (bool, error)

+ func (f *XLS) OnEvent(event *data.Event)

Jul 20, 2022

Changes in this version

type Filter

+ func NewHTMLFilter(p map[string]string) (Filter, error)

+ type HTML struct

+ func (f *HTML) DoFilter(msg *data.Message) (bool, error)

+ func (f *HTML) OnEvent(event *data.Event)

Oct 29, 2021

Changes in this version

+ type ElasticSearch struct

+ func (f *ElasticSearch) DoFilter(msg *data.Message) (bool, error)

+ func (f *ElasticSearch) OnEvent(event *data.Event)

+ type File struct

+ func (f *File) DoFilter(msg *data.Message) (bool, error)

+ func (f *File) OnEvent(event *data.Event)

type Filter

+ func NewElasticSearchFilter(p map[string]string) (Filter, error)

+ func NewFileFilter(p map[string]string) (Filter, error)

Jul 1, 2021

Changes in this version

type Filter

+ func NewStripTagFilter(p map[string]string) (Filter, error)

+ type StripTag struct

+ func (f *StripTag) DoFilter(msg *data.Message) (bool, error)

+ func (f *StripTag) OnEvent(event *data.Event)

Apr 27, 2021

Changes in this version

type Cache

+ func (f *Cache) OnEvent(event *data.Event)

type Changed

+ func (f *Changed) OnEvent(event *data.Event)

type Echo

+ func (f *Echo) OnEvent(event *data.Event)

type Filter

+ OnEvent func(e *data.Event)

type Format

+ func (f *Format) OnEvent(event *data.Event)

type HTTP

+ func (f *HTTP) OnEvent(event *data.Event)

type Hash

+ func (f *Hash) OnEvent(event *data.Event)

type Js

+ func (f *Js) OnEvent(event *data.Event)

type Mail

+ func (f *Mail) OnEvent(event *data.Event)

type Mimetype

+ func (f *Mimetype) OnEvent(event *data.Event)

type Override

+ func (f *Override) OnEvent(event *data.Event)

type PDF

+ func (f *PDF) OnEvent(event *data.Event)

type Random

+ func (f *Random) OnEvent(event *data.Event)

type Slack

+ func (f *Slack) OnEvent(event *data.Event)

type System

+ func (f *System) OnEvent(event *data.Event)

type Text

+ func (f *Text) OnEvent(event *data.Event)

type URL

+ func (f *URL) OnEvent(event *data.Event)

Oct 13, 2020

Changes in this version

type Filter

+ func NewSlackFilter(p map[string]string) (Filter, error)

+ type Slack struct

+ func (f *Slack) DoFilter(msg *data.Message) (bool, error)

Sep 22, 2020

Changes in this version

type Base

+ func (f *Base) Log(format string, args ...interface{})

type Filter

+ func NewRandomFilter(p map[string]string) (Filter, error)

+ Log func(format string, args ...interface{})

+ type Random struct

+ func (f *Random) DoFilter(msg *data.Message) (bool, error)

Sep 21, 2020

Changes in this version

type Filter

+ func NewMimetypeFilter(p map[string]string) (Filter, error)

+ func NewPDFFilter(p map[string]string) (Filter, error)

+ type Mimetype struct

+ func (f *Mimetype) DoFilter(msg *data.Message) (bool, error)

+ type PDF struct

+ func (f *PDF) DoFilter(msg *data.Message) (bool, error)

Sep 20, 2020

Changes in this version

+ type Base struct

+ func (f *Base) GetIdentifier() string

+ func (f *Base) Name() string

+ func (f *Base) Pipe(msg *data.Message)

+ func (f *Base) Propagate(data *data.Message)

+ func (f *Base) Rule() string

+ type Cache struct

+ func (f *Cache) DoFilter(msg *data.Message) (bool, error)

+ type Changed struct

+ func (f *Changed) DoFilter(msg *data.Message) (bool, error)

+ type Echo struct

+ func (f *Echo) DoFilter(msg *data.Message) (bool, error)

+ type Filter interface

+ DoFilter func(msg *data.Message) (bool, error)

+ GetIdentifier func() string

+ Name func() string

+ Pipe func(msg *data.Message)

+ Rule func() string

+ func NewCacheFilter(p map[string]string) (Filter, error)

+ func NewChangedFilter(p map[string]string) (Filter, error)

+ func NewEchoFilter(p map[string]string) (Filter, error)

+ func NewFilter(rule string, name string, conf map[string]string, bus EventBus.Bus, id int32, ...) (Filter, error)

+ func NewFormatFilter(p map[string]string) (Filter, error)

+ func NewHTTPFilter(p map[string]string) (Filter, error)

+ func NewHashFilter(p map[string]string) (Filter, error)

+ func NewJsFilter(p map[string]string) (Filter, error)

+ func NewMailFilter(p map[string]string) (Filter, error)

+ func NewOverrideFilter(p map[string]string) (Filter, error)

+ func NewSystemFilter(p map[string]string) (Filter, error)

+ func NewTextFilter(p map[string]string) (Filter, error)

+ func NewURLFilter(p map[string]string) (Filter, error)

+ type FilterFactory func(conf map[string]string) (Filter, error)

+ type Format struct

+ func (f *Format) DoFilter(msg *data.Message) (bool, error)

+ type HTTP struct

+ func (f *HTTP) DoFilter(msg *data.Message) (bool, error)

+ type Hash struct

+ func (f *Hash) DoFilter(msg *data.Message) (bool, error)

+ type Js struct

+ func (f *Js) DoFilter(msg *data.Message) (bool, error)

+ type Mail struct

+ func (f *Mail) DoFilter(msg *data.Message) (bool, error)

+ type Override struct

+ func (f *Override) DoFilter(msg *data.Message) (bool, error)

+ type System struct

+ func (f *System) DoFilter(msg *data.Message) (bool, error)

+ type Text struct

+ func (f *Text) DoFilter(msg *data.Message) (bool, error)

+ type URL struct

+ func (f *URL) DoFilter(msg *data.Message) (bool, error)