executor

package
v1.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 29, 2024 License: Apache-2.0, MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	AggType_name = map[int32]string{
		0: "TagSet",
		1: "CountDistinct",
		2: "Normal",
	}
	AggType_value = map[string]int32{
		"TagSet":        0,
		"CountDistinct": 1,
		"Normal":        2,
	}
)

Enum value maps for AggType.

View Source 
var (
	LogicPlanType_name = map[int32]string{
		0:  "LogicalExchange",
		1:  "LogicalLimit",
		2:  "LogicalIndexScan",
		3:  "LogicalAggregate",
		4:  "LogicalMerge",
		5:  "LogicalSortMerge",
		6:  "LogicalFilter",
		7:  "LogicalDedupe",
		8:  "LogicalInterval",
		9:  "LogicalSeries",
		10: "LogicalReader",
		11: "LogicalTagSubset",
		12: "LogicalFill",
		13: "LogicalAlign",
		14: "LogicalMst",
		15: "LogicalProject",
		16: "LogicalSlidingWindow",
		17: "LogicalFilterBlank",
		18: "LogicalHttpSender",
		19: "LogicalFullJoin",
		20: "LogicalWriteIntoStorage",
		21: "LogicalSequenceAggregate",
		22: "LogicalSplitGroup",
		23: "LogicalHoltWinters",
		24: "LogicalSubQuery",
		25: "LogicalGroupBy",
		26: "LogicalOrderBy",
		27: "LogicalHttpSenderHint",
		28: "LogicalTarget",
		29: "LogicalDummyShard",
		30: "LogicalTSSPScan",
		31: "LogicalSortAppend",
		32: "LogicalSort",
		33: "LogicalHashMerge",
		34: "LogicalSparseIndexScan",
		35: "LogicalColumnStoreReader",
		36: "LogicalHashAgg",
		37: "LogicalJoin",
	}
	LogicPlanType_value = map[string]int32{
		"LogicalExchange":          0,
		"LogicalLimit":             1,
		"LogicalIndexScan":         2,
		"LogicalAggregate":         3,
		"LogicalMerge":             4,
		"LogicalSortMerge":         5,
		"LogicalFilter":            6,
		"LogicalDedupe":            7,
		"LogicalInterval":          8,
		"LogicalSeries":            9,
		"LogicalReader":            10,
		"LogicalTagSubset":         11,
		"LogicalFill":              12,
		"LogicalAlign":             13,
		"LogicalMst":               14,
		"LogicalProject":           15,
		"LogicalSlidingWindow":     16,
		"LogicalFilterBlank":       17,
		"LogicalHttpSender":        18,
		"LogicalFullJoin":          19,
		"LogicalWriteIntoStorage":  20,
		"LogicalSequenceAggregate": 21,
		"LogicalSplitGroup":        22,
		"LogicalHoltWinters":       23,
		"LogicalSubQuery":          24,
		"LogicalGroupBy":           25,
		"LogicalOrderBy":           26,
		"LogicalHttpSenderHint":    27,
		"LogicalTarget":            28,
		"LogicalDummyShard":        29,
		"LogicalTSSPScan":          30,
		"LogicalSortAppend":        31,
		"LogicalSort":              32,
		"LogicalHashMerge":         33,
		"LogicalSparseIndexScan":   34,
		"LogicalColumnStoreReader": 35,
		"LogicalHashAgg":           36,
		"LogicalJoin":              37,
	}
)

Enum value maps for LogicPlanType.

View Source 
var File_internal_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AggType 

type AggType int32
const (
	AggType_TagSet        AggType = 0
	AggType_CountDistinct AggType = 1
	AggType_Normal        AggType = 2
)

func (AggType) Descriptor 

func (AggType) Descriptor() protoreflect.EnumDescriptor

func (AggType) Enum 

func (x AggType) Enum() *AggType

func (AggType) EnumDescriptor deprecated 

func (AggType) EnumDescriptor() ([]byte, []int)

Deprecated: Use AggType.Descriptor instead.

func (AggType) Number 

func (x AggType) Number() protoreflect.EnumNumber

func (AggType) String 

func (x AggType) String() string

func (AggType) Type 

func (AggType) Type() protoreflect.EnumType

type Chunk 

type Chunk struct {
	Name          string       `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
	Tags          []*ChunkTags `protobuf:"bytes,2,rep,name=Tags,proto3" json:"Tags,omitempty"`
	TagIndex      []int64      `protobuf:"varint,3,rep,packed,name=TagIndex,proto3" json:"TagIndex,omitempty"`
	Time          []int64      `protobuf:"varint,4,rep,packed,name=Time,proto3" json:"Time,omitempty"`
	IntervalIndex []int64      `protobuf:"varint,5,rep,packed,name=IntervalIndex,proto3" json:"IntervalIndex,omitempty"`
	Columns       []*Column    `protobuf:"bytes,6,rep,name=Columns,proto3" json:"Columns,omitempty"`
	// contains filtered or unexported fields
}

func (*Chunk) Descriptor deprecated 

func (*Chunk) Descriptor() ([]byte, []int)

Deprecated: Use Chunk.ProtoReflect.Descriptor instead.

func (*Chunk) GetColumns 

func (x *Chunk) GetColumns() []*Column

func (*Chunk) GetIntervalIndex 

func (x *Chunk) GetIntervalIndex() []int64

func (*Chunk) GetName 

func (x *Chunk) GetName() string

func (*Chunk) GetTagIndex 

func (x *Chunk) GetTagIndex() []int64

func (*Chunk) GetTags 

func (x *Chunk) GetTags() []*ChunkTags

func (*Chunk) GetTime 

func (x *Chunk) GetTime() []int64

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) ProtoReflect 

func (x *Chunk) ProtoReflect() protoreflect.Message

func (*Chunk) Reset 

func (x *Chunk) Reset()

func (*Chunk) String 

func (x *Chunk) String() string

type ChunkTags 

type ChunkTags struct {
	Subset []byte `protobuf:"bytes,1,opt,name=Subset,proto3" json:"Subset,omitempty"`
	// contains filtered or unexported fields
}

func (*ChunkTags) Descriptor deprecated 

func (*ChunkTags) Descriptor() ([]byte, []int)

Deprecated: Use ChunkTags.ProtoReflect.Descriptor instead.

func (*ChunkTags) GetSubset 

func (x *ChunkTags) GetSubset() []byte

func (*ChunkTags) ProtoMessage 

func (*ChunkTags) ProtoMessage()

func (*ChunkTags) ProtoReflect 

func (x *ChunkTags) ProtoReflect() protoreflect.Message

func (*ChunkTags) Reset 

func (x *ChunkTags) Reset()

func (*ChunkTags) String 

func (x *ChunkTags) String() string

type Column 

type Column struct {
	DataType      int64     `protobuf:"varint,1,opt,name=DataType,proto3" json:"DataType,omitempty"`
	FloatValues   []float64 `protobuf:"fixed64,2,rep,packed,name=FloatValues,proto3" json:"FloatValues,omitempty"`
	IntegerValues []int64   `protobuf:"varint,3,rep,packed,name=IntegerValues,proto3" json:"IntegerValues,omitempty"`
	StringBytes   []byte    `protobuf:"bytes,4,opt,name=StringBytes,proto3" json:"StringBytes,omitempty"`
	Offset        []uint32  `protobuf:"varint,8,rep,packed,name=Offset,proto3" json:"Offset,omitempty"`
	BooleanValues []bool    `protobuf:"varint,5,rep,packed,name=BooleanValues,proto3" json:"BooleanValues,omitempty"`
	Times         []int64   `protobuf:"varint,6,rep,packed,name=Times,proto3" json:"Times,omitempty"`
	NilsV2        []byte    `protobuf:"bytes,7,opt,name=NilsV2,proto3" json:"NilsV2,omitempty"`
	// contains filtered or unexported fields
}

func (*Column) Descriptor deprecated 

func (*Column) Descriptor() ([]byte, []int)

Deprecated: Use Column.ProtoReflect.Descriptor instead.

func (*Column) GetBooleanValues 

func (x *Column) GetBooleanValues() []bool

func (*Column) GetDataType 

func (x *Column) GetDataType() int64

func (*Column) GetFloatValues 

func (x *Column) GetFloatValues() []float64

func (*Column) GetIntegerValues 

func (x *Column) GetIntegerValues() []int64

func (*Column) GetNilsV2 

func (x *Column) GetNilsV2() []byte

func (*Column) GetOffset 

func (x *Column) GetOffset() []uint32

func (*Column) GetStringBytes 

func (x *Column) GetStringBytes() []byte

func (*Column) GetTimes 

func (x *Column) GetTimes() []int64

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) ProtoReflect 

func (x *Column) ProtoReflect() protoreflect.Message

func (*Column) Reset 

func (x *Column) Reset()

func (*Column) String 

func (x *Column) String() string

type ExprOptions 

type ExprOptions struct {
	Expr string `protobuf:"bytes,1,opt,name=Expr,proto3" json:"Expr,omitempty"`
	Ref  string `protobuf:"bytes,2,opt,name=Ref,proto3" json:"Ref,omitempty"`
	// contains filtered or unexported fields
}

func (*ExprOptions) Descriptor deprecated 

func (*ExprOptions) Descriptor() ([]byte, []int)

Deprecated: Use ExprOptions.ProtoReflect.Descriptor instead.

func (*ExprOptions) GetExpr 

func (x *ExprOptions) GetExpr() string

func (*ExprOptions) GetRef 

func (x *ExprOptions) GetRef() string

func (*ExprOptions) ProtoMessage 

func (*ExprOptions) ProtoMessage()

func (*ExprOptions) ProtoReflect 

func (x *ExprOptions) ProtoReflect() protoreflect.Message

func (*ExprOptions) Reset 

func (x *ExprOptions) Reset()

func (*ExprOptions) String 

func (x *ExprOptions) String() string

type IndexList 

type IndexList struct {
	IList []string `protobuf:"bytes,1,rep,name=IList,proto3" json:"IList,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexList) Descriptor deprecated 

func (*IndexList) Descriptor() ([]byte, []int)

Deprecated: Use IndexList.ProtoReflect.Descriptor instead.

func (*IndexList) GetIList 

func (x *IndexList) GetIList() []string

func (*IndexList) ProtoMessage 

func (*IndexList) ProtoMessage()

func (*IndexList) ProtoReflect 

func (x *IndexList) ProtoReflect() protoreflect.Message

func (*IndexList) Reset 

func (x *IndexList) Reset()

func (*IndexList) String 

func (x *IndexList) String() string

type IndexOption 

type IndexOption struct {
	Tokens              string `protobuf:"bytes,1,opt,name=Tokens,proto3" json:"Tokens,omitempty"`
	Tokenizers          string `protobuf:"bytes,2,opt,name=Tokenizers,proto3" json:"Tokenizers,omitempty"`
	TimeClusterDuration int64  `protobuf:"varint,3,opt,name=TimeClusterDuration,proto3" json:"TimeClusterDuration,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexOption) Descriptor deprecated 

func (*IndexOption) Descriptor() ([]byte, []int)

Deprecated: Use IndexOption.ProtoReflect.Descriptor instead.

func (*IndexOption) GetTimeClusterDuration 

func (x *IndexOption) GetTimeClusterDuration() int64

func (*IndexOption) GetTokenizers 

func (x *IndexOption) GetTokenizers() string

func (*IndexOption) GetTokens 

func (x *IndexOption) GetTokens() string

func (*IndexOption) ProtoMessage 

func (*IndexOption) ProtoMessage()

func (*IndexOption) ProtoReflect 

func (x *IndexOption) ProtoReflect() protoreflect.Message

func (*IndexOption) Reset 

func (x *IndexOption) Reset()

func (*IndexOption) String 

func (x *IndexOption) String() string

type IndexOptions 

type IndexOptions struct {
	Infos []*IndexOption `protobuf:"bytes,1,rep,name=Infos,proto3" json:"Infos,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexOptions) Descriptor deprecated 

func (*IndexOptions) Descriptor() ([]byte, []int)

Deprecated: Use IndexOptions.ProtoReflect.Descriptor instead.

func (*IndexOptions) GetInfos 

func (x *IndexOptions) GetInfos() []*IndexOption

func (*IndexOptions) ProtoMessage 

func (*IndexOptions) ProtoMessage()

func (*IndexOptions) ProtoReflect 

func (x *IndexOptions) ProtoReflect() protoreflect.Message

func (*IndexOptions) Reset 

func (x *IndexOptions) Reset()

func (*IndexOptions) String 

func (x *IndexOptions) String() string

type IndexRelation 

type IndexRelation struct {
	Rid          uint32          `protobuf:"varint,1,opt,name=Rid,proto3" json:"Rid,omitempty"`
	Oids         []uint32        `protobuf:"varint,2,rep,packed,name=Oids,proto3" json:"Oids,omitempty"`
	IndexNames   []string        `protobuf:"bytes,3,rep,name=IndexNames,proto3" json:"IndexNames,omitempty"`
	IndexLists   []*IndexList    `protobuf:"bytes,4,rep,name=IndexLists,proto3" json:"IndexLists,omitempty"`
	IndexOptions []*IndexOptions `protobuf:"bytes,5,rep,name=IndexOptions,proto3" json:"IndexOptions,omitempty"`
	// contains filtered or unexported fields
}

func (*IndexRelation) Descriptor deprecated 

func (*IndexRelation) Descriptor() ([]byte, []int)

Deprecated: Use IndexRelation.ProtoReflect.Descriptor instead.

func (*IndexRelation) GetIndexLists 

func (x *IndexRelation) GetIndexLists() []*IndexList

func (*IndexRelation) GetIndexNames 

func (x *IndexRelation) GetIndexNames() []string

func (*IndexRelation) GetIndexOptions 

func (x *IndexRelation) GetIndexOptions() []*IndexOptions

func (*IndexRelation) GetOids 

func (x *IndexRelation) GetOids() []uint32

func (*IndexRelation) GetRid 

func (x *IndexRelation) GetRid() uint32

func (*IndexRelation) ProtoMessage 

func (*IndexRelation) ProtoMessage()

func (*IndexRelation) ProtoReflect 

func (x *IndexRelation) ProtoReflect() protoreflect.Message

func (*IndexRelation) Reset 

func (x *IndexRelation) Reset()

func (*IndexRelation) String 

func (x *IndexRelation) String() string

type Interval 

type Interval struct {
	Duration int64 `protobuf:"varint,1,opt,name=Duration,proto3" json:"Duration,omitempty"`
	Offset   int64 `protobuf:"varint,2,opt,name=Offset,proto3" json:"Offset,omitempty"`
	// contains filtered or unexported fields
}

func (*Interval) Descriptor deprecated 

func (*Interval) Descriptor() ([]byte, []int)

Deprecated: Use Interval.ProtoReflect.Descriptor instead.

func (*Interval) GetDuration 

func (x *Interval) GetDuration() int64

func (*Interval) GetOffset 

func (x *Interval) GetOffset() int64

func (*Interval) ProtoMessage 

func (*Interval) ProtoMessage()

func (*Interval) ProtoReflect 

func (x *Interval) ProtoReflect() protoreflect.Message

func (*Interval) Reset 

func (x *Interval) Reset()

func (*Interval) String 

func (x *Interval) String() string

type IteratorStats 

type IteratorStats struct {
	SeriesN int64 `protobuf:"varint,1,opt,name=SeriesN,proto3" json:"SeriesN,omitempty"`
	PointN  int64 `protobuf:"varint,2,opt,name=PointN,proto3" json:"PointN,omitempty"`
	// contains filtered or unexported fields
}

func (*IteratorStats) Descriptor deprecated 

func (*IteratorStats) Descriptor() ([]byte, []int)

Deprecated: Use IteratorStats.ProtoReflect.Descriptor instead.

func (*IteratorStats) GetPointN 

func (x *IteratorStats) GetPointN() int64

func (*IteratorStats) GetSeriesN 

func (x *IteratorStats) GetSeriesN() int64

func (*IteratorStats) ProtoMessage 

func (*IteratorStats) ProtoMessage()

func (*IteratorStats) ProtoReflect 

func (x *IteratorStats) ProtoReflect() protoreflect.Message

func (*IteratorStats) Reset 

func (x *IteratorStats) Reset()

func (*IteratorStats) String 

func (x *IteratorStats) String() string

type LogicPlanType 

type LogicPlanType int32
const (
	LogicPlanType_LogicalExchange          LogicPlanType = 0
	LogicPlanType_LogicalLimit             LogicPlanType = 1
	LogicPlanType_LogicalIndexScan         LogicPlanType = 2
	LogicPlanType_LogicalAggregate         LogicPlanType = 3
	LogicPlanType_LogicalMerge             LogicPlanType = 4
	LogicPlanType_LogicalSortMerge         LogicPlanType = 5
	LogicPlanType_LogicalFilter            LogicPlanType = 6
	LogicPlanType_LogicalDedupe            LogicPlanType = 7
	LogicPlanType_LogicalInterval          LogicPlanType = 8
	LogicPlanType_LogicalSeries            LogicPlanType = 9
	LogicPlanType_LogicalReader            LogicPlanType = 10
	LogicPlanType_LogicalTagSubset         LogicPlanType = 11
	LogicPlanType_LogicalFill              LogicPlanType = 12
	LogicPlanType_LogicalAlign             LogicPlanType = 13
	LogicPlanType_LogicalMst               LogicPlanType = 14
	LogicPlanType_LogicalProject           LogicPlanType = 15
	LogicPlanType_LogicalSlidingWindow     LogicPlanType = 16
	LogicPlanType_LogicalFilterBlank       LogicPlanType = 17
	LogicPlanType_LogicalHttpSender        LogicPlanType = 18
	LogicPlanType_LogicalFullJoin          LogicPlanType = 19
	LogicPlanType_LogicalWriteIntoStorage  LogicPlanType = 20
	LogicPlanType_LogicalSequenceAggregate LogicPlanType = 21
	LogicPlanType_LogicalSplitGroup        LogicPlanType = 22
	LogicPlanType_LogicalHoltWinters       LogicPlanType = 23
	LogicPlanType_LogicalSubQuery          LogicPlanType = 24
	LogicPlanType_LogicalGroupBy           LogicPlanType = 25
	LogicPlanType_LogicalOrderBy           LogicPlanType = 26
	LogicPlanType_LogicalHttpSenderHint    LogicPlanType = 27
	LogicPlanType_LogicalTarget            LogicPlanType = 28
	LogicPlanType_LogicalDummyShard        LogicPlanType = 29
	LogicPlanType_LogicalTSSPScan          LogicPlanType = 30
	LogicPlanType_LogicalSortAppend        LogicPlanType = 31
	LogicPlanType_LogicalSort              LogicPlanType = 32
	LogicPlanType_LogicalHashMerge         LogicPlanType = 33
	LogicPlanType_LogicalSparseIndexScan   LogicPlanType = 34
	LogicPlanType_LogicalColumnStoreReader LogicPlanType = 35
	LogicPlanType_LogicalHashAgg           LogicPlanType = 36
	LogicPlanType_LogicalJoin              LogicPlanType = 37
)

func (LogicPlanType) Descriptor 

func (LogicPlanType) Descriptor() protoreflect.EnumDescriptor

func (LogicPlanType) Enum 

func (x LogicPlanType) Enum() *LogicPlanType

func (LogicPlanType) EnumDescriptor deprecated 

func (LogicPlanType) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogicPlanType.Descriptor instead.

func (LogicPlanType) Number 

func (x LogicPlanType) Number() protoreflect.EnumNumber

func (LogicPlanType) String 

func (x LogicPlanType) String() string

func (LogicPlanType) Type 

func (LogicPlanType) Type() protoreflect.EnumType

type Measurement 

type Measurement struct {
	Database        string         `protobuf:"bytes,1,opt,name=Database,proto3" json:"Database,omitempty"`
	RetentionPolicy string         `protobuf:"bytes,2,opt,name=RetentionPolicy,proto3" json:"RetentionPolicy,omitempty"`
	Name            string         `protobuf:"bytes,3,opt,name=Name,proto3" json:"Name,omitempty"`
	Regex           string         `protobuf:"bytes,4,opt,name=Regex,proto3" json:"Regex,omitempty"`
	IsTarget        bool           `protobuf:"varint,5,opt,name=IsTarget,proto3" json:"IsTarget,omitempty"`
	SystemIterator  string         `protobuf:"bytes,6,opt,name=SystemIterator,proto3" json:"SystemIterator,omitempty"`
	EngineType      uint32         `protobuf:"varint,7,opt,name=EngineType,proto3" json:"EngineType,omitempty"`
	IndexRelation   *IndexRelation `protobuf:"bytes,8,opt,name=indexRelation,proto3" json:"indexRelation,omitempty"`
	ObsOptions      *ObsOptions    `protobuf:"bytes,9,opt,name=ObsOptions,proto3" json:"ObsOptions,omitempty"`
	IsTimeSorted    bool           `protobuf:"varint,10,opt,name=IsTimeSorted,proto3" json:"IsTimeSorted,omitempty"`
	// contains filtered or unexported fields
}

func (*Measurement) Descriptor deprecated 

func (*Measurement) Descriptor() ([]byte, []int)

Deprecated: Use Measurement.ProtoReflect.Descriptor instead.

func (*Measurement) GetDatabase 

func (x *Measurement) GetDatabase() string

func (*Measurement) GetEngineType 

func (x *Measurement) GetEngineType() uint32

func (*Measurement) GetIndexRelation 

func (x *Measurement) GetIndexRelation() *IndexRelation

func (*Measurement) GetIsTarget 

func (x *Measurement) GetIsTarget() bool

func (*Measurement) GetIsTimeSorted 

func (x *Measurement) GetIsTimeSorted() bool

func (*Measurement) GetName 

func (x *Measurement) GetName() string

func (*Measurement) GetObsOptions 

func (x *Measurement) GetObsOptions() *ObsOptions

func (*Measurement) GetRegex 

func (x *Measurement) GetRegex() string

func (*Measurement) GetRetentionPolicy 

func (x *Measurement) GetRetentionPolicy() string

func (*Measurement) GetSystemIterator 

func (x *Measurement) GetSystemIterator() string

func (*Measurement) ProtoMessage 

func (*Measurement) ProtoMessage()

func (*Measurement) ProtoReflect 

func (x *Measurement) ProtoReflect() protoreflect.Message

func (*Measurement) Reset 

func (x *Measurement) Reset()

func (*Measurement) String 

func (x *Measurement) String() string

type ObsOptions 

type ObsOptions struct {
	Enabled    bool   `protobuf:"varint,1,opt,name=Enabled,proto3" json:"Enabled,omitempty"`
	BucketName string `protobuf:"bytes,2,opt,name=BucketName,proto3" json:"BucketName,omitempty"`
	Ak         string `protobuf:"bytes,3,opt,name=Ak,proto3" json:"Ak,omitempty"`
	Sk         string `protobuf:"bytes,4,opt,name=Sk,proto3" json:"Sk,omitempty"`
	Endpoint   string `protobuf:"bytes,5,opt,name=Endpoint,proto3" json:"Endpoint,omitempty"`
	BasePath   string `protobuf:"bytes,6,opt,name=BasePath,proto3" json:"BasePath,omitempty"`
	// contains filtered or unexported fields
}

func (*ObsOptions) Descriptor deprecated 

func (*ObsOptions) Descriptor() ([]byte, []int)

Deprecated: Use ObsOptions.ProtoReflect.Descriptor instead.

func (*ObsOptions) GetAk 

func (x *ObsOptions) GetAk() string

func (*ObsOptions) GetBasePath 

func (x *ObsOptions) GetBasePath() string

func (*ObsOptions) GetBucketName 

func (x *ObsOptions) GetBucketName() string

func (*ObsOptions) GetEnabled 

func (x *ObsOptions) GetEnabled() bool

func (*ObsOptions) GetEndpoint 

func (x *ObsOptions) GetEndpoint() string

func (*ObsOptions) GetSk 

func (x *ObsOptions) GetSk() string

func (*ObsOptions) ProtoMessage 

func (*ObsOptions) ProtoMessage()

func (*ObsOptions) ProtoReflect 

func (x *ObsOptions) ProtoReflect() protoreflect.Message

func (*ObsOptions) Reset 

func (x *ObsOptions) Reset()

func (*ObsOptions) String 

func (x *ObsOptions) String() string

type ProcessorOptions 

type ProcessorOptions struct {
	Name                  string          `protobuf:"bytes,23,opt,name=Name,proto3" json:"Name,omitempty"`
	Expr                  string          `protobuf:"bytes,1,opt,name=Expr,proto3" json:"Expr,omitempty"`
	Aux                   []*VarRef       `protobuf:"bytes,2,rep,name=Aux,proto3" json:"Aux,omitempty"`
	Sources               []*Measurement  `protobuf:"bytes,3,rep,name=Sources,proto3" json:"Sources,omitempty"`
	Interval              *Interval       `protobuf:"bytes,4,opt,name=Interval,proto3" json:"Interval,omitempty"`
	Dimensions            []string        `protobuf:"bytes,5,rep,name=Dimensions,proto3" json:"Dimensions,omitempty"`
	GroupBy               map[string]bool `` /* 157-byte string literal not displayed */
	Fill                  int32           `protobuf:"varint,6,opt,name=Fill,proto3" json:"Fill,omitempty"`
	FillValue             float64         `protobuf:"fixed64,7,opt,name=FillValue,proto3" json:"FillValue,omitempty"`
	Condition             string          `protobuf:"bytes,8,opt,name=Condition,proto3" json:"Condition,omitempty"`
	StartTime             int64           `protobuf:"varint,9,opt,name=StartTime,proto3" json:"StartTime,omitempty"`
	EndTime               int64           `protobuf:"varint,10,opt,name=EndTime,proto3" json:"EndTime,omitempty"`
	Location              string          `protobuf:"bytes,21,opt,name=Location,proto3" json:"Location,omitempty"`
	Ascending             bool            `protobuf:"varint,11,opt,name=Ascending,proto3" json:"Ascending,omitempty"`
	Limit                 int64           `protobuf:"varint,12,opt,name=Limit,proto3" json:"Limit,omitempty"`
	Offset                int64           `protobuf:"varint,13,opt,name=Offset,proto3" json:"Offset,omitempty"`
	SLimit                int64           `protobuf:"varint,14,opt,name=SLimit,proto3" json:"SLimit,omitempty"`
	SOffset               int64           `protobuf:"varint,15,opt,name=SOffset,proto3" json:"SOffset,omitempty"`
	StripName             bool            `protobuf:"varint,22,opt,name=StripName,proto3" json:"StripName,omitempty"`
	Dedupe                bool            `protobuf:"varint,16,opt,name=Dedupe,proto3" json:"Dedupe,omitempty"`
	MaxSeriesN            int64           `protobuf:"varint,18,opt,name=MaxSeriesN,proto3" json:"MaxSeriesN,omitempty"`
	Ordered               bool            `protobuf:"varint,20,opt,name=Ordered,proto3" json:"Ordered,omitempty"`
	ChunkSize             int64           `protobuf:"varint,25,opt,name=ChunkSize,proto3" json:"ChunkSize,omitempty"`
	MaxParallel           int64           `protobuf:"varint,26,opt,name=MaxParallel,proto3" json:"MaxParallel,omitempty"`
	Query                 string          `protobuf:"bytes,27,opt,name=Query,proto3" json:"Query,omitempty"`
	HintType              int64           `protobuf:"varint,28,opt,name=HintType,proto3" json:"HintType,omitempty"`
	EnableBinaryTreeMerge int64           `protobuf:"varint,29,opt,name=EnableBinaryTreeMerge,proto3" json:"EnableBinaryTreeMerge,omitempty"`
	QueryId               uint64          `protobuf:"varint,30,opt,name=QueryId,proto3" json:"QueryId,omitempty"`
	SeriesKey             []byte          `protobuf:"bytes,31,opt,name=SeriesKey,proto3" json:"SeriesKey,omitempty"`
	GroupByAllDims        bool            `protobuf:"varint,32,opt,name=GroupByAllDims,proto3" json:"GroupByAllDims,omitempty"`
	EngineType            uint32          `protobuf:"varint,33,opt,name=EngineType,proto3" json:"EngineType,omitempty"`
	SortFields            string          `protobuf:"bytes,34,opt,name=SortFields,proto3" json:"SortFields,omitempty"`
	HasFieldWildcard      bool            `protobuf:"varint,35,opt,name=HasFieldWildcard,proto3" json:"HasFieldWildcard,omitempty"`
	LogQueryCurrId        string          `protobuf:"bytes,36,opt,name=LogQueryCurrId,proto3" json:"LogQueryCurrId,omitempty"`
	IncQuery              bool            `protobuf:"varint,37,opt,name=IncQuery,proto3" json:"IncQuery,omitempty"`
	IterID                int32           `protobuf:"varint,38,opt,name=IterID,proto3" json:"IterID,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessorOptions) Descriptor deprecated 

func (*ProcessorOptions) Descriptor() ([]byte, []int)

Deprecated: Use ProcessorOptions.ProtoReflect.Descriptor instead.

func (*ProcessorOptions) GetAscending 

func (x *ProcessorOptions) GetAscending() bool

func (*ProcessorOptions) GetAux 

func (x *ProcessorOptions) GetAux() []*VarRef

func (*ProcessorOptions) GetChunkSize 

func (x *ProcessorOptions) GetChunkSize() int64

func (*ProcessorOptions) GetCondition 

func (x *ProcessorOptions) GetCondition() string

func (*ProcessorOptions) GetDedupe 

func (x *ProcessorOptions) GetDedupe() bool

func (*ProcessorOptions) GetDimensions 

func (x *ProcessorOptions) GetDimensions() []string

func (*ProcessorOptions) GetEnableBinaryTreeMerge 

func (x *ProcessorOptions) GetEnableBinaryTreeMerge() int64

func (*ProcessorOptions) GetEndTime 

func (x *ProcessorOptions) GetEndTime() int64

func (*ProcessorOptions) GetEngineType 

func (x *ProcessorOptions) GetEngineType() uint32

func (*ProcessorOptions) GetExpr 

func (x *ProcessorOptions) GetExpr() string

func (*ProcessorOptions) GetFill 

func (x *ProcessorOptions) GetFill() int32

func (*ProcessorOptions) GetFillValue 

func (x *ProcessorOptions) GetFillValue() float64

func (*ProcessorOptions) GetGroupBy 

func (x *ProcessorOptions) GetGroupBy() map[string]bool

func (*ProcessorOptions) GetGroupByAllDims 

func (x *ProcessorOptions) GetGroupByAllDims() bool

func (*ProcessorOptions) GetHasFieldWildcard 

func (x *ProcessorOptions) GetHasFieldWildcard() bool

func (*ProcessorOptions) GetHintType 

func (x *ProcessorOptions) GetHintType() int64

func (*ProcessorOptions) GetIncQuery 

func (x *ProcessorOptions) GetIncQuery() bool

func (*ProcessorOptions) GetInterval 

func (x *ProcessorOptions) GetInterval() *Interval

func (*ProcessorOptions) GetIterID 

func (x *ProcessorOptions) GetIterID() int32

func (*ProcessorOptions) GetLimit 

func (x *ProcessorOptions) GetLimit() int64

func (*ProcessorOptions) GetLocation 

func (x *ProcessorOptions) GetLocation() string

func (*ProcessorOptions) GetLogQueryCurrId 

func (x *ProcessorOptions) GetLogQueryCurrId() string

func (*ProcessorOptions) GetMaxParallel 

func (x *ProcessorOptions) GetMaxParallel() int64

func (*ProcessorOptions) GetMaxSeriesN 

func (x *ProcessorOptions) GetMaxSeriesN() int64

func (*ProcessorOptions) GetName 

func (x *ProcessorOptions) GetName() string

func (*ProcessorOptions) GetOffset 

func (x *ProcessorOptions) GetOffset() int64

func (*ProcessorOptions) GetOrdered 

func (x *ProcessorOptions) GetOrdered() bool

func (*ProcessorOptions) GetQuery 

func (x *ProcessorOptions) GetQuery() string

func (*ProcessorOptions) GetQueryId 

func (x *ProcessorOptions) GetQueryId() uint64

func (*ProcessorOptions) GetSLimit 

func (x *ProcessorOptions) GetSLimit() int64

func (*ProcessorOptions) GetSOffset 

func (x *ProcessorOptions) GetSOffset() int64

func (*ProcessorOptions) GetSeriesKey 

func (x *ProcessorOptions) GetSeriesKey() []byte

func (*ProcessorOptions) GetSortFields 

func (x *ProcessorOptions) GetSortFields() string

func (*ProcessorOptions) GetSources 

func (x *ProcessorOptions) GetSources() []*Measurement

func (*ProcessorOptions) GetStartTime 

func (x *ProcessorOptions) GetStartTime() int64

func (*ProcessorOptions) GetStripName 

func (x *ProcessorOptions) GetStripName() bool

func (*ProcessorOptions) ProtoMessage 

func (*ProcessorOptions) ProtoMessage()

func (*ProcessorOptions) ProtoReflect 

func (x *ProcessorOptions) ProtoReflect() protoreflect.Message

func (*ProcessorOptions) Reset 

func (x *ProcessorOptions) Reset()

func (*ProcessorOptions) String 

func (x *ProcessorOptions) String() string

type PtQuery 

type PtQuery struct {
	PtID       uint32       `protobuf:"varint,1,opt,name=PtID,proto3" json:"PtID,omitempty"`
	ShardInfos []*ShardInfo `protobuf:"bytes,2,rep,name=ShardInfos,proto3" json:"ShardInfos,omitempty"`
	// contains filtered or unexported fields
}

func (*PtQuery) Descriptor deprecated 

func (*PtQuery) Descriptor() ([]byte, []int)

Deprecated: Use PtQuery.ProtoReflect.Descriptor instead.

func (*PtQuery) GetPtID 

func (x *PtQuery) GetPtID() uint32

func (*PtQuery) GetShardInfos 

func (x *PtQuery) GetShardInfos() []*ShardInfo

func (*PtQuery) ProtoMessage 

func (*PtQuery) ProtoMessage()

func (*PtQuery) ProtoReflect 

func (x *PtQuery) ProtoReflect() protoreflect.Message

func (*PtQuery) Reset 

func (x *PtQuery) Reset()

func (*PtQuery) String 

func (x *PtQuery) String() string

type QueryNode 

type QueryNode struct {
	Name      LogicPlanType  `protobuf:"varint,1,opt,name=Name,proto3,enum=executor.LogicPlanType" json:"Name,omitempty"`
	Inputs    [][]byte       `protobuf:"bytes,3,rep,name=Inputs,proto3" json:"Inputs,omitempty"`
	Ops       []*ExprOptions `protobuf:"bytes,6,rep,name=Ops,proto3" json:"Ops,omitempty"`
	Exchange  uint32         `protobuf:"varint,7,opt,name=Exchange,proto3" json:"Exchange,omitempty"`
	Limit     int64          `protobuf:"varint,8,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset    int64          `protobuf:"varint,9,opt,name=Offset,proto3" json:"Offset,omitempty"`
	LimitType int64          `protobuf:"varint,10,opt,name=limitType,proto3" json:"limitType,omitempty"`
	AggType   AggType        `protobuf:"varint,11,opt,name=AggType,proto3,enum=executor.AggType" json:"AggType,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryNode) Descriptor deprecated 

func (*QueryNode) Descriptor() ([]byte, []int)

Deprecated: Use QueryNode.ProtoReflect.Descriptor instead.

func (*QueryNode) GetAggType 

func (x *QueryNode) GetAggType() AggType

func (*QueryNode) GetExchange 

func (x *QueryNode) GetExchange() uint32

func (*QueryNode) GetInputs 

func (x *QueryNode) GetInputs() [][]byte

func (*QueryNode) GetLimit 

func (x *QueryNode) GetLimit() int64

func (*QueryNode) GetLimitType 

func (x *QueryNode) GetLimitType() int64

func (*QueryNode) GetName 

func (x *QueryNode) GetName() LogicPlanType

func (*QueryNode) GetOffset 

func (x *QueryNode) GetOffset() int64

func (*QueryNode) GetOps 

func (x *QueryNode) GetOps() []*ExprOptions

func (*QueryNode) ProtoMessage 

func (*QueryNode) ProtoMessage()

func (*QueryNode) ProtoReflect 

func (x *QueryNode) ProtoReflect() protoreflect.Message

func (*QueryNode) Reset 

func (x *QueryNode) Reset()

func (*QueryNode) String 

func (x *QueryNode) String() string

type QueryParam 

type QueryParam struct {
	SeriesKey   string  `protobuf:"bytes,1,opt,name=SeriesKey,proto3" json:"SeriesKey,omitempty"`
	TagsAsKey   string  `protobuf:"bytes,2,opt,name=TagsAsKey,proto3" json:"TagsAsKey,omitempty"`
	QueryFields int32   `protobuf:"varint,3,opt,name=QueryFields,proto3" json:"QueryFields,omitempty"`
	QueryPct    float32 `protobuf:"fixed32,4,opt,name=QueryPct,proto3" json:"QueryPct,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryParam) Descriptor deprecated 

func (*QueryParam) Descriptor() ([]byte, []int)

Deprecated: Use QueryParam.ProtoReflect.Descriptor instead.

func (*QueryParam) GetQueryFields 

func (x *QueryParam) GetQueryFields() int32

func (*QueryParam) GetQueryPct 

func (x *QueryParam) GetQueryPct() float32

func (*QueryParam) GetSeriesKey 

func (x *QueryParam) GetSeriesKey() string

func (*QueryParam) GetTagsAsKey 

func (x *QueryParam) GetTagsAsKey() string

func (*QueryParam) ProtoMessage 

func (*QueryParam) ProtoMessage()

func (*QueryParam) ProtoReflect 

func (x *QueryParam) ProtoReflect() protoreflect.Message

func (*QueryParam) Reset 

func (x *QueryParam) Reset()

func (*QueryParam) String 

func (x *QueryParam) String() string

type QuerySchema 

type QuerySchema struct {
	QueryFields string    `protobuf:"bytes,2,opt,name=QueryFields,proto3" json:"QueryFields,omitempty"`
	ColumnNames []string  `protobuf:"bytes,3,rep,name=ColumnNames,proto3" json:"ColumnNames,omitempty"`
	Unnests     []*Unnest `protobuf:"bytes,5,rep,name=Unnests,proto3" json:"Unnests,omitempty"`
	// contains filtered or unexported fields
}

func (*QuerySchema) Descriptor deprecated 

func (*QuerySchema) Descriptor() ([]byte, []int)

Deprecated: Use QuerySchema.ProtoReflect.Descriptor instead.

func (*QuerySchema) GetColumnNames 

func (x *QuerySchema) GetColumnNames() []string

func (*QuerySchema) GetQueryFields 

func (x *QuerySchema) GetQueryFields() string

func (*QuerySchema) GetUnnests 

func (x *QuerySchema) GetUnnests() []*Unnest

func (*QuerySchema) ProtoMessage 

func (*QuerySchema) ProtoMessage()

func (*QuerySchema) ProtoReflect 

func (x *QuerySchema) ProtoReflect() protoreflect.Message

func (*QuerySchema) Reset 

func (x *QuerySchema) Reset()

func (*QuerySchema) String 

func (x *QuerySchema) String() string

type RemoteQuery 

type RemoteQuery struct {
	Database  string     `protobuf:"bytes,1,opt,name=Database,proto3" json:"Database,omitempty"`
	PtID      uint32     `protobuf:"varint,2,opt,name=PtID,proto3" json:"PtID,omitempty"`
	ShardIDs  []uint64   `protobuf:"varint,3,rep,packed,name=ShardIDs,proto3" json:"ShardIDs,omitempty"`
	Opt       []byte     `protobuf:"bytes,4,opt,name=Opt,proto3" json:"Opt,omitempty"`
	NodeID    uint64     `protobuf:"varint,5,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
	Analyze   bool       `protobuf:"varint,6,opt,name=analyze,proto3" json:"analyze,omitempty"`
	QueryNode []byte     `protobuf:"bytes,7,opt,name=QueryNode,proto3" json:"QueryNode,omitempty"`
	PtQuerys  []*PtQuery `protobuf:"bytes,8,rep,name=PtQuerys,proto3" json:"PtQuerys,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoteQuery) Descriptor deprecated 

func (*RemoteQuery) Descriptor() ([]byte, []int)

Deprecated: Use RemoteQuery.ProtoReflect.Descriptor instead.

func (*RemoteQuery) GetAnalyze 

func (x *RemoteQuery) GetAnalyze() bool

func (*RemoteQuery) GetDatabase 

func (x *RemoteQuery) GetDatabase() string

func (*RemoteQuery) GetNodeID 

func (x *RemoteQuery) GetNodeID() uint64

func (*RemoteQuery) GetOpt 

func (x *RemoteQuery) GetOpt() []byte

func (*RemoteQuery) GetPtID 

func (x *RemoteQuery) GetPtID() uint32

func (*RemoteQuery) GetPtQuerys 

func (x *RemoteQuery) GetPtQuerys() []*PtQuery

func (*RemoteQuery) GetQueryNode 

func (x *RemoteQuery) GetQueryNode() []byte

func (*RemoteQuery) GetShardIDs 

func (x *RemoteQuery) GetShardIDs() []uint64

func (*RemoteQuery) ProtoMessage 

func (*RemoteQuery) ProtoMessage()

func (*RemoteQuery) ProtoReflect 

func (x *RemoteQuery) ProtoReflect() protoreflect.Message

func (*RemoteQuery) Reset 

func (x *RemoteQuery) Reset()

func (*RemoteQuery) String 

func (x *RemoteQuery) String() string

type ShardInfo 

type ShardInfo struct {
	ID      uint64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Path    string `protobuf:"bytes,2,opt,name=Path,proto3" json:"Path,omitempty"`
	Version uint32 `protobuf:"varint,3,opt,name=Version,proto3" json:"Version,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardInfo) Descriptor deprecated 

func (*ShardInfo) Descriptor() ([]byte, []int)

Deprecated: Use ShardInfo.ProtoReflect.Descriptor instead.

func (*ShardInfo) GetID 

func (x *ShardInfo) GetID() uint64

func (*ShardInfo) GetPath 

func (x *ShardInfo) GetPath() string

func (*ShardInfo) GetVersion 

func (x *ShardInfo) GetVersion() uint32

func (*ShardInfo) ProtoMessage 

func (*ShardInfo) ProtoMessage()

func (*ShardInfo) ProtoReflect 

func (x *ShardInfo) ProtoReflect() protoreflect.Message

func (*ShardInfo) Reset 

func (x *ShardInfo) Reset()

func (*ShardInfo) String 

func (x *ShardInfo) String() string

type Unnest 

type Unnest struct {
	Expr    string   `protobuf:"bytes,1,opt,name=Expr,proto3" json:"Expr,omitempty"`
	Aliases []string `protobuf:"bytes,2,rep,name=Aliases,proto3" json:"Aliases,omitempty"`
	DstType []int32  `protobuf:"varint,3,rep,packed,name=DstType,proto3" json:"DstType,omitempty"`
	// contains filtered or unexported fields
}

func (*Unnest) Descriptor deprecated 

func (*Unnest) Descriptor() ([]byte, []int)

Deprecated: Use Unnest.ProtoReflect.Descriptor instead.

func (*Unnest) GetAliases 

func (x *Unnest) GetAliases() []string

func (*Unnest) GetDstType 

func (x *Unnest) GetDstType() []int32

func (*Unnest) GetExpr 

func (x *Unnest) GetExpr() string

func (*Unnest) ProtoMessage 

func (*Unnest) ProtoMessage()

func (*Unnest) ProtoReflect 

func (x *Unnest) ProtoReflect() protoreflect.Message

func (*Unnest) Reset 

func (x *Unnest) Reset()

func (*Unnest) String 

func (x *Unnest) String() string

type VarRef 

type VarRef struct {
	Val  string `protobuf:"bytes,1,opt,name=Val,proto3" json:"Val,omitempty"`
	Type int32  `protobuf:"varint,2,opt,name=Type,proto3" json:"Type,omitempty"`
	// contains filtered or unexported fields
}

func (*VarRef) Descriptor deprecated 

func (*VarRef) Descriptor() ([]byte, []int)

Deprecated: Use VarRef.ProtoReflect.Descriptor instead.

func (*VarRef) GetType 

func (x *VarRef) GetType() int32

func (*VarRef) GetVal 

func (x *VarRef) GetVal() string

func (*VarRef) ProtoMessage 

func (*VarRef) ProtoMessage()

func (*VarRef) ProtoReflect 

func (x *VarRef) ProtoReflect() protoreflect.Message

func (*VarRef) Reset 

func (x *VarRef) Reset()

func (*VarRef) String 

func (x *VarRef) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.