broker

Documentation

Index

• type Broker
  • func Local[T any]() Broker[T]
• type Subscription
• type Topic

Types

type Broker

type Broker[T any] interface {
	Topic(context.Context, string) Topic[T]
}

func Local

func Local[T any]() Broker[T]

type Subscription

type Subscription interface {
	ID() string
	Unsubscribe()
}

type Topic

type Topic[T any] interface {
	Publish(context.Context, events.Event) error
	Subscribe(context.Context, events.Hook[T]) (Subscription, error)
}