mirror of
https://github.com/kubernetes/client-go.git
synced 2025-07-01 17:32:20 +00:00
Use consistent short name for receivers
Kubernetes-commit: 21b11c2b6434f949299f85a12c535bfd169c2cf3
This commit is contained in:
parent
1210218b4a
commit
9be50f2e07
@ -164,11 +164,11 @@ type eventBroadcasterImpl struct {
|
|||||||
// StartRecordingToSink starts sending events received from the specified eventBroadcaster to the given sink.
|
// 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.
|
// 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
|
// TODO: make me an object with parameterizable queue length and retry interval
|
||||||
func (eventBroadcaster *eventBroadcasterImpl) StartRecordingToSink(sink EventSink) watch.Interface {
|
func (e *eventBroadcasterImpl) StartRecordingToSink(sink EventSink) watch.Interface {
|
||||||
eventCorrelator := NewEventCorrelatorWithOptions(eventBroadcaster.options)
|
eventCorrelator := NewEventCorrelatorWithOptions(e.options)
|
||||||
return eventBroadcaster.StartEventWatcher(
|
return e.StartEventWatcher(
|
||||||
func(event *v1.Event) {
|
func(event *v1.Event) {
|
||||||
recordToSink(sink, event, eventCorrelator, eventBroadcaster.sleepDuration)
|
recordToSink(sink, event, eventCorrelator, e.sleepDuration)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -256,8 +256,8 @@ func recordEvent(sink EventSink, event *v1.Event, patch []byte, updateExistingEv
|
|||||||
|
|
||||||
// StartLogging starts sending events received from this EventBroadcaster to the given logging function.
|
// 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.
|
// The return value can be ignored or used to stop recording, if desired.
|
||||||
func (eventBroadcaster *eventBroadcasterImpl) StartLogging(logf func(format string, args ...interface{})) watch.Interface {
|
func (e *eventBroadcasterImpl) StartLogging(logf func(format string, args ...interface{})) watch.Interface {
|
||||||
return eventBroadcaster.StartEventWatcher(
|
return e.StartEventWatcher(
|
||||||
func(e *v1.Event) {
|
func(e *v1.Event) {
|
||||||
logf("Event(%#v): type: '%v' reason: '%v' %v", e.InvolvedObject, e.Type, e.Reason, e.Message)
|
logf("Event(%#v): type: '%v' reason: '%v' %v", e.InvolvedObject, e.Type, e.Reason, e.Message)
|
||||||
})
|
})
|
||||||
@ -265,8 +265,8 @@ func (eventBroadcaster *eventBroadcasterImpl) StartLogging(logf func(format stri
|
|||||||
|
|
||||||
// StartEventWatcher starts sending events received from this EventBroadcaster to the given event handler function.
|
// 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.
|
// The return value can be ignored or used to stop recording, if desired.
|
||||||
func (eventBroadcaster *eventBroadcasterImpl) StartEventWatcher(eventHandler func(*v1.Event)) watch.Interface {
|
func (e *eventBroadcasterImpl) StartEventWatcher(eventHandler func(*v1.Event)) watch.Interface {
|
||||||
watcher := eventBroadcaster.Watch()
|
watcher := e.Watch()
|
||||||
go func() {
|
go func() {
|
||||||
defer utilruntime.HandleCrash()
|
defer utilruntime.HandleCrash()
|
||||||
for watchEvent := range watcher.ResultChan() {
|
for watchEvent := range watcher.ResultChan() {
|
||||||
@ -283,8 +283,8 @@ func (eventBroadcaster *eventBroadcasterImpl) StartEventWatcher(eventHandler fun
|
|||||||
}
|
}
|
||||||
|
|
||||||
// NewRecorder returns an EventRecorder that records events with the given event source.
|
// NewRecorder returns an EventRecorder that records events with the given event source.
|
||||||
func (eventBroadcaster *eventBroadcasterImpl) NewRecorder(scheme *runtime.Scheme, source v1.EventSource) EventRecorder {
|
func (e *eventBroadcasterImpl) NewRecorder(scheme *runtime.Scheme, source v1.EventSource) EventRecorder {
|
||||||
return &recorderImpl{scheme, source, eventBroadcaster.Broadcaster, clock.RealClock{}}
|
return &recorderImpl{scheme, source, e.Broadcaster, clock.RealClock{}}
|
||||||
}
|
}
|
||||||
|
|
||||||
type recorderImpl struct {
|
type recorderImpl struct {
|
||||||
|
Loading…
Reference in New Issue
Block a user