diff --git a/controller/eventService/Service.go b/controller/eventService/Service.go index e891e4ad95ae677fbddccd156cbb2107d763f00e..0ace2760fd5a9dfe890b21566adffcb179dd9d5d 100644 --- a/controller/eventService/Service.go +++ b/controller/eventService/Service.go @@ -85,6 +85,7 @@ func (e *EventService) PublishEvent(topic string, event event.Event) error { return nil } +// RetryPublish is used to retry publishing an event after a failed attempt. func (e *EventService) RetryPublish(topic string, event event.Event) error { ctx := context.Background() backOff := retry.NewConstant(2 * time.Second)