Versions in this module Expand all Collapse all v0 v0.16.0 Dec 11, 2024 Changes in this version + const ConnCheckInterval + const MaxEventStreamLen + const MaxUnpublishedEvents + const UnpublishedEventsCheckInterval + func ReadStringSlice(event map[string]interface{}, key string) []string + func Read[T any](event map[string]interface{}, key string, def T) T + type Event interface + Encode func() (map[string]interface{}, error) + type EventHandler interface + Handle func(ctx context.Context, event Event) error + type Publisher interface + Close func() error + Publish func(ctx context.Context, event Event) error + type Subscriber interface + Close func() error + Subscribe func(ctx context.Context, cfg SubscriberConfig) error + type SubscriberConfig struct + Consumer string + Handler EventHandler + Stream string
Go to main page