broker

package

v0.1.0 Latest Latest Go to latest Published: Jan 3, 2025 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Broker interface {
	Topic(context.Context, string) Topic
}

func Local() Broker

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

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