Versions in this module Expand all Collapse all v1 v1.5.1 Apr 23, 2018 Changes in this version + type Buffer struct + func NewBuffer(size int) *Buffer + func (d *Buffer) Alert(missed int) + func (d *Buffer) Next() *events.Envelope + func (d *Buffer) Set(e *events.Envelope) + func (d *Buffer) TryNext() (*events.Envelope, bool) + type Inc func(string) + type Ingestor struct + func NewIngestor(msgs <-chan *events.Envelope, s Set) *Ingestor + func (i *Ingestor) Run() + type Next func() *events.Envelope + type Processor struct + func NewProcessor(n Next, i Inc, includeRouterLogs bool) *Processor + func (p *Processor) Run() + type Set func(*events.Envelope)