read_replica_database.go at 2e4d56cfb1dfd5f427c1b3076b83cfa3c39cf4d1 - STRLCPY/dolt

ROOT /

go /

sqle /

read_replica_database.go

442 lines | ISO-8859-1 | 12 KB

Blame Outline

Outline

ReadReplicaDatabase

remote : env.Remote

srcDB : *doltdb.DoltDB

tmpDir : string

limiter : *limiter

StartTransaction(ctx *sql.Context, tCharacteristic sql.TransactionCharacteristic) : (sql.Transaction, error)

PullFromRemote(ctx *sql.Context) : error

_ : SqlDatabase

_ : sql.VersionedDatabase

_ : sql.TableDropper

_ : sql.TableCreator

_ : sql.TemporaryTableCreator

_ : sql.TableRenamer

_ : sql.TriggerDatabase

_ : sql.StoredProcedureDatabase

_ : sql.TransactionDatabase

ErrFailedToLoadReplicaDB

ErrInvalidReplicateHeadsSetting

ErrFailedToCastToReplicaDb

ErrCannotCreateReplicaRevisionDbForCommit

EmptyReadReplica

NewReadReplicaDatabase(ctx context.Context, db Database, remoteName string, dEnv *env.DoltEnv) : (ReadReplicaDatabase, error)

pullBehavior_fastForward : pullBehavior

pullBehavior_forcePull : pullBehavior

pullBranches(ctx *sql.Context, rrd ReadReplicaDatabase, branches []string, currentBranchRef ref.DoltRef, behavior pullBehavior) : error

getReplicationBranches(ctx *sql.Context, rrd ReadReplicaDatabase) : (allBranches []string, deletedBranches []ref.DoltRef, err error)

branchesToDelete(remRefs, localRefs []ref.DoltRef) : []ref.DoltRef

deleteBranches(ctx *sql.Context, rrd ReadReplicaDatabase, branches []ref.DoltRef, currentBranchRef ref.DoltRef) : error

parseBranches(arg string) : []string

f : func() (any, error)

waiters : []chan res

newLimiter() : *limiter

mu : sync.Mutex

running : map[string]*blocked

Run(ctx context.Context, s string, f func() (any, error)) : (any, error)

finish(s string)

Please wait...

Page is in error, reload to recover