Versions in this module Expand all Collapse all v0 v0.40.4 May 19, 2022 Changes in this version + var ErrDuplicateKey = errors.New("duplicate key error") + func RebuildAllIndexes(ctx context.Context, t *doltdb.Table, opts Options) (*doltdb.Table, error) + func RebuildIndex(ctx context.Context, tbl *doltdb.Table, indexName string, opts Options) (types.Map, error) + type BulkImportIEA struct + func (iea *BulkImportIEA) Commit(ctx context.Context, nbf *types.NomsBinFormat) error + func (iea *BulkImportIEA) Delete(ctx context.Context, keyHash, partialKeyHash hash.Hash, key, value types.Tuple) error + func (iea *BulkImportIEA) Has(ctx context.Context, keyHash hash.Hash, key types.Tuple) (bool, error) + func (iea *BulkImportIEA) HasPartial(ctx context.Context, idxSch schema.Schema, partialKeyHash hash.Hash, ...) ([]hashedTuple, error) + func (iea *BulkImportIEA) Insert(ctx context.Context, keyHash, partialKeyHash hash.Hash, key, val types.Tuple) error + func (iea *BulkImportIEA) MaterializeEdits(ctx context.Context, nbf *types.NomsBinFormat) (m types.Map, err error) + func (iea *BulkImportIEA) Rollback(ctx context.Context) error + type BulkImportTEA struct + func (tea *BulkImportTEA) Commit(ctx context.Context, nbf *types.NomsBinFormat) error + func (tea *BulkImportTEA) Delete(keyHash hash.Hash, key types.Tuple) error + func (tea *BulkImportTEA) Get(ctx context.Context, keyHash hash.Hash, key types.Tuple) (*doltKVP, bool, error) + func (tea *BulkImportTEA) Insert(keyHash hash.Hash, key types.Tuple, val types.Tuple) error + func (tea *BulkImportTEA) MaterializeEdits(ctx context.Context, nbf *types.NomsBinFormat) (m types.Map, err error) + func (tea *BulkImportTEA) Rollback(ctx context.Context) error + type BulkImportTEAFactory struct + func NewBulkImportTEAFactory(nbf *types.NomsBinFormat, vrw types.ValueReadWriter, directory string) *BulkImportTEAFactory + func (b *BulkImportTEAFactory) NewIndexEA(ctx context.Context, rowData types.Map) IndexEditAccumulator + func (b *BulkImportTEAFactory) NewTableEA(ctx context.Context, rowData types.Map) TableEditAccumulator + type DbEaFactory interface + NewIndexEA func(ctx context.Context, rowData types.Map) IndexEditAccumulator + NewTableEA func(ctx context.Context, rowData types.Map) TableEditAccumulator + func NewDbEaFactory(directory string, vrw types.ValueReadWriter) DbEaFactory + func NewInMemDeaf(nbf *types.NomsBinFormat) DbEaFactory + func NewInMemDeafWithMaxCapacity(nbf *types.NomsBinFormat, maxCapacity int64) DbEaFactory + type InMemDEAF struct + func (i *InMemDEAF) NewIndexEA(ctx context.Context, rowData types.Map) IndexEditAccumulator + func (i *InMemDEAF) NewTableEA(ctx context.Context, rowData types.Map) TableEditAccumulator + type IndexEditAccumulator interface + Commit func(ctx context.Context, nbf *types.NomsBinFormat) error + Delete func(ctx context.Context, keyHash, partialKeyHash hash.Hash, key, value types.Tuple) error + Has func(ctx context.Context, keyHash hash.Hash, key types.Tuple) (bool, error) + HasPartial func(ctx context.Context, idxSch schema.Schema, partialKeyHash hash.Hash, ...) ([]hashedTuple, error) + Insert func(ctx context.Context, keyHash, partialKeyHash hash.Hash, key, value types.Tuple) error + MaterializeEdits func(ctx context.Context, nbf *types.NomsBinFormat) (types.Map, error) + Rollback func(ctx context.Context) error + type IndexEditor struct + func NewIndexEditor(ctx context.Context, index schema.Index, indexData types.Map, ...) *IndexEditor + func (ie *IndexEditor) Close() error + func (ie *IndexEditor) DeleteRow(ctx context.Context, key, partialKey, value types.Tuple) error + func (ie *IndexEditor) HasPartial(ctx context.Context, partialKey types.Tuple) (bool, error) + func (ie *IndexEditor) Index() schema.Index + func (ie *IndexEditor) InsertRow(ctx context.Context, key, partialKey types.Tuple, value types.Tuple) error + func (ie *IndexEditor) Map(ctx context.Context) (types.Map, error) + func (ie *IndexEditor) StatementFinished(ctx context.Context, errored bool) error + func (ie *IndexEditor) StatementStarted(ctx context.Context) + func (ie *IndexEditor) Undo(ctx context.Context) + type Options struct + Deaf DbEaFactory + ForeignKeyChecksDisabled bool + Tempdir string + func TestEditorOptions(vrw types.ValueReadWriter) Options + func (o Options) WithDeaf(deaf DbEaFactory) Options + type PKDuplicateErrFunc func(keyString, indexName string, k, v types.Tuple, isPk bool) error + type TableEditAccumulator interface + Commit func(ctx context.Context, nbf *types.NomsBinFormat) error + Delete func(keyHash hash.Hash, key types.Tuple) error + Get func(ctx context.Context, keyHash hash.Hash, key types.Tuple) (*doltKVP, bool, error) + Insert func(keyHash hash.Hash, key types.Tuple, val types.Tuple) error + MaterializeEdits func(ctx context.Context, nbf *types.NomsBinFormat) (m types.Map, err error) + Rollback func(ctx context.Context) error + type TableEditor interface + Close func(ctx context.Context) error + DeleteByKey func(ctx context.Context, key types.Tuple, tagToVal map[uint64]types.Value) error + DeleteRow func(ctx context.Context, r row.Row) error + Format func() *types.NomsBinFormat + GetIndexedRows func(ctx context.Context, key types.Tuple, indexName string, idxSch schema.Schema) ([]row.Row, error) + HasEdits func() bool + InsertKeyVal func(ctx context.Context, key, val types.Tuple, tagToVal map[uint64]types.Value, ...) error + InsertRow func(ctx context.Context, r row.Row, errFunc PKDuplicateErrFunc) error + MarkDirty func() + Name func() string + Schema func() schema.Schema + SetConstraintViolation func(ctx context.Context, k types.LesserValuable, v types.Valuable) error + StatementFinished func(ctx context.Context, errored bool) error + StatementStarted func(ctx context.Context) + Table func(ctx context.Context) (*doltdb.Table, error) + UpdateRow func(ctx context.Context, old, new row.Row, errFunc PKDuplicateErrFunc) error + ValueReadWriter func() types.ValueReadWriter + func NewTableEditor(ctx context.Context, t *doltdb.Table, tableSch schema.Schema, name string, ...) (TableEditor, error)