queues

Mar 11, 2020

Changes in this version

+ type InMemory struct

+ func (q *InMemory) Get(ctx context.Context) (Response, error)

+ func (q *InMemory) Publish(ctx context.Context, msgs ...Message) error

+ type InMemoryMessage struct

+ func (m *InMemoryMessage) Acknowledgement() error

+ func (m *InMemoryMessage) NegativeAcknowledgement() error

+ func (m *InMemoryMessage) Value() interface{}

+ type Interface interface

+ type Message interface

+ Value func() interface{}

+ type Publisher interface

+ Publish func(ctx context.Context, msgs ...Message) error

+ type Response interface

+ type Signaler interface

+ Acknowledgement func() error

+ NegativeAcknowledgement func() error

+ type Subscriber interface

+ Get func(ctx context.Context) (Response, error)