testutil

Documentation

Index

• func NewDB(t *testing.T, r copydb.Redis, opts ...copydb.DBOpt) *copydb.DB
• func NewRedis(t *testing.T) copydb.Redis
• func ServeDB(t *testing.T, db *copydb.DB)
• func StopDB(t *testing.T, db *copydb.DB, timeout time.Duration)
• func WaitForError(d time.Duration, db *copydb.DB, id string, unix int64) error
• func WaitForItem(d time.Duration, db *copydb.DB, id string, unix int64, ...) error

Functions

func NewDB

func NewDB(t *testing.T, r copydb.Redis, opts ...copydb.DBOpt) *copydb.DB

NewDB creates a new database instance.

func NewRedis

func NewRedis(t *testing.T) copydb.Redis

NewRedis returns a client connected to standalone Redis.

func ServeDB

func ServeDB(t *testing.T, db *copydb.DB)

ServeDB runs a database.

func StopDB

func StopDB(t *testing.T, db *copydb.DB, timeout time.Duration)

StopDB terminates a database.

func WaitForError

func WaitForError(d time.Duration, db *copydb.DB, id string, unix int64) error

WaitForError waits until an error will be returned.

func WaitForItem

func WaitForItem(d time.Duration, db *copydb.DB, id string, unix int64, resolve ...copydb.QueryResolve) error

WaitForItem waits until an identifier will be found in the database.