const maxTriesPerEvent … var defaultSleepDuration … const maxQueuedEvents … type EventSink … type CorrelatorOptions … type EventRecorder … type EventRecorderLogger … type EventBroadcaster … type EventRecorderAdapter … var _ … // NewEventRecorderAdapter returns an adapter implementing the new // "k8s.io/client-go/tools/events".EventRecorder interface. func NewEventRecorderAdapter(recorder EventRecorderLogger) *EventRecorderAdapter { … } // Eventf is a wrapper around v1 Eventf func (a *EventRecorderAdapter) Eventf(regarding, _ runtime.Object, eventtype, reason, action, note string, args ...interface{ … } func (a *EventRecorderAdapter) WithLogger(logger klog.Logger) internalevents.EventRecorderLogger { … } // Creates a new event broadcaster. func NewBroadcaster(opts ...BroadcasterOption) EventBroadcaster { … } func NewBroadcasterForTests(sleepDuration time.Duration) EventBroadcaster { … } func NewBroadcasterWithCorrelatorOptions(options CorrelatorOptions) EventBroadcaster { … } func WithCorrelatorOptions(options CorrelatorOptions) BroadcasterOption { … } // WithContext sets a context for the broadcaster. Canceling the context will // shut down the broadcaster, Shutdown doesn't need to be called. The context // can also be used to provide a logger. func WithContext(ctx context.Context) BroadcasterOption { … } func WithSleepDuration(sleepDuration time.Duration) BroadcasterOption { … } type BroadcasterOption … type config … type eventBroadcasterImpl … // StartRecordingToSink starts sending events received from the specified eventBroadcaster to the given sink. // The return value can be ignored or used to stop recording, if desired. // TODO: make me an object with parameterizable queue length and retry interval func (e *eventBroadcasterImpl) StartRecordingToSink(sink EventSink) watch.Interface { … } func (e *eventBroadcasterImpl) Shutdown() { … } func (e *eventBroadcasterImpl) recordToSink(sink EventSink, event *v1.Event, eventCorrelator *EventCorrelator) { … } // recordEvent attempts to write event to a sink. It returns true if the event // was successfully recorded or discarded, false if it should be retried. // If updateExistingEvent is false, it creates a new event, otherwise it updates // existing event. func recordEvent(ctx context.Context, sink EventSink, event *v1.Event, patch []byte, updateExistingEvent bool, eventCorrelator *EventCorrelator) bool { … } // StartLogging starts sending events received from this EventBroadcaster to the given logging function. // The return value can be ignored or used to stop recording, if desired. func (e *eventBroadcasterImpl) StartLogging(logf func(format string, args ...interface{ … } // StartStructuredLogging starts sending events received from this EventBroadcaster to a structured logger. // The logger is retrieved from a context if the broadcaster was constructed with a context, otherwise // the global default is used. // The return value can be ignored or used to stop recording, if desired. func (e *eventBroadcasterImpl) StartStructuredLogging(verbosity klog.Level) watch.Interface { … } // StartEventWatcher starts sending events received from this EventBroadcaster to the given event handler function. // The return value can be ignored or used to stop recording, if desired. func (e *eventBroadcasterImpl) StartEventWatcher(eventHandler func(*v1.Event)) watch.Interface { … } // NewRecorder returns an EventRecorder that records events with the given event source. func (e *eventBroadcasterImpl) NewRecorder(scheme *runtime.Scheme, source v1.EventSource) EventRecorderLogger { … } type recorderImpl … var _ … func (recorder *recorderImpl) generateEvent(logger klog.Logger, object runtime.Object, annotations map[string]string, eventtype, reason, message string) { … } func (recorder *recorderImpl) Event(object runtime.Object, eventtype, reason, message string) { … } func (recorder *recorderImpl) Eventf(object runtime.Object, eventtype, reason, messageFmt string, args ...interface{ … } func (recorder *recorderImpl) AnnotatedEventf(object runtime.Object, annotations map[string]string, eventtype, reason, messageFmt string, args ...interface{ … } func (recorder *recorderImpl) makeEvent(ref *v1.ObjectReference, annotations map[string]string, eventtype, reason, message string) *v1.Event { … } type recorderImplLogger … var _ … func (recorder recorderImplLogger) Event(object runtime.Object, eventtype, reason, message string) { … } func (recorder recorderImplLogger) Eventf(object runtime.Object, eventtype, reason, messageFmt string, args ...interface{ … } func (recorder recorderImplLogger) AnnotatedEventf(object runtime.Object, annotations map[string]string, eventtype, reason, messageFmt string, args ...interface{ … } func (recorder recorderImplLogger) WithLogger(logger klog.Logger) EventRecorderLogger { … }
Codebase Browser
kubernetes