pubsub

package

v0.0.32 Latest Latest Go to latest Published: Mar 30, 2023 License: MPL-2.0 Imports: 12 Imported by: 0

Details

Package pubsub implements cluster-wide publishing and subscribing of events

This section is empty.

This section is empty.

func NewBroker(logger logr.Logger, db otf.DB) *broker

type Broker interface {
	otf.PubSubService
	Register(t reflect.Type, getter Getter)
	Start(context.Context) error
	WaitUntilListening()
}

type Getter interface {
	GetByID(context.Context, string) (any, error)
}

Getter retrieves an event payload using its ID.