Method EventDispatcher

api/pkg/di/container.go:724–740

EventDispatcher creates a new instance of services.EventDispatcher

()

// EventDispatcher creates a new instance of services.EventDispatcher
func (container *Container) EventDispatcher() (dispatcher *services.EventDispatcher) {
	if container.eventDispatcher != nil {
		return container.eventDispatcher
	}

	container.logger.Debug(fmt.Sprintf("creating %T", dispatcher))
	dispatcher = services.NewEventDispatcher(
		container.Logger(),
		container.Tracer(),
		container.Float64Histogram("event.publisher.duration", "ms", "measures the duration of processing CloudEvents"),
		container.EventsQueue(),
		container.EventsQueueConfiguration(),
	)

	container.eventDispatcher = dispatcher
	return dispatcher
}

// Float64Histogram creates a new instance of metric.Float64Histogram
func (container *Container) Float64Histogram(name, unit, description string) otelMetric.Float64Histogram {