driver

type Driver interface {

	// Subscribe registers a named subscriber for the given topic and returns
	// a channel that will receive messages published to matching topics.
	Subscribe(name string, topic string) (<-chan entity.PubsubMessage, error)

	// GetSubscribers returns the names of all subscribers matching the given topic,
	// including those subscribed to parent topics.
	GetSubscribers(topic string) []string

	// Unsubscribe removes a subscriber from receiving events for the given topic.
	// The subscriber's channel is closed.
	Unsubscribe(name string, topic string) error

	// Publish dispatches an event to local subscribers and handles
	// cross-instance delivery (e.g., via Redis).
	// The from parameter is the publisher's name, used to skip self-delivery.
	// ctx applies only to the cross-instance hop; local fan-out runs to
	// completion regardless, so partial delivery is possible if ctx is
	// canceled mid-publish.
	Publish(ctx context.Context, from string, topic string, kind string, payload any) error

	// lifecycle
	common.Daemon
}

type OnFull int

type Option func(*options)

type Stats interface {
	// Dropped returns the number of messages discarded because a subscriber
	// could not keep up.
	Dropped() uint64
	// Evicted returns the number of subscribers removed because they could
	// not keep up.
	Evicted() uint64
}