disk_edit_flusher.go at 0324e0752e97e6c14b9208d5f2a0a7039e4866fa - STRLCPY/dolt

ROOT /

go /

store /

types /

edits /

disk_edit_flusher.go

268 lines | ISO-8859-1 | 6 KB

Blame Outline

Outline

Edits : types.EditProvider

DiskEditFlusher

ctx : context.Context

directory : string

nbf : *types.NomsBinFormat

vrw : types.ValueReadWriter

eg : *errgroup.Group

mu : *sync.Mutex

entries : []flusherEntry

NewDiskEditFlusher(ctx context.Context, directory string, nbf *types.NomsBinFormat, vrw types.ValueReadWriter) : *DiskEditFlusher

EditProviderFromDisk(nbf *types.NomsBinFormat, vrw types.ValueReadWriter, path string) : (types.EditProvider, error)

FlushEditsToDisk(ctx context.Context, directory string, ea types.EditAccumulator) : (string, error)

openTupleWriter(directory string) : (string, types.TupleWriteCloser, error)

flushKVPs(wr types.TupleWriter, itr types.EditProvider) : error

closeTupleWriter(ctx context.Context, absPath string, wr types.TupleWriteCloser, err error) : error

_ : types.EditProvider

deleteOnCloseEP

types.EditProvider

*DiskEditFlusher

Flush(accumulator types.EditAccumulator, id uint64)

resultsFromEntries(ctx context.Context, entries []flusherEntry) : (FlushResults, error)

Wait(ctx context.Context) : (FlushResults, error)

WaitForIDs(ctx context.Context, idFilter *set.Uint64Set) : (FlushResults, error)

*deleteOnCloseEP

Close(ctx context.Context) : error

Please wait...

Page is in error, reload to recover