tests

func CompareTables ¶

func CompareTables(t *testing.T, configs []TableCompareConfig)

func Consumed ¶

func Consumed(t *testing.T, table optimus.Table)

Consumed tests that a table has been completely consumed: that is to say, there are no more remaining Rows to read.

func GetRows ¶

func GetRows(table optimus.Table) []optimus.Row

func HasRows ¶

func HasRows(t *testing.T, table optimus.Table, expected int) []optimus.Row

HasRows tests that a table has the correct number of rows, and returns all the rows.

func Stop ¶

func Stop(t *testing.T, table optimus.Table)

Stop tests that a Table correctly implements Stop. It assumes that it is invoked with a newly-created Table.