Versions in this module Expand all Collapse all v1 v1.3.1 Jul 11, 2018 v1.3.0 Jun 10, 2018 Changes in this version + type Event struct + Message []byte + Topic string + type PublishSubscriber interface + type Publisher interface + Publish func(ctx context.Context, topic string, msg []byte) error + type Subscriber interface + Subscribe func(ctx context.Context, name, topic string) (<-chan Event, error)