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
57854eb3
ROOT
/
go
/
store
/
nbs
/
table_reader.go
Search
History
681 lines
|
ISO-8859-1
|
17 KB
Blame
Outline
2
4
8
No wrap
Soft wrap
Outline
maxReadSize
CompressedChunk
H
:
hash.Hash
FullCompressedChunk
:
[]byte
CompressedData
:
[]byte
ToChunk
()
:
(chunks.Chunk, error)
Hash
()
:
hash.Hash
IsEmpty
()
:
bool
NewCompressedChunk
(h hash.Hash, buff []byte)
:
(CompressedChunk, error)
ChunkToCompressedChunk
(chunk chunks.Chunk)
:
CompressedChunk
EmptyCompressedChunk
:
CompressedChunk
init
()
ErrInvalidTableFile
indexEntry
Offset
()
:
uint64
Length
()
:
uint32
indexResult
o
:
uint64
l
:
uint32
Offset
()
:
uint64
Length
()
:
uint32
tableReaderAt
ReadAtWithStats
(ctx context.Context, p []byte, off int64, stats *Stats)
:
(n int, err error)
tableReader
prefixes
:
[]uint64
idx
:
tableIndex
r
:
tableReaderAt
blockSize
:
uint64
hasMany
(addrs []hasRecord)
:
(bool, error)
count
()
:
(uint32, error)
uncompressedLen
()
:
(uint64, error)
index
()
:
(tableIndex, error)
has
(h addr)
:
(bool, error)
get
(ctx context.Context, h addr, stats *Stats)
:
([]byte, error)
readCompressedAtOffsets
( ctx context.Context, rb readBatch, found func(context.Context, CompressedChunk), stats *Stats, )
:
error
readAtOffsets
( ctx context.Context, rb readBatch, found func(context.Context, *chunks.Chunk), stats *Stats, )
:
error
readAtOffsetsWithCB
( ctx context.Context, rb readBatch, stats *Stats, cb func(ctx context.Context, cmp CompressedChunk) error, )
:
error
getMany
( ctx context.Context, eg *errgroup.Group, reqs []getRecord, found func(context.Context, *chunks.Chunk), stats *Stats)
:
(bool, error)
getManyCompressed
(ctx context.Context, eg *errgroup.Group, reqs []getRecord, found func(context.Context, CompressedChunk), stats *Stats)
:
(bool, error)
getManyCompressedAtOffsets
(ctx context.Context, eg *errgroup.Group, offsetRecords offsetRecSlice, found func(context.Context, CompressedChunk), stats *Stats)
:
error
getManyAtOffsets
( ctx context.Context, eg *errgroup.Group, offsetRecords offsetRecSlice, found func(context.Context, *chunks.Chunk), stats *Stats, )
:
error
getManyAtOffsetsWithReadFunc
( ctx context.Context, eg *errgroup.Group, offsetRecords offsetRecSlice, stats *Stats, readAtOffsets func( ctx context.Context, rb readBatch, stats *Stats) error, )
:
error
findOffsets
(reqs []getRecord)
:
(ors offsetRecSlice, remaining bool, err error)
calcReads
(reqs []getRecord, blockSize uint64)
:
(reads int, remaining bool, err error)
extract
(ctx context.Context, chunks chan<- extractRecord)
:
error
reader
(ctx context.Context)
:
(io.Reader, error)
size
()
:
(uint64, error)
close
()
:
error
clone
()
:
(tableReader, error)
newTableReader
(index tableIndex, r tableReaderAt, blockSize uint64)
:
(tableReader, error)
offsetRec
a
:
*addr
offset
:
uint64
length
:
uint32
offsetRecSlice
Len
()
:
int
Less
(i, j int)
:
bool
Swap
(i, j int)
_
:
chunkReader
readBatch
Start
()
:
uint64
End
()
:
uint64
ExtractChunkFromRead
(buff []byte, idx int)
:
(CompressedChunk, error)
toReadBatches
(offsets offsetRecSlice, blockSize uint64)
:
[]readBatch
canReadAhead
(fRec offsetRec, curStart, curEnd, blockSize uint64)
:
(newEnd uint64, canRead bool)
readerAdapter
rat
:
tableReaderAt
off
:
int64
ctx
:
context.Context
*readerAdapter
Read
(p []byte)
:
(n int, err error)
All occurrences
Please wait...
Page is in error, reload to recover
