Versions in this module Expand all Collapse all v1 v1.5.5 May 18, 2020 Changes in this version + const Group + const StatusClosed + const StatusInit + const Topic + type BackendQueue interface + Close func() error + Delete func() error + Depth func() int64 + Empty func() error + Name func() string + Put func([]byte) error + ReadChan func() <-chan []byte + SyncMeta func() + func NewKafkaQueue(name string, hosts []string, exitChan chan struct{}) BackendQueue + type DataQueue interface + PutDatas func([]Data) error + ReadDatasChan func() <-chan []Data