publish

Feb 2, 2016

Changes in this version

+ type ChanTransactions struct

+ Channel chan common.MapStr

+ func (t *ChanTransactions) PublishTransaction(event common.MapStr) bool

+ type PacketbeatPublisher struct

+ func NewPublisher(pub *publisher.PublisherType, hwm int) *PacketbeatPublisher

+ func (t *PacketbeatPublisher) PublishTransaction(event common.MapStr) bool

+ func (t *PacketbeatPublisher) Start()

+ func (t *PacketbeatPublisher) Stop()

+ type Transactions interface

+ PublishTransaction func(common.MapStr) bool