Versions in this module Expand all Collapse all v1 v1.1.2 Nov 2, 2020 Changes in this version + type FileCache struct + func NewFileCache(rowLimit int) (*FileCache, error) + func (f *FileCache) AddRow(msg *msgs.BEDataRowMsg) + func (f *FileCache) Close() error + func (f *FileCache) Finalize() error + func (f *FileCache) GetRow() *msgs.BEDataRowMsg + func (f *FileCache) Peek() *msgs.BEDataRowMsg + type MemoryCache struct + func NewMemoryCache(size int) *MemoryCache + func (m *MemoryCache) AddRow(msg *msgs.BEDataRowMsg) + func (m *MemoryCache) Close() error + func (m *MemoryCache) Finalize() error + func (m *MemoryCache) GetRow() *msgs.BEDataRowMsg + func (m *MemoryCache) Peek() *msgs.BEDataRowMsg