single

Jul 24, 2022

Changes in this version

+ var ErrNotEnoughSpace = errors.New("target disk is at capacity") — darwin/amd64, linux/amd64, windows/amd64

+ var ErrWrongTrackerLength = errors.New("tracker was unexpected length") — darwin/amd64, linux/amd64, windows/amd64

+ type CachedMmap struct — darwin/amd64, linux/amd64, windows/amd64

+ type Memory struct

+ func NewMemory(config MemoryConfig) *Memory

+ func (m *Memory) Close()

+ func (m *Memory) CloseOnceEmpty()

+ func (m *Memory) NextMessage() (types.Message, error)

+ func (m *Memory) PushMessage(msg types.Message) (int, error)

+ func (m *Memory) ShiftMessage() (int, error)

+ type MemoryConfig struct

+ Limit int

+ func NewMemoryConfig() MemoryConfig

+ type MmapBuffer struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewMmapBuffer(config MmapBufferConfig, log log.Modular, stats metrics.Type) (*MmapBuffer, error)

+ func (f *MmapBuffer) Close()

+ func (f *MmapBuffer) CloseOnceEmpty()

+ func (f *MmapBuffer) NextMessage() (types.Message, error)

+ func (f *MmapBuffer) PushMessage(msg types.Message) (int, error)

+ func (f *MmapBuffer) ShiftMessage() (int, error)

+ type MmapBufferConfig MmapCacheConfig — darwin/amd64, linux/amd64, windows/amd64

+ func NewMmapBufferConfig() MmapBufferConfig

+ type MmapCache struct — darwin/amd64, linux/amd64, windows/amd64

+ func NewMmapCache(config MmapCacheConfig, log log.Modular, stats metrics.Type) (*MmapCache, error)

+ func (f *MmapCache) Delete(index int) error

+ func (f *MmapCache) EnsureCached(index int) error

+ func (f *MmapCache) Get(index int) []byte

+ func (f *MmapCache) GetTracker() []byte

+ func (f *MmapCache) IsCached(index int) bool

+ func (f *MmapCache) Remove(index int) error

+ func (f *MmapCache) RemoveAll() error

+ type MmapCacheConfig struct — darwin/amd64, linux/amd64, windows/amd64

+ CleanUp bool

+ FileSize int

+ Path string

+ ReservedDiskSpace uint64

+ RetryPeriod string

+ func NewMmapCacheConfig() MmapCacheConfig