pubsub

Nov 15, 2017

Changes in this version

+ type MessageHandler interface

+ OnMessage func(*pubsub.Message) error

+ type Publish interface

+ Publish func(message *ps.Message)

+ type PublishClient struct

+ Batch bool

+ Context context.Context

+ Topic *ps.Topic

+ func (pc *PublishClient) Publish(message *ps.Message)

+ type SubscriberClient struct

+ Context context.Context

+ Handler MessageHandler

+ Subscritpion *pubsub.Subscription

+ func NewSubscriberClient(ctx context.Context, s *pubsub.Subscription, mh MessageHandler) SubscriberClient