engine

Documentation

Index

• Variables
• func Schema(table string) (o sql.Schema)
• type Auth
  • func (a Auth) AuthMethod(user, addr string) (string, error)
  • func (a Auth) Negotiate(c *mysql.Conn, user string, remoteAddr net.Addr) (mysql.Getter, error)
  • func (a Auth) Salt() ([]byte, error)
  • func (a Auth) ValidateHash(salt []byte, user string, authResponse []byte, remoteAddr net.Addr) (mysql.Getter, error)
• type DB
  • func (db *DB) GetTableInsensitive(ctx *sql.Context, tblName string) (table sql.Table, ok bool, err error)
  • func (db *DB) GetTableNames(ctx *sql.Context) (names []string, err error)
  • func (DB) IsReadOnly() bool
  • func (DB) Name() string
• type Engine
  • func Get(ctx context.Context) *Engine
  • func New(db *badger.DB) *Engine
  • func Open(ctx context.Context) (context.Context, *Engine)
• type Handler
  • func (h *Handler) ComInitDB(c *mysql.Conn, schemaName string) error
  • func (h *Handler) ComMultiQuery(c *mysql.Conn, query string, callback func(*sqltypes.Result, bool) error) (string, error)
  • func (h *Handler) ComPrepare(c *mysql.Conn, query string) ([]*query.Field, error)
  • func (h *Handler) ComQuery(c *mysql.Conn, query string, callback func(*sqltypes.Result, bool) error) error
  • func (h *Handler) ComResetConnection(c *mysql.Conn)
  • func (h *Handler) ComStmtExecute(c *mysql.Conn, prepare *mysql.PrepareData, ...) error
  • func (h *Handler) ConnectionClosed(c *mysql.Conn)
  • func (h *Handler) NewConnection(c *mysql.Conn)
  • func (h *Handler) ParserOptionsForConnection(c *mysql.Conn) (sqlparser.ParserOptions, error)
  • func (h *Handler) WarningCount(c *mysql.Conn) uint16
• type Partition
  • func (p *Partition) Key() []byte
• type Provider
  • func (p *Provider) AllDatabases(_ *sql.Context) []sql.Database
  • func (p *Provider) Database(_ *sql.Context, name string) (sql.Database, error)
  • func (p *Provider) HasDatabase(_ *sql.Context, name string) bool
• type Server
  • func Listen(ctx context.Context) (*Server, error)
  • func (s *Server) Close() error
  • func (s *Server) Start() error
• type StaticUserData
  • func (sud StaticUserData) Get() *querypb.VTGateCallerID
• type Table
  • func (t *Table) Collation() sql.CollationID
  • func (t *Table) Name() string
  • func (t *Table) PartitionRows(*sql.Context, sql.Partition) (sql.RowIter, error)
  • func (t *Table) Partitions(*sql.Context) (sql.PartitionIter, error)
  • func (t *Table) Projections() []string
  • func (t *Table) Schema() sql.Schema
  • func (t *Table) String() string
  • func (t *Table) WithProjections(colNames []string) sql.Table

Variables

var (
	// QueryCounter describes a metric that accumulates number of queries monotonically.
	QueryCounter = discard.NewCounter()

	// QueryErrorCounter describes a metric that accumulates number of failed queries monotonically.
	QueryErrorCounter = discard.NewCounter()

	// QueryHistogram describes a queries latency.
	QueryHistogram = discard.NewHistogram()
)

Functions

func Schema

func Schema(table string) (o sql.Schema)

Creates a schema for a site table. Each site is treated as an individual read only table.

Physically timestamps are stored as int64, but we expose this a DateTime.

Types

type Auth

type Auth struct {
	DB *badger.DB
}

func (Auth) AuthMethod

func (a Auth) AuthMethod(user, addr string) (string, error)

func (Auth) Negotiate

func (a Auth) Negotiate(c *mysql.Conn, user string, remoteAddr net.Addr) (mysql.Getter, error)

func (Auth) Salt

func (a Auth) Salt() ([]byte, error)

func (Auth) ValidateHash

func (a Auth) ValidateHash(salt []byte, user string, authResponse []byte, remoteAddr net.Addr) (mysql.Getter, error)

type DB

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

func (*DB) GetTableInsensitive

func (db *DB) GetTableInsensitive(ctx *sql.Context, tblName string) (table sql.Table, ok bool, err error)

func (*DB) GetTableNames

func (db *DB) GetTableNames(ctx *sql.Context) (names []string, err error)

func (DB) IsReadOnly

func (DB) IsReadOnly() bool

func (DB) Name

func (DB) Name() string

type Engine

type Engine struct {
	*sqle.Engine
}

func Get

func Get(ctx context.Context) *Engine

func New

func New(db *badger.DB) *Engine

func Open

func Open(ctx context.Context) (context.Context, *Engine)

type Handler

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

Handler is a connection handler for a SQLe engine, implementing the Vitess mysql.Handler interface.

func (*Handler) ComInitDB

func (h *Handler) ComInitDB(c *mysql.Conn, schemaName string) error

func (*Handler) ComMultiQuery

func (h *Handler) ComMultiQuery(
	c *mysql.Conn,
	query string,
	callback func(*sqltypes.Result, bool) error,
) (string, error)

func (*Handler) ComPrepare

func (h *Handler) ComPrepare(c *mysql.Conn, query string) ([]*query.Field, error)

ComPrepare parses, partially analyzes, and caches a prepared statement's plan with the given [c.ConnectionID].

func (*Handler) ComQuery

func (h *Handler) ComQuery(
	c *mysql.Conn,
	query string,
	callback func(*sqltypes.Result, bool) error,
) error

ComQuery executes a SQL query on the SQLe engine.

func (*Handler) ComResetConnection

func (h *Handler) ComResetConnection(c *mysql.Conn)

func (*Handler) ComStmtExecute

func (h *Handler) ComStmtExecute(c *mysql.Conn, prepare *mysql.PrepareData, callback func(*sqltypes.Result) error) error

func (*Handler) ConnectionClosed

func (h *Handler) ConnectionClosed(c *mysql.Conn)

ConnectionClosed reports that a connection has been closed.

func (*Handler) NewConnection

func (h *Handler) NewConnection(c *mysql.Conn)

NewConnection reports that a new connection has been established.

func (*Handler) ParserOptionsForConnection

func (h *Handler) ParserOptionsForConnection(c *mysql.Conn) (sqlparser.ParserOptions, error)

func (*Handler) WarningCount

func (h *Handler) WarningCount(c *mysql.Conn) uint16

WarningCount is called at the end of each query to obtain the value to be returned to the client in the EOF packet. Note that this will be called either in the context of the ComQuery callback if the result does not contain any fields, or after the last ComQuery call completes.

type Partition

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

func (*Partition) Key

func (p *Partition) Key() []byte

type Provider

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

func (*Provider) AllDatabases

func (p *Provider) AllDatabases(_ *sql.Context) []sql.Database

func (*Provider) Database

func (p *Provider) Database(_ *sql.Context, name string) (sql.Database, error)

func (*Provider) HasDatabase

func (p *Provider) HasDatabase(_ *sql.Context, name string) bool

type Server

type Server struct {
	*mysql.Listener
}

func Listen

func Listen(ctx context.Context) (*Server, error)

func (*Server) Close

func (s *Server) Close() error

func (*Server) Start

func (s *Server) Start() error

type StaticUserData

type StaticUserData string

func (StaticUserData) Get

func (sud StaticUserData) Get() *querypb.VTGateCallerID

Get returns the wrapped username and groups

type Table

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

func (*Table) Collation

func (t *Table) Collation() sql.CollationID

func (*Table) Name

func (t *Table) Name() string

func (*Table) PartitionRows

func (t *Table) PartitionRows(*sql.Context, sql.Partition) (sql.RowIter, error)

func (*Table) Partitions

func (t *Table) Partitions(*sql.Context) (sql.PartitionIter, error)

func (*Table) Projections

func (t *Table) Projections() []string

func (*Table) Schema

func (t *Table) Schema() sql.Schema

func (*Table) String

func (t *Table) String() string

func (*Table) WithProjections

func (t *Table) WithProjections(colNames []string) sql.Table