fetch

Sep 7, 2026

Changes in this version

+ func AnyEqualPredicate(set [][]byte) func(signal.Value) bool

+ func AnyEqualSet(vals [][]byte) [][]byte

+ func AnyEqualStrings(vals []string) [][]byte

+ func InAnyEqual(set [][]byte, v []byte) bool

+ func SortedAnyEqual(set [][]byte) bool

+ type ColumnKind uint8

+ const KindBytes

+ const KindFloat64

+ const KindInt64

+ const KindUnknown

+ func (k ColumnKind) String() string

+ func (k ColumnKind) Valid() bool

type Condition

+ AnyEqual [][]byte

+ func NormalizeConditions(conds []Condition) []Condition

type NamedColumn

+ Kind ColumnKind

+ func BytesColumn(name string, vals [][]byte) NamedColumn

+ func Float64Column(name string, vals []float64) NamedColumn

+ func Int64Column(name string, vals []int64) NamedColumn

+ func (c NamedColumn) Len() int

Aug 30, 2026

Changes in this version

+ const AttrsColumn

+ const TimestampColumn

+ func FilterRows(b *Batch, conds []Condition) int

+ func MatchesRow(b *Batch, i int, conds []Condition) bool

+ func RowValue(b *Batch, i int, name string) (signal.Value, bool)

Aug 17, 2026

Changes in this version

+ func FilterSeries(series []signal.Series, matchers []Matcher) []signal.Series

+ func MatchesSeries(s signal.Series, matchers []Matcher) bool

+ func SeriesLabel(s signal.Series, name []byte) (signal.Value, bool)

type EqualMatcher

+ func EqualitySpecs(matchers []Matcher) []EqualMatcher

type Fetcher

+ func Filter(f Fetcher) Fetcher

Aug 15, 2026

Changes in this version

+ var ErrLabelsUnsupported = errors.New("fetch: label listing unsupported by this fetcher")

+ func SortSeries(series []signal.Series) []signal.Series

+ func WithScope(ctx context.Context, s *Scope) context.Context

+ type LabelLister interface

+ LabelNames func(ctx context.Context, r Request) ([]string, error)

+ LabelValues func(ctx context.Context, r Request, name []byte) ([]string, error)

+ func LabelListerOf(f Fetcher) LabelLister

type Request

+ Scope *Scope

+ type Scope struct

+ func NewScope() *Scope

+ func ScopeFrom(ctx context.Context) *Scope

+ func (s *Scope) Abort()

+ func (s *Scope) Charge(n int64)

+ func (s *Scope) Enter() (holding bool)

+ func (s *Scope) Release(n int64)

+ type SeriesLister interface

+ Series func(ctx context.Context, r Request) ([]signal.Series, error)

+ func SeriesListerOf(f Fetcher) SeriesLister

Jul 2, 2026

Changes in this version

+ type GroupCounter interface

+ CountBy func(ctx context.Context, r Request, label []byte) (map[string]int, error)

+ func GroupCounterOf(f Fetcher) GroupCounter

Jun 29, 2026

Changes in this version

+ type Counter interface

+ Count func(ctx context.Context, r Request) (int, error)

+ func CounterOf(f Fetcher) Counter

+ type Unwraper interface

+ Unwrap func() Fetcher

Jun 28, 2026

Changes in this version

type Request

+ Limit int

+ Reverse bool

Jun 28, 2026

Changes in this version

type Batch

+ func (b *Batch) Release()

+ func (b *Batch) ReleaseState() any

+ func (b *Batch) SetRelease(fn func(*Batch))

+ func (b *Batch) SetReleaseState(s any)

type Request

+ Recycle bool

Jun 26, 2026

Changes in this version

type Batch

+ ScaleFactors []float64

+ func (b *Batch) ScaleFactor(i int) float64

Jun 26, 2026

Changes in this version

type Batch

+ Columns []NamedColumn

+ func MergeBatches(groups ...[]*Batch) []*Batch

+ func (b *Batch) Column(name string) (NamedColumn, bool)

+ type Condition struct

+ Column string

+ Equal *EqualMatcher

+ Match func(value signal.Value) bool

+ Tokens [][]byte

+ type NamedColumn struct

+ Bytes [][]byte

+ Float64 []float64

+ Int64 []int64

+ Name string

type Request

+ AllConditions bool

+ Conditions []Condition

+ Projection []string

+ SecondPass func(*Batch) bool

+ Signal signal.Signal

Jun 26, 2026

Changes in this version

+ type Batch struct

+ ID signal.SeriesID

+ Series signal.Series

+ Timestamps []int64

+ Values []float64

+ func Drain(ctx context.Context, it Iterator) ([]*Batch, error)

+ type EqualMatcher struct

+ Name string

+ Value string

+ func (m EqualMatcher) Predicate() func(signal.Value) bool

+ type Fetcher interface

+ Fetch func(ctx context.Context, r Request) (Iterator, error)

+ func Merge(fetchers ...Fetcher) Fetcher

+ type Iterator interface

+ Close func() error

+ Next func(ctx context.Context) (*Batch, error)

+ type Matcher struct

+ Match func(value signal.Value) bool

+ Name []byte

+ Spec *EqualMatcher

+ type Request struct

+ End int64

+ Matchers []Matcher

+ Start int64

+ Tenant signal.TenantID

+ type SliceIterator struct

+ func NewSliceIterator(batches []*Batch) *SliceIterator

+ func (it *SliceIterator) Close() error

+ func (it *SliceIterator) Next(context.Context) (*Batch, error)