indexpointers

Mar 26, 2026

Changes in this version

+ type AndPredicate struct

+ Left Predicate

+ Right Predicate

+ 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 Predicate interface

+ 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) 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

+ func (opts *ReaderOptions) Validate() error

type RowReader

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

+ type TenantIndexPointer struct

+ Tenant string

+ type TruePredicate struct

Nov 17, 2025

Changes in this version

+ func CheckSection(section *dataobj.Section) bool

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

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

+ type Builder struct

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

+ func (b *Builder) Append(path string, startTs time.Time, endTs time.Time)

+ func (b *Builder) EstimatedSize() int

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

+ 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 ColumnTypeInvalid

+ const ColumnTypeMaxTimestamp

+ const ColumnTypeMinTimestamp

+ const ColumnTypePath

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

+ func (ct ColumnType) String() string

+ type IndexPointer struct

+ EndTs time.Time

+ Path string

+ StartTs time.Time

+ 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 RowPredicate interface

+ type RowReader struct

+ func NewRowReader(sec *Section) *RowReader

+ func (r *RowReader) Close() error

+ func (r *RowReader) Read(ctx context.Context, s []IndexPointer) (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 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