queuev2

Documentation

Index

• Constants
• type BackendQueue
  • func NewKafkaQueue(name string, hosts []string, exitChan chan struct{}) BackendQueue
• type DataQueue

Constants

const (
	Topic = "edge_topic"
	Group = "edge_group"

	StatusInit int32 = iota
	StatusClosed
)

Types

type BackendQueue

type BackendQueue interface {
	Name() string
	Put([]byte) error
	ReadChan() <-chan []byte // this is expected to be an *unbuffered* channel
	Close() error
	Delete() error
	Depth() int64
	Empty() error
	SyncMeta()
}

BackendQueue represents the behavior for the secondary message storage system

func NewKafkaQueue

func NewKafkaQueue(name string, hosts []string, exitChan chan struct{}) BackendQueue

type DataQueue

type DataQueue interface {
	// PutDatas 用于存放一组数据
	PutDatas([]Data) error
	// ReadDatasChan 用于获取直接读取 Data 的管道
	ReadDatasChan() <-chan []Data
}

DataQueue 代表了无需编解码可直接放取 Data 的队列