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
e87a8262
ROOT
/
go
/
store
/
nbs
/
chunk_journal.go
Search
History
435 lines
|
ISO-8859-1
|
10 KB
Blame
Outline
2
4
8
No wrap
Soft wrap
Outline
chunkJournalFeatureFlag
init
()
chunkJournalName
chunkJournal
journal
:
*journalWriter
sources
:
map[addr]chunkSource
contents
:
manifestContents
backing
:
manifest
_
:
tablePersister
_
:
manifest
_
:
io.Closer
journalChunkSource
address
:
addr
journal
:
io.ReaderAt
lookups
:
map[addr]jrecordLookup
compressedSz
:
uint64
has
(h addr)
:
(bool, error)
hasMany
(addrs []hasRecord)
:
(missing bool, err error)
getCompressed
(_ context.Context, h addr, _ *Stats)
:
(cc CompressedChunk, err error)
get
(ctx context.Context, h addr, stats *Stats)
:
([]byte, error)
getMany
(ctx context.Context, _ *errgroup.Group, reqs []getRecord, found func(context.Context, *chunks.Chunk), stats *Stats)
:
(bool, error)
getManyCompressed
(ctx context.Context, _ *errgroup.Group, reqs []getRecord, found func(context.Context, CompressedChunk), stats *Stats)
:
(bool, error)
count
()
:
(uint32, error)
uncompressedLen
()
:
(uint64, error)
hash
()
:
addr
reader
(context.Context)
:
(io.Reader, error)
size
()
:
(uint64, error)
index
()
:
(tableIndex, error)
clone
()
:
(chunkSource, error)
close
()
:
error
_
:
chunkSource
jrecordLookup
offset
:
int64
length
:
uint32
newChunkJournal
(ctx context.Context, dir string, m manifest)
:
(*chunkJournal, error)
emptyAddr
(a addr)
:
bool
*chunkJournal
Persist
(ctx context.Context, mt *memTable, haver chunkReader, stats *Stats)
:
(chunkSource, error)
ConjoinAll
(ctx context.Context, sources chunkSources, stats *Stats)
:
(chunkSource, error)
Open
(ctx context.Context, name addr, chunkCount uint32, stats *Stats)
:
(chunkSource, error)
Exists
(ctx context.Context, name addr, chunkCount uint32, stats *Stats)
:
(bool, error)
PruneTableFiles
(ctx context.Context, contents manifestContents, mtime time.Time)
:
error
Name
()
:
string
Update
(ctx context.Context, lastLock addr, next manifestContents, stats *Stats, writeHook func() error)
:
(manifestContents, error)
ParseIfExists
(ctx context.Context, stats *Stats, readHook func() error)
:
(ok bool, mc manifestContents, err error)
flushManifest
()
:
(err error)
Close
()
:
(err error)
All occurrences
Please wait...
Page is in error, reload to recover
