Versions in this module Expand all Collapse all v0 v0.15.0 Nov 26, 2024 v0.14.0 Jan 29, 2024 Changes in this version + type PubSub struct + func NewPubSub(t interface{ ... }) *PubSub + func (_m *PubSub) Close() error + func (_m *PubSub) Publish(ctx context.Context, topic string, msg *messaging.Message) error + func (_m *PubSub) Subscribe(ctx context.Context, cfg messaging.SubscriberConfig) error + func (_m *PubSub) Unsubscribe(ctx context.Context, id string, topic string) error
Go to main page