record

Jul 1, 2016

Changes in this version

type EventBroadcaster

+ func NewBroadcasterForTests(sleepDuration time.Duration) EventBroadcaster

type FakeRecorder

+ func NewFakeRecorder(bufferSize int) *FakeRecorder

Mar 16, 2016

Changes in this version

+ func DefaultEventFilterFunc(event *api.Event) bool

+ func EventAggregatorByReasonFunc(event *api.Event) (string, string)

+ func EventAggregatorByReasonMessageFunc(event *api.Event) string

+ type EventAggregator struct

+ func NewEventAggregator(lruCacheSize int, keyFunc EventAggregatorKeyFunc, ...) *EventAggregator

+ func (e *EventAggregator) EventAggregate(newEvent *api.Event) (*api.Event, error)

+ type EventAggregatorKeyFunc func(event *api.Event) (aggregateKey string, localKey string)

+ type EventAggregatorMessageFunc func(event *api.Event) string

+ type EventCorrelateResult struct

+ Event *api.Event

+ Patch []byte

+ Skip bool

+ type EventCorrelator struct

+ func NewEventCorrelator(clock util.Clock) *EventCorrelator

+ func (c *EventCorrelator) EventCorrelate(newEvent *api.Event) (*EventCorrelateResult, error)

+ func (c *EventCorrelator) UpdateState(event *api.Event)

+ type EventFilterFunc func(event *api.Event) bool

type EventSink

+ Patch func(oldEvent *api.Event, data []byte) (*api.Event, error)

Sep 25, 2015

Changes in this version

+ func NewEventCache() *historyCache

type FakeRecorder

+ Events []string

May 12, 2015

Changes in this version

type EventRecorder

+ PastEventf func(object runtime.Object, timestamp util.Time, reason, messageFmt string, ...)

type FakeRecorder

+ func (f *FakeRecorder) PastEventf(object runtime.Object, timestamp util.Time, reason, messageFmt string, ...)

Apr 13, 2015

Changes in this version

+ type EventBroadcaster interface

+ NewRecorder func(source api.EventSource) EventRecorder

+ StartEventWatcher func(eventHandler func(*api.Event)) watch.Interface

+ StartLogging func(logf func(format string, args ...interface{})) watch.Interface

+ StartRecordingToSink func(sink EventSink) watch.Interface

+ func NewBroadcaster() EventBroadcaster

Mar 16, 2015

Changes in this version

type EventRecorder

+ func FromSource(source api.EventSource) EventRecorder

+ Event func(object runtime.Object, reason, message string)

+ Eventf func(object runtime.Object, reason, messageFmt string, args ...interface{})

+ type EventSink interface

+ Create func(event *api.Event) (*api.Event, error)

+ Update func(event *api.Event) (*api.Event, error)

+ type FakeRecorder struct

+ func (f *FakeRecorder) Event(object runtime.Object, reason, message string)

+ func (f *FakeRecorder) Eventf(object runtime.Object, reason, messageFmt string, args ...interface{})

Feb 18, 2015

Changes in this version

type EventRecorder

+ Update func(event *api.Event) (*api.Event, error)

Nov 18, 2014

Changes in this version

+ func Event(object runtime.Object, status, reason, message string)

+ func Eventf(object runtime.Object, status, reason, messageFmt string, args ...interface{})

+ func GetEvents(f func(*api.Event)) watch.Interface

+ func StartLogging(logf func(format string, args ...interface{})) watch.Interface

+ func StartRecording(recorder EventRecorder, sourceName string) watch.Interface

+ type EventRecorder interface

+ Create func(event *api.Event) (*api.Event, error)