Versions in this module Expand all Collapse all v0 v0.10.0 Apr 9, 2018 Changes in this version + var ErrNotEnoughSpace = errors.New("target disk is at capacity") + var ErrWrongTrackerLength = errors.New("tracker was unexpected length") + type CachedMmap struct + 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 + 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 + func NewMmapBufferConfig() MmapBufferConfig + type MmapCache struct + 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 + CleanUp bool + FileSize int + Path string + ReservedDiskSpace uint64 + RetryPeriodMS int + func NewMmapCacheConfig() MmapCacheConfig
Go to main page