Versions in this module Expand all Collapse all v0 v0.7.0 Dec 13, 2018 Changes in this version + type Message struct + Body []byte + Metadata map[string]string + func (m *Message) Ack() + type Subscription struct + func NewSubscription(d driver.Subscription) *Subscription + func (s *Subscription) As(i interface{}) bool + func (s *Subscription) Receive(ctx context.Context) (*Message, error) + func (s *Subscription) Shutdown(ctx context.Context) error + type Topic struct + func NewTopic(d driver.Topic) *Topic + func (t *Topic) As(i interface{}) bool + func (t *Topic) Send(ctx context.Context, m *Message) error + func (t *Topic) Shutdown(ctx context.Context) error