Versions in this module Expand all Collapse all v0 v0.3.2 Jun 22, 2015 Changes in this version + type Console struct + func (cons *Console) Configure(conf core.PluginConfig) error + func (cons *Console) Consume(workers *sync.WaitGroup) + type File struct + func (cons *File) Configure(conf core.PluginConfig) error + func (cons *File) Consume(workers *sync.WaitGroup) + type Http struct + func (cons *Http) Configure(conf core.PluginConfig) error + func (cons Http) Consume(workers *sync.WaitGroup) + type Kafka struct + MaxPartitionID int32 + func (cons *Kafka) Configure(conf core.PluginConfig) error + func (cons *Kafka) Consume(workers *sync.WaitGroup) + type LoopBack struct + func (cons *LoopBack) Configure(conf core.PluginConfig) error + func (cons *LoopBack) Consume(workers *sync.WaitGroup) + type Profiler struct + func (cons *Profiler) Configure(conf core.PluginConfig) error + func (cons *Profiler) Consume(workers *sync.WaitGroup) + type Proxy struct + func (cons *Proxy) Configure(conf core.PluginConfig) error + func (cons *Proxy) Consume(workers *sync.WaitGroup) + type Socket struct + func (cons *Socket) Configure(conf core.PluginConfig) error + func (cons *Socket) Consume(workers *sync.WaitGroup) + type Syslogd struct + func (cons *Syslogd) Configure(conf core.PluginConfig) error + func (cons *Syslogd) Consume(workers *sync.WaitGroup) + func (cons *Syslogd) Handle(parts syslogparser.LogParts, code int64, err error)