commit_hooks.go at 2aa112355ede407067a899611b892b4ed11dd688 - STRLCPY/dolt

ROOT /

go /

commit_hooks.go

300 lines | ISO-8859-1 | 7 KB

Blame Outline

Outline

PushOnWriteHook

destDB : datas.Database

tmpDir : string

out : io.Writer

fmt : *types.NomsBinFormat

NewPushOnWriteHook(destDB *DoltDB, tmpDir string) : *PushOnWriteHook

pushDataset(ctx context.Context, destDB, srcDB datas.Database, ds datas.Dataset, tmpDir string) : error

ds : datas.Dataset

db : datas.Database

hash : hash.Hash

AsyncPushOnWriteHook

out : io.Writer

ch : chan PushArg

asyncPushBufferSize

asyncPushInterval

asyncPushProcessCommit

asyncPushSyncReplica

NewAsyncPushOnWriteHook(bThreads *sql.BackgroundThreads, destDB *DoltDB, tmpDir string, logger io.Writer) : (*AsyncPushOnWriteHook, error)

out : io.Writer

NewLogHook(msg []byte) : *LogHook

RunAsyncReplicationThreads(bThreads *sql.BackgroundThreads, ch chan PushArg, destDB *DoltDB, tmpDir string, logger io.Writer) : error

*PushOnWriteHook

Execute(ctx context.Context, ds datas.Dataset, db datas.Database) : error

HandleError(ctx context.Context, err error) : error

ExecuteForWorkingSets() : bool

SetLogger(ctx context.Context, wr io.Writer) : error

*AsyncPushOnWriteHook

ExecuteForWorkingSets() : bool

Execute(ctx context.Context, ds datas.Dataset, db datas.Database) : error

HandleError(ctx context.Context, err error) : error

SetLogger(ctx context.Context, wr io.Writer) : error

Execute(ctx context.Context, ds datas.Dataset, db datas.Database) : error

HandleError(ctx context.Context, err error) : error

SetLogger(ctx context.Context, wr io.Writer) : error

ExecuteForWorkingSets() : bool

Please wait...

Page is in error, reload to recover