Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

ring

package

Go to main page

Versions in this module

v0

v0.1.1

Jan 3, 2017

v0.0.2

Oct 18, 2016

v0.0.1

Sep 14, 2016

Changes in this version

+ 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 MessageStack interface

+ Close func()

+ CloseOnceEmpty func()

+ NextMessage func() (types.Message, error)

+ PushMessage func(types.Message) (int, error)

+ ShiftMessage func() (int, error)

+ type Mmap struct

+ func NewMmap(config MmapConfig, log log.Modular, stats metrics.Aggregator) (*Mmap, error)

+ func (f *Mmap) Close()

+ func (f *Mmap) CloseOnceEmpty()

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

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

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

+ type MmapCache struct

+ func NewMmapCache(config MmapCacheConfig) (*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

+ RetryPeriodMS int

+ func NewMmapCacheConfig() MmapCacheConfig

+ type MmapConfig MmapCacheConfig

+ func NewMmapConfig() MmapConfig