coordinator

type DatabaseConsumer struct {
	// contains filtered or unexported fields
}

type EventAggregator struct {
	// contains filtered or unexported fields
}

type EventData struct {
	Name      string
	Value     float64
	Timestamp time.Time
}

type EventRaiser interface {
	AddListener(eventName string, f func(interface{}))
}

type MetricConsumer struct {
	// contains filtered or unexported fields
}

type QueueListener struct {
	// contains filtered or unexported fields
}