diff --git a/tools/record/fake.go b/tools/record/fake.go index a5b523fb..9cea1fb5 100644 --- a/tools/record/fake.go +++ b/tools/record/fake.go @@ -41,29 +41,31 @@ func objectString(object runtime.Object, includeObject bool) string { ) } -func (f *FakeRecorder) writeEvent(event string) { +func annotationsString(annotations map[string]string) string { + if len(annotations) == 0 { + return "" + } else { + return " " + fmt.Sprint(annotations) + } +} + +func (f *FakeRecorder) writeEvent(object runtime.Object, annotations map[string]string, eventtype, reason, messageFmt string, args ...interface{}) { if f.Events != nil { - f.Events <- event + f.Events <- fmt.Sprintf(eventtype+" "+reason+" "+messageFmt, args...) + + objectString(object, f.IncludeObject) + annotationsString(annotations) } } func (f *FakeRecorder) Event(object runtime.Object, eventtype, reason, message string) { - f.writeEvent(fmt.Sprintf("%s %s %s%s", eventtype, reason, message, objectString(object, f.IncludeObject))) + f.writeEvent(object, map[string]string{}, eventtype, reason, "%s", message) } func (f *FakeRecorder) Eventf(object runtime.Object, eventtype, reason, messageFmt string, args ...interface{}) { - f.writeEvent( - fmt.Sprintf(eventtype+" "+reason+" "+messageFmt, args...) + - objectString(object, f.IncludeObject), - ) + f.writeEvent(object, map[string]string{}, eventtype, reason, messageFmt, args) } func (f *FakeRecorder) AnnotatedEventf(object runtime.Object, annotations map[string]string, eventtype, reason, messageFmt string, args ...interface{}) { - f.writeEvent( - fmt.Sprintf(eventtype+" "+reason+" "+messageFmt, args...) + - objectString(object, f.IncludeObject) + - " " + fmt.Sprint(annotations), - ) + f.writeEvent(object, annotations, eventtype, reason, messageFmt, args) } // NewFakeRecorder creates new fake event recorder with event channel with