helpers

Documentation

Index

• Variables
• func ColumnExists(db *sql.DB, tableName string, columnName string) (bool, error)
• func SetupTestMemorySQLDB(dbInit dbsetup.DatabaseInitializer) (*sql.DB, error)
• func SetupTestSQLDB(dbInit dbsetup.DatabaseInitializer, prefix string) (*sql.DB, func() error, error)
• func WaitForPeerAsync(p *p2p.Server, u string, e p2p.PeerEventType, t time.Duration) <-chan error

Variables

var (
	// ErrNoRunningNode node is not running.
	ErrNoRunningNode = errors.New("there is no running node")
	// ErrEmptyPeerURL provided peer URL is empty
	ErrEmptyPeerURL = errors.New("empty peer url")
)

Functions

func ColumnExists

func ColumnExists(db *sql.DB, tableName string, columnName string) (bool, error)

func SetupTestMemorySQLDB

func SetupTestMemorySQLDB(dbInit dbsetup.DatabaseInitializer) (*sql.DB, error)

func SetupTestSQLDB

func SetupTestSQLDB(dbInit dbsetup.DatabaseInitializer, prefix string) (*sql.DB, func() error, error)

SetupTestSQLDB creates a temporary sqlite database file, initialises and then returns with a teardown func

func WaitForPeerAsync

func WaitForPeerAsync(p *p2p.Server, u string, e p2p.PeerEventType, t time.Duration) <-chan error

WaitForPeerAsync waits for a peer to be added asynchronously