pubsub

type Broker ¶

type Broker[T any] struct {
	// contains filtered or unexported fields
}

Broker manages the publisher/subscriber pattern in a thread-safe, generic way.

func NewBroker[T any]() *Broker[T]

func NewBrokerWithOptions[T any](bufferSize int) *Broker[T]

func (b *Broker[T]) GetSubscriberCount() int

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

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

func (b *Broker[T]) Subscribe() (<-chan Event[T], func())

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

type Event ¶

type Event[T any] struct {
	Type    EventType
	Payload T
}

Event represents an event in the lifecycle of a resource

type EventType ¶

type EventType string

EventType identifies the type of event

const (
	CreatedEvent EventType = "created"
	UpdatedEvent EventType = "updated"
	DeletedEvent EventType = "deleted"
)

type Publisher ¶

type Publisher[T any] interface {
	Publish(EventType, T)
}

type Subscriber ¶ added in v1.7.0

type Subscriber[T any] interface {
	SubscribeWithContext(context.Context) <-chan Event[T]
}