event

Jan 23, 2025

Changes in this version

+ type EventWithCtx struct

+ type MemoryEventBus struct

+ func NewMemoryEventBus() (*MemoryEventBus, error)

+ func (b *MemoryEventBus) Close() error

+ func (b *MemoryEventBus) Publish(ctx context.Context, event Event) error

+ func (b *MemoryEventBus) Subscribe(eventType string, handler func(ctx context.Context, event Event)) error

Jan 3, 2025

Changes in this version

+ type Event struct

+ Data map[string]any

+ ID string

+ Source string

+ SpecVersion string

+ Time time.Time

+ Type string

+ type EventBus interface

+ Close func() error

+ Publish func(ctx context.Context, event Event) error

+ Subscribe func(eventType string, handler func(ctx context.Context, event Event)) error

+ var DefaultEventBus EventBus