Versions in this module Expand all Collapse all v0 v0.1442.0 Feb 27, 2024 v0.1441.2 Jan 12, 2016 Changes in this version + type Bulker struct + func NewBulker(logger lager.Logger, pollInterval time.Duration, ...) *Bulker + func (b *Bulker) Run(signals <-chan os.Signal, ready chan<- struct{}) error + type EventConsumer struct + func NewEventConsumer(logger lager.Logger, generator generator.Generator, queue operationq.Queue) *EventConsumer + func (consumer *EventConsumer) Run(signals <-chan os.Signal, ready chan<- struct{}) error