Lines Matching refs:flux
20 flux.Table
107 func (fi *filterIterator) Do(f func(flux.Table) error) error {
146 func (fi *filterIterator) handleRead(f func(flux.Table) error, rs ResultSet) error {
177 cols, defs := determineTableColsForSeries(rs.Tags(), flux.TInt)
180 cols, defs := determineTableColsForSeries(rs.Tags(), flux.TFloat)
183 cols, defs := determineTableColsForSeries(rs.Tags(), flux.TUInt)
186 cols, defs := determineTableColsForSeries(rs.Tags(), flux.TBool)
189 cols, defs := determineTableColsForSeries(rs.Tags(), flux.TString)
231 func (gi *groupIterator) Do(f func(flux.Table) error) error {
278 func (gi *groupIterator) handleRead(f func(flux.Table) error, rs GroupResultSet) error {
321 cols, defs := determineTableColsForGroup(gc.Keys(), flux.TInt)
324 cols, defs := determineTableColsForGroup(gc.Keys(), flux.TFloat)
327 cols, defs := determineTableColsForGroup(gc.Keys(), flux.TUInt)
330 cols, defs := determineTableColsForGroup(gc.Keys(), flux.TBool)
333 cols, defs := determineTableColsForGroup(gc.Keys(), flux.TString)
394 func determineTableColsForSeries(tags models.Tags, typ flux.ColType) ([]flux.ColMeta, [][]byte) {
395 cols := make([]flux.ColMeta, 4+len(tags))
397 cols[startColIdx] = flux.ColMeta{
399 Type: flux.TTime,
401 cols[stopColIdx] = flux.ColMeta{
403 Type: flux.TTime,
405 cols[timeColIdx] = flux.ColMeta{
407 Type: flux.TTime,
409 cols[valueColIdx] = flux.ColMeta{
414 cols[4+j] = flux.ColMeta{
416 Type: flux.TString,
423 func defaultGroupKeyForSeries(tags models.Tags, bnds execute.Bounds) flux.GroupKey {
424 cols := make([]flux.ColMeta, 2, len(tags)+2)
426 cols[0] = flux.ColMeta{
428 Type: flux.TTime,
431 cols[1] = flux.ColMeta{
433 Type: flux.TTime,
437 cols = append(cols, flux.ColMeta{
439 Type: flux.TString,
446 func determineTableColsForGroup(tagKeys [][]byte, typ flux.ColType) ([]flux.ColMeta, [][]byte) {
447 cols := make([]flux.ColMeta, 4+len(tagKeys))
449 cols[startColIdx] = flux.ColMeta{
451 Type: flux.TTime,
453 cols[stopColIdx] = flux.ColMeta{
455 Type: flux.TTime,
457 cols[timeColIdx] = flux.ColMeta{
459 Type: flux.TTime,
461 cols[valueColIdx] = flux.ColMeta{
466 cols[4+j] = flux.ColMeta{
468 Type: flux.TString,
476 func groupKeyForGroup(kv [][]byte, spec *influxdb.ReadGroupSpec, bnds execute.Bounds) flux.GroupKey…
477 cols := make([]flux.ColMeta, 2, len(spec.GroupKeys)+2)
479 cols[0] = flux.ColMeta{
481 Type: flux.TTime,
484 cols[1] = flux.ColMeta{
486 Type: flux.TTime,
493 cols = append(cols, flux.ColMeta{
495 Type: flux.TString,
511 func (ti *tagKeysIterator) Do(f func(flux.Table) error) error {
534 func (ti *tagKeysIterator) handleRead(f func(flux.Table) error, rs cursors.StringIterator) error {
537 valueIdx, err := builder.AddCol(flux.ColMeta{
539 Type: flux.TString,
593 func (ti *tagValuesIterator) Do(f func(flux.Table) error) error {
624 func (ti *tagValuesIterator) handleRead(f func(flux.Table) error, rs cursors.StringIterator) error {
627 valueIdx, err := builder.AddCol(flux.ColMeta{
629 Type: flux.TString,