pubsub

type PubSub interface {
	Publisher
	Subscriber
}

type Publisher interface {
	// Publish publishes a webhook event
	Publish(ctx context.Context, topic string, msg *message.Message) error
	// Close closes the publisher
	Close() error
}

type Subscriber interface {
	// Subscribe starts consuming webhook events
	Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)
	// Close closes the subscriber
	Close() error
}