diff --git a/pkg/eventchannel/event.go b/pkg/eventchannel/event.go index acf09566b..ef11d4297 100644 --- a/pkg/eventchannel/event.go +++ b/pkg/eventchannel/event.go @@ -54,6 +54,16 @@ func Emit(msg proto.Message) error { return err } +// LogEmit is a helper method that calls DefaultEmitter.Emit. +// It also logs a warning message when an error occurs. +func LogEmit(msg proto.Message) error { + _, err := DefaultEmitter.Emit(msg) + if err != nil { + log.Warningf("unable to emit event: %s", err) + } + return err +} + // AddEmitter is a helper method that calls DefaultEmitter.AddEmitter. func AddEmitter(e Emitter) { DefaultEmitter.AddEmitter(e)