Struct queue

pkg/queue/queue.go:83–100

queue implements queue.

// queue implements queue.
type queue struct {
	indexPage       page.MappedPage // index buffer
	dataPage        page.MappedPage // data buffer
	indexPageFct    page.Factory    // index page factory
	dataPageFct     page.Factory    // data page factory
	metaPage        page.MappedPage // meta buffer
	metaPageFct     page.Factory    // meta page factory
	notEmpty        *sync.Cond      // not empty condition
	rwMutex         *sync.RWMutex
	dirPath         string       // path for queue file
	appendedSeq     atomic.Int64 // current written sequence
	dataPageIndex   int64
	indexPageIndex  int64
	messageOffset   int
	closed          atomic.Bool
	acknowledgedSeq atomic.Int64 // acknowledged sequence
	pageSize        int64        // data page size
}

// NewQueue returns Queue based on dirPath, pageSize is used to limit the data page size,
func NewQueue(dirPath string, pageSize int64) (Queue, error) {