datatest

Documentation

Overview

Package datatest provides common datadriven test commands for use outside of the root Pebble package.

Index

• func DefineBatch(d *datadriven.TestData, b *pebble.Batch) error
• type CompactionTracker
  • func NewCompactionTracker(options *pebble.Options) *CompactionTracker
  • func (cql *CompactionTracker) WaitForInflightCompactionsToEqual(target int)

Functions

func DefineBatch

func DefineBatch(d *datadriven.TestData, b *pebble.Batch) error

DefineBatch interprets the provided datadriven command as a sequence of write operations, one-per-line, to apply to the provided batch.

Types

type CompactionTracker

type CompactionTracker struct {
	sync.Cond
	// contains filtered or unexported fields
}

CompactionTracker is a listener that tracks the number of compactions.

func NewCompactionTracker

func NewCompactionTracker(options *pebble.Options) *CompactionTracker

NewCompactionTracker setups the necessary options to keep track of the compactions that are in flight.

func (*CompactionTracker) WaitForInflightCompactionsToEqual

func (cql *CompactionTracker) WaitForInflightCompactionsToEqual(target int)

WaitForInflightCompactionsToEqual waits until compactions meet the specified target.