event

type Event ¶

type Event struct {
	Timestamp time.Time
	Data      any
	Type      EventType
}

func NewEvent(eventType EventType, eventData any) Event

type EventBus ¶

type EventBus struct {
	Logger *slog.Logger
	// contains filtered or unexported fields
}

func NewEventBus(
	promRegistry prometheus.Registerer,
	logger *slog.Logger,
) *EventBus

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

func (e *EventBus) RegisterSubscriber(
	eventType EventType,
	sub Subscriber,
) EventSubscriberId

func (e *EventBus) Stop()

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 ¶

type EventHandlerFunc func(Event)

type EventSubscriberId ¶

type EventSubscriberId int

type EventType ¶

type EventType string

type Subscriber ¶ added in v0.18.0

type Subscriber interface {
	Deliver(Event) error
	Close()
}

Subscriber is a delivery abstraction that allows the EventBus to deliver events to in-memory channels and to network-backed subscribers via the same interface. Implementations must ensure Close() is idempotent and safe to call multiple times.