eventbus

type Event = internal.Event

type EventHandler = internal.EventHandler

type Eventbus interface {
	// Close closes the eventbus.
	Close() error
	// Publish publishes an event.
	Publish(ctx context.Context, topic string, message any) error
	// Subscribe subscribes to an event.
	Subscribe(ctx context.Context, topic string, handler EventHandler, balance ...bool) (Subscription, error)
}

type Subscription interface {
	// Unsubscribe cancels the subscription.
	Unsubscribe(ctx context.Context) error
}