tsreader

type CombinedIterator interface {
	Next() (sid uint64, rec *record.Record, err error)
	Close()
}

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

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

type Index interface {
	GetSeries(sid uint64, buf []byte, condition influxql.Expr, callback func(key *influx.SeriesKey)) error
}

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

type TSSPReader interface {
	Ref()
	Unref()
	RefFileReader()
	UnrefFileReader()
	MetaIndex(id uint64, tr util.TimeRange) (int, *immutable.MetaIndex, error)
	ChunkMeta(id uint64, offset int64, size, itemCount uint32, metaIdx int,
		ctx *immutable.ChunkMetaContext, ioPriority int) (*immutable.ChunkMeta, error)
	ReadAt(cm *immutable.ChunkMeta, segment int, dst *record.Record,
		ctx *immutable.ReadContext, ioPriority int) (*record.Record, error)
}