Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventWorker ¶
type EventWorker struct {
// contains filtered or unexported fields
}
EventWorker processes events from the queue using handlers
func NewEventWorker ¶
func NewEventWorker( reg *registry.Registry, notif *notifier.Notifier, healthCheck *notifier.HealthChecker, dualStore *storage.DualStore, ) *EventWorker
NewEventWorker creates a new event worker
func (*EventWorker) RegisterHandlers ¶
func (w *EventWorker) RegisterHandlers(queue eventqueue.IEventQueue)
RegisterHandlers registers all event handlers to the queue
Source Files
Click to show internal directories.
Click to hide internal directories.