comm

Documentation

Overview

Copyright 2022 Huawei Cloud Computing Technologies Co., Ltd.

Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• type CallOption
• type Cursor
• type Cursors
  • func (cursors Cursors) Close() error
• type ExprOptions
• type FileInfo
• type KeyCursor
• type KeyCursors
  • func (cursors KeyCursors) Close() error
  • func (cursors KeyCursors) SetOps(ops []*CallOption)
  • func (cursors KeyCursors) SinkPlan(plan hybridqp.QueryNode)
• type SeriesInfoIntf
• type TopNList
  • func NewTopNList(n int, compare func(interface{}, interface{}) bool) *TopNList
  • func (m *TopNList) Back() *list.Element
  • func (m *TopNList) GetList() *list.List
  • func (m *TopNList) Insert(node interface{})

Types

type CallOption

type CallOption struct {
	Call *influxql.Call
	Ref  *influxql.VarRef
}

type Cursor

type Cursor interface {
	SetOps(ops []*CallOption)
	Next() (*record.Record, error)
	Close() error
	StartSpan(span *tracing.Span)
	EndSpan()
}

type Cursors

type Cursors []Cursor

func (Cursors) Close

func (cursors Cursors) Close() error

type ExprOptions

type ExprOptions struct {
	Expr influxql.Expr
	Ref  influxql.VarRef
}

type FileInfo

type FileInfo struct {
	MinTime    int64
	MaxTime    int64
	SeriesInfo SeriesInfoIntf
}

type KeyCursor

type KeyCursor interface {
	SetOps(ops []*CallOption)
	SinkPlan(plan hybridqp.QueryNode)
	Next() (*record.Record, SeriesInfoIntf, error)
	Name() string
	Close() error
	GetSchema() record.Schemas
	StartSpan(span *tracing.Span)
	EndSpan()
	NextAggData() (*record.Record, *FileInfo, error)
}

type KeyCursors

type KeyCursors []KeyCursor

func (KeyCursors) Close

func (cursors KeyCursors) Close() error

func (KeyCursors) SetOps

func (cursors KeyCursors) SetOps(ops []*CallOption)

func (KeyCursors) SinkPlan

func (cursors KeyCursors) SinkPlan(plan hybridqp.QueryNode)

type SeriesInfoIntf

type SeriesInfoIntf interface {
	GetSeriesKey() []byte
	GetSeriesTags() *influx.PointTags
}

type TopNList

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

func NewTopNList

func NewTopNList(n int, compare func(interface{}, interface{}) bool) *TopNList

func (*TopNList) Back

func (m *TopNList) Back() *list.Element

func (*TopNList) GetList

func (m *TopNList) GetList() *list.List

func (*TopNList) Insert

func (m *TopNList) Insert(node interface{})