Versions in this module Expand all Collapse all v0 v0.0.1 Apr 13, 2023 Changes in this version + func EventAggregatorByReasonFunc(event *v1.Event) (string, string) + func EventAggregatorByReasonMessageFunc(event *v1.Event) string + type CorrelatorOptions struct + BurstSize int + Clock clock.PassiveClock + KeyFunc EventAggregatorKeyFunc + LRUCacheSize int + MaxEvents int + MaxIntervalInSeconds int + MessageFunc EventAggregatorMessageFunc + QPS float32 + SpamKeyFunc EventSpamKeyFunc + type EventAggregator struct + func NewEventAggregator(lruCacheSize int, keyFunc EventAggregatorKeyFunc, ...) *EventAggregator + func (e *EventAggregator) EventAggregate(newEvent *v1.Event) (*v1.Event, string) + 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 + Shutdown func() + StartEventWatcher func(eventHandler func(*v1.Event)) watch.Interface + StartLogging func(logf func(format string, args ...interface{})) watch.Interface + StartRecordingToSink func(sink EventSink) watch.Interface + StartStructuredLogging func(verbosity klog.Level) watch.Interface + func NewBroadcaster() EventBroadcaster + func NewBroadcasterForTests(sleepDuration time.Duration) EventBroadcaster + func NewBroadcasterWithCorrelatorOptions(options CorrelatorOptions) EventBroadcaster + type EventCorrelateResult struct + Event *v1.Event + Patch []byte + Skip bool + type EventCorrelator struct + func NewEventCorrelator(clock clock.PassiveClock) *EventCorrelator + func NewEventCorrelatorWithOptions(options CorrelatorOptions) *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 + AnnotatedEventf func(object runtime.Object, annotations map[string]string, ...) + Event func(object runtime.Object, eventtype, reason, message string) + Eventf func(object runtime.Object, eventtype, reason, messageFmt string, ...) + type EventRecorderAdapter struct + func NewEventRecorderAdapter(recorder EventRecorder) *EventRecorderAdapter + func (a *EventRecorderAdapter) Eventf(regarding, _ runtime.Object, eventtype, reason, action, note string, ...) + 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 EventSourceObjectSpamFilter struct + func NewEventSourceObjectSpamFilter(lruCacheSize, burst int, qps float32, clock clock.PassiveClock, ...) *EventSourceObjectSpamFilter + func (f *EventSourceObjectSpamFilter) Filter(event *v1.Event) bool + type EventSpamKeyFunc func(event *v1.Event) string + type FakeRecorder struct + Events chan string + IncludeObject bool + func NewFakeRecorder(bufferSize int) *FakeRecorder + func (f *FakeRecorder) AnnotatedEventf(object runtime.Object, annotations map[string]string, ...) + func (f *FakeRecorder) Event(object runtime.Object, eventtype, reason, message string) + func (f *FakeRecorder) Eventf(object runtime.Object, eventtype, reason, messageFmt string, ...)
Go to main page