lines

Documentation

Index

• func Creator(ctx context.Context) (physical.Database, error)
• type Database
  • func (d *Database) GetTable(ctx context.Context, name string, options map[string]string) (physical.DatasourceImplementation, physical.Schema, error)
  • func (d *Database) ListTables(ctx context.Context) ([]string, error)
• type DatasourceExecuting
  • func (d *DatasourceExecuting) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error

Functions

func Creator

func Creator(ctx context.Context) (physical.Database, error)

Types

type Database

type Database struct {
}

func (*Database) GetTable

func (d *Database) GetTable(ctx context.Context, name string, options map[string]string) (physical.DatasourceImplementation, physical.Schema, error)

func (*Database) ListTables

func (d *Database) ListTables(ctx context.Context) ([]string, error)

type DatasourceExecuting

type DatasourceExecuting struct {
	// contains filtered or unexported fields
}

func (*DatasourceExecuting) Run

func (d *DatasourceExecuting) Run(ctx ExecutionContext, produce ProduceFn, metaSend MetaSendFn) error