Versions in this module Expand all Collapse all v0 v0.9.0 Apr 14, 2017 Changes in this version + var ApiRegistry = make(map[string]interface{}) + var PluginRegistry = map[string]Creator + func MapPayload(name string, event *Event) error + func RandomString(strlen int) string + func RegisterApi(i interface{}) + func RegisterPlugin(name string, creator Creator) + func SliceContains(name string, list []string) bool + type Agent struct + Events chan Event + Plugins []*RunningPlugin + Queueing bool + Shutdown chan struct{} + TestEvents chan Event + func NewAgent() (*Agent, error) + func NewTestAgent(config []byte) (*Agent, error) + func (a *Agent) GetTestEvent(name string, timeout time.Duration) Event + func (a *Agent) LoadPlugins() error + func (a *Agent) PluginNames() []string + func (a *Agent) Run() error + func (a *Agent) Stop() + type Caller struct + File string + LineNumber int + type Creator func() Plugin + type Event struct + Caller Caller + CreatedAt time.Time + Error error + ID string + Name string + ParentID string + Payload interface{} + PayloadModel string + func NewEvent(payload interface{}, err error) Event + func (e *Event) Dump() + func (e *Event) NewEvent(payload interface{}, err error) Event + type Plugin interface + Description func() string + Process func(Event) error + SampleConfig func() string + Start func(chan Event) error + Stop func() + Subscribe func() []string + type RunningPlugin struct + Enabled bool + Name string + Plugin Plugin + Work func(*workers.Msg) + Workers int