generational_chunk_store.go at 30025a0dc85708d0a0f85a93b3c33af0dd853ee2 - STRLCPY/dolt

ROOT /

go /

store /

nbs /

generational_chunk_store.go

381 lines | ISO-8859-1 | 10 KB

Blame Outline

Outline

_ : chunks.ChunkStore

_ : chunks.GenerationalCS

_ : TableFileStore

GenerationalNBS

oldGen : *NomsBlockStore

newGen : *NomsBlockStore

NewGenerationalCS(oldGen, newGen *NomsBlockStore) : *GenerationalNBS

prefixedTableFile

prefix : string

FileID() : string

*GenerationalNBS

NewGen() : chunks.ChunkStoreGarbageCollector

OldGen() : chunks.ChunkStoreGarbageCollector

Get(ctx context.Context, h hash.Hash) : (chunks.Chunk, error)

GetMany(ctx context.Context, hashes hash.HashSet, found func(context.Context, *chunks.Chunk)) : error

GetManyCompressed(ctx context.Context, hashes hash.HashSet, found func(context.Context, CompressedChunk)) : error

Has(ctx context.Context, h hash.Hash) : (bool, error)

HasMany(ctx context.Context, hashes hash.HashSet) : (absent hash.HashSet, err error)

Put(ctx context.Context, c chunks.Chunk) : error

Version() : string

Rebase(ctx context.Context) : error

Root(ctx context.Context) : (hash.Hash, error)

Commit(ctx context.Context, current, last hash.Hash) : (bool, error)

Stats() : interface{}

StatsSummary() : string

Close() : error

copyToOldGen(ctx context.Context, hashes hash.HashSet) : error

Sources(ctx context.Context) : (hash.Hash, []TableFile, []TableFile, error)

Size(ctx context.Context) : (uint64, error)

WriteTableFile(ctx context.Context, fileId string, numChunks int, contentHash []byte, getRd func() (io.ReadCloser, uint64, error)) : error

AddTableFilesToManifest(ctx context.Context, fileIdToNumChunks map[string]int) : error

PruneTableFiles(ctx context.Context) : error

SetRootChunk(ctx context.Context, root, previous hash.Hash) : error

SupportedOperations() : TableFileStoreOps

GetChunkLocationsWithPaths(hashes hash.HashSet) : (map[string]map[hash.Hash]Range, error)

GetChunkLocations(hashes hash.HashSet) : (map[hash.Hash]map[hash.Hash]Range, error)

RelativeOldGenPath() : string

Path() : (string, bool)

UpdateManifest(ctx context.Context, updates map[hash.Hash]uint32) : (mi ManifestInfo, err error)

Please wait...

Page is in error, reload to recover