disk

Jul 31, 2025

Changes in this version

+ const DocBlockHeaderLen

+ const IndexBlockHeaderSize

+ type BlockFormer struct

+ Buf []byte

+ func NewBlockFormer(blockType string, writer *BlocksWriter, blockSize int, buf []byte) *BlockFormer

+ func (b *BlockFormer) FlushForced(options ...FlushOption) error

+ func (b *BlockFormer) FlushIfNeeded(options ...FlushOption) (bool, error)

+ func (b *BlockFormer) GetStats() *BlockStats

+ type BlockStats struct

+ Blocks uint64

+ Comp uint64

+ Duration time.Duration

+ Name string

+ Raw uint64

+ func (s *BlockStats) WriteLogs()

+ type BlocksWriter struct

+ func NewBlocksWriter(ws io.WriteSeeker) *BlocksWriter

+ func (w *BlocksWriter) GetBlockIndex() uint32

+ func (w *BlocksWriter) WriteBlock(blockType string, data []byte, compress bool, zstdLevel int, ext1, ext2 uint64) (uint32, error)

+ func (w *BlocksWriter) WriteBlocksRegistry() error

+ func (w *BlocksWriter) WriteEmptyBlock()

+ type Codec byte

+ const CodecLZ4

+ const CodecNo

+ const CodecZSTD

+ type DocBlock []byte

+ func CompressDocBlock(src []byte, dst DocBlock, zstdLevel int) DocBlock

+ func NewBlock() DocBlock

+ func PackDocBlock(payload []byte, dst DocBlock) DocBlock

+ func (b DocBlock) CalcLen()

+ func (b DocBlock) Codec() Codec

+ func (b DocBlock) DecompressTo(dst []byte) ([]byte, error)

+ func (b DocBlock) FullLen() uint64

+ func (b DocBlock) GetExt1() uint64

+ func (b DocBlock) GetExt2() uint64

+ func (b DocBlock) Len() uint64

+ func (b DocBlock) Payload() []byte

+ func (b DocBlock) RawLen() uint64

+ func (b DocBlock) SetCodec(codecVal Codec)

+ func (b DocBlock) SetExt1(x uint64)

+ func (b DocBlock) SetExt2(x uint64)

+ func (b DocBlock) SetLen(val uint64)

+ func (b DocBlock) SetRawLen(x uint64)

+ type DocBlocksReader struct

+ func NewDocBlocksReader(reader *ReadLimiter, file *os.File) DocBlocksReader

+ func (r *DocBlocksReader) ReadDocBlock(offset int64) ([]byte, uint64, error)

+ func (r *DocBlocksReader) ReadDocBlockPayload(offset int64) ([]byte, uint64, error)

+ type DocsReader struct

+ func NewDocsReader(reader *ReadLimiter, file *os.File, docsCache *cache.Cache[[]byte]) DocsReader

+ func (r *DocsReader) ReadDocs(blockOffset uint64, docOffsets []uint64) ([][]byte, error)

+ func (r *DocsReader) ReadDocsFunc(blockOffset uint64, docOffsets []uint64, cb func([]byte) error) error

+ type FlushOption func(*FlushOptions)

+ func WithExt(ext1, ext2 uint64) FlushOption

+ func WithZstdCompressLevel(level int) FlushOption

+ type FlushOptions struct

+ func NewDefaultFlushOptions() *FlushOptions

+ type IndexBlockHeader []byte

+ func NewEmptyIndexBlockHeader() IndexBlockHeader

+ func NewIndexBlockHeader(pos int64, ext1, ext2 uint64, origBuff, finalBuf []byte, codec Codec) IndexBlockHeader

+ func (b IndexBlockHeader) Codec() Codec

+ func (b IndexBlockHeader) GetExt1() uint64

+ func (b IndexBlockHeader) GetExt2() uint64

+ func (b IndexBlockHeader) GetPos() uint64

+ func (b IndexBlockHeader) Len() uint32

+ func (b IndexBlockHeader) RawLen() uint32

+ func (b IndexBlockHeader) SetCodec(codecVal Codec)

+ func (b IndexBlockHeader) SetExt1(x uint64)

+ func (b IndexBlockHeader) SetExt2(x uint64)

+ func (b IndexBlockHeader) SetLen(val uint32)

+ func (b IndexBlockHeader) SetPos(x uint64)

+ func (b IndexBlockHeader) SetRawLen(x uint32)

+ type IndexReader struct

+ func NewIndexReader(reader *ReadLimiter, file *os.File, registryCache *cache.Cache[[]byte]) IndexReader

+ func (r *IndexReader) GetBlockHeader(index uint32) (IndexBlockHeader, error)

+ func (r *IndexReader) ReadIndexBlock(blockIndex uint32, dst []byte) ([]byte, uint64, error)

+ type ReadLimiter struct

+ func NewReadLimiter(maxReadsNum int, counter prometheus.Counter) *ReadLimiter

+ func (r *ReadLimiter) ReadAt(f *os.File, buf []byte, offset int64) (int, error)

+ type SealingStats []*BlockStats

+ func (s SealingStats) WriteLogs()