event

Nov 22, 2024

Changes in this version

+ const EventQueueSize

+ type Event struct

+ Data any

+ Timestamp time.Time

+ Type EventType

+ func NewEvent(eventType EventType, eventData any) Event

+ type EventBus struct

+ func NewEventBus(promRegistry prometheus.Registerer) *EventBus

+ func (e *EventBus) Publish(eventType EventType, evt Event)

+ func (e *EventBus) Subscribe(eventType EventType) (EventSubscriberId, <-chan Event)

+ func (e *EventBus) SubscribeFunc(eventType EventType, handlerFunc EventHandlerFunc) EventSubscriberId

+ func (e *EventBus) Unsubscribe(eventType EventType, subId EventSubscriberId)

+ type EventHandlerFunc func(Event)

+ type EventSubscriberId int

+ type EventType string