Versions in this module Expand all Collapse all v1 v1.5.0 Oct 23, 2016 Changes in this version + func DefaultEventFilterFunc(event *v1.Event) bool + func EventAggregatorByReasonFunc(event *v1.Event) (string, string) + func EventAggregatorByReasonMessageFunc(event *v1.Event) string + type EventAggregator struct + func NewEventAggregator(lruCacheSize int, keyFunc EventAggregatorKeyFunc, ...) *EventAggregator + func (e *EventAggregator) EventAggregate(newEvent *v1.Event) (*v1.Event, error) + type EventAggregatorKeyFunc func(event *v1.Event) (aggregateKey string, localKey string) + type EventAggregatorMessageFunc func(event *v1.Event) string + type EventBroadcaster interface + NewRecorder func(source v1.EventSource) EventRecorder + StartEventWatcher func(eventHandler func(*v1.Event)) watch.Interface + StartLogging func(logf func(format string, args ...interface{})) watch.Interface + StartRecordingToSink func(sink EventSink) watch.Interface + func NewBroadcaster() EventBroadcaster + func NewBroadcasterForTests(sleepDuration time.Duration) EventBroadcaster + type EventCorrelateResult struct + Event *v1.Event + Patch []byte + Skip bool + type EventCorrelator struct + func NewEventCorrelator(clock clock.Clock) *EventCorrelator + func (c *EventCorrelator) EventCorrelate(newEvent *v1.Event) (*EventCorrelateResult, error) + func (c *EventCorrelator) UpdateState(event *v1.Event) + type EventFilterFunc func(event *v1.Event) bool + type EventRecorder interface + Event func(object runtime.Object, eventtype, reason, message string) + Eventf func(object runtime.Object, eventtype, reason, messageFmt string, ...) + PastEventf func(object runtime.Object, timestamp unversioned.Time, ...) + type EventSink interface + Create func(event *v1.Event) (*v1.Event, error) + Patch func(oldEvent *v1.Event, data []byte) (*v1.Event, error) + Update func(event *v1.Event) (*v1.Event, error) + type FakeRecorder struct + Events chan string + func NewFakeRecorder(bufferSize int) *FakeRecorder + func (f *FakeRecorder) Event(object runtime.Object, eventtype, reason, message string) + func (f *FakeRecorder) Eventf(object runtime.Object, eventtype, reason, messageFmt string, ...) + func (f *FakeRecorder) PastEventf(object runtime.Object, timestamp unversioned.Time, ...)
Go to main page