index

Documentation

Overview

Copyright (c) 2013-2016 Errplane Inc. This code is originally from: https://github.com/influxdata/influxdb/blob/1.7/tsdb/index.go

2022.01.23 has been modified to make NewSeriesIDSetIterators visible. Copyright 2022 Huawei Cloud Computing Technologies Co., Ltd.

Index

• type SeriesIDElem
• type SeriesIDElems
  • func (a SeriesIDElems) Len() int
  • func (a SeriesIDElems) Less(i, j int) bool
  • func (a SeriesIDElems) Swap(i, j int)
• type SeriesIDIterator
  • func IntersectSeriesIDIterators(itr0, itr1 SeriesIDIterator) SeriesIDIterator
  • func NewSeriesIDExprIterator(itr SeriesIDIterator, expr influxql.Expr) SeriesIDIterator
  • func NewSeriesIDExprIteratorWithSeries(ids *uint64set.Set, expr *influxql.BinaryExpr) SeriesIDIterator
  • func UnionSeriesIDIterators(itr0, itr1 SeriesIDIterator) SeriesIDIterator
• type SeriesIDSet
  • func NewSeriesIDSet(a ...uint64) *SeriesIDSet
  • func NewSeriesIDSetWithSet(set *uint64set.Set) *SeriesIDSet
  • func (s *SeriesIDSet) And(other *SeriesIDSet) *SeriesIDSet
  • func (s *SeriesIDSet) Iterator() SeriesIDSetIterable
  • func (s *SeriesIDSet) Merge(others ...*SeriesIDSet)
• type SeriesIDSetIterable
• type SeriesIDSetIterator
  • func NewSeriesIDSetIterator(ss *SeriesIDSet) SeriesIDSetIterator
  • func NewSeriesIDSetIteratorWithCloser(ss *SeriesIDSet, closer io.Closer) SeriesIDSetIterator
  • func NewSeriesIDSetIterators(itrs []SeriesIDIterator) []SeriesIDSetIterator
• type SeriesIDSetIterators
  • func (a SeriesIDSetIterators) Close() (err error)

Types

type SeriesIDElem

type SeriesIDElem struct {
	SeriesID uint64
	Expr     influxql.Expr
}

type SeriesIDElems

type SeriesIDElems []SeriesIDElem

func (SeriesIDElems) Len

func (a SeriesIDElems) Len() int

func (SeriesIDElems) Less

func (a SeriesIDElems) Less(i, j int) bool

func (SeriesIDElems) Swap

func (a SeriesIDElems) Swap(i, j int)

type SeriesIDIterator

type SeriesIDIterator interface {
	Next() (SeriesIDElem, error)
	Ids() *uint64set.Set
	Close() error
}

func IntersectSeriesIDIterators

func IntersectSeriesIDIterators(itr0, itr1 SeriesIDIterator) SeriesIDIterator

func NewSeriesIDExprIterator

func NewSeriesIDExprIterator(itr SeriesIDIterator, expr influxql.Expr) SeriesIDIterator

func NewSeriesIDExprIteratorWithSeries

func NewSeriesIDExprIteratorWithSeries(ids *uint64set.Set, expr *influxql.BinaryExpr) SeriesIDIterator

func UnionSeriesIDIterators

func UnionSeriesIDIterators(itr0, itr1 SeriesIDIterator) SeriesIDIterator

type SeriesIDSet

type SeriesIDSet struct {
	// contains filtered or unexported fields
}

func NewSeriesIDSet

func NewSeriesIDSet(a ...uint64) *SeriesIDSet

func NewSeriesIDSetWithSet

func NewSeriesIDSetWithSet(set *uint64set.Set) *SeriesIDSet

func (*SeriesIDSet) And

func (s *SeriesIDSet) And(other *SeriesIDSet) *SeriesIDSet

func (*SeriesIDSet) Iterator

func (s *SeriesIDSet) Iterator() SeriesIDSetIterable

func (*SeriesIDSet) Merge

func (s *SeriesIDSet) Merge(others ...*SeriesIDSet)

type SeriesIDSetIterable

type SeriesIDSetIterable interface {
	roaring64.IntIterable64
}

type SeriesIDSetIterator

type SeriesIDSetIterator interface {
	SeriesIDIterator
	SeriesIDSet() *SeriesIDSet
}

SeriesIDSetIterator represents an iterator that can produce a SeriesIDSet.

func NewSeriesIDSetIterator

func NewSeriesIDSetIterator(ss *SeriesIDSet) SeriesIDSetIterator

func NewSeriesIDSetIteratorWithCloser

func NewSeriesIDSetIteratorWithCloser(ss *SeriesIDSet, closer io.Closer) SeriesIDSetIterator

func NewSeriesIDSetIterators

func NewSeriesIDSetIterators(itrs []SeriesIDIterator) []SeriesIDSetIterator

type SeriesIDSetIterators

type SeriesIDSetIterators []SeriesIDSetIterator

func (SeriesIDSetIterators) Close

func (a SeriesIDSetIterators) Close() (err error)