test

package
v0.18.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 9, 2024 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewCatalog added in v0.11.0

func NewCatalog(provider sql.DatabaseProvider) sql.Catalog

NewCatalog returns a new empty Catalog with the given provider

Types

type Catalog added in v0.11.0

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

func (*Catalog) AllDatabases added in v0.11.0

func (c *Catalog) AllDatabases(ctx *sql.Context) []sql.Database

AllDatabases returns all sliceDBProvider in the catalog.

func (*Catalog) CreateDatabase added in v0.11.0

func (c *Catalog) CreateDatabase(ctx *sql.Context, dbName string, collation sql.CollationID) error

CreateDatabase creates a new Database and adds it to the catalog.

func (*Catalog) DataLength added in v0.18.0

func (c *Catalog) DataLength(ctx *sql.Context, db, table string) (uint64, error)

func (*Catalog) Database added in v0.11.0

func (c *Catalog) Database(ctx *sql.Context, db string) (sql.Database, error)

Database returns the database with the given name.

func (*Catalog) DatabaseTable added in v0.16.0

func (c *Catalog) DatabaseTable(ctx *sql.Context, db sql.Database, tableName string) (sql.Table, sql.Database, error)

func (*Catalog) DatabaseTableAsOf added in v0.16.0

func (c *Catalog) DatabaseTableAsOf(ctx *sql.Context, db sql.Database, tableName string, asOf interface{}) (sql.Table, sql.Database, error)

func (*Catalog) DropDbStats added in v0.18.0

func (c *Catalog) DropDbStats(ctx *sql.Context, db string, flush bool) error

func (*Catalog) DropStats added in v0.18.0

func (c *Catalog) DropStats(ctx *sql.Context, qual sql.StatQualifier, cols []string) error

func (*Catalog) ExternalStoredProcedure added in v0.16.0

func (c *Catalog) ExternalStoredProcedure(ctx *sql.Context, name string, numOfParams int) (*sql.ExternalStoredProcedureDetails, error)

func (*Catalog) ExternalStoredProcedures added in v0.16.0

func (c *Catalog) ExternalStoredProcedures(ctx *sql.Context, name string) ([]sql.ExternalStoredProcedureDetails, error)

func (*Catalog) Function added in v0.11.0

func (c *Catalog) Function(ctx *sql.Context, name string) (sql.Function, error)

func (*Catalog) GetStats added in v0.18.0

func (c *Catalog) GetStats(ctx *sql.Context, qual sql.StatQualifier, cols []string) (sql.Statistic, bool)

func (*Catalog) GetTableStats added in v0.18.0

func (c *Catalog) GetTableStats(ctx *sql.Context, db, table string) ([]sql.Statistic, error)

func (*Catalog) HasDatabase added in v0.16.0

func (c *Catalog) HasDatabase(ctx *sql.Context, db string) bool

func (*Catalog) LockTable added in v0.11.0

func (c *Catalog) LockTable(ctx *sql.Context, table string)

func (*Catalog) RefreshTableStats added in v0.18.0

func (c *Catalog) RefreshTableStats(ctx *sql.Context, table sql.Table, db string) error

func (*Catalog) RegisterFunction added in v0.11.0

func (c *Catalog) RegisterFunction(ctx *sql.Context, fns ...sql.Function)

func (*Catalog) RemoveDatabase added in v0.11.0

func (c *Catalog) RemoveDatabase(ctx *sql.Context, dbName string) error

RemoveDatabase removes a database from the catalog.

func (*Catalog) RowCount added in v0.18.0

func (c *Catalog) RowCount(ctx *sql.Context, db, table string) (uint64, error)

func (*Catalog) SetStats added in v0.18.0

func (c *Catalog) SetStats(ctx *sql.Context, stats sql.Statistic) error

func (*Catalog) Table added in v0.11.0

func (c *Catalog) Table(ctx *sql.Context, dbName, tableName string) (sql.Table, sql.Database, error)

Table returns the table in the given database with the given name.

func (*Catalog) TableAsOf added in v0.11.0

func (c *Catalog) TableAsOf(ctx *sql.Context, dbName, tableName string, asOf interface{}) (sql.Table, sql.Database, error)

func (*Catalog) TableFunction added in v0.16.0

func (c *Catalog) TableFunction(ctx *sql.Context, name string) (sql.TableFunction, error)

func (*Catalog) UnlockTables added in v0.11.0

func (c *Catalog) UnlockTables(ctx *sql.Context, id uint32) error

func (*Catalog) WithTableFunctions added in v0.18.0

func (c *Catalog) WithTableFunctions(fns ...sql.TableFunction) (sql.TableFunctionProvider, error)

type MemTracer

type MemTracer struct {
	Spans []string
	sync.Mutex
}

MemTracer implements a simple tracer in memory for testing.

func (*MemTracer) Start added in v0.14.0

func (t *MemTracer) Start(ctx context.Context, operationName string, opts ...trace.SpanStartOption) (context.Context, trace.Span)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL