EventAggregatorByReasonFunc aggregates events by exact match on event.Source, event.InvolvedObject, event.Type and event.Reason.

EventAggregratorByReasonMessageFunc returns an aggregate message by prefixing the incoming message.

Creates a new event broadcaster.

NewEventAggregator returns a new instance of an EventAggregator.

NewEventCorrelator returns an EventCorrelator configured with default values.

NewEventSourceObjectSpamFilter allows burst events from a source about an object with the specified qps refill.

NewFakeRecorder creates new fake event recorder with event channel with buffer of given size.

EventAggregator identifies similar events and aggregates them into a single event.

EventCorrelateResult is the result of a Correlate.

EventCorrelator processes all incoming events and performs analysis to avoid overwhelming the system.

EventSourceObjectSpamFilter is responsible for throttling the amount of events a source and object can produce.

FakeRecorder is used as a fake during tests.

EventBroadcaster knows how to receive events and send them to any EventSink, watcher, or log.

EventRecorder knows how to record events on behalf of an EventSource.

EventSink knows how to store events (client.Client implements it.) EventSink must respect the namespace that will be embedded in 'event'.

EventAggregatorKeyFunc is responsible for grouping events for aggregation It returns a tuple of the following: aggregateKey - key the identifies the aggregate group to bucket this event localKey - key that makes this event in the local group.

EventAggregatorMessageFunc is responsible for producing an aggregation message.

EventFilterFunc is a function that returns true if the event should be skipped.