Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var MaxTTL = time.Minute
Functions ¶
This section is empty.
Types ¶
type MessageAggregator ¶
type MessageAggregator interface { instrumentation.Instrumentable Run(inputChan <-chan *events.Envelope, outputChan chan<- *events.Envelope) }
func NewMessageAggregator ¶
func NewMessageAggregator(logger *gosteno.Logger) MessageAggregator
Click to show internal directories.
Click to hide internal directories.