Method enqueue

api/pkg/services/event_dispatcher_service.go:88–102

(ctx context.Context, event cloudevents.Event, task *PushQueueTask, timeout time.Duration)

}

func (dispatcher *EventDispatcher) enqueue(ctx context.Context, event cloudevents.Event, task *PushQueueTask, timeout time.Duration) (string, error) {
	ctx, span, ctxLogger := dispatcher.tracer.StartWithLogger(ctx, dispatcher.logger)
	defer span.End()

	queueID, err := dispatcher.queue.Enqueue(ctx, task, timeout)
	if errors.Is(err, context.DeadlineExceeded) {
		msg := fmt.Sprintf("cannot enqueue event with ID [%s] and type [%s] to [%T]", event.ID(), event.Type(), dispatcher.queue)
		ctxLogger.Warn(stacktrace.Propagate(err, msg))
		queueID, err = fmt.Sprintf("local-%s", event.ID()), nil
		time.AfterFunc(timeout, func() {
			dispatcher.Publish(ctx, event)
		})
	}
	return queueID, err
}

// Dispatch a new event by adding it to the queue to be processed async
func (dispatcher *EventDispatcher) Dispatch(ctx context.Context, event cloudevents.Event) error {