Versions in this module Expand all Collapse all v11 v11.0.0 Mar 13, 2019 Changes in this version + 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, string) + type EventAggregatorKeyFunc func(event *v1.Event) (aggregateKey string, localKey string) + type EventAggregatorMessageFunc func(event *v1.Event) string + type EventBroadcaster interface + NewRecorder func(scheme *runtime.Scheme, 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 + 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, ...) + PastEventf func(object runtime.Object, timestamp metav1.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 EventSourceObjectSpamFilter struct + func NewEventSourceObjectSpamFilter(lruCacheSize, burst int, qps float32, clock clock.Clock) *EventSourceObjectSpamFilter + func (f *EventSourceObjectSpamFilter) Filter(event *v1.Event) bool + type FakeRecorder struct + Events chan string + 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, ...) + func (f *FakeRecorder) PastEventf(object runtime.Object, timestamp metav1.Time, ...) Other modules containing this package gopkg.in/kubernetes/client-go.v2
Go to main page