Versions in this module Expand all Collapse all v0 v0.0.20 May 20, 2022 Changes in this version + type PubSubMessage struct + func NewPubSubMessage(topic, message string) PubSubMessage + func UnmarshalPubSubMessage(data []byte) PubSubMessage + func (m PubSubMessage) Marshal() []byte + func (m PubSubMessage) Message() string + func (m PubSubMessage) String() string + func (m PubSubMessage) Topic() string + type Publisher struct + func NewPublisher() (*Publisher, error) + func (p *Publisher) Close() + func (p *Publisher) Publish(message PubSubMessage) error + type Subscriber struct + func NewSubscriber(topics []string, messageChan chan<- PubSubMessage) *Subscriber + func (s *Subscriber) Close() + func (s *Subscriber) Start(ctx context.Context) error