queuev2

package
v1.5.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 18, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

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

	StatusInit int32 = iota
	StatusClosed
)

Variables

This section is empty.

Functions

This section is empty.

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 的队列

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL