The highest tagged major version is v2.

events

package

v1.5.2 Latest Latest Go to latest Published: Jan 5, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

func NewEventBus(config *models.Config, ps models.PubSub) models.EventBus

func NewInMemoryPubSub() models.PubSub

NewInMemoryPubSub creates an in-memory PubSub implementation.

func NewWatermillPubSub(publisher message.Publisher, subscriber message.Subscriber) models.PubSub

NewWatermillPubSub creates a PubSub adapter for Watermill transports. Users can pass any Watermill-compatible publisher and subscriber.

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

func (s *InMemoryPubSub) Close() error

func (s *InMemoryPubSub) Publish(ctx context.Context, topic string, msg *models.Message) error

func (s *InMemoryPubSub) Subscribe(ctx context.Context, topic string) (<-chan *models.Message, error)