core

func Commands ¶ added in v0.3.0

func Commands(message models.Message, outputMsgs chan<- models.Message, rules *map[string]models.Rule, config models.Config)

func Config ¶

func Config(config *models.Config, version string)

Config func

func DirExists ¶ added in v0.3.0

func DirExists(dir string) bool

func FileExists ¶

func FileExists(file string) bool

func Handler ¶ added in v0.3.0

func Handler(plugins *map[string]models.Plugin, config models.Config)

func Inputs ¶

func Inputs(inputMsgs chan<- models.Message, rules *map[string]models.Rule, config models.Config)

func Logging ¶ added in v0.3.0

func Logging(config *models.Config)

func MakePath ¶ added in v0.3.0

func MakePath(dir string, file string) string

func Matcher ¶ added in v0.3.0

func Matcher(inputMsgs <-chan models.Message, outputMsgs chan<- models.Message, plugins *map[string]models.Plugin, rules *map[string]models.Rule, config models.Config)

Matcher function

func Outputs ¶

func Outputs(outputMsgs <-chan models.Message, plugins *map[string]models.Plugin, config models.Config)

func Plugins ¶ added in v0.3.0

func Plugins(plugins *map[string]models.Plugin, rules map[string]models.Rule, config models.Config)

func ResolvePluginName ¶ added in v0.3.0

func ResolvePluginName(pluginName string) string

func Rules ¶ added in v0.3.0

func Rules(rules *map[string]models.Rule, config models.Config)

func StopPlugins ¶ added in v0.3.0

func StopPlugins(plugins map[string]models.Plugin, config models.Config)