queue

type Event struct {
	ID        string
	Type      EventType
	EntityID  string
	Entity    any
	CreatedAt time.Time
}

type EventType string

type M struct {
	ID            string
	ContentType   string
	ContentLength int // In bytes
	CreatedAt     time.Time
	Metadata      Metadata
	Body          []byte
}

type Metadata map[string]string

type Pub[e any] interface {
	Pub(ctx context.Context, e Event) error
}

type PubSub[K comparable, E any] interface {
	Server
	Pub(context.Context, E) error
	Sub(context.Context, K) (Subscription[E], error)
}

type Server interface {
	Start(context.Context) error
	Stop(context.Context) error
}

type Subscription[E any] interface {
	Close() error
	Ch() <-chan E
}