memory

package

v1.1.59 Latest Latest Go to latest Published: Jan 20, 2026 License: AGPL-3.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

func NewPubSub(
	cfg *config.Configuration,
	logger *logger.Logger,
) pubsub.PubSub

NewPubSub creates a new memory-based pubsub

type PubSub struct {
	// contains filtered or unexported fields
}

PubSub implements both Publisher and Subscriber interfaces using watermill's gochannel

func (p *PubSub) Close() error

Close closes both publisher and subscriber

func (p *PubSub) Publish(ctx context.Context, topic string, msg *message.Message) error

Publish publishes a webhook event

func (p *PubSub) Subscribe(ctx context.Context, topic string) (<-chan *message.Message, error)

Subscribe starts consuming webhook events