Method Dispatch

api/pkg/services/event_dispatcher_service.go:105–110

Dispatch a new event by adding it to the queue to be processed async

(ctx context.Context, event cloudevents.Event)

// 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 {
	ctx, span := dispatcher.tracer.Start(ctx)
	defer span.End()
	_, err := dispatcher.DispatchWithTimeout(ctx, event, time.Nanosecond*1)
	return err
}

// Subscribe a listener to an event
func (dispatcher *EventDispatcher) Subscribe(eventType string, listener events.EventListener) {