const maxTriesPerEvent … const finishTime … const refreshTime … const maxQueuedEvents … var defaultSleepDuration … type eventKey … type eventBroadcasterImpl … type EventSinkImpl … // Create takes the representation of a event and creates it. Returns the server's representation of the event, and an error, if there is any. func (e *EventSinkImpl) Create(ctx context.Context, event *eventsv1.Event) (*eventsv1.Event, error) { … } // Update takes the representation of a event and updates it. Returns the server's representation of the event, and an error, if there is any. func (e *EventSinkImpl) Update(ctx context.Context, event *eventsv1.Event) (*eventsv1.Event, error) { … } // Patch applies the patch and returns the patched event, and an error, if there is any. func (e *EventSinkImpl) Patch(ctx context.Context, event *eventsv1.Event, data []byte) (*eventsv1.Event, error) { … } // NewBroadcaster Creates a new event broadcaster. func NewBroadcaster(sink EventSink) EventBroadcaster { … } // NewBroadcasterForTest Creates a new event broadcaster for test purposes. func newBroadcaster(sink EventSink, sleepDuration time.Duration, eventCache map[eventKey]*eventsv1.Event) EventBroadcaster { … } func (e *eventBroadcasterImpl) Shutdown() { … } // refreshExistingEventSeries refresh events TTL func (e *eventBroadcasterImpl) refreshExistingEventSeries(ctx context.Context) { … } // finishSeries checks if a series has ended and either: // - write final count to the apiserver // - delete a singleton event (i.e. series field is nil) from the cache func (e *eventBroadcasterImpl) finishSeries(ctx context.Context) { … } // NewRecorder returns an EventRecorder that records events with the given event source. func (e *eventBroadcasterImpl) NewRecorder(scheme *runtime.Scheme, reportingController string) EventRecorderLogger { … } func (e *eventBroadcasterImpl) recordToSink(ctx context.Context, event *eventsv1.Event, clock clock.Clock) { … } func (e *eventBroadcasterImpl) attemptRecording(ctx context.Context, event *eventsv1.Event) { … } func recordEvent(ctx context.Context, sink EventSink, event *eventsv1.Event) (*eventsv1.Event, bool) { … } func createPatchBytesForSeries(event *eventsv1.Event) ([]byte, error) { … } func getKey(event *eventsv1.Event) eventKey { … } // StartStructuredLogging starts sending events received from this EventBroadcaster to the structured logging function. // The return value can be ignored or used to stop recording, if desired. // TODO: this function should also return an error. // // Deprecated: use StartLogging instead. func (e *eventBroadcasterImpl) StartStructuredLogging(verbosity klog.Level) func() { … } // StartLogging starts sending events received from this EventBroadcaster to the structured logger. // To adjust verbosity, use the logger's V method (i.e. pass `logger.V(3)` instead of `logger`). // The returned function can be ignored or used to stop recording, if desired. func (e *eventBroadcasterImpl) StartLogging(logger klog.Logger) (func(), error) { … } // StartEventWatcher starts sending events received from this EventBroadcaster to the given event handler function. // The return value is used to stop recording func (e *eventBroadcasterImpl) StartEventWatcher(eventHandler func(event runtime.Object)) (func(), error) { … } func (e *eventBroadcasterImpl) startRecordingEvents(ctx context.Context) error { … } // StartRecordingToSink starts sending events received from the specified eventBroadcaster to the given sink. // Deprecated: use StartRecordingToSinkWithContext instead. func (e *eventBroadcasterImpl) StartRecordingToSink(stopCh <-chan struct{ … } // StartRecordingToSinkWithContext starts sending events received from the specified eventBroadcaster to the given sink. func (e *eventBroadcasterImpl) StartRecordingToSinkWithContext(ctx context.Context) error { … } type eventBroadcasterAdapterImpl … // NewEventBroadcasterAdapter creates a wrapper around new and legacy broadcasters to simplify // migration of individual components to the new Event API. // //logcheck:context // NewEventBroadcasterAdapterWithContext should be used instead because record.NewBroadcaster is called and works better when a context is supplied (contextual logging, cancellation). func NewEventBroadcasterAdapter(client clientset.Interface) EventBroadcasterAdapter { … } // NewEventBroadcasterAdapterWithContext creates a wrapper around new and legacy broadcasters to simplify // migration of individual components to the new Event API. func NewEventBroadcasterAdapterWithContext(ctx context.Context, client clientset.Interface) EventBroadcasterAdapter { … } // StartRecordingToSink starts sending events received from the specified eventBroadcaster to the given sink. func (e *eventBroadcasterAdapterImpl) StartRecordingToSink(stopCh <-chan struct{ … } func (e *eventBroadcasterAdapterImpl) NewRecorder(name string) EventRecorderLogger { … } func (e *eventBroadcasterAdapterImpl) DeprecatedNewLegacyRecorder(name string) record.EventRecorderLogger { … } func (e *eventBroadcasterAdapterImpl) Shutdown() { … }
Codebase Browser
kubernetes