Versions in this module Expand all Collapse all v0 v0.40.4 May 19, 2022 Changes in this version + const BranchesTableName + const CommitAncestorsTableName + const CommitsTableName + const DiffTableName + const DocPkColumnName + const DocTableName + const DocTextColumnName + const DoltBlameViewPrefix + const DoltCommitDiffTablePrefix + const DoltConfTablePrefix + const DoltConstViolTablePrefix + const DoltDiffTablePrefix + const DoltHistoryTablePrefix + const DoltNamespace + const DoltQueryCatalogTableName + const ForeignKeyNameRegexStr + const IndexNameRegexStr + const LogTableName + const ProceduresTableCreateStmtCol + const ProceduresTableCreatedAtCol + const ProceduresTableModifiedAtCol + const ProceduresTableName + const ProceduresTableNameCol + const QueryCatalogDescriptionCol + const QueryCatalogIdCol + const QueryCatalogNameCol + const QueryCatalogOrderCol + const QueryCatalogQueryCol + const RemotesTableName + const SchemasTableName + const SchemasTablesExtraCol + const SchemasTablesFragmentCol + const SchemasTablesIdCol + const SchemasTablesIndexName + const SchemasTablesNameCol + const SchemasTablesTypeCol + const StatusTableName + const TableNameRegexStr + const TableOfTablesInConflictName + const TableOfTablesWithViolationsName + var ErrAlreadyOnBranch = errors.New("Already on branch") + var ErrAlreadyOnWorkspace = errors.New("Already on workspace") + var ErrBranchNotFound = errors.New("branch not found") + var ErrCannotDeleteLastBranch = errors.New("cannot delete the last branch") + var ErrFoundHashNotACommit = errors.New("the value retrieved for this hash is not a commit") + var ErrHashNotFound = errors.New("could not find a value for this hash") + var ErrInvBranchName = errors.New("not a valid user branch name") + var ErrInvHash = errors.New("not a valid hash") + var ErrInvTableName = errors.New("not a valid table name") + var ErrInvTagName = errors.New("not a valid user tag name") + var ErrInvWorkspaceName = errors.New("not a valid user workspace name") + var ErrInvalidAncestorSpec = errors.New("invalid ancestor spec") + var ErrInvalidBranchOrHash = errors.New("string is not a valid branch or hash") + var ErrInvalidHash = errors.New("string is not a valid hash") + var ErrIsAhead = errors.New("current fast forward from a to b. a is ahead of b already") + var ErrIsBehind = errors.New("cannot reverse from b to a. b is a is behind a already") + var ErrMergeActive = errors.New("merging is not possible because you have not committed an active merge") + var ErrNoCommonAncestor = errors.New("no common ancestor") + var ErrNoConflictsResolved = errors.New("no conflicts resolved") + var ErrNoRootValAtHash = errors.New("there is no dolt root value at that hash") + var ErrNomsIO = errors.New("error reading from or writing to noms") + var ErrSystemTableCannotBeModified = errors.New("system tables cannot be dropped or altered") + var ErrTableExists = errors.New("table already exists") + var ErrTableNotFound = errors.New("table not found") + var ErrTagNotFound = errors.New("tag not found") + var ErrUnresolvedConflicts = errors.New(...) + var ErrUnresolvedConstraintViolations = errors.New(...) + var ErrUpToDate = errors.New("up to date") + var ErrWorkingSetNotFound = errors.New("working set not found") + var ErrWorkspaceNotFound = errors.New("workspace not found") + var InMemDoltDB = "mem://" + var LocalDirDoltDB = "file://./" + dbfactory.DoltDataDir + func GetAllTableNames(ctx context.Context, root *RootValue) ([]string, error) + func GetGeneratedSystemTables(ctx context.Context, root *RootValue) ([]string, error) + func GetNonSystemTableNames(ctx context.Context, root *RootValue) ([]string, error) + func GetPersistedSystemTables(ctx context.Context, root *RootValue) ([]string, error) + func GetRootValueSuperSchema(ctx context.Context, root *RootValue) (*schema.SuperSchema, error) + func GetSystemTableNames(ctx context.Context, root *RootValue) ([]string, error) + func GetUnreachableRootCause(err error) error + func HasDoltPrefix(s string) bool + func IsInvalidFormatErr(err error) bool + func IsNotACommit(err error) bool + func IsNotFoundErr(err error) bool + func IsReadOnlySystemTable(name string) bool + func IsRootValUnreachable(err error) bool + func IsValidBranchRef(dref ref.DoltRef) bool + func IsValidCommitHash(s string) bool + func IsValidForeignKeyName(name string) bool + func IsValidIndexName(name string) bool + func IsValidTableName(name string) bool + func IsValidTagRef(dref ref.DoltRef) bool + func IsValidUserBranchName(name string) bool + func RunAsyncReplicationThreads(bThreads *sql.BackgroundThreads, ch chan PushArg, destDB *DoltDB, ...) error + func TodoWorkingSetMeta() *datas.WorkingSetMeta + func UnionTableNames(ctx context.Context, roots ...*RootValue) ([]string, error) + func WriteValAndGetRef(ctx context.Context, vrw types.ValueReadWriter, val types.Value) (types.Ref, error) + type AncestorSpec struct + Instructions []int + SpecStr string + func NewAncestorSpec(s string) (*AncestorSpec, error) + func SplitAncestorSpec(s string) (string, *AncestorSpec, error) + type AsyncPushOnWriteHook struct + func NewAsyncPushOnWriteHook(bThreads *sql.BackgroundThreads, destDB *DoltDB, tmpDir string, ...) (*AsyncPushOnWriteHook, error) + func (ah *AsyncPushOnWriteHook) Execute(ctx context.Context, ds datas.Dataset, db datas.Database) error + func (ah *AsyncPushOnWriteHook) HandleError(ctx context.Context, err error) error + func (ah *AsyncPushOnWriteHook) SetLogger(ctx context.Context, wr io.Writer) error + type BranchWithHash struct + Hash hash.Hash + Ref ref.DoltRef + type Commit struct + func GetCommitAncestor(ctx context.Context, cm1, cm2 *Commit) (*Commit, error) + func NewCommit(ctx context.Context, vrw types.ValueReadWriter, commit *datas.Commit) (*Commit, error) + func (c *Commit) CanFastForwardTo(ctx context.Context, new *Commit) (bool, error) + func (c *Commit) CanFastReverseTo(ctx context.Context, new *Commit) (bool, error) + func (c *Commit) DatasParents() []*datas.Commit + func (c *Commit) GetAncestor(ctx context.Context, as *AncestorSpec) (*Commit, error) + func (c *Commit) GetCommitMeta(ctx context.Context) (*datas.CommitMeta, error) + func (c *Commit) GetParent(ctx context.Context, idx int) (*Commit, error) + func (c *Commit) GetRootValue(ctx context.Context) (*RootValue, error) + func (c *Commit) HashOf() (hash.Hash, error) + func (c *Commit) Height() (uint64, error) + func (c *Commit) NumParents() (int, error) + func (c *Commit) ParentHashes(ctx context.Context) ([]hash.Hash, error) + type CommitFilter func(context.Context, hash.Hash, *Commit) (filterOut bool, err error) + type CommitHook interface + Execute func(ctx context.Context, ds datas.Dataset, db datas.Database) error + HandleError func(ctx context.Context, err error) error + SetLogger func(ctx context.Context, wr io.Writer) error + type CommitItr interface + Next func(ctx context.Context) (hash.Hash, *Commit, error) + Reset func(ctx context.Context) error + func CommitItrForAllBranches(ctx context.Context, ddb *DoltDB) (CommitItr, error) + func CommitItrForRoots(ddb *DoltDB, rootCommits ...*Commit) CommitItr + type CommitSpec struct + func NewCommitSpec(cSpecStr string) (*CommitSpec, error) + type DoltDB struct + func DoltDBFromCS(cs chunks.ChunkStore) *DoltDB + func LoadDoltDB(ctx context.Context, nbf *types.NomsBinFormat, urlStr string, ...) (*DoltDB, error) + func LoadDoltDBWithParams(ctx context.Context, nbf *types.NomsBinFormat, urlStr string, ...) (*DoltDB, error) + func (ddb *DoltDB) CSMetricsSummary() string + func (ddb *DoltDB) CanFastForward(ctx context.Context, branch ref.DoltRef, new *Commit) (bool, error) + func (ddb *DoltDB) Clone(ctx context.Context, destDB *DoltDB, eventCh chan<- pull.TableFileEvent) error + func (ddb *DoltDB) Commit(ctx context.Context, valHash hash.Hash, dref ref.DoltRef, cm *datas.CommitMeta) (*Commit, error) + func (ddb *DoltDB) CommitDanglingWithParentCommits(ctx context.Context, valHash hash.Hash, parentCommits []*Commit, ...) (*Commit, error) + func (ddb *DoltDB) CommitRoot(ctx context.Context, last, current hash.Hash) (bool, error) + func (ddb *DoltDB) CommitWithParentCommits(ctx context.Context, valHash hash.Hash, dref ref.DoltRef, ...) (*Commit, error) + func (ddb *DoltDB) CommitWithParentSpecs(ctx context.Context, valHash hash.Hash, dref ref.DoltRef, ...) (*Commit, error) + func (ddb *DoltDB) CommitWithWorkingSet(ctx context.Context, headRef ref.DoltRef, workingSetRef ref.WorkingSetRef, ...) (*Commit, error) + func (ddb *DoltDB) CopyWorkingSet(ctx context.Context, fromWSRef ref.WorkingSetRef, toWSRef ref.WorkingSetRef, ...) error + func (ddb *DoltDB) DeleteBranch(ctx context.Context, branch ref.DoltRef) error + func (ddb *DoltDB) DeleteTag(ctx context.Context, tag ref.DoltRef) error + func (ddb *DoltDB) DeleteWorkingSet(ctx context.Context, workingSetRef ref.WorkingSetRef) error + func (ddb *DoltDB) DeleteWorkspace(ctx context.Context, workRef ref.DoltRef) error + func (ddb *DoltDB) ExecuteCommitHooks(ctx context.Context, datasetId string) error + func (ddb *DoltDB) FastForward(ctx context.Context, branch ref.DoltRef, commit *Commit) error + func (ddb *DoltDB) Format() *types.NomsBinFormat + func (ddb *DoltDB) GC(ctx context.Context, uncommitedVals ...hash.Hash) error + func (ddb *DoltDB) GetBranches(ctx context.Context) ([]ref.DoltRef, error) + func (ddb *DoltDB) GetBranchesWithHashes(ctx context.Context) ([]BranchWithHash, error) + func (ddb *DoltDB) GetHeadRefs(ctx context.Context) ([]ref.DoltRef, error) + func (ddb *DoltDB) GetRefsOfType(ctx context.Context, refTypeFilter map[ref.RefType]struct{}) ([]ref.DoltRef, error) + func (ddb *DoltDB) GetRemoteRefs(ctx context.Context) ([]ref.DoltRef, error) + func (ddb *DoltDB) GetRemotesWithHashes(ctx context.Context) ([]RemoteWithHash, error) + func (ddb *DoltDB) GetTags(ctx context.Context) ([]ref.DoltRef, error) + func (ddb *DoltDB) GetTagsWithHashes(ctx context.Context) ([]TagWithHash, error) + func (ddb *DoltDB) GetWorkspaces(ctx context.Context) ([]ref.DoltRef, error) + func (ddb *DoltDB) Has(ctx context.Context, h hash.Hash) (bool, error) + func (ddb *DoltDB) HasBranch(ctx context.Context, branchName string) (bool, error) + func (ddb *DoltDB) HasRef(ctx context.Context, doltRef ref.DoltRef) (bool, error) + func (ddb *DoltDB) NewBranchAtCommit(ctx context.Context, branchRef ref.DoltRef, commit *Commit) error + func (ddb *DoltDB) NewPendingCommit(ctx context.Context, roots Roots, headRef ref.DoltRef, parentCommits []*Commit, ...) (*PendingCommit, error) + func (ddb *DoltDB) NewTagAtCommit(ctx context.Context, tagRef ref.DoltRef, c *Commit, meta *datas.TagMeta) error + func (ddb *DoltDB) NewWorkspaceAtCommit(ctx context.Context, workRef ref.DoltRef, c *Commit) error + func (ddb *DoltDB) NomsRoot(ctx context.Context) (hash.Hash, error) + func (ddb *DoltDB) PullChunks(ctx context.Context, tempDir string, srcDB *DoltDB, targetHash hash.Hash, ...) error + func (ddb *DoltDB) ReadRootValue(ctx context.Context, h hash.Hash) (*RootValue, error) + func (ddb *DoltDB) Rebase(ctx context.Context) error + func (ddb *DoltDB) Resolve(ctx context.Context, cs *CommitSpec, cwb ref.DoltRef) (*Commit, error) + func (ddb *DoltDB) ResolveAllParents(ctx context.Context, commit *Commit) ([]*Commit, error) + func (ddb *DoltDB) ResolveCommitRef(ctx context.Context, ref ref.DoltRef) (*Commit, error) + func (ddb *DoltDB) ResolveParent(ctx context.Context, commit *Commit, parentIdx int) (*Commit, error) + func (ddb *DoltDB) ResolveTag(ctx context.Context, tagRef ref.TagRef) (*Tag, error) + func (ddb *DoltDB) ResolveWorkingSet(ctx context.Context, workingSetRef ref.WorkingSetRef) (*WorkingSet, error) + func (ddb *DoltDB) SetCommitHookLogger(ctx context.Context, wr io.Writer) *DoltDB + func (ddb *DoltDB) SetCommitHooks(ctx context.Context, postHooks []CommitHook) *DoltDB + func (ddb *DoltDB) SetHead(ctx context.Context, ref ref.DoltRef, addr hash.Hash) error + func (ddb *DoltDB) SetHeadToCommit(ctx context.Context, ref ref.DoltRef, cm *Commit) error + func (ddb *DoltDB) ShallowGC(ctx context.Context) error + func (ddb *DoltDB) UpdateWorkingSet(ctx context.Context, workingSetRef ref.WorkingSetRef, workingSet *WorkingSet, ...) error + func (ddb *DoltDB) ValueReadWriter() types.ValueReadWriter + func (ddb *DoltDB) VisitRefsOfType(ctx context.Context, refTypeFilter map[ref.RefType]struct{}, ...) error + func (ddb *DoltDB) WriteEmptyRepo(ctx context.Context, initBranch, name, email string) error + func (ddb *DoltDB) WriteEmptyRepoWithCommitTime(ctx context.Context, initBranch, name, email string, t time.Time) error + func (ddb *DoltDB) WriteEmptyRepoWithCommitTimeAndDefaultBranch(ctx context.Context, name, email string, t time.Time, init ref.BranchRef) error + func (ddb *DoltDB) WriteRootValue(ctx context.Context, rv *RootValue) (*RootValue, hash.Hash, error) + type ErrClientOutOfDate struct + ClientVer FeatureVersion + RepoVer FeatureVersion + func (e ErrClientOutOfDate) Error() string + type FeatureVersion int64 + var DoltFeatureVersion FeatureVersion = 3 + type FilteringCommitItr struct + func NewFilteringCommitItr(itr CommitItr, filter CommitFilter) FilteringCommitItr + func (itr FilteringCommitItr) Next(ctx context.Context) (hash.Hash, *Commit, error) + func (itr FilteringCommitItr) Reset(ctx context.Context) error + type ForeignKey struct + Name string + OnDelete ForeignKeyReferentialAction + OnUpdate ForeignKeyReferentialAction + ReferencedTableColumns []uint64 + ReferencedTableIndex string + ReferencedTableName string + TableColumns []uint64 + TableIndex string + TableName string + UnresolvedFKDetails UnresolvedFKDetails + func (fk ForeignKey) DeepEquals(other ForeignKey) bool + func (fk ForeignKey) EqualDefs(other ForeignKey) bool + func (fk ForeignKey) HashOf() hash.Hash + func (fk ForeignKey) IsResolved() bool + func (fk ForeignKey) IsSelfReferential() bool + func (fk ForeignKey) ValidateData(ctx context.Context, childSch schema.Schema, ...) error + func (fk ForeignKey) ValidateReferencedTableSchema(sch schema.Schema) error + func (fk ForeignKey) ValidateTableSchema(sch schema.Schema) error + type ForeignKeyCollection struct + func LoadForeignKeyCollection(ctx context.Context, fkMap types.Map) (*ForeignKeyCollection, error) + func NewForeignKeyCollection(keys ...ForeignKey) (*ForeignKeyCollection, error) + func (fkc *ForeignKeyCollection) AddKeys(fks ...ForeignKey) error + func (fkc *ForeignKeyCollection) AllKeys() []ForeignKey + func (fkc *ForeignKeyCollection) ColumnHasFkRelationship(tag uint64) (ForeignKey, bool) + func (fkc *ForeignKeyCollection) Contains(foreignKeyName string) bool + func (fkc *ForeignKeyCollection) Count() int + func (fkc *ForeignKeyCollection) GetByNameCaseInsensitive(foreignKeyName string) (ForeignKey, bool) + func (fkc *ForeignKeyCollection) GetByTags(childTags, parentTags []uint64) (ForeignKey, bool) + func (fkc *ForeignKeyCollection) GetMatchingKey(fk ForeignKey, allSchemas map[string]schema.Schema) (ForeignKey, bool) + func (fkc *ForeignKeyCollection) Iter(cb func(fk ForeignKey) (stop bool, err error)) error + func (fkc *ForeignKeyCollection) KeysForTable(tableName string) (declaredFk, referencedByFk []ForeignKey) + func (fkc *ForeignKeyCollection) Map(ctx context.Context, vrw types.ValueReadWriter) (types.Map, error) + func (fkc *ForeignKeyCollection) RemoveAndUnresolveTables(ctx context.Context, root *RootValue, tables ...string) error + func (fkc *ForeignKeyCollection) RemoveKeyByName(foreignKeyName string) bool + func (fkc *ForeignKeyCollection) RemoveKeys(fks ...ForeignKey) + func (fkc *ForeignKeyCollection) RemoveTables(ctx context.Context, tables ...string) error + func (fkc *ForeignKeyCollection) RenameTable(oldTableName, newTableName string) + func (fkc *ForeignKeyCollection) Stage(ctx context.Context, fksToAdd []ForeignKey, fksToRemove []ForeignKey) + func (fkc *ForeignKeyCollection) Tables() map[string]struct{} + type ForeignKeyReferentialAction byte + const ForeignKeyReferentialAction_Cascade + const ForeignKeyReferentialAction_DefaultAction + const ForeignKeyReferentialAction_NoAction + const ForeignKeyReferentialAction_Restrict + const ForeignKeyReferentialAction_SetNull + func (refOp ForeignKeyReferentialAction) ReducedString() string + func (refOp ForeignKeyReferentialAction) String() string + type ForeignKeyViolationError struct + ForeignKey ForeignKey + Schema schema.Schema + ViolationRows []row.Row + func (f *ForeignKeyViolationError) Error() string + type LogHook struct + func NewLogHook(msg []byte) *LogHook + func (lh *LogHook) Execute(ctx context.Context, ds datas.Dataset, db datas.Database) error + func (lh *LogHook) HandleError(ctx context.Context, err error) error + func (lh *LogHook) SetLogger(ctx context.Context, wr io.Writer) error + type MergeState struct + func MergeStateFromCommitAndWorking(commit *Commit, preMergeWorking *RootValue) *MergeState + func (m MergeState) Commit() *Commit + func (m MergeState) PreMergeWorkingRoot() *RootValue + type PendingCommit struct + CommitOptions datas.CommitOptions + Roots Roots + Val types.Value + type PushArg struct + type PushOnWriteHook struct + func NewPushOnWriteHook(destDB *DoltDB, tmpDir string) *PushOnWriteHook + func (ph *PushOnWriteHook) Execute(ctx context.Context, ds datas.Dataset, db datas.Database) error + func (ph *PushOnWriteHook) HandleError(ctx context.Context, err error) error + func (ph *PushOnWriteHook) SetLogger(ctx context.Context, wr io.Writer) error + type RemoteWithHash struct + Hash hash.Hash + Ref ref.DoltRef + type RootType int + const CommitRoot + const HeadRoot + const InvalidRoot + const StagedRoot + const WorkingRoot + func GetUnreachableRootType(err error) RootType + func (rt RootType) String() string + type RootTypeSet map[RootType]struct + func NewRootTypeSet(rts ...RootType) RootTypeSet + func (rts RootTypeSet) Contains(rt RootType) bool + func (rts RootTypeSet) First(rtList []RootType) RootType + func (rts RootTypeSet) IsEmpty() bool + type RootValue struct + func EmptyRootValue(ctx context.Context, vrw types.ValueReadWriter) (*RootValue, error) + func (root *RootValue) CreateEmptyTable(ctx context.Context, tName string, sch schema.Schema) (*RootValue, error) + func (root *RootValue) DebugString(ctx context.Context, transitive bool) string + func (root *RootValue) GenerateTagsForNewColColl(ctx context.Context, tableName string, cc *schema.ColCollection) (*schema.ColCollection, error) + func (root *RootValue) GenerateTagsForNewColumns(ctx context.Context, tableName string, newColNames []string, ...) ([]uint64, error) + func (root *RootValue) GetAllSchemas(ctx context.Context) (map[string]schema.Schema, error) + func (root *RootValue) GetFeatureVersion(ctx context.Context) (ver FeatureVersion, ok bool, err error) + func (root *RootValue) GetForeignKeyCollection(ctx context.Context) (*ForeignKeyCollection, error) + func (root *RootValue) GetForeignKeyCollectionMap(ctx context.Context) (types.Map, error) + func (root *RootValue) GetSuperSchema(ctx context.Context, tName string) (*schema.SuperSchema, bool, error) + func (root *RootValue) GetSuperSchemaMap(ctx context.Context) (types.Map, error) + func (root *RootValue) GetTable(ctx context.Context, tName string) (*Table, bool, error) + func (root *RootValue) GetTableByColTag(ctx context.Context, tag uint64) (tbl *Table, name string, found bool, err error) + func (root *RootValue) GetTableHash(ctx context.Context, tName string) (hash.Hash, bool, error) + func (root *RootValue) GetTableInsensitive(ctx context.Context, tName string) (*Table, string, bool, error) + func (root *RootValue) GetTableNames(ctx context.Context) ([]string, error) + func (root *RootValue) HasConflicts(ctx context.Context) (bool, error) + func (root *RootValue) HasConstraintViolations(ctx context.Context) (bool, error) + func (root *RootValue) HasTable(ctx context.Context, tName string) (bool, error) + func (root *RootValue) HashOf() (hash.Hash, error) + func (root *RootValue) IterTables(ctx context.Context, ...) error + func (root *RootValue) MapTableHashes(ctx context.Context) (map[string]hash.Hash, error) + func (root *RootValue) PutForeignKeyCollection(ctx context.Context, fkc *ForeignKeyCollection) (*RootValue, error) + func (root *RootValue) PutSuperSchema(ctx context.Context, tName string, ss *schema.SuperSchema) (*RootValue, error) + func (root *RootValue) PutTable(ctx context.Context, tName string, table *Table) (*RootValue, error) + func (root *RootValue) RemoveTables(ctx context.Context, skipFKHandling bool, allowDroppingFKReferenced bool, ...) (*RootValue, error) + func (root *RootValue) RenameTable(ctx context.Context, oldName, newName string) (*RootValue, error) + func (root *RootValue) ResolveTableName(ctx context.Context, tName string) (string, bool, error) + func (root *RootValue) SetTableHash(ctx context.Context, tName string, h hash.Hash) (*RootValue, error) + func (root *RootValue) TablesInConflict(ctx context.Context) ([]string, error) + func (root *RootValue) TablesWithConstraintViolations(ctx context.Context) ([]string, error) + func (root *RootValue) UpdateSuperSchemasFromOther(ctx context.Context, tblNames []string, other *RootValue) (*RootValue, error) + func (root *RootValue) VRW() types.ValueReadWriter + func (root *RootValue) ValidateForeignKeysOnSchemas(ctx context.Context) (*RootValue, error) + type RootValueUnreadable struct + Cause error + RootType RootType + func (rvu RootValueUnreadable) Error() string + type Roots struct + Head *RootValue + Staged *RootValue + Working *RootValue + type Table struct + func NewNomsTable(ctx context.Context, vrw types.ValueReadWriter, sch schema.Schema, ...) (*Table, error) + func NewTable(ctx context.Context, vrw types.ValueReadWriter, sch schema.Schema, ...) (*Table, error) + func (t *Table) AddColumnToRows(ctx context.Context, newCol string, newSchema schema.Schema) (*Table, error) + func (t *Table) ClearConflicts(ctx context.Context) (*Table, error) + func (t *Table) DebugString(ctx context.Context) string + func (t *Table) DeleteIndexRowData(ctx context.Context, indexName string) (*Table, error) + func (t *Table) Format() *types.NomsBinFormat + func (t *Table) GetAutoIncrementValue(ctx context.Context) (uint64, error) + func (t *Table) GetConflictSchemas(ctx context.Context) (base, sch, mergeSch schema.Schema, err error) + func (t *Table) GetConflicts(ctx context.Context) (conflict.ConflictSchema, durable.ConflictIndex, error) + func (t *Table) GetConstraintViolations(ctx context.Context) (types.Map, error) + func (t *Table) GetConstraintViolationsSchema(ctx context.Context) (schema.Schema, error) + func (t *Table) GetIndexRowData(ctx context.Context, indexName string) (durable.Index, error) + func (t *Table) GetIndexSet(ctx context.Context) (durable.IndexSet, error) + func (t *Table) GetNomsIndexRowData(ctx context.Context, indexName string) (types.Map, error) + func (t *Table) GetNomsRowData(ctx context.Context) (types.Map, error) + func (t *Table) GetRowData(ctx context.Context) (durable.Index, error) + func (t *Table) GetSchema(ctx context.Context) (schema.Schema, error) + func (t *Table) GetSchemaHash(ctx context.Context) (hash.Hash, error) + func (t *Table) HasConflicts(ctx context.Context) (bool, error) + func (t *Table) HashOf() (hash.Hash, error) + func (t *Table) NumRowsInConflict(ctx context.Context) (uint64, error) + func (t *Table) RenameIndexRowData(ctx context.Context, oldIndexName, newIndexName string) (*Table, error) + func (t *Table) ResolveConflicts(ctx context.Context, pkTuples []types.Value) (invalid, notFound []types.Value, tbl *Table, err error) + func (t *Table) SetAutoIncrementValue(ctx context.Context, val uint64) (*Table, error) + func (t *Table) SetConflicts(ctx context.Context, schemas conflict.ConflictSchema, ...) (*Table, error) + func (t *Table) SetConstraintViolations(ctx context.Context, violationsMap types.Map) (*Table, error) + func (t *Table) SetIndexRows(ctx context.Context, indexName string, idx durable.Index) (*Table, error) + func (t *Table) SetIndexSet(ctx context.Context, indexes durable.IndexSet) (*Table, error) + func (t *Table) SetNomsIndexRows(ctx context.Context, indexName string, idx types.Map) (*Table, error) + func (t *Table) UpdateNomsRows(ctx context.Context, updatedRows types.Map) (*Table, error) + func (t *Table) UpdateRows(ctx context.Context, updatedRows durable.Index) (*Table, error) + func (t *Table) UpdateSchema(ctx context.Context, sch schema.Schema) (*Table, error) + func (t *Table) ValueReadWriter() types.ValueReadWriter + func (t *Table) VerifyIndexRowData(ctx context.Context, indexName string) error + type Tag struct + Commit *Commit + Meta *datas.TagMeta + Name string + func NewTag(ctx context.Context, name string, ds datas.Dataset, vrw types.ValueReadWriter) (*Tag, error) + func (t *Tag) GetAddr() (hash.Hash, error) + func (t *Tag) GetDoltRef() ref.DoltRef + type TagWithHash struct + Hash hash.Hash + Ref ref.DoltRef + type UnresolvedFKDetails struct + ReferencedTableColumns []string + TableColumns []string + type WorkingSet struct + Name string + func EmptyWorkingSet(wsRef ref.WorkingSetRef) *WorkingSet + func NewWorkingSet(ctx context.Context, name string, vrw types.ValueReadWriter, ds datas.Dataset) (*WorkingSet, error) + func (ws *WorkingSet) HashOf() (hash.Hash, error) + func (ws *WorkingSet) MergeActive() bool + func (ws *WorkingSet) MergeState() *MergeState + func (ws *WorkingSet) Ref() ref.WorkingSetRef + func (ws *WorkingSet) StagedRoot() *RootValue + func (ws *WorkingSet) WorkingRoot() *RootValue + func (ws WorkingSet) AbortMerge() *WorkingSet + func (ws WorkingSet) ClearMerge() *WorkingSet + func (ws WorkingSet) Meta() *datas.WorkingSetMeta + func (ws WorkingSet) StartMerge(commit *Commit) *WorkingSet + func (ws WorkingSet) WithMergeState(mergeState *MergeState) *WorkingSet + func (ws WorkingSet) WithStagedRoot(stagedRoot *RootValue) *WorkingSet + func (ws WorkingSet) WithWorkingRoot(workingRoot *RootValue) *WorkingSet
Go to main page