queue

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
}

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

type NewDiskQueueOptions struct {
	Name              string
	DataPath          string
	MaxBytesPerFile   int64
	MinMsgSize        int32
	MaxMsgSize        int32
	SyncEveryWrite    int64
	SyncEveryRead     int64
	SyncTimeout       time.Duration
	WriteRateLimit    int
	EnableMemoryQueue bool
	MemoryQueueSize   int64

	// DisableDiskUsedLimit 指示是否禁用磁盘占用限制，超出限制后数据将不会再写入到文件而被直接丢弃
	DisableDiskUsedLimit bool
	MaxDiskUsedBytes     int64
}