test

Documentation

Index

• func NewCatalog(provider sql.DatabaseProvider) sql.Catalog
• type Catalog
  • func (c *Catalog) AllDatabases() []sql.Database
  • func (c *Catalog) CreateDatabase(ctx *sql.Context, dbName string) error
  • func (c *Catalog) Database(db string) (sql.Database, error)
  • 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
  • func (c *Catalog) Table(ctx *sql.Context, dbName, tableName string) (sql.Table, sql.Database, error)
  • 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
  • func (t *MemTracer) Extract(format interface{}, carrier interface{}) (opentracing.SpanContext, error)
  • func (t *MemTracer) Inject(sm opentracing.SpanContext, format interface{}, carrier interface{}) error
  • func (t *MemTracer) StartSpan(operationName string, opts ...opentracing.StartSpanOption) opentracing.Span

Functions

func NewCatalog

func NewCatalog(provider sql.DatabaseProvider) sql.Catalog

NewCatalog returns a new empty Catalog with the given provider

Types

type Catalog

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

func (*Catalog) AllDatabases

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

AllDatabases returns all sliceDBProvider in the catalog.

func (*Catalog) CreateDatabase

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

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

func (*Catalog) Database

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

Database returns the database with the given name.

func (*Catalog) Function

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

func (*Catalog) HasDB

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

func (*Catalog) LockTable

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

func (*Catalog) RegisterFunction

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

func (*Catalog) RemoveDatabase

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

RemoveDatabase removes a database from the catalog.

func (*Catalog) Table

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

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

func (*Catalog) UnlockTables

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

type MemTracer

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

MemTracer implements a simple tracer in memory for testing.

func (*MemTracer) Extract

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

Extract implements opentracing.Tracer interface.

func (*MemTracer) Inject

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

Inject implements opentracing.Tracer interface.

func (*MemTracer) StartSpan

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

StartSpan implements opentracing.Tracer interface.