Documentation ¶
Index ¶
- type FileWAL
- 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
- 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
- type TestingOption
- type Ticker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FileWAL ¶
type FileWAL struct {
// contains filtered or unexported fields
}
func Open ¶
func Open( logger log.Logger, reg prometheus.Registerer, path string, opts ...TestingOption, ) (*FileWAL, error)
func (*FileWAL) FirstIndex ¶
type TestingOption ¶
type TestingOption func(*FileWAL)
func WithTestingLogStoreWrapper ¶
func WithTestingLogStoreWrapper(newLogStoreWrapper func(wal.LogStore) wal.LogStore) TestingOption
func WithTestingLoopTicker ¶
func WithTestingLoopTicker(t Ticker) TestingOption
WithTestingLoopTicker allows the caller to force processing of pending WAL entries by providing a custom ticker implementation.
Click to show internal directories.
Click to hide internal directories.