replay

Documentation

Overview

Package replay implements facilities for replaying writes to a database.

Index

• type DB
  • func Open(dirname string, opts *pebble.Options) (*DB, error)
  • func (d *DB) Close() error
  • func (d *DB) Done() *pebble.DB
  • func (d *DB) FlushExternal(tbl Table) error
  • func (d *DB) Ingest(tables []Table) error
  • func (d *DB) Metrics() *pebble.Metrics
• type Table

Types

type DB

type DB struct {
	// contains filtered or unexported fields
}

A DB is a wrapper around a Pebble database for replaying table-level writes to a database. It is not safe for concurrent access.

func Open

func Open(dirname string, opts *pebble.Options) (*DB, error)

Open opens a database for replaying flushed and ingested tables. It's intended for use by the `pebble bench compact` command.

func (*DB) Close

func (d *DB) Close() error

Close closes a replay and the underlying database. If Close is called after Done, Close does nothing.

func (*DB) Done

func (d *DB) Done() *pebble.DB

Done finishes a replay, returning the underlying database. All of the *replay.DB's methods except Close will error if called after Done.

func (*DB) FlushExternal

func (d *DB) FlushExternal(tbl Table) error

FlushExternal simulates a flush of the table, linking it directly into level zero.

func (*DB) Ingest

func (d *DB) Ingest(tables []Table) error

Ingest ingests a set of sstables into the DB.

func (*DB) Metrics

func (d *DB) Metrics() *pebble.Metrics

Metrics returns the underlying DB's Metrics.

type Table

type Table struct {
	Path         string
	FileMetadata *manifest.FileMetadata
}

Table describes a sstable from the reference database whose writes are being replayed.