From 50f04e5aac0dce17f67dfd92a5d0b34e230cfa81 Mon Sep 17 00:00:00 2001 From: Shambhavi Srivastava Date: Tue, 29 Nov 2022 17:23:05 -0800 Subject: [PATCH] Adding a LogEmit in event.go. This creates a single function that logs a warning in case of an error. PiperOrigin-RevId: 491777874 --- pkg/eventchannel/event.go | 10 ++++++++++ 1 file changed, 10 insertions(+) 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)