block

Sep 7, 2026

Changes in this version

+ func PartPresent(ctx context.Context, b backend.Backend, prefix string) (bool, error)

Aug 21, 2026

Changes in this version

type ColumnDesc

+ Checked bool

Aug 17, 2026

Changes in this version

type Column

+ BytesDict [][]byte

+ BytesIDs []int32

Aug 15, 2026

Changes in this version

+ func WriteStreamPart(ctx context.Context, b backend.Backend, prefix string, w *StreamWriter) error

type ColumnDesc

+ Bytes int64

+ Footer bool

+ Framed bool

+ Level compress.Level

+ SharedDict bool

type ColumnReader

+ func (r *ColumnReader) DecodeBlocksBytes(blocks []int) (*chunk.DictColumn, error)

+ func (r *ColumnReader) DecodeBlocksBytesIntoColumn(blocks []int) (*chunk.DictColumn, error)

+ func (r *ColumnReader) Frames() ([]FrameExtent, error)

+ func (r *ColumnReader) ObjectBytes() int64

+ type FrameExtent struct

+ Bytes int64

+ EndRow int

+ StartRow int

type Manifest

+ DiskBytes int64

+ RawBytes int64

type PartOption

+ func WithCompressBlockBytes(n int) PartOption

type PartReader

+ func (r *PartReader) ColumnBlocks(ctx context.Context, name string) (*Decoder, error)

+ type StreamWriter struct

+ func NewStreamWriter(opts ...PartOption) *StreamWriter

+ func NewStreamWriterTo(ctx context.Context, b backend.Backend, prefix string, opts ...PartOption) *StreamWriter

+ func (w *StreamWriter) Abort()

+ func (w *StreamWriter) AddColumn(c Column) error

+ func (w *StreamWriter) AppendFloat64(i int, vals []float64) error

+ func (w *StreamWriter) AppendInt64(i int, vals []int64) error

+ func (w *StreamWriter) AppendU128Run(i int, v chunk.U128, count int) error

+ func (w *StreamWriter) EncodedBytes() int64

+ func (w *StreamWriter) OmitConstColumn(v float64) error

+ func (w *StreamWriter) ResidentBytes() int64

+ func (w *StreamWriter) Rows() int

Jul 21, 2026

Changes in this version

type ColumnReader

+ func (r *ColumnReader) BytesRaw() (blob []byte, width int, err error)

Jul 2, 2026

Changes in this version

type Column

+ BytesBlob []byte

+ BytesOffsets []int32

Jul 1, 2026

Changes in this version

type Decoder

+ func (d *Decoder) DecodeFloat64Into(blk int, dst []float64) ([]float64, error)

+ func (d *Decoder) DecodeInt64Into(blk int, dst []int64) ([]int64, error)

Jun 30, 2026

Changes in this version

type Column

+ Block bool

type ColumnDesc

+ Blocked bool

type ColumnReader

+ func (r *ColumnReader) BlockDecoder() (*Decoder, error)

+ func (r *ColumnReader) BlockRows() (int, error)

+ func (r *ColumnReader) Blocked() bool

+ func (r *ColumnReader) DecodeBlocksFloat64(dst []float64, blocks []int) ([]float64, error)

+ func (r *ColumnReader) DecodeBlocksInt64(dst []int64, blocks []int) ([]int64, error)

+ func (r *ColumnReader) RangeFloat64(dst []float64, lo, hi int) ([]float64, error)

+ func (r *ColumnReader) RangeInt64(dst []int64, lo, hi int) ([]int64, error)

+ type Decoder struct

+ func (d *Decoder) BlockRows() int

+ func (d *Decoder) BlockSpan(blk int) (lo, hi int)

+ func (d *Decoder) DecodeFloat64(blk int) ([]float64, error)

+ func (d *Decoder) DecodeInt64(blk int) ([]int64, error)

+ func (d *Decoder) NumBlocks() int

type PartReader

+ func (r *PartReader) ColumnDescByName(name string) (ColumnDesc, bool)

Jun 29, 2026

Changes in this version

type ColumnReader

+ func (r *ColumnReader) FloatCursor() (chunk.FloatDecoder, error)

+ func (r *ColumnReader) TsCursor() (chunk.TsCursor, error)

Jun 27, 2026

Changes in this version

type Column

+ AutoCodec bool

+ FloatPrecisionBits uint8

type ColumnDesc

+ FloatPrecisionBits uint8

Jun 26, 2026

Changes in this version

type PartOption

+ func WithCompressionLevel(level compress.Level) PartOption

Jun 26, 2026

Changes in this version

+ var ErrCorrupt = errors.New("block: corrupt metadata")

+ func WritePart(ctx context.Context, b backend.Backend, prefix string, w *PartWriter) error

+ type Column struct

+ Bytes [][]byte

+ Codec chunk.Codec

+ Compress compress.Algorithm

+ Float64 []float64

+ Int128 []chunk.U128

+ Int64 []int64

+ Kind Kind

+ Name string

+ type ColumnDesc struct

+ Codec chunk.Codec

+ Compress compress.Algorithm

+ Const bool

+ ConstBytes []byte

+ ConstFloat64 float64

+ ConstInt64 int64

+ Kind Kind

+ MaxFloat64 float64

+ MaxInt64 int64

+ MinFloat64 float64

+ MinInt64 int64

+ Name string

+ type ColumnReader struct

+ func (r *ColumnReader) Bytes() (*chunk.DictColumn, error)

+ func (r *ColumnReader) Const() (any, bool)

+ func (r *ColumnReader) Float64(dst []float64) ([]float64, error)

+ func (r *ColumnReader) ID128(dst []chunk.U128) ([]chunk.U128, error)

+ func (r *ColumnReader) Int64(dst []int64) ([]int64, error)

+ func (r *ColumnReader) Kind() Kind

+ func (r *ColumnReader) Len() int

+ type Granule struct

+ FirstRow int

+ MaxKey int64

+ MinKey int64

+ type Kind uint8

+ const KindBytes

+ const KindFloat64

+ const KindInt128

+ const KindInt64

+ func (k Kind) String() string

+ type Manifest struct

+ Columns []ColumnDesc

+ GranuleSize int

+ MaxTime int64

+ MinTime int64

+ RowCount int

+ Version uint32

+ func DecodeManifest(src []byte) (Manifest, error)

+ func (m Manifest) Encode(dst []byte) []byte

+ type Marks struct

+ GranuleSize int

+ Granules []Granule

+ func BuildMarks(sortKey []int64, granuleSize int) Marks

+ func DecodeMarks(src []byte) (Marks, error)

+ func (m Marks) Encode(dst []byte) []byte

+ func (m Marks) Overlapping(lo, hi int64) []Granule

+ type PartOption func(*PartWriter)

+ func WithCompression(alg compress.Algorithm) PartOption

+ func WithGranuleSize(n int) PartOption

+ func WithSortKey(name string) PartOption

+ type PartReader struct

+ func OpenPart(ctx context.Context, b backend.Backend, prefix string) (*PartReader, error)

+ func (r *PartReader) Column(ctx context.Context, name string) (*ColumnReader, error)

+ func (r *PartReader) ColumnNames() []string

+ func (r *PartReader) Manifest() Manifest

+ func (r *PartReader) Marks(ctx context.Context) (Marks, error)

+ func (r *PartReader) RowCount() int

+ type PartWriter struct

+ func NewPartWriter(opts ...PartOption) *PartWriter

+ func (w *PartWriter) AddColumn(c Column) error