Documentation
¶
Index ¶
- type Base
- type Cache
- type Changed
- type Echo
- type Filter
- 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
- type Format
- type HTTP
- type Hash
- type Js
- type Mail
- type Override
- type System
- type Text
- type URL
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Base ¶
type Base struct {
// contains filtered or unexported fields
}
Base is inherited from the feeders
func (*Base) GetIdentifier ¶
GetIdentifier returns the Node identifier ID used in the bus
func (*Base) Pipe ¶
Pipe gets a Message from the previous Node and Propagate it to the next one if the Filter's callback will return true
type Changed ¶
Changed is a Filter that call the propagation method only if the input Message is different from the previous one
type Echo ¶
type Echo struct {
Base
// contains filtered or unexported fields
}
Echo is a filter that print the input Message on the logs.
type Filter ¶
type Filter interface {
Rule() string
Name() string
DoFilter(msg *data.Message) (bool, error)
Pipe(msg *data.Message)
GetIdentifier() string
// contains filtered or unexported methods
}
Filter defines Base methods of the object
func NewCacheFilter ¶
NewCacheFilter is the registered method to instantiate a CacheFilter
func NewChangedFilter ¶
NewChangedFilter is the registered method to instantiate a ChangedFilter
func NewEchoFilter ¶
NewEchoFilter is the registered method to instantiate a EchoFilter
func NewFilter ¶
func NewFilter(rule string, name string, conf map[string]string, bus EventBus.Bus, id int32, neg bool) (Filter, error)
NewFilter creates a new registered Filter from it's name
func NewFormatFilter ¶
NewFormatFilter is the registered method to instantiate a FormatFilter
func NewHTTPFilter ¶
NewHTTPFilter is the registered method to instantiate a HttpFilter
func NewHashFilter ¶
NewHashFilter is the registered method to instantiate a HashFilter
func NewJsFilter ¶
NewJsFilter is the registered method to instantiate a JsFilter
func NewMailFilter ¶
NewMailFilter is the registered method to instantiate a MailFilter
func NewOverrideFilter ¶
NewOverrideFilter is the registered method to instantiate a OverrideFilter
func NewSystemFilter ¶
NewSystemFilter is the registered method to instantiate a SystemFilter
func NewTextFilter ¶
NewTextFilter is the registered method to instantiate a TextFilter
type FilterFactory ¶
FilterFactory identifies a function to instantiate a Filter using the Factory
type Format ¶
type Format struct {
Base
// contains filtered or unexported fields
}
Format is a Filter that apply a Golang Template to the input Message and propagate it to the next Filter
type HTTP ¶
type HTTP struct {
Base
// contains filtered or unexported fields
}
HTTP is a filter to handle http requests using the input Message
type Hash ¶
type Hash struct {
Base
// contains filtered or unexported fields
}
Hash is a Filter that searches for hashes in the Message
type Js ¶
type Js struct {
Base
// contains filtered or unexported fields
}
Js is a Filter that load a plugin written in Javascript to create a custom Filter
type Mail ¶
type Mail struct {
Base
// contains filtered or unexported fields
}
Mail is a Filter to send e-mail using the input Message
type Override ¶
type Override struct {
Base
// contains filtered or unexported fields
}
Override is a Filter that allow to change the current Message before to send it to the next Filter
type System ¶
type System struct {
Base
// contains filtered or unexported fields
}
System is a Filter to exec a command on the host machine using the input Message