Versions in this module Expand all Collapse all v0 v0.1.1 Sep 18, 2019 v0.1.0 Sep 12, 2019 Changes in this version + type Consumer interface + Config func() string + Subject func() string + Subscribe func(Listener) error + func NewConsumer(subject string) (Consumer, error) + type Listener func([]byte, Consumer) + type LocalConsumer struct + func (c *LocalConsumer) Config() string + func (c *LocalConsumer) Subject() string + func (c *LocalConsumer) Subscribe(listener Listener) error + type LocalProducer struct + func (p *LocalProducer) Config() string + func (p *LocalProducer) Produce(data []byte) error + func (p *LocalProducer) Subject() string + type LocalQueue struct + Config string + Subject string + func (q *LocalQueue) Init() error + func (q *LocalQueue) NewConsumer() (c Consumer, err error) + func (q *LocalQueue) NewProducer() (p Producer, err error) + type NatsConsumer struct + func (c *NatsConsumer) Config() string + func (c *NatsConsumer) Subject() string + func (c *NatsConsumer) Subscribe(listener Listener) (err error) + type NatsProducer struct + func (p *NatsProducer) Config() string + func (p *NatsProducer) Produce(data []byte) (err error) + func (p *NatsProducer) Subject() string + type NatsQueue struct + Config string + Subject string + func (q *NatsQueue) Init() error + func (q *NatsQueue) NewConsumer() (c Consumer, err error) + func (q *NatsQueue) NewProducer() (p Producer, err error) + type Producer interface + Config func() string + Produce func([]byte) error + Subject func() string + func NewProducer(subject string) (Producer, error) + type Queue interface + Init func() error + NewConsumer func() (Consumer, error) + NewProducer func() (Producer, error)