pubsub

Documentation

Index

• type Broker
  • func NewBroker[T resource.Resource](logger Logger) *Broker[T]
  • func (b *Broker[T]) Publish(t resource.EventType, payload T)
  • func (b *Broker[T]) Shutdown()
  • func (b *Broker[T]) Subscribe(ctx context.Context) <-chan resource.Event[T]
• type Logger

Types

type Broker

type Broker[T resource.Resource] struct {
	// contains filtered or unexported fields
}

Broker allows clients to publish events and subscribe to events

func NewBroker

func NewBroker[T resource.Resource](logger Logger) *Broker[T]

NewBroker constructs a pub/sub broker.

func (*Broker[T]) Publish

func (b *Broker[T]) Publish(t resource.EventType, payload T)

Publish an event to subscribers.

func (*Broker[T]) Shutdown

func (b *Broker[T]) Shutdown()

Shutdown the broker, terminating any subscriptions.

func (*Broker[T]) Subscribe

func (b *Broker[T]) Subscribe(ctx context.Context) <-chan resource.Event[T]

Subscribe subscribes the caller to a stream of events. The returned channel is closed when the broker is shutdown.

type Logger

type Logger interface {
	Debug(msg string, args ...any)
	Info(msg string, args ...any)
	Warn(msg string, args ...any)
	Error(msg string, args ...any)
}