Versions in this module Expand all Collapse all v1 v1.3.5 Mar 19, 2026 Changes in this version + type FileCache struct + func NewFileCache(rowLimit int) (*FileCache, error) + func (f *FileCache) AddRow(msg *msgs.BEDataRowMsg) error + 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) error + func (m *MemoryCache) Close() error + func (m *MemoryCache) Finalize() error + func (m *MemoryCache) GetRow() *msgs.BEDataRowMsg + func (m *MemoryCache) Peek() *msgs.BEDataRowMsg
Go to main page