pubsub

Aug 31, 2023

Changes in this version

+ func AddProvider(uri string, init ProviderInit)

+ func SupportedProviders() []string

+ type ProviderInit func(ctx context.Context, topicResourceID string) (Publisher, error)

+ type ProviderNotFoundError struct

+ func (e *ProviderNotFoundError) Error() string

+ type Publisher interface

+ Close func() error

+ Publish func(ctx context.Context, event *events.Event, encoding events.EventContentType) error

+ func Get(ctx context.Context, topicResourceID string) (Publisher, error)