Versions in this module Expand all Collapse all v1 v1.5.5 May 18, 2020 Changes in this version + const FromDisk + const FromMemory + const FromNone + const StatusClosed + const StatusInit + func AtomicRename(sourceFile, targetFile string) error + type BackendQueue interface + Close func() error + Delete func() error + Depth func() int64 + Empty func() error + Name func() string + Put func([]byte) error + ReadChan func() <-chan []byte + func NewDirectQueue(name string) BackendQueue + func NewDiskQueue(opts NewDiskQueueOptions) BackendQueue + type DataQueue interface + PutDatas func([]Data) error + ReadDatasChan func() <-chan []Data + type LinesQueue interface + PutLines func([]string) error + ReadLinesChan func() <-chan []string + type NewDiskQueueOptions struct + DataPath string + DisableDiskUsedLimit bool + EnableMemoryQueue bool + MaxBytesPerFile int64 + MaxDiskUsedBytes int64 + MaxMsgSize int32 + MemoryQueueSize int64 + MinMsgSize int32 + Name string + SyncEveryRead int64 + SyncEveryWrite int64 + SyncTimeout time.Duration + WriteRateLimit int
Go to main page