memory

Oct 25, 2020

Changes in this version

type PublisherOption

+ func WithPublisherID(id string) PublisherOption

type SubscriberOption

+ func WithSubscriberID(id string) SubscriberOption

Feb 9, 2020

Changes in this version

+ func NewPublisher(_ ...PublisherOption) pubsub.Publisher

+ func NewSubscriber(opts ...SubscriberOption) pubsub.Subscriber

+ type PublisherOption func(*publisher)

+ type SubscriberOption func(*subscriber)

+ func WithMaxAttempts(retries int) SubscriberOption

+ func WithQueueSize(queueSize int) SubscriberOption