Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetKBrokers ¶
给定zookeeper地址列表 获取 broker 地址列表
func TestKConsumer ¶
func TestKConsumer()
func TestKProducer ¶
func TestKProducer()
Types ¶
type IKProducer ¶
type IKProducer interface { IMQWorker Setup(_zk_addrs string) Push(_topic *string, _part int, _key, _val []byte) }
func NewKProducer ¶
func NewKProducer() IKProducer
type IKmqConsumer ¶
type IKmqConsumer interface { IMQWorker Setup(_zks, _app, _group string, _receiver chan KMessage) Subscribe(_topic string) }
func NewKmqConsumer ¶
func NewKmqConsumer() IKmqConsumer
type IRmqConsumer ¶
type IRmqConsumer interface { IMQWorker Setup(_name_svr, _app, _group string, _receiver chan RMessage) Subscribe(_topic string, _need bool) }
func NewRmqConsumer ¶
func NewRmqConsumer() IRmqConsumer
type IRmqProducer ¶
type KMessage ¶
type KMessage *kmq.ConsumerMessage
type RMessage ¶
type RMessage *rmq.MessageExt
Click to show internal directories.
Click to hide internal directories.