Versions in this module Expand all Collapse all v0 v0.6.1 Jun 12, 2020 Changes in this version + const IndexDriverId + type AscendIndexLookup struct + Gte []interface{} + Index ExpressionsIndex + Lt []interface{} + func (*AscendIndexLookup) Difference(...sql.IndexLookup) sql.IndexLookup + func (l *AscendIndexLookup) EvalExpression() sql.Expression + func (l *AscendIndexLookup) ID() string + func (l *AscendIndexLookup) Indexes() []string + func (l *AscendIndexLookup) Intersection(lookups ...sql.IndexLookup) sql.IndexLookup + func (l *AscendIndexLookup) IsMergeable(lookup sql.IndexLookup) bool + func (l *AscendIndexLookup) String() string + func (l *AscendIndexLookup) Union(lookups ...sql.IndexLookup) sql.IndexLookup + func (l *AscendIndexLookup) Values(p sql.Partition) (sql.IndexValueIter, error) + type Database struct + func NewDatabase(name string) *Database + func (d *Database) AddTable(name string, t sql.Table) + func (d *Database) CreateTable(ctx *sql.Context, name string, schema sql.Schema) error + func (d *Database) DropTable(ctx *sql.Context, name string) error + func (d *Database) GetTableInsensitive(ctx *sql.Context, tblName string) (sql.Table, bool, error) + func (d *Database) GetTableNames(ctx *sql.Context) ([]string, error) + func (d *Database) Name() string + func (d *Database) RenameTable(ctx *sql.Context, oldName, newName string) error + func (d *Database) Tables() map[string]sql.Table + type DescendIndexLookup struct + Gt []interface{} + Index ExpressionsIndex + Lte []interface{} + func (*DescendIndexLookup) Difference(...sql.IndexLookup) sql.IndexLookup + func (l *DescendIndexLookup) EvalExpression() sql.Expression + func (l *DescendIndexLookup) ID() string + func (l *DescendIndexLookup) Indexes() []string + func (l *DescendIndexLookup) Intersection(lookups ...sql.IndexLookup) sql.IndexLookup + func (l *DescendIndexLookup) IsMergeable(lookup sql.IndexLookup) bool + func (l *DescendIndexLookup) String() string + func (l *DescendIndexLookup) Union(lookups ...sql.IndexLookup) sql.IndexLookup + func (l *DescendIndexLookup) Values(p sql.Partition) (sql.IndexValueIter, error) + type ExpressionsIndex interface + ColumnExpressions func() []sql.Expression + MemTable func() *Table + type HistoryDatabase struct + Revisions map[string]map[interface{}]sql.Table + func NewHistoryDatabase(name string) *HistoryDatabase + func (db *HistoryDatabase) AddTableAsOf(name string, t sql.Table, asOf interface{}) + func (db *HistoryDatabase) GetTableInsensitiveAsOf(ctx *sql.Context, tblName string, time interface{}) (sql.Table, bool, error) + func (db *HistoryDatabase) GetTableNamesAsOf(ctx *sql.Context, time interface{}) ([]string, error) + type MergeableIndex struct + DB string + DriverName string + Exprs []sql.Expression + TableName string + Tbl *Table + func (i *MergeableIndex) AscendGreaterOrEqual(keys ...interface{}) (sql.IndexLookup, error) + func (i *MergeableIndex) AscendLessThan(keys ...interface{}) (sql.IndexLookup, error) + func (i *MergeableIndex) AscendRange(greaterOrEqual, lessThan []interface{}) (sql.IndexLookup, error) + func (i *MergeableIndex) ColumnExpressions() []sql.Expression + func (i *MergeableIndex) Database() string + func (i *MergeableIndex) DescendGreater(keys ...interface{}) (sql.IndexLookup, error) + func (i *MergeableIndex) DescendLessOrEqual(keys ...interface{}) (sql.IndexLookup, error) + func (i *MergeableIndex) DescendRange(lessOrEqual, greaterThan []interface{}) (sql.IndexLookup, error) + func (i *MergeableIndex) Driver() string + func (i *MergeableIndex) Expressions() []string + func (i *MergeableIndex) Get(key ...interface{}) (sql.IndexLookup, error) + func (i *MergeableIndex) Has(sql.Partition, ...interface{}) (bool, error) + func (i *MergeableIndex) ID() string + func (i *MergeableIndex) MemTable() *Table + func (i *MergeableIndex) Not(keys ...interface{}) (sql.IndexLookup, error) + func (i *MergeableIndex) Table() string + type MergeableIndexLookup struct + Index ExpressionsIndex + Key []interface{} + func (i *MergeableIndexLookup) Difference(...sql.IndexLookup) sql.IndexLookup + func (i *MergeableIndexLookup) EvalExpression() sql.Expression + func (i *MergeableIndexLookup) ID() string + func (i *MergeableIndexLookup) Indexes() []string + func (i *MergeableIndexLookup) Intersection(lookups ...sql.IndexLookup) sql.IndexLookup + func (i *MergeableIndexLookup) IsMergeable(lookup sql.IndexLookup) bool + func (i *MergeableIndexLookup) String() string + func (i *MergeableIndexLookup) Union(lookups ...sql.IndexLookup) sql.IndexLookup + func (i *MergeableIndexLookup) Values(p sql.Partition) (sql.IndexValueIter, error) + type MergeableLookup interface + ID func() string + type MergedIndexLookup struct + Index ExpressionsIndex + Intersections []sql.IndexLookup + Unions []sql.IndexLookup + func (m *MergedIndexLookup) Difference(...sql.IndexLookup) sql.IndexLookup + func (m *MergedIndexLookup) EvalExpression() sql.Expression + func (m *MergedIndexLookup) ID() string + func (m *MergedIndexLookup) Indexes() []string + func (m *MergedIndexLookup) Intersection(lookups ...sql.IndexLookup) sql.IndexLookup + func (m *MergedIndexLookup) IsMergeable(lookup sql.IndexLookup) bool + func (m *MergedIndexLookup) String() string + func (m *MergedIndexLookup) Union(lookups ...sql.IndexLookup) sql.IndexLookup + func (m *MergedIndexLookup) Values(p sql.Partition) (sql.IndexValueIter, error) + type NegateIndexLookup struct + Index ExpressionsIndex + Lookup MergeableLookup + func (*NegateIndexLookup) Difference(...sql.IndexLookup) sql.IndexLookup + func (*NegateIndexLookup) IsMergeable(lookup sql.IndexLookup) bool + func (l *NegateIndexLookup) EvalExpression() sql.Expression + func (l *NegateIndexLookup) ID() string + func (l *NegateIndexLookup) Indexes() []string + func (l *NegateIndexLookup) Intersection(indexes ...sql.IndexLookup) sql.IndexLookup + func (l *NegateIndexLookup) String() string + func (l *NegateIndexLookup) Union(lookups ...sql.IndexLookup) sql.IndexLookup + func (l *NegateIndexLookup) Values(p sql.Partition) (sql.IndexValueIter, error) + type Table struct + func NewPartitionedTable(name string, schema sql.Schema, numPartitions int) *Table + func NewTable(name string, schema sql.Schema) *Table + func (t *Table) AddColumn(ctx *sql.Context, column *sql.Column, order *sql.ColumnOrder) error + func (t *Table) CreateIndex(ctx *sql.Context, indexName string, using sql.IndexUsing, ...) error + func (t *Table) Deleter(*sql.Context) sql.RowDeleter + func (t *Table) DropColumn(ctx *sql.Context, columnName string) error + func (t *Table) DropIndex(ctx *sql.Context, indexName string) error + func (t *Table) EnablePrimaryKeyIndexes() + func (t *Table) Filters() []sql.Expression + func (t *Table) GetIndexes(ctx *sql.Context) ([]sql.Index, error) + func (t *Table) HandledFilters(filters []sql.Expression) []sql.Expression + func (t *Table) IndexKeyValues(ctx *sql.Context, colNames []string) (sql.PartitionIndexKeyValueIter, error) + func (t *Table) Insert(ctx *sql.Context, row sql.Row) error + func (t *Table) Inserter(*sql.Context) sql.RowInserter + func (t *Table) ModifyColumn(ctx *sql.Context, columnName string, column *sql.Column, ...) error + func (t *Table) Name() string + func (t *Table) PartitionCount(ctx *sql.Context) (int64, error) + func (t *Table) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error) + func (t *Table) Partitions(ctx *sql.Context) (sql.PartitionIter, error) + func (t *Table) Projection() []string + func (t *Table) RenameIndex(ctx *sql.Context, fromIndexName string, toIndexName string) error + func (t *Table) Replacer(*sql.Context) sql.RowReplacer + func (t *Table) Schema() sql.Schema + func (t *Table) String() string + func (t *Table) Updater(*sql.Context) sql.RowUpdater + func (t *Table) WithFilters(filters []sql.Expression) sql.Table + func (t *Table) WithIndexLookup(lookup sql.IndexLookup) sql.Table + func (t *Table) WithProjection(colNames []string) sql.Table + type TestIndexDriver struct + func NewIndexDriver(db string, indexes map[string][]sql.DriverIndex) *TestIndexDriver + func (d *TestIndexDriver) Create(db, table, id string, expressions []sql.Expression, config map[string]string) (sql.DriverIndex, error) + func (d *TestIndexDriver) Delete(sql.DriverIndex, sql.PartitionIter) error + func (d *TestIndexDriver) ID() string + func (d *TestIndexDriver) LoadAll(ctx *sql.Context, db, table string) ([]sql.DriverIndex, error) + func (d *TestIndexDriver) Save(*sql.Context, sql.DriverIndex, sql.PartitionIndexKeyValueIter) error + type UnmergeableIndex struct + DB string + DriverName string + Exprs []sql.Expression + TableName string + Tbl *Table + func (u *UnmergeableIndex) Database() string + func (u *UnmergeableIndex) Driver() string + func (u *UnmergeableIndex) Expressions() []string + func (u *UnmergeableIndex) Get(key ...interface{}) (sql.IndexLookup, error) + func (u *UnmergeableIndex) Has(partition sql.Partition, key ...interface{}) (bool, error) + func (u *UnmergeableIndex) ID() string + func (u *UnmergeableIndex) Table() string + type UnmergeableIndexLookup struct + func (u *UnmergeableIndexLookup) Indexes() []string + func (u *UnmergeableIndexLookup) String() string + func (u *UnmergeableIndexLookup) Values(p sql.Partition) (sql.IndexValueIter, error)
Go to main page