dbtest

Documentation

Index

• Variables
• func BenchmarkBuilder(b *testing.B)
• func BenchmarkConcatenation(b *testing.B)
• func FromBytes(data driver3.RawVersion) (driver3.BlockNum, driver3.TxNum, error)
• func ReadExisting(b *testing.B, db driver.TransactionalVersionedPersistence)
• func ReadNonExisting(b *testing.B, db driver.TransactionalVersionedPersistence)
• func TTestCompositeKeys(t *testing.T, db driver.TransactionalVersionedPersistence)
• func TTestDB1(t *testing.T, db driver.TransactionalVersionedPersistence)
• func TTestDB2(t *testing.T, db driver.TransactionalVersionedPersistence)
• func TTestDuplicate(t *testing.T, _ *sql.DB, writeDB *sql.DB, errorWrapper driver.SQLErrorWrapper, ...)
• func TTestGetNonExistent(t *testing.T, db driver.TransactionalVersionedPersistence)
• func TTestMeta(t *testing.T, db driver.TransactionalVersionedPersistence)
• func TTestMetadata(t *testing.T, db driver.TransactionalVersionedPersistence)
• func TTestMultiWrites(t *testing.T, db driver.TransactionalVersionedPersistence)
• func TTestMultiWritesAndRangeQueries(t *testing.T, db driver.TransactionalVersionedPersistence)
• func TTestNonUTF8keys(t *testing.T, db driver.UnversionedPersistence)
• func TTestRangeQueries(t *testing.T, db driver.TransactionalVersionedPersistence)
• func TTestRangeQueries1(t *testing.T, db driver.TransactionalVersionedPersistence)
• func TTestSimpleReadWrite(t *testing.T, db driver.TransactionalVersionedPersistence)
• func TTestUnversionedNotifierSimple(t *testing.T, db driver.UnversionedNotifier)
• func TTestUnversionedRange(t *testing.T, db driver.UnversionedPersistence)
• func TTestUnversionedSimple(t *testing.T, db driver.UnversionedPersistence)
• func TTestVersionedNotifierSimple(t *testing.T, db driver.VersionedNotifier)
• func ToBytes(Block driver3.BlockNum, TxNum driver3.TxNum) []byte
• func WriteMany(b *testing.B, db driver.TransactionalVersionedPersistence)
• func WriteOne(b *testing.B, db driver.TransactionalVersionedPersistence)
• func WriteParallel(b *testing.B, db driver.TransactionalUnversionedPersistence)

Variables

var Cases = []struct {
	Name string
	Fn   func(*testing.T, driver.TransactionalVersionedPersistence)
}{
	{"RangeQueries", TTestRangeQueries},
	{"Meta", TTestMeta},
	{"SimpleReadWrite", TTestSimpleReadWrite},
	{"GetNonExistent", TTestGetNonExistent},
	{"Metadata", TTestMetadata},
	{"DB1", TTestDB1},
	{"DB2", TTestDB2},
	{"RangeQueries1", TTestRangeQueries1},
	{"MultiWritesAndRangeQueries", TTestMultiWritesAndRangeQueries},
	{"TTestMultiWrites", TTestMultiWrites},
	{"CompositeKeys", TTestCompositeKeys},
}

This file exposes functions that db drivers can use for integration tests

var ErrorCases = []struct {
	Name string
	Fn   func(t *testing.T, readDB *sql.DB, writeDB *sql.DB, errorWrapper driver.SQLErrorWrapper, table string)
}{
	{"Duplicate", TTestDuplicate},
}

var UnversionedCases = []struct {
	Name string
	Fn   func(*testing.T, driver.UnversionedPersistence)
}{
	{"UnversionedSimple", TTestUnversionedSimple},
	{"UnversionedRange", TTestUnversionedRange},
	{"NonUTF8keys", TTestNonUTF8keys},
}

var UnversionedNotifierCases = []struct {
	Name string
	Fn   func(*testing.T, driver.UnversionedNotifier)
}{
	{"UnversionedNotifierSimple", TTestUnversionedNotifierSimple},
}

var VersionedNotifierCases = []struct {
	Name string
	Fn   func(*testing.T, driver.VersionedNotifier)
}{
	{"VersionedNotifierSimple", TTestVersionedNotifierSimple},
}

Functions

func BenchmarkBuilder

func BenchmarkBuilder(b *testing.B)

func BenchmarkConcatenation

func BenchmarkConcatenation(b *testing.B)

func FromBytes

func FromBytes(data driver3.RawVersion) (driver3.BlockNum, driver3.TxNum, error)

func ReadExisting

func ReadExisting(b *testing.B, db driver.TransactionalVersionedPersistence)

func ReadNonExisting

func ReadNonExisting(b *testing.B, db driver.TransactionalVersionedPersistence)

func TTestCompositeKeys

func TTestCompositeKeys(t *testing.T, db driver.TransactionalVersionedPersistence)

func TTestDB1

func TTestDB1(t *testing.T, db driver.TransactionalVersionedPersistence)

func TTestDB2

func TTestDB2(t *testing.T, db driver.TransactionalVersionedPersistence)

func TTestDuplicate

func TTestDuplicate(t *testing.T, _ *sql.DB, writeDB *sql.DB, errorWrapper driver.SQLErrorWrapper, table string)

func TTestGetNonExistent

func TTestGetNonExistent(t *testing.T, db driver.TransactionalVersionedPersistence)

func TTestMeta

func TTestMeta(t *testing.T, db driver.TransactionalVersionedPersistence)

func TTestMetadata

func TTestMetadata(t *testing.T, db driver.TransactionalVersionedPersistence)

func TTestMultiWrites

func TTestMultiWrites(t *testing.T, db driver.TransactionalVersionedPersistence)

func TTestMultiWritesAndRangeQueries

func TTestMultiWritesAndRangeQueries(t *testing.T, db driver.TransactionalVersionedPersistence)

func TTestNonUTF8keys

func TTestNonUTF8keys(t *testing.T, db driver.UnversionedPersistence)

Postgres doesn't like non-utf8 in TEXT fields, so we made it a BYTEA. cannot check if key exists: pq: invalid byte sequence for encoding "UTF8": 0xc2 0x32]

func TTestRangeQueries

func TTestRangeQueries(t *testing.T, db driver.TransactionalVersionedPersistence)

func TTestRangeQueries1

func TTestRangeQueries1(t *testing.T, db driver.TransactionalVersionedPersistence)

func TTestSimpleReadWrite

func TTestSimpleReadWrite(t *testing.T, db driver.TransactionalVersionedPersistence)

func TTestUnversionedNotifierSimple

func TTestUnversionedNotifierSimple(t *testing.T, db driver.UnversionedNotifier)

func TTestUnversionedRange

func TTestUnversionedRange(t *testing.T, db driver.UnversionedPersistence)

func TTestUnversionedSimple

func TTestUnversionedSimple(t *testing.T, db driver.UnversionedPersistence)

func TTestVersionedNotifierSimple

func TTestVersionedNotifierSimple(t *testing.T, db driver.VersionedNotifier)

func ToBytes

func ToBytes(Block driver3.BlockNum, TxNum driver3.TxNum) []byte

func WriteMany

func WriteMany(b *testing.B, db driver.TransactionalVersionedPersistence)

func WriteOne

func WriteOne(b *testing.B, db driver.TransactionalVersionedPersistence)

func WriteParallel

func WriteParallel(b *testing.B, db driver.TransactionalUnversionedPersistence)