Versions in this module Expand all Collapse all v0 v0.0.1 Mar 23, 2024 Changes in this version + type FileWAL struct + func Open(logger log.Logger, reg prometheus.Registerer, path string) (*FileWAL, error) + func (w *FileWAL) Close() error + func (w *FileWAL) FirstIndex() (uint64, error) + func (w *FileWAL) LastIndex() (uint64, error) + func (w *FileWAL) Log(tx uint64, record *walpb.Record) error + func (w *FileWAL) LogRecord(tx uint64, table string, record arrow.Record) error + func (w *FileWAL) Replay(tx uint64, handler ReplayHandlerFunc) (err error) + func (w *FileWAL) Reset(nextTx uint64) error + func (w *FileWAL) RunAsync() + func (w *FileWAL) Truncate(tx uint64) error + type NopWAL struct + func (w *NopWAL) Close() error + func (w *NopWAL) FirstIndex() (uint64, error) + func (w *NopWAL) LastIndex() (uint64, error) + func (w *NopWAL) Log(_ uint64, _ *walpb.Record) error + func (w *NopWAL) LogRecord(_ uint64, _ string, _ arrow.Record) error + func (w *NopWAL) Replay(_ uint64, _ ReplayHandlerFunc) error + func (w *NopWAL) Reset(_ uint64) error + func (w *NopWAL) Truncate(_ uint64) error + type ReplayHandlerFunc func(tx uint64, record *walpb.Record) error