common

package
v4.2.789+incompatible Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2020 License: Apache-2.0 Imports: 5 Imported by: 11

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ColumnType_name = map[int32]string{
	0: "COLUMNTYPE_UDEFINED",
	1: "COLUMNTYPE_TAG",
	2: "COLUMNTYPE_FIELD",
}
View Source 
var ColumnType_value = map[string]int32{
	"COLUMNTYPE_UDEFINED": 0,
	"COLUMNTYPE_TAG":      1,
	"COLUMNTYPE_FIELD":    2,
}
View Source 
var DataType_name = map[int32]string{
	0:  "DATATYPE_UNDEFINED",
	1:  "DATATYPE_BOOL",
	2:  "DATATYPE_INT",
	3:  "DATATYPE_INT8",
	4:  "DATATYPE_INT16",
	5:  "DATATYPE_INT32",
	6:  "DATATYPE_INT64",
	7:  "DATATYPE_UINT",
	8:  "DATATYPE_UINT8",
	9:  "DATATYPE_UINT16",
	10: "DATATYPE_UINT32",
	11: "DATATYPE_UTIN64",
	12: "DATATYPE_FLOAT32",
	13: "DATATYPE_FLOAT64",
	14: "DATATYPE_STRING",
}
View Source 
var DataType_value = map[string]int32{
	"DATATYPE_UNDEFINED": 0,
	"DATATYPE_BOOL":      1,
	"DATATYPE_INT":       2,
	"DATATYPE_INT8":      3,
	"DATATYPE_INT16":     4,
	"DATATYPE_INT32":     5,
	"DATATYPE_INT64":     6,
	"DATATYPE_UINT":      7,
	"DATATYPE_UINT8":     8,
	"DATATYPE_UINT16":    9,
	"DATATYPE_UINT32":    10,
	"DATATYPE_UTIN64":    11,
	"DATATYPE_FLOAT32":   12,
	"DATATYPE_FLOAT64":   13,
	"DATATYPE_STRING":    14,
}
View Source 
var DatabaseType_name = map[int32]string{
	0: "UNDEFINED",
	1: "INFLUXDB",
	2: "PROMETHEUS",
}
View Source 
var DatabaseType_value = map[string]int32{
	"UNDEFINED":  0,
	"INFLUXDB":   1,
	"PROMETHEUS": 2,
}
View Source 
var QueryCondition_Order_name = map[int32]string{
	0: "NONE",
	1: "ASC",
	2: "DESC",
}
View Source 
var QueryCondition_Order_value = map[string]int32{
	"NONE": 0,
	"ASC":  1,
	"DESC": 2,
}
View Source 
var RecommendationPolicy_name = map[int32]string{
	0: "RECOMMENDATION_POLICY_UNDEFINED",
	1: "STABLE",
	2: "COMPACT",
}
View Source 
var RecommendationPolicy_value = map[string]int32{
	"RECOMMENDATION_POLICY_UNDEFINED": 0,
	"STABLE":                          1,
	"COMPACT":                         2,
}
View Source 
var TimeRange_AggregateFunction_name = map[int32]string{
	0: "NONE",
	1: "MAX",
	2: "AVG",
}
View Source 
var TimeRange_AggregateFunction_value = map[string]int32{
	"NONE": 0,
	"MAX":  1,
	"AVG":  2,
}

Functions

This section is empty.

Types

type ColumnType 

type ColumnType int32
const (
	ColumnType_COLUMNTYPE_UDEFINED ColumnType = 0
	ColumnType_COLUMNTYPE_TAG      ColumnType = 1
	ColumnType_COLUMNTYPE_FIELD    ColumnType = 2
)

func (ColumnType) EnumDescriptor 

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

func (ColumnType) String 

func (x ColumnType) String() string

type DataType 

type DataType int32
const (
	DataType_DATATYPE_UNDEFINED DataType = 0
	DataType_DATATYPE_BOOL      DataType = 1
	DataType_DATATYPE_INT       DataType = 2
	DataType_DATATYPE_INT8      DataType = 3
	DataType_DATATYPE_INT16     DataType = 4
	DataType_DATATYPE_INT32     DataType = 5
	DataType_DATATYPE_INT64     DataType = 6
	DataType_DATATYPE_UINT      DataType = 7
	DataType_DATATYPE_UINT8     DataType = 8
	DataType_DATATYPE_UINT16    DataType = 9
	DataType_DATATYPE_UINT32    DataType = 10
	DataType_DATATYPE_UTIN64    DataType = 11
	DataType_DATATYPE_FLOAT32   DataType = 12
	DataType_DATATYPE_FLOAT64   DataType = 13
	DataType_DATATYPE_STRING    DataType = 14
)

func (DataType) EnumDescriptor 

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

func (DataType) String 

func (x DataType) String() string

type DatabaseType 

type DatabaseType int32
const (
	DatabaseType_UNDEFINED  DatabaseType = 0
	DatabaseType_INFLUXDB   DatabaseType = 1
	DatabaseType_PROMETHEUS DatabaseType = 2
)

func (DatabaseType) EnumDescriptor 

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

func (DatabaseType) String 

func (x DatabaseType) String() string

type Group 

type Group struct {
	Rows                 []*Row   `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Group) Descriptor 

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

func (*Group) GetRows 

func (m *Group) GetRows() []*Row

func (*Group) ProtoMessage 

func (*Group) ProtoMessage()

func (*Group) Reset 

func (m *Group) Reset()

func (*Group) String 

func (m *Group) String() string

func (*Group) XXX_DiscardUnknown 

func (m *Group) XXX_DiscardUnknown()

func (*Group) XXX_Marshal 

func (m *Group) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Group) XXX_Merge 

func (m *Group) XXX_Merge(src proto.Message)

func (*Group) XXX_Size 

func (m *Group) XXX_Size() int

func (*Group) XXX_Unmarshal 

func (m *Group) XXX_Unmarshal(b []byte) error

type Query 

type Query struct {
	Database             string          `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Table                string          `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Expression           string          `protobuf:"bytes,3,opt,name=expression,proto3" json:"expression,omitempty"`
	Condition            *QueryCondition `protobuf:"bytes,4,opt,name=condition,proto3" json:"condition,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*Query) Descriptor 

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

func (*Query) GetCondition 

func (m *Query) GetCondition() *QueryCondition

func (*Query) GetDatabase 

func (m *Query) GetDatabase() string

func (*Query) GetExpression 

func (m *Query) GetExpression() string

func (*Query) GetTable 

func (m *Query) GetTable() string

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) String 

func (m *Query) String() string

func (*Query) XXX_DiscardUnknown 

func (m *Query) XXX_DiscardUnknown()

func (*Query) XXX_Marshal 

func (m *Query) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Query) XXX_Merge 

func (m *Query) XXX_Merge(src proto.Message)

func (*Query) XXX_Size 

func (m *Query) XXX_Size() int

func (*Query) XXX_Unmarshal 

func (m *Query) XXX_Unmarshal(b []byte) error

type QueryCondition 

type QueryCondition struct {
	TimeRange            *TimeRange           `protobuf:"bytes,1,opt,name=time_range,json=timeRange,proto3" json:"time_range,omitempty"`
	Order                QueryCondition_Order `protobuf:"varint,2,opt,name=order,proto3,enum=containersai.common.QueryCondition_Order" json:"order,omitempty"`
	WhereClause          string               `protobuf:"bytes,3,opt,name=where_clause,json=whereClause,proto3" json:"where_clause,omitempty"`
	Selects              []string             `protobuf:"bytes,4,rep,name=selects,proto3" json:"selects,omitempty"`
	Groups               []string             `protobuf:"bytes,5,rep,name=groups,proto3" json:"groups,omitempty"`
	Limit                uint64               `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*QueryCondition) Descriptor 

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

func (*QueryCondition) GetGroups 

func (m *QueryCondition) GetGroups() []string

func (*QueryCondition) GetLimit 

func (m *QueryCondition) GetLimit() uint64

func (*QueryCondition) GetOrder 

func (m *QueryCondition) GetOrder() QueryCondition_Order

func (*QueryCondition) GetSelects 

func (m *QueryCondition) GetSelects() []string

func (*QueryCondition) GetTimeRange 

func (m *QueryCondition) GetTimeRange() *TimeRange

func (*QueryCondition) GetWhereClause 

func (m *QueryCondition) GetWhereClause() string

func (*QueryCondition) ProtoMessage 

func (*QueryCondition) ProtoMessage()

func (*QueryCondition) Reset 

func (m *QueryCondition) Reset()

func (*QueryCondition) String 

func (m *QueryCondition) String() string

func (*QueryCondition) XXX_DiscardUnknown 

func (m *QueryCondition) XXX_DiscardUnknown()

func (*QueryCondition) XXX_Marshal 

func (m *QueryCondition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryCondition) XXX_Merge 

func (m *QueryCondition) XXX_Merge(src proto.Message)

func (*QueryCondition) XXX_Size 

func (m *QueryCondition) XXX_Size() int

func (*QueryCondition) XXX_Unmarshal 

func (m *QueryCondition) XXX_Unmarshal(b []byte) error

type QueryCondition_Order 

type QueryCondition_Order int32
const (
	QueryCondition_NONE QueryCondition_Order = 0
	QueryCondition_ASC  QueryCondition_Order = 1
	QueryCondition_DESC QueryCondition_Order = 2
)

func (QueryCondition_Order) EnumDescriptor 

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

func (QueryCondition_Order) String 

func (x QueryCondition_Order) String() string

type ReadRawdata 

type ReadRawdata struct {
	Query                *Query   `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	Columns              []string `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	Groups               []*Group `protobuf:"bytes,3,rep,name=groups,proto3" json:"groups,omitempty"`
	Rawdata              string   `protobuf:"bytes,4,opt,name=rawdata,proto3" json:"rawdata,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadRawdata) Descriptor 

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

func (*ReadRawdata) GetColumns 

func (m *ReadRawdata) GetColumns() []string

func (*ReadRawdata) GetGroups 

func (m *ReadRawdata) GetGroups() []*Group

func (*ReadRawdata) GetQuery 

func (m *ReadRawdata) GetQuery() *Query

func (*ReadRawdata) GetRawdata 

func (m *ReadRawdata) GetRawdata() string

func (*ReadRawdata) ProtoMessage 

func (*ReadRawdata) ProtoMessage()

func (*ReadRawdata) Reset 

func (m *ReadRawdata) Reset()

func (*ReadRawdata) String 

func (m *ReadRawdata) String() string

func (*ReadRawdata) XXX_DiscardUnknown 

func (m *ReadRawdata) XXX_DiscardUnknown()

func (*ReadRawdata) XXX_Marshal 

func (m *ReadRawdata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadRawdata) XXX_Merge 

func (m *ReadRawdata) XXX_Merge(src proto.Message)

func (*ReadRawdata) XXX_Size 

func (m *ReadRawdata) XXX_Size() int

func (*ReadRawdata) XXX_Unmarshal 

func (m *ReadRawdata) XXX_Unmarshal(b []byte) error

type RecommendationPolicy 

type RecommendationPolicy int32

Recommendation policy. A policy may be either stable or compact. 

const (
	RecommendationPolicy_RECOMMENDATION_POLICY_UNDEFINED RecommendationPolicy = 0
	RecommendationPolicy_STABLE                          RecommendationPolicy = 1
	RecommendationPolicy_COMPACT                         RecommendationPolicy = 2
)

func (RecommendationPolicy) EnumDescriptor 

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

func (RecommendationPolicy) String 

func (x RecommendationPolicy) String() string

type Row 

type Row struct {
	Time                 *timestamp.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	Values               []string             `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Row) Descriptor 

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

func (*Row) GetTime 

func (m *Row) GetTime() *timestamp.Timestamp

func (*Row) GetValues 

func (m *Row) GetValues() []string

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) Reset 

func (m *Row) Reset()

func (*Row) String 

func (m *Row) String() string

func (*Row) XXX_DiscardUnknown 

func (m *Row) XXX_DiscardUnknown()

func (*Row) XXX_Marshal 

func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Row) XXX_Merge 

func (m *Row) XXX_Merge(src proto.Message)

func (*Row) XXX_Size 

func (m *Row) XXX_Size() int

func (*Row) XXX_Unmarshal 

func (m *Row) XXX_Unmarshal(b []byte) error

type TimeRange 

type TimeRange struct {
	StartTime            *timestamp.Timestamp        `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	EndTime              *timestamp.Timestamp        `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	Timeout              *timestamp.Timestamp        `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
	Step                 *duration.Duration          `protobuf:"bytes,4,opt,name=step,proto3" json:"step,omitempty"`
	AggregateFunction    TimeRange_AggregateFunction `` /* 166-byte string literal not displayed */
	ApplyTime            *timestamp.Timestamp        `protobuf:"bytes,6,opt,name=apply_time,json=applyTime,proto3" json:"apply_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Represents a time range definition

func (*TimeRange) Descriptor 

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

func (*TimeRange) GetAggregateFunction 

func (m *TimeRange) GetAggregateFunction() TimeRange_AggregateFunction

func (*TimeRange) GetApplyTime 

func (m *TimeRange) GetApplyTime() *timestamp.Timestamp

func (*TimeRange) GetEndTime 

func (m *TimeRange) GetEndTime() *timestamp.Timestamp

func (*TimeRange) GetStartTime 

func (m *TimeRange) GetStartTime() *timestamp.Timestamp

func (*TimeRange) GetStep 

func (m *TimeRange) GetStep() *duration.Duration

func (*TimeRange) GetTimeout 

func (m *TimeRange) GetTimeout() *timestamp.Timestamp

func (*TimeRange) ProtoMessage 

func (*TimeRange) ProtoMessage()

func (*TimeRange) Reset 

func (m *TimeRange) Reset()

func (*TimeRange) String 

func (m *TimeRange) String() string

func (*TimeRange) XXX_DiscardUnknown 

func (m *TimeRange) XXX_DiscardUnknown()

func (*TimeRange) XXX_Marshal 

func (m *TimeRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeRange) XXX_Merge 

func (m *TimeRange) XXX_Merge(src proto.Message)

func (*TimeRange) XXX_Size 

func (m *TimeRange) XXX_Size() int

func (*TimeRange) XXX_Unmarshal 

func (m *TimeRange) XXX_Unmarshal(b []byte) error

type TimeRange_AggregateFunction 

type TimeRange_AggregateFunction int32
const (
	TimeRange_NONE TimeRange_AggregateFunction = 0
	TimeRange_MAX  TimeRange_AggregateFunction = 1
	TimeRange_AVG  TimeRange_AggregateFunction = 2
)

func (TimeRange_AggregateFunction) EnumDescriptor 

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

func (TimeRange_AggregateFunction) String 

func (x TimeRange_AggregateFunction) String() string

type WriteRawdata 

type WriteRawdata struct {
	Database             string       `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
	Table                string       `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	Columns              []string     `protobuf:"bytes,3,rep,name=columns,proto3" json:"columns,omitempty"`
	Rows                 []*Row       `protobuf:"bytes,4,rep,name=rows,proto3" json:"rows,omitempty"`
	ColumnTypes          []ColumnType `` /* 138-byte string literal not displayed */
	DataTypes            []DataType   `` /* 130-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*WriteRawdata) Descriptor 

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

func (*WriteRawdata) GetColumnTypes 

func (m *WriteRawdata) GetColumnTypes() []ColumnType

func (*WriteRawdata) GetColumns 

func (m *WriteRawdata) GetColumns() []string

func (*WriteRawdata) GetDataTypes 

func (m *WriteRawdata) GetDataTypes() []DataType

func (*WriteRawdata) GetDatabase 

func (m *WriteRawdata) GetDatabase() string

func (*WriteRawdata) GetRows 

func (m *WriteRawdata) GetRows() []*Row

func (*WriteRawdata) GetTable 

func (m *WriteRawdata) GetTable() string

func (*WriteRawdata) ProtoMessage 

func (*WriteRawdata) ProtoMessage()

func (*WriteRawdata) Reset 

func (m *WriteRawdata) Reset()

func (*WriteRawdata) String 

func (m *WriteRawdata) String() string

func (*WriteRawdata) XXX_DiscardUnknown 

func (m *WriteRawdata) XXX_DiscardUnknown()

func (*WriteRawdata) XXX_Marshal 

func (m *WriteRawdata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteRawdata) XXX_Merge 

func (m *WriteRawdata) XXX_Merge(src proto.Message)

func (*WriteRawdata) XXX_Size 

func (m *WriteRawdata) XXX_Size() int

func (*WriteRawdata) XXX_Unmarshal 

func (m *WriteRawdata) XXX_Unmarshal(b []byte) error

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.