pubsub

type Adapter interface {
	// Publish publishes a events to a channel.
	Publish(ctx context.Context, channel string, events ...Event) error
	// Subscribe subscribes to a channel.
	Subscribe(ctx context.Context, channel string) (Subscription, error)
	// HasSubscribers returns true if there are subscribers to the given pattern.
	HasSubscribers(ctx context.Context, pattern string) bool
}

type Event struct {
	Type         *string `json:"type"`
	Target       *string `json:"target"`
	TemplateName *string `json:"template_name"`
	Data         any     `json:"data"`
}

type Subscription interface {
	// C returns a receive-only go channel of events published
	C() <-chan []Event
	// Close closes the subscription.
	Close()
}