test

Documentation

Index

• Variables
• func DefaultListenAndExecute(rcvr interface{}, rpcCallback func(*RpcTestEnv))
• func ExecuteInTx(txCallback func(*sql.Tx))
• func ExecuteOrFail(query string, args ...interface{}) sql.Result
• func ExecuteQueriesOrFailInTx(queries ...string)
• func InitDb(c *check.C)
• func QueryForRow(rowCallback func(row *sql.Row), sqlQuery string, args ...interface{})
• func QueryForRows(rowsCallback func(row *sql.Rows), sqlQuery string, args ...interface{})
• func ReleaseDb(c *check.C)
• type RpcTestEnv
  • func (rpcTestEnvInstance *RpcTestEnv) ListenAndExecute(rcvr interface{}, rpcCallback func(*RpcTestEnv))

Variables

var DbForTest *sql.DB

Functions

func DefaultListenAndExecute

func DefaultListenAndExecute(
	rcvr interface{}, rpcCallback func(*RpcTestEnv),
)

func ExecuteInTx

func ExecuteInTx(txCallback func(*sql.Tx))

IoC execution(in transaction)

func ExecuteOrFail

func ExecuteOrFail(query string, args ...interface{}) sql.Result

IoC execution

func ExecuteQueriesOrFailInTx

func ExecuteQueriesOrFailInTx(queries ...string)

IoC execution(in transaction)

func InitDb

func InitDb(c *check.C)

func QueryForRow

func QueryForRow(
	rowCallback func(row *sql.Row),
	sqlQuery string, args ...interface{},
)

IoC Callback for row This method would use sql.DB.QueryRow method to retrive data

func QueryForRows

func QueryForRows(
	rowsCallback func(row *sql.Rows),
	sqlQuery string, args ...interface{},
)

IoC Callback for rows This method would use sql.DB.Query method to retrive data

func ReleaseDb

func ReleaseDb(c *check.C)

Types

type RpcTestEnv

type RpcTestEnv struct {
	Port      int
	RpcClient *rpc.Client
	// contains filtered or unexported fields
}

func (*RpcTestEnv) ListenAndExecute

func (rpcTestEnvInstance *RpcTestEnv) ListenAndExecute(
	rcvr interface{}, rpcCallback func(*RpcTestEnv),
)