starter

Aug 20, 2020

Changes in this version

+ func RemoveEnd(buf []byte) []byte

Aug 12, 2020

Changes in this version

type BrokerConf

+ FailureTimes int

Jul 20, 2020

Changes in this version

+ func GetEnd() byte

+ func Pack(payload []byte) []byte

+ func Tail() []byte

type Broker

+ func (b Broker) Sub(handle func(topic string, payload []byte))

Jul 20, 2020

Changes in this version

+ type Broker struct

+ func NewBroker(conf *BrokerConf) Broker

+ func (b Broker) Run(handle func(topic string, payload []byte))

+ type BrokerConf struct

+ Addr string

+ ConnectTimeout int

+ Password string

+ Topics []string

+ Username string

+ WaitTimeout int

+ var DefaultConfig *BrokerConf = &BrokerConf{ ... }