pubsub

Documentation

Index

• type Broker
  • func NewBroker[T any]() *Broker[T]
  • func (b *Broker[T]) GetSubscriberCount() int
  • func (b *Broker[T]) Publish(eventType EventType, payload T)
  • func (b *Broker[T]) Shutdown()
  • func (b *Broker[T]) Subscribe(ctx context.Context) <-chan Event[T]
• type Event
• type EventType
• type Publisher
• type Subscriber

Types

type Broker

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

func NewBroker

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

func (*Broker[T]) GetSubscriberCount

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

func (*Broker[T]) Publish

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

func (*Broker[T]) Shutdown

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

func (*Broker[T]) Subscribe

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

type Event

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

type EventType

type EventType string

const (
	EventTypeCreated EventType = "created"
	EventTypeUpdated EventType = "updated"
	EventTypeDeleted EventType = "deleted"
)

type Publisher

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

type Subscriber

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