crash.software
Projects
Pull Requests
Issues
Builds
dolt
Code
Files
Commits
Branches
Tags
Pull Requests
Code Comments
Code Compare
Issues
List
Boards
Milestones
Builds
Statistics
Contributions
Source Lines
Child Projects
Projects
STRLCPY
dolt
Files
🤬
Sign In
5fdcdc92
ROOT
/
go
/
store
/
nbs
/
store.go
Search
History
1670 lines
|
ISO-8859-1
|
40 KB
Blame
Outline
2
4
8
No wrap
Soft wrap
Outline
ErrFetchFailure
ErrSpecWithoutChunkSource
ErrConcurrentManifestWriteDuringOverwrite
StorageVersion
defaultMemTableSize
:
uint64
defaultMaxTables
defaultManifestCacheSize
preflushChunkCount
cacheOnce
makeManifestManager
:
func(manifest) manifestManager
globalFDCache
:
*fdCache
tracer
makeGlobalCaches
()
NBSCompressedChunkStore
chunks.ChunkStore
GetManyCompressed
(context.Context, hash.HashSet, func(context.Context, CompressedChunk))
:
error
NomsBlockStore
mm
:
manifestManager
p
:
tablePersister
c
:
conjoiner
mu
:
sync.RWMutex
mt
:
*memTable
tables
:
tableSet
upstream
:
manifestContents
mtSize
:
uint64
putCount
:
uint64
stats
:
*Stats
_
:
TableFileStore
_
:
chunks.ChunkStoreGarbageCollector
Range
Offset
:
uint64
Length
:
uint32
fromManifestAppendixOptionNewContents
(upstream manifestContents, appendixSpecs []tableSpec, option ManifestAppendixOption)
:
(manifestContents, error)
OverwriteStoreManifest
(ctx context.Context, store *NomsBlockStore, root hash.Hash, tableFiles map[hash.Hash]uint32, appendixTableFiles map[hash.Hash]uint32)
:
(err error)
NewAWSStoreWithMMapIndex
(ctx context.Context, nbfVerStr string, table, ns, bucket string, s3 s3svc, ddb ddbsvc, memTableSize uint64, q MemoryQuotaProvider)
:
(*NomsBlockStore, error)
NewAWSStore
(ctx context.Context, nbfVerStr string, table, ns, bucket string, s3 s3svc, ddb ddbsvc, memTableSize uint64, q MemoryQuotaProvider)
:
(*NomsBlockStore, error)
NewGCSStore
(ctx context.Context, nbfVerStr string, bucketName, path string, gcs *storage.Client, memTableSize uint64, q MemoryQuotaProvider)
:
(*NomsBlockStore, error)
NewBSStore
(ctx context.Context, nbfVerStr string, bs blobstore.Blobstore, memTableSize uint64, q MemoryQuotaProvider)
:
(*NomsBlockStore, error)
NewLocalStore
(ctx context.Context, nbfVerStr string, dir string, memTableSize uint64, q MemoryQuotaProvider)
:
(*NomsBlockStore, error)
newLocalStore
(ctx context.Context, nbfVerStr string, dir string, memTableSize uint64, maxTables int, q MemoryQuotaProvider)
:
(*NomsBlockStore, error)
checkDir
(dir string)
:
error
newNomsBlockStore
(ctx context.Context, nbfVerStr string, mm manifestManager, p tablePersister, q MemoryQuotaProvider, c conjoiner, memTableSize uint64)
:
(*NomsBlockStore, error)
toGetRecords
(hashes hash.HashSet)
:
[]getRecord
toHasRecords
(hashes hash.HashSet)
:
[]hasRecord
errLastRootMismatch
errOptimisticLockFailedRoot
errOptimisticLockFailedTables
tableFile
info
:
TableSpecInfo
open
:
func(ctx context.Context) (io.ReadCloser, uint64, error)
FileID
()
:
string
NumChunks
()
:
int
Open
(ctx context.Context)
:
(io.ReadCloser, uint64, error)
getTableFiles
(css map[addr]chunkSource, contents manifestContents, numSpecs int, specFunc func(mc manifestContents, idx int) tableSpec)
:
([]TableFile, error)
newTableFile
(cs chunkSource, info tableSpec)
:
tableFile
CalcReads
(nbs *NomsBlockStore, hashes hash.HashSet, blockSize uint64)
:
(reads int, split bool, err error)
*NomsBlockStore
GetChunkLocationsWithPaths
(hashes hash.HashSet)
:
(map[string]map[hash.Hash]Range, error)
GetChunkLocations
(hashes hash.HashSet)
:
(map[hash.Hash]map[hash.Hash]Range, error)
UpdateManifest
(ctx context.Context, updates map[hash.Hash]uint32)
:
(mi ManifestInfo, err error)
UpdateManifestWithAppendix
(ctx context.Context, updates map[hash.Hash]uint32, option ManifestAppendixOption)
:
(mi ManifestInfo, err error)
WithoutConjoiner
()
:
*NomsBlockStore
Put
(ctx context.Context, c chunks.Chunk)
:
error
addChunk
(ctx context.Context, h addr, data []byte)
:
bool
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
getManyWithFunc
( ctx context.Context, hashes hash.HashSet, getManyFunc func(ctx context.Context, cr chunkReader, eg *errgroup.Group, reqs []getRecord, stats *Stats) (bool, error), )
:
error
Count
()
:
(uint32, error)
Has
(ctx context.Context, h hash.Hash)
:
(bool, error)
HasMany
(ctx context.Context, hashes hash.HashSet)
:
(hash.HashSet, error)
Rebase
(ctx context.Context)
:
error
Root
(ctx context.Context)
:
(hash.Hash, error)
Commit
(ctx context.Context, current, last hash.Hash)
:
(success bool, err error)
updateManifest
(ctx context.Context, current, last hash.Hash)
:
error
Version
()
:
string
Close
()
:
error
Stats
()
:
interface{}
StatsSummary
()
:
string
Sources
(ctx context.Context)
:
(hash.Hash, []TableFile, []TableFile, error)
Size
(ctx context.Context)
:
(uint64, error)
chunkSourcesByAddr
()
:
(map[addr]chunkSource, error)
SupportedOperations
()
:
TableFileStoreOps
Path
()
:
(string, bool)
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)
:
(err error)
MarkAndSweepChunks
(ctx context.Context, last hash.Hash, keepChunks <-chan []hash.Hash, dest chunks.ChunkStore)
:
error
copyMarkedChunks
(ctx context.Context, keepChunks <-chan []hash.Hash, dest *NomsBlockStore)
:
([]tableSpec, error)
gcTableSize
()
:
(uint64, error)
swapTables
(ctx context.Context, specs []tableSpec)
:
(err error)
SetRootChunk
(ctx context.Context, root, previous hash.Hash)
:
error
All occurrences
Please wait...
Page is in error, reload to recover