in_mem_table

Feb 28, 2024

Changes in this version

type IndexedSetTable

+ func (t *IndexedSetTable[V]) TableId() sql.TableId

Aug 23, 2023

Changes in this version

+ var ErrEntryNotFound = errors.New("cannot insert row; matching entry not found")

+ func Delete(ctx *sql.Context, ops *ValueOps[V], is IndexedSet[V], row sql.Row) error

+ func Insert(ctx *sql.Context, ops *ValueOps[V], is IndexedSet[V], row sql.Row) error

+ func MultiDelete(ctx *sql.Context, ops *MultiValueOps[V], is IndexedSet[V], row sql.Row) error

+ func MultiInsert(ctx *sql.Context, ops *MultiValueOps[V], is IndexedSet[V], row sql.Row) error

+ func MultiToRows(ctx *sql.Context, ops *MultiValueOps[V], is IndexedSet[V]) ([]sql.Row, error)

+ func MultiUpdate(ctx *sql.Context, ops *MultiValueOps[V], is IndexedSet[V], old, new sql.Row) error

+ func ToRows(ctx *sql.Context, ops *ValueOps[V], is IndexedSet[V]) ([]sql.Row, error)

+ func Update(ctx *sql.Context, ops *ValueOps[V], is IndexedSet[V], old, new sql.Row) error

+ type IndexedSet struct

+ Indexes []MultiMap[V]

+ Keyers []Keyer[V]

+ func NewIndexedSet(eqf func(V, V) bool, keyers []Keyer[V]) IndexedSet[V]

+ func (is IndexedSet[V]) Clear()

+ func (is IndexedSet[V]) Count() int

+ func (is IndexedSet[V]) Get(v V) (V, bool)

+ func (is IndexedSet[V]) GetMany(keyer Keyer[V], k any) []V

+ func (is IndexedSet[V]) Put(v V)

+ func (is IndexedSet[V]) Remove(v V) (res V, found bool)

+ func (is IndexedSet[V]) RemoveMany(keyer Keyer[V], k any)

+ func (is IndexedSet[V]) VisitEntries(f func(v V))

+ type IndexedSetTable struct

+ func NewIndexedSetTable(name string, schema sql.Schema, coll sql.CollationID, set IndexedSet[V], ...) *IndexedSetTable[V]

+ func (t *IndexedSetTable[V]) Collation() sql.CollationID

+ func (t *IndexedSetTable[V]) Deleter(ctx *sql.Context) sql.RowDeleter

+ func (t *IndexedSetTable[V]) Editor() editor

+ func (t *IndexedSetTable[V]) Inserter(ctx *sql.Context) sql.RowInserter

+ func (t *IndexedSetTable[V]) Name() string

+ func (t *IndexedSetTable[V]) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error)

+ func (t *IndexedSetTable[V]) Partitions(ctx *sql.Context) (sql.PartitionIter, error)

+ func (t *IndexedSetTable[V]) Replacer(ctx *sql.Context) sql.RowReplacer

+ func (t *IndexedSetTable[V]) Schema() sql.Schema

+ func (t *IndexedSetTable[V]) Set() IndexedSet[V]

+ func (t *IndexedSetTable[V]) String() string

+ func (t *IndexedSetTable[V]) Truncate(ctx *sql.Context) (int, error)

+ func (t *IndexedSetTable[V]) Updater(ctx *sql.Context) sql.RowUpdater

+ type IndexedSetTableEditor struct

+ Ops ValueOps[V]

+ Set IndexedSet[V]

+ func (e *IndexedSetTableEditor[V]) Close(ctx *sql.Context) error

+ func (e *IndexedSetTableEditor[V]) Delete(ctx *sql.Context, row sql.Row) error

+ func (e *IndexedSetTableEditor[V]) DiscardChanges(ctx *sql.Context, cause error) error

+ func (e *IndexedSetTableEditor[V]) Insert(ctx *sql.Context, row sql.Row) error

+ func (e *IndexedSetTableEditor[V]) StatementBegin(ctx *sql.Context)

+ func (e *IndexedSetTableEditor[V]) StatementComplete(ctx *sql.Context) error

+ func (e *IndexedSetTableEditor[V]) Update(ctx *sql.Context, old, new sql.Row) error

+ type Keyer interface

+ GetKey func(V) any

+ type MultiIndexedSetTable struct

+ func NewMultiIndexedSetTable(name string, schema sql.Schema, coll sql.CollationID, set IndexedSet[V], ...) *MultiIndexedSetTable[V]

+ func (t *MultiIndexedSetTable[V]) Collation() sql.CollationID

+ func (t *MultiIndexedSetTable[V]) Deleter(ctx *sql.Context) sql.RowDeleter

+ func (t *MultiIndexedSetTable[V]) Editor() editor

+ func (t *MultiIndexedSetTable[V]) Inserter(ctx *sql.Context) sql.RowInserter

+ func (t *MultiIndexedSetTable[V]) Name() string

+ func (t *MultiIndexedSetTable[V]) PartitionRows(ctx *sql.Context, partition sql.Partition) (sql.RowIter, error)

+ func (t *MultiIndexedSetTable[V]) Partitions(ctx *sql.Context) (sql.PartitionIter, error)

+ func (t *MultiIndexedSetTable[V]) Replacer(ctx *sql.Context) sql.RowReplacer

+ func (t *MultiIndexedSetTable[V]) Schema() sql.Schema

+ func (t *MultiIndexedSetTable[V]) Set() IndexedSet[V]

+ func (t *MultiIndexedSetTable[V]) String() string

+ func (t *MultiIndexedSetTable[V]) Updater(ctx *sql.Context) sql.RowUpdater

+ type MultiIndexedSetTableEditor struct

+ Ops MultiValueOps[V]

+ Set IndexedSet[V]

+ func (e *MultiIndexedSetTableEditor[V]) Close(ctx *sql.Context) error

+ func (e *MultiIndexedSetTableEditor[V]) Delete(ctx *sql.Context, row sql.Row) error

+ func (e *MultiIndexedSetTableEditor[V]) DiscardChanges(ctx *sql.Context, cause error) error

+ func (e *MultiIndexedSetTableEditor[V]) Insert(ctx *sql.Context, row sql.Row) error

+ func (e *MultiIndexedSetTableEditor[V]) StatementBegin(ctx *sql.Context)

+ func (e *MultiIndexedSetTableEditor[V]) StatementComplete(ctx *sql.Context) error

+ func (e *MultiIndexedSetTableEditor[V]) Update(ctx *sql.Context, old, new sql.Row) error

+ type MultiMap struct

+ Equals func(v1, v2 V) bool

+ func NewMultiMap(f func(v1, v2 V) bool) MultiMap[V]

+ func (m MultiMap[V]) Clear()

+ func (m MultiMap[V]) Get(k any, v V) (res V, found bool)

+ func (m MultiMap[V]) GetMany(k any) []V

+ func (m MultiMap[V]) Put(k any, v V)

+ func (m MultiMap[V]) Remove(k any, v V) (res V, found bool)

+ func (m MultiMap[V]) VisitEntries(f func(v V))

+ type MultiValueOps struct

+ AddRow func(*sql.Context, sql.Row, V) (V, error)

+ DeleteRow func(*sql.Context, sql.Row, V) (V, error)

+ FromRow func(*sql.Context, sql.Row) (V, error)

+ ToRows func(*sql.Context, V) ([]sql.Row, error)

+ type OperationLockingTableEditor struct

+ E sql.TableEditor

+ L sync.Locker

+ func (e OperationLockingTableEditor) Close(ctx *sql.Context) error

+ func (e OperationLockingTableEditor) Delete(ctx *sql.Context, row sql.Row) error

+ func (e OperationLockingTableEditor) DiscardChanges(ctx *sql.Context, errorEncountered error) error

+ func (e OperationLockingTableEditor) Insert(ctx *sql.Context, row sql.Row) error

+ func (e OperationLockingTableEditor) StatementBegin(ctx *sql.Context)

+ func (e OperationLockingTableEditor) StatementComplete(ctx *sql.Context) error

+ func (e OperationLockingTableEditor) Update(ctx *sql.Context, old sql.Row, new sql.Row) error

+ type StatementLockingTableEditor struct

+ E sql.TableEditor

+ L sync.Locker

+ func (e StatementLockingTableEditor) Close(ctx *sql.Context) error

+ func (e StatementLockingTableEditor) Delete(ctx *sql.Context, row sql.Row) error

+ func (e StatementLockingTableEditor) DiscardChanges(ctx *sql.Context, errorEncountered error) error

+ func (e StatementLockingTableEditor) Insert(ctx *sql.Context, row sql.Row) error

+ func (e StatementLockingTableEditor) StatementBegin(ctx *sql.Context)

+ func (e StatementLockingTableEditor) StatementComplete(ctx *sql.Context) error

+ func (e StatementLockingTableEditor) Update(ctx *sql.Context, old sql.Row, new sql.Row) error

+ type ValueOps struct

+ FromRow func(*sql.Context, sql.Row) (V, error)

+ ToRow func(*sql.Context, V) (sql.Row, error)

+ UpdateWithRow func(*sql.Context, sql.Row, V) (V, error)

Jun 12, 2022

Changes in this version

+ var ErrNoEntry = errors.NewKind("unable to update table due to a missing entry")

+ type Data struct

+ func NewData(entryReference Entry, primaryKey Key, secondaryKeys []Key) *Data

+ func (data *Data) Clear()

+ func (data *Data) Count() int64

+ func (data *Data) Get(key Key) []Entry

+ func (data *Data) Has(ctx *sql.Context, entry Entry) bool

+ func (data *Data) Put(ctx *sql.Context, entry Entry) error

+ func (data *Data) Remove(ctx *sql.Context, key Key, entry Entry) error

+ func (data *Data) ToRowIter(ctx *sql.Context) sql.RowIter

+ func (data *Data) ToSlice(ctx *sql.Context) []Entry

+ type DataEditor struct

+ func NewDataEditor(data *Data) *DataEditor

+ func (editor *DataEditor) Close(ctx *sql.Context) error

+ func (editor *DataEditor) Delete(ctx *sql.Context, row sql.Row) error

+ func (editor *DataEditor) DiscardChanges(ctx *sql.Context, errorEncountered error) error

+ func (editor *DataEditor) Insert(ctx *sql.Context, row sql.Row) error

+ func (editor *DataEditor) StatementBegin(ctx *sql.Context)

+ func (editor *DataEditor) StatementComplete(ctx *sql.Context) error

+ func (editor *DataEditor) Update(ctx *sql.Context, old sql.Row, new sql.Row) (retErr error)

+ type DataEditorConverter interface

+ AddRowToEntry func(ctx *sql.Context, row sql.Row, entry Entry) (Entry, error)

+ EntryToRows func(ctx *sql.Context, entry Entry) ([]sql.Row, error)

+ RemoveRowFromEntry func(ctx *sql.Context, row sql.Row, entry Entry) (Entry, error)

+ RowToKey func(ctx *sql.Context, row sql.Row) (Key, error)

+ type DataEditorView struct

+ func NewDataEditorView(data *Data, converter DataEditorConverter) *DataEditorView

+ func (editor *DataEditorView) Close(ctx *sql.Context) error

+ func (editor *DataEditorView) Delete(ctx *sql.Context, row sql.Row) (retErr error)

+ func (editor *DataEditorView) DiscardChanges(ctx *sql.Context, errorEncountered error) error

+ func (editor *DataEditorView) Insert(ctx *sql.Context, row sql.Row) (retErr error)

+ func (editor *DataEditorView) StatementBegin(ctx *sql.Context)

+ func (editor *DataEditorView) StatementComplete(ctx *sql.Context) error

+ func (editor *DataEditorView) Update(ctx *sql.Context, old sql.Row, new sql.Row) (retErr error)

+ type Entry interface

+ Copy func(ctx *sql.Context) Entry

+ Equals func(ctx *sql.Context, otherEntry Entry) bool

+ FromJson func(ctx *sql.Context, jsonStr string) (Entry, error)

+ NewFromRow func(ctx *sql.Context, row sql.Row) (Entry, error)

+ ToJson func(ctx *sql.Context) (string, error)

+ ToRow func(ctx *sql.Context) sql.Row

+ UpdateFromRow func(ctx *sql.Context, row sql.Row) (Entry, error)

+ type Key interface

+ KeyFromEntry func(ctx *sql.Context, entry Entry) (Key, error)

+ KeyFromRow func(ctx *sql.Context, row sql.Row) (Key, error)