pointers

Mar 26, 2026

Changes in this version

+ const InternalLabelsFieldName

+ func FromRecordBatch(rec arrow.RecordBatch, dest []SectionPointer, ...) (int, error)

+ func InternalLabelsColumn(rec arrow.RecordBatch) *array.String

+ func PopulateSection(_ arrow.Field, columnType ColumnType) bool

+ func PopulateSectionKey(_ arrow.Field, columnType ColumnType) bool

+ type AndPredicate struct

+ Left Predicate

+ Right Predicate

type ColumnType

+ func ColumnTypeFromField(field arrow.Field) ColumnType

+ type EqualPredicate struct

+ Column *Column

+ Value scalar.Scalar

+ type FalsePredicate struct

+ type FuncPredicate struct

+ Column *Column

+ Keep func(column *Column, value scalar.Scalar) bool

+ type GreaterThanPredicate struct

+ Column *Column

+ Value scalar.Scalar

+ type InPredicate struct

+ Column *Column

+ Values []scalar.Scalar

+ type LessThanPredicate struct

+ Column *Column

+ Value scalar.Scalar

+ type NotPredicate struct

+ Inner Predicate

+ type OrPredicate struct

+ Left Predicate

+ Right Predicate

+ type PopulateColumnFilter func(arrow.Field, ColumnType) bool

+ type Predicate interface

+ func WhereBloomFilterMatches(colColumnName *Column, colBloom *Column, columnName scalar.Scalar, ...) Predicate

+ func WhereTimeRangeOverlapsWith(colMinTimestamp *Column, colMaxTimestamp *Column, start scalar.Scalar, ...) Predicate

+ type Reader struct

+ func NewReader(opts ReaderOptions) *Reader

+ func (r *Reader) Close() error

+ func (r *Reader) Columns() []*Column

+ func (r *Reader) Open(ctx context.Context) error

+ func (r *Reader) Read(ctx context.Context, batchSize int) (arrow.RecordBatch, error)

+ func (r *Reader) Reset(opts ReaderOptions)

+ func (r *Reader) Schema() *arrow.Schema

+ type ReaderOptions struct

+ Allocator memory.Allocator

+ Columns []*Column

+ Predicates []Predicate

+ StreamIDToLabelNames map[int64][]string

+ func (opts *ReaderOptions) Validate() error

type RowReader

+ func (r *RowReader) Open(ctx context.Context) error

+ type TruePredicate struct

Dec 11, 2025 GO-2026-5115

  GO-2026-5115: Grafana Loki Path Traversal - CVE-2021-36156 Bypass in github.com/grafana/loki

Nov 25, 2025 GO-2026-5115

  GO-2026-5115: Grafana Loki Path Traversal - CVE-2021-36156 Bypass in github.com/grafana/loki

Nov 21, 2025 GO-2026-5115

  GO-2026-5115: Grafana Loki Path Traversal - CVE-2021-36156 Bypass in github.com/grafana/loki

Nov 17, 2025 GO-2026-5115

  GO-2026-5115: Grafana Loki Path Traversal - CVE-2021-36156 Bypass in github.com/grafana/loki

Changes in this version

+ func CheckSection(section *dataobj.Section) bool

+ func Iter(ctx context.Context, obj *dataobj.Object) result.Seq[SectionPointer]

+ func IterSection(ctx context.Context, section *Section) result.Seq[SectionPointer]

+ type AndRowPredicate struct

+ Left RowPredicate

+ Right RowPredicate

+ type BloomExistenceRowPredicate struct

+ Name string

+ Value string

+ type Builder struct

+ func NewBuilder(metrics *Metrics, pageSize, pageRows int) *Builder

+ func (b *Builder) EstimatedSize() int

+ func (b *Builder) Flush(w dataobj.SectionWriter) (n int64, err error)

+ func (b *Builder) ObserveStream(path string, section int64, idInObject int64, idInIndex int64, ts time.Time, ...)

+ func (b *Builder) RecordColumnIndex(path string, section int64, columnName string, columnIndex int64, ...)

+ func (b *Builder) Reset()

+ func (b *Builder) SetTenant(tenant string)

+ func (b *Builder) Tenant() string

+ func (b *Builder) Type() dataobj.SectionType

+ type Column struct

+ Name string

+ Section *Section

+ Type ColumnType

+ type ColumnStats struct

+ Cardinality uint64

+ CompressedSize uint64

+ Compression string

+ MetadataOffset uint64

+ MetadataSize uint64

+ Name string

+ Pages []PageStats

+ RowsCount uint64

+ Type string

+ UncompressedSize uint64

+ ValueType string

+ ValuesCount uint64

+ type ColumnType int

+ const ColumnTypeColumnIndex

+ const ColumnTypeColumnName

+ const ColumnTypeInvalid

+ const ColumnTypeMaxTimestamp

+ const ColumnTypeMinTimestamp

+ const ColumnTypePath

+ const ColumnTypePointerKind

+ const ColumnTypeRowCount

+ const ColumnTypeSection

+ const ColumnTypeStreamID

+ const ColumnTypeStreamIDRef

+ const ColumnTypeUncompressedSize

+ const ColumnTypeValuesBloomFilter

+ func ParseColumnType(text string) (ColumnType, error)

+ func (ct ColumnType) String() string

+ type Metrics struct

+ func NewMetrics() *Metrics

+ func (m *Metrics) Observe(ctx context.Context, section *Section) error

+ func (m *Metrics) Register(reg prometheus.Registerer) error

+ func (m *Metrics) Unregister(reg prometheus.Registerer)

+ type PageStats struct

+ CRC32 uint32

+ CompressedSize uint64

+ DataOffset uint64

+ DataSize uint64

+ Encoding string

+ RowsCount uint64

+ UncompressedSize uint64

+ ValuesCount uint64

+ type PointerKind int

+ const PointerKindColumnIndex

+ const PointerKindInvalid

+ const PointerKindStreamIndex

+ type RowPredicate interface

+ type RowReader struct

+ func NewRowReader(sec *Section) *RowReader

+ func (r *RowReader) Close() error

+ func (r *RowReader) MatchStreams(ids iter.Seq[int64]) error

+ func (r *RowReader) Read(ctx context.Context, s []SectionPointer) (int, error)

+ func (r *RowReader) Reset(sec *Section)

+ func (r *RowReader) SetPredicate(p RowPredicate) error

+ type Section struct

+ func Open(ctx context.Context, section *dataobj.Section) (*Section, error)

+ func (s *Section) Columns() []*Column

+ type SectionPointer struct

+ ColumnIndex int64

+ ColumnName string

+ EndTs time.Time

+ LineCount int64

+ Path string

+ PointerKind PointerKind

+ Section int64

+ StartTs time.Time

+ StreamID int64

+ StreamIDRef int64

+ UncompressedSize int64

+ ValuesBloomFilter []byte

+ func (p *SectionPointer) Reset()

+ type Stats struct

+ Columns []ColumnStats

+ CompressedSize uint64

+ MaxTimestamp time.Time

+ MinTimestamp time.Time

+ TimestampDistribution []uint64

+ UncompressedSize uint64

+ func ReadStats(ctx context.Context, section *Section) (Stats, error)

+ type TimeRangeRowPredicate struct

+ End time.Time

+ Start time.Time