infra

Documentation

Index

• Variables
• func Register(name string, driver Driver)
• type Column
• type Connection
• type Driver
• type InformationSchema
• type Statement
• type Table

Variables

var Drivers = make(map[string]Driver)

Drivers is a registry of drivers

var ErrClosed = errors.New("infra: connection is closed")

ErrClosed should be returned by Execute if the connection is closed

var ErrNotFound = errors.New("infra: not found")

ErrNotFound should be returned by InformationSchema.Lookup if no resource was found

Functions

func Register

func Register(name string, driver Driver)

Register registers a new driver

Types

type Column

type Column struct {
	Name     string
	Type     string
	Nullable bool
}

type Connection

type Connection interface {
	Execute(ctx context.Context, stmt *Statement) (*sqlx.Rows, error)
	Close() error
	InformationSchema() InformationSchema
}

type Driver

type Driver interface {
	Open(dsn string) (Connection, error)
}

type InformationSchema

type InformationSchema interface {
	All(ctx context.Context) ([]*Table, error)
	Lookup(ctx context.Context, name string) (*Table, error)
}

type Statement

type Statement struct {
	Query    string
	Args     []any
	DryRun   bool
	Priority int
}

type Table

type Table struct {
	Database string
	Schema   string
	Name     string
	Type     string
	Columns  []Column
}