engine

Oct 10, 2023

Changes in this version

+ var VinceFuncs = []sql.Function

Oct 3, 2023

Changes in this version

type IndexedTable

+ func (IndexedTable) Name() string

+ func (IndexedTable) String() string

+ func (t IndexedTable) Collation() sql.CollationID

+ func (t IndexedTable) GetIndexes(ctx *sql.Context) ([]sql.Index, error)

+ func (t IndexedTable) IndexedAccess(i sql.IndexLookup) sql.IndexedTable

+ func (t IndexedTable) Partitions(ctx *sql.Context) (sql.PartitionIter, error)

+ func (t IndexedTable) Projections() (o []string)

+ func (t IndexedTable) Schema() sql.Schema

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

type Provider

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

Sep 29, 2023

Changes in this version

+ const SitesTableName

+ type Domains []string

+ func (h *Domains) Pop() any

+ func (h *Domains) Push(x any)

+ func (h Domains) Len() int

+ func (h Domains) Less(i, j int) bool

+ func (h Domains) Swap(i, j int)

+ type FilterContext struct

+ Domains Domains

+ Index []IndexFilter

+ Values []ValueFilter

type Partition

+ Filters FilterContext

type Provider

+ func NewProvider() *Provider

+ func (p *Provider) ExternalStoredProcedure(_ *sql.Context, name string, numOfParams int) (*sql.ExternalStoredProcedureDetails, error)

+ func (p *Provider) ExternalStoredProcedures(_ *sql.Context, name string) ([]sql.ExternalStoredProcedureDetails, error)

type Server

+ Listener *mysql.Listener

+ func (s *Server) Shutdown(_ context.Context) error

+ type SitesTable struct

+ func (*SitesTable) Name() string

+ func (*SitesTable) String() string

+ func (t *SitesTable) Collation() sql.CollationID

+ func (t *SitesTable) GetIndexes(ctx *sql.Context) ([]sql.Index, error)

+ func (t *SitesTable) IndexedAccess(i sql.IndexLookup) sql.IndexedTable

+ func (t *SitesTable) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error)

+ func (t *SitesTable) Partitions(ctx *sql.Context) (sql.PartitionIter, error)

+ func (t *SitesTable) Projections() (o []string)

+ func (t *SitesTable) Schema() sql.Schema

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

Sep 24, 2023

Changes in this version

+ var ErrSkipBlock = errors.New("skip block")

+ type FilterIndexFunc func(ctx context.Context, idx *blocksv1.ColumnIndex) (*RowGroups, error)

type IndexMatchFuncs

+ Value any

type Partition

+ Expr sql.Expression

+ Pages []*bitset.BitSet

+ Range bool

+ Values []ValueFilter

+ func (p *Partition) Valid() error

type RowGroups

+ func NewRowGroups() *RowGroups

+ func (g *RowGroups) Empty() bool

type ValueMatchFuncs

+ Value any

Sep 21, 2023

Changes in this version

type DB

+ func NewDB(db db.Provider, rd b3.Reader, e func() *sqle.Engine) *DB

+ func (db *DB) AllViews(ctx *sql.Context) ([]sql.ViewDefinition, error)

+ func (db *DB) CreateView(ctx *sql.Context, name string, selectStatement, createViewStmt string) error

+ func (db *DB) DropView(ctx *sql.Context, name string) error

+ func (db *DB) GetViewDefinition(ctx *sql.Context, viewName string) (sql.ViewDefinition, bool, error)

+ type FieldHint struct

+ Field string

+ Op Op

+ Value any

+ type Filters struct

+ Index []IndexFilter

+ Value []ValueFilter

type IndexFilter

+ Column func() v1.Column

+ type IndexFilterResult struct

+ Pages []*bitset.BitSet

+ RowGroups []uint

+ type IndexHint struct

+ Fields []*FieldHint

+ func (v *IndexHint) Visit(node sql.Node, expr sql.Expression) sql.NodeVisitor

type Partition

+ Hints *IndexHint

+ type PlaintextAuthPluginFunc func(db *mysql_db.MySQLDb, user string, userEntry *mysql_db.User, pass string) (bool, error)

+ func (f PlaintextAuthPluginFunc) Authenticate(db *mysql_db.MySQLDb, user string, userEntry *mysql_db.User, pass string) (bool, error)

+ type RowGroups struct

+ func (g *RowGroups) SelectGroup(groups *bitset.BitSet, f func(uint, *bitset.BitSet))

+ func (g *RowGroups) Set(index uint, pages []uint)

+ type Value interface

type ValueFilter

+ Column func() v1.Column

Sep 17, 2023

Changes in this version

+ var ErrNoFilter = errors.New("no filters")

+ func BuildIndexFilter(ctx context.Context, f []IndexFilter, source func(v1.Column) []int) ([]int, error)

+ func BuildValueFilter(ctx context.Context, f []ValueFilter, source func(v1.Column) arrow.Array) (arrow.Array, error)

+ type Filter interface

+ Column func() v1.Column

+ type FilterIndex func(ctx context.Context, rowGroups []int) ([]int, error)

+ type FilterValue func(ctx context.Context, b *array.BooleanBuilder, value arrow.Array) (arrow.Array, error)

+ type IndexFilter interface

+ FilterIndex func(ctx context.Context, rowGroups []int) ([]int, error)

+ type IndexMatchFuncs struct

+ Col v1.Column

+ FilterIndexFunc func(ctx context.Context, rowGroups []int) ([]int, error)

+ func (i *IndexMatchFuncs) Column() v1.Column

+ func (i *IndexMatchFuncs) FilterIndex(ctx context.Context, rowGroups []int) ([]int, error)

+ type Op uint

+ const Eq

+ const Gt

+ const GtEg

+ const Lt

+ const LtEq

+ const Ne

+ const ReEq

+ const ReNe

+ func (o Op) String() string

type Partition

+ Info blocksv1.BlockInfo

+ type ValueFilter interface

+ FilterValue func(ctx context.Context, value arrow.Array) (arrow.Array, error)

+ func Match(col v1.Column, matchValue any, op Op) ValueFilter

+ type ValueMatchFuncs struct

+ Col v1.Column

+ FilterValueFunc func(ctx context.Context, value arrow.Array) (arrow.Array, error)

+ func (i *ValueMatchFuncs) Column() v1.Column

+ func (i *ValueMatchFuncs) FilterValue(ctx context.Context, value arrow.Array) (arrow.Array, error)

Sep 14, 2023

Changes in this version

+ const TimeBucketName

+ func NewTimeBucket(args ...sql.Expression) (sql.Expression, error)

type Partition

+ BlockID []byte

+ BlockIndex *blocksv1.BlockIndex

+ func (p *Partition) Groups() []int

+ func (p *Partition) Index() *blocksv1.BlockIndex

type Provider

+ func (p *Provider) Function(ctx *sql.Context, name string) (sql.Function, error)

+ type TimeBucket struct

+ func (t *TimeBucket) Children() []sql.Expression

+ func (t *TimeBucket) Description() string

+ func (t *TimeBucket) Eval(ctx *sql.Context, row sql.Row) (interface{}, error)

+ func (t *TimeBucket) FunctionName() string

+ func (t *TimeBucket) IsNullable() bool

+ func (t *TimeBucket) Resolved() bool

+ func (t *TimeBucket) String() string

+ func (t *TimeBucket) Type() sql.Type

+ func (t *TimeBucket) WithChildren(children ...sql.Expression) (sql.Expression, error)

Sep 13, 2023

Changes in this version

type Context

+ Metrics *metrics.Metrics

Sep 11, 2023

Changes in this version

+ var ErrConnectionWasClosed = errors.NewKind("connection was closed")

+ var ErrRowTimeout = errors.NewKind("row read wait bigger than connection timeout")

+ var Indexed = func() (o []storev1.Column, idx map[string]bool) { ... }()

+ type Index struct

+ DB string

+ Exprs []sql.Expression

+ Name string

+ PrefixLens []uint16

+ TableName string

+ Tbl *Table

+ func (idx *Index) CanSupport(...sql.Range) bool

+ func (idx *Index) ColumnExpressionTypes() []sql.ColumnExpressionType

+ func (idx *Index) ColumnExpressions() []sql.Expression

+ func (idx *Index) Comment() string

+ func (idx *Index) Database() string

+ func (idx *Index) Expressions() []string

+ func (idx *Index) ExtendedColumnExpressionTypes() []sql.ColumnExpressionType

+ func (idx *Index) ExtendedExpressions() []string

+ func (idx *Index) ID() string

+ func (idx *Index) IndexType() string

+ func (idx *Index) IsFullText() bool

+ func (idx *Index) IsGenerated() bool

+ func (idx *Index) IsSpatial() bool

+ func (idx *Index) IsUnique() bool

+ func (idx *Index) PrefixLengths() []uint16

+ func (idx *Index) Table() string

+ type IndexedTable struct

+ Lookup sql.IndexLookup

+ func (t *IndexedTable) LookupPartitions(ctx *sql.Context, lookup sql.IndexLookup) (sql.PartitionIter, error)

+ func (t *IndexedTable) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error)

+ type MultiStmtMode int

+ const MultiStmtModeOff

+ const MultiStmtModeOn

type Table

+ func (t *Table) GetIndexes(ctx *sql.Context) ([]sql.Index, error)

+ func (t *Table) IndexedAccess(i sql.IndexLookup) sql.IndexedTable

Sep 10, 2023

Changes in this version

type Auth

+ PrivateKey ed25519.PrivateKey

Sep 4, 2023

Changes in this version

type Context

+ Reader b3.Reader

Aug 26, 2023

Changes in this version

+ var Columns = func() (o []v1.Column) { ... }()

+ type Context struct

+ DB *badger.DB

+ PrepareTableForQuery func(string)

+ ReadBlock func(ulid.ULID, func(parquet.ReaderAtSeeker))

type Partition

+ Block ulid.ULID

+ RowGroups []int

Aug 25, 2023

Changes in this version

+ type DB struct

+ func (DB) IsReadOnly() bool

+ func (DB) Name() string

+ 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)

+ type Partition struct

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

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

Aug 19, 2023

Changes in this version

type Engine

+ func (e *Engine) Add(name string)

+ func (e *Engine) Remove(name string)

Aug 18, 2023

Changes in this version

+ type Server struct

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

+ func (s *Server) Close() error

+ func (s *Server) Start() error

Aug 17, 2023

Changes in this version

+ var QueryCounter = discard.NewCounter()

+ var QueryErrorCounter = discard.NewCounter()

+ var QueryHistogram = discard.NewHistogram()

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

+ func Table(name string) *core.Table

+ type Auth struct

+ DB *badger.DB

+ 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 Engine struct

+ DB *RadOnly

+ func Get(ctx context.Context) *Engine

+ func New() *Engine

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

+ type Handler struct

+ 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 Provider struct

+ 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 RadOnly struct

+ func Database(name string) *RadOnly

+ func (r RadOnly) IsReadOnly() bool

+ type StaticUserData string

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