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
2e4d56cf
ROOT
/
go
/
store
/
nbs
/
byte_sink.go
Search
History
373 lines
|
ISO-8859-1
|
9 KB
Blame
Outline
2
4
8
No wrap
Soft wrap
Outline
flushSinkToFile
(sink ByteSink, path string)
:
(err error)
ByteSink
io.Writer
Flush
(wr io.Writer)
:
error
FlushToFile
(path string)
:
error
Reader
()
:
(io.ReadCloser, error)
ErrBufferFull
FixedBufferByteSink
buff
:
[]byte
pos
:
uint64
NewFixedBufferTableSink
(buff []byte)
:
*FixedBufferByteSink
BlockBufferByteSink
blockSize
:
int
pos
:
uint64
blocks
:
[][]byte
NewBlockBufferTableSink
(blockSize int)
:
*BlockBufferByteSink
BufferedFileByteSink
blockSize
:
int
pos
:
uint64
currentBlock
:
[]byte
writeCh
:
chan []byte
ae
:
*atomicerr.AtomicError
wg
:
*sync.WaitGroup
wr
:
io.WriteCloser
path
:
string
NewBufferedFileByteSink
(tempDir string, blockSize, chBufferSize int)
:
(*BufferedFileByteSink, error)
HashingByteSink
backingSink
:
ByteSink
hasher
:
hash.Hash
size
:
uint64
NewHashingByteSink
(backingSink ByteSink)
:
*HashingByteSink
*FixedBufferByteSink
Write
(src []byte)
:
(int, error)
Flush
(wr io.Writer)
:
error
FlushToFile
(path string)
:
(err error)
Reader
()
:
(io.ReadCloser, error)
*BlockBufferByteSink
Write
(src []byte)
:
(int, error)
Flush
(wr io.Writer)
:
(err error)
FlushToFile
(path string)
:
(err error)
Reader
()
:
(io.ReadCloser, error)
*BufferedFileByteSink
Write
(src []byte)
:
(int, error)
backgroundWrite
()
finish
()
:
error
Flush
(wr io.Writer)
:
(err error)
FlushToFile
(path string)
:
(err error)
Reader
()
:
(io.ReadCloser, error)
*HashingByteSink
Write
(src []byte)
:
(int, error)
Flush
(wr io.Writer)
:
error
FlushToFile
(path string)
:
error
Reader
()
:
(io.ReadCloser, error)
GetMD5
()
:
[]byte
Size
()
:
uint64
All occurrences
Please wait...
Page is in error, reload to recover
