Versions in this module Expand all Collapse all v0 v0.0.2 May 15, 2023 Changes in this version + type Queue struct + func New(dataDir string, fileSize int) (*Queue, error) + func (q *Queue) Close() error + func (q *Queue) Put(data []byte) error + func (q *Queue) ReadChan() <-chan []byte
Go to main page