Versions in this module Expand all Collapse all v0 v0.5.1 Apr 24, 2026 Changes in this version + var ErrFull = errors.New("full") + var ErrStopped = errors.New("stopped") + type Event struct + CreatedAt time.Time + Entity any + EntityID string + ID string + Type EventType + type EventType string + type M struct + Body []byte + ContentLength int + ContentType string + CreatedAt time.Time + ID string + Metadata Metadata + type Metadata map[string]string + type Pub interface + Pub func(ctx context.Context, e Event) error + type PubSub interface + Pub func(context.Context, E) error + Sub func(context.Context, K) (Subscription[E], error) + type Server interface + Start func(context.Context) error + Stop func(context.Context) error + type Subscription interface + Ch func() <-chan E + Close func() error Other modules containing this package github.com/adobaai/pkg
Go to main page