package buffer // import "github.com/rodrigo0345/omag/internal/storage/buffer"

const BatchSizeThreshold = 512 * 1024 ... var ErrBufferFull = errors.New("buffer pool is full") ... var ErrDiskManagerClosed = errors.New("disk manager is closed") type BufferPoolManager struct{ ... } type DiskManager struct{ ... } func NewDiskManager(dbPath string) (DiskManager, error) type IBufferPoolManager interface{ ... } func NewBufferPoolManager(poolSize int, diskManager DiskManager) IBufferPoolManager func NewBufferPoolManagerWithReplacer(poolSize int, diskManager *DiskManager, replacerManager concurrency.IReplacer) IBufferPoolManager type ReplacerType int const ReplacerLRU ReplacerType = iota ... type WALFlusher interface{ ... }