Documentation ¶ Index ¶ type DB type Runner func NewRunner(db DB, schemas map[string]*schemapb.Schema) *Runner func (r *Runner) RunCmd(ctx context.Context, c *datadriven.TestData) string type Table Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ This section is empty. Types ¶ type DB ¶ type DB interface { CreateTable(name string, schema *schemapb.Schema) (Table, error) // ScanTable returns a query.Builder prepared to scan the given table. ScanTable(name string) query.Builder } type Runner ¶ type Runner struct { // contains filtered or unexported fields } func NewRunner ¶ func NewRunner(db DB, schemas map[string]*schemapb.Schema) *Runner func (*Runner) RunCmd ¶ func (r *Runner) RunCmd(ctx context.Context, c *datadriven.TestData) string RunCmd parses and runs datadriven command with the associated arguments, and returns the result. type Table ¶ type Table interface { Schema() *dynparquet.Schema InsertRecord(context.Context, arrow.Record) (uint64, error) } Source Files ¶ View all Source files runner.go Click to show internal directories. Click to hide internal directories.