test

package

v0.1.16 Latest Latest Go to latest Published: Sep 30, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

func NewCatalog(provider sql.DatabaseProvider) sql.Catalog

NewCatalog returns a new empty Catalog with the given provider

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

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

AllDatabases returns all sliceDBProvider in the catalog.

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

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

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

Database returns the database with the given name.

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

func (c *Catalog) HasDB(db string) bool

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

func (c *Catalog) RegisterFunction(fns ...sql.Function)

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

RemoveDatabase removes a database from the catalog.

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 (c *Catalog) TableAsOf(ctx *sql.Context, dbName, tableName string, asOf interface{}) (sql.Table, sql.Database, error)

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

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

MemTracer implements a simple tracer in memory for testing.

func (t *MemTracer) Extract(format interface{}, carrier interface{}) (opentracing.SpanContext, error)

Extract implements opentracing.Tracer interface.

func (t *MemTracer) Inject(sm opentracing.SpanContext, format interface{}, carrier interface{}) error

Inject implements opentracing.Tracer interface.

func (t *MemTracer) StartSpan(operationName string, opts ...opentracing.StartSpanOption) opentracing.Span

StartSpan implements opentracing.Tracer interface.