datatypes

package
v0.10.2 Latest Latest
Warning

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

Go to latest
Published: Mar 25, 2022 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	Node_Type_name = map[int32]string{
		0: "TypeLogicalExpression",
		1: "TypeComparisonExpression",
		2: "TypeParenExpression",
		3: "TypeTagRef",
		4: "TypeLiteral",
		5: "TypeFieldRef",
	}
	Node_Type_value = map[string]int32{
		"TypeLogicalExpression":    0,
		"TypeComparisonExpression": 1,
		"TypeParenExpression":      2,
		"TypeTagRef":               3,
		"TypeLiteral":              4,
		"TypeFieldRef":             5,
	}
)

Enum value maps for Node_Type.

View Source
var (
	Node_Comparison_name = map[int32]string{
		0: "ComparisonEqual",
		1: "ComparisonNotEqual",
		2: "ComparisonStartsWith",
		3: "ComparisonRegex",
		4: "ComparisonNotRegex",
		5: "ComparisonLess",
		6: "ComparisonLessEqual",
		7: "ComparisonGreater",
		8: "ComparisonGreaterEqual",
	}
	Node_Comparison_value = map[string]int32{
		"ComparisonEqual":        0,
		"ComparisonNotEqual":     1,
		"ComparisonStartsWith":   2,
		"ComparisonRegex":        3,
		"ComparisonNotRegex":     4,
		"ComparisonLess":         5,
		"ComparisonLessEqual":    6,
		"ComparisonGreater":      7,
		"ComparisonGreaterEqual": 8,
	}
)

Enum value maps for Node_Comparison.

View Source
var (
	Node_Logical_name = map[int32]string{
		0: "LogicalAnd",
		1: "LogicalOr",
	}
	Node_Logical_value = map[string]int32{
		"LogicalAnd": 0,
		"LogicalOr":  1,
	}
)

Enum value maps for Node_Logical.

View Source
var (
	ReadGroupRequest_Group_name = map[int32]string{
		0: "GroupNone",
		2: "GroupBy",
	}
	ReadGroupRequest_Group_value = map[string]int32{
		"GroupNone": 0,
		"GroupBy":   2,
	}
)

Enum value maps for ReadGroupRequest_Group.

View Source
var (
	ReadGroupRequest_HintFlags_name = map[int32]string{
		0: "HintNone",
		1: "HintNoPoints",
		2: "HintNoSeries",
		4: "HintSchemaAllTime",
	}
	ReadGroupRequest_HintFlags_value = map[string]int32{
		"HintNone":          0,
		"HintNoPoints":      1,
		"HintNoSeries":      2,
		"HintSchemaAllTime": 4,
	}
)

Enum value maps for ReadGroupRequest_HintFlags.

View Source
var (
	Aggregate_AggregateType_name = map[int32]string{
		0: "AggregateTypeNone",
		1: "AggregateTypeSum",
		2: "AggregateTypeCount",
		3: "AggregateTypeMin",
		4: "AggregateTypeMax",
		5: "AggregateTypeFirst",
		6: "AggregateTypeLast",
		7: "AggregateTypeMean",
	}
	Aggregate_AggregateType_value = map[string]int32{
		"AggregateTypeNone":  0,
		"AggregateTypeSum":   1,
		"AggregateTypeCount": 2,
		"AggregateTypeMin":   3,
		"AggregateTypeMax":   4,
		"AggregateTypeFirst": 5,
		"AggregateTypeLast":  6,
		"AggregateTypeMean":  7,
	}
)

Enum value maps for Aggregate_AggregateType.

View Source
var (
	ReadResponse_FrameType_name = map[int32]string{
		0: "FrameTypeSeries",
		1: "FrameTypePoints",
	}
	ReadResponse_FrameType_value = map[string]int32{
		"FrameTypeSeries": 0,
		"FrameTypePoints": 1,
	}
)

Enum value maps for ReadResponse_FrameType.

View Source
var (
	ReadResponse_DataType_name = map[int32]string{
		0: "DataTypeFloat",
		1: "DataTypeInteger",
		2: "DataTypeUnsigned",
		3: "DataTypeBoolean",
		4: "DataTypeString",
		5: "DataTypeMulti",
	}
	ReadResponse_DataType_value = map[string]int32{
		"DataTypeFloat":    0,
		"DataTypeInteger":  1,
		"DataTypeUnsigned": 2,
		"DataTypeBoolean":  3,
		"DataTypeString":   4,
		"DataTypeMulti":    5,
	}
)

Enum value maps for ReadResponse_DataType.

View Source
var AggregateNameMap = make(map[string]int32)

AggregateNameMap is a set of uppercase aggregate names.

View Source
var File_predicate_proto protoreflect.FileDescriptor
View Source
var File_storage_common_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Aggregate

type Aggregate struct {
	Type Aggregate_AggregateType `protobuf:"varint,1,opt,name=type,proto3,enum=cnosdb.platform.storage.Aggregate_AggregateType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*Aggregate) Descriptor deprecated

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

Deprecated: Use Aggregate.ProtoReflect.Descriptor instead.

func (*Aggregate) GetType

func (x *Aggregate) GetType() Aggregate_AggregateType

func (*Aggregate) ProtoMessage

func (*Aggregate) ProtoMessage()

func (*Aggregate) ProtoReflect

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

func (*Aggregate) Reset

func (x *Aggregate) Reset()

func (*Aggregate) String

func (x *Aggregate) String() string

type Aggregate_AggregateType

type Aggregate_AggregateType int32
const (
	Aggregate_AggregateTypeNone  Aggregate_AggregateType = 0
	Aggregate_AggregateTypeSum   Aggregate_AggregateType = 1
	Aggregate_AggregateTypeCount Aggregate_AggregateType = 2
	Aggregate_AggregateTypeMin   Aggregate_AggregateType = 3
	Aggregate_AggregateTypeMax   Aggregate_AggregateType = 4
	Aggregate_AggregateTypeFirst Aggregate_AggregateType = 5
	Aggregate_AggregateTypeLast  Aggregate_AggregateType = 6
	Aggregate_AggregateTypeMean  Aggregate_AggregateType = 7
)

func (Aggregate_AggregateType) Descriptor

func (Aggregate_AggregateType) Enum

func (Aggregate_AggregateType) EnumDescriptor deprecated

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

Deprecated: Use Aggregate_AggregateType.Descriptor instead.

func (Aggregate_AggregateType) Number

func (Aggregate_AggregateType) String

func (x Aggregate_AggregateType) String() string

func (Aggregate_AggregateType) Type

type CapabilitiesResponse

type CapabilitiesResponse struct {
	Caps map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CapabilitiesResponse) Descriptor deprecated

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

Deprecated: Use CapabilitiesResponse.ProtoReflect.Descriptor instead.

func (*CapabilitiesResponse) GetCaps

func (x *CapabilitiesResponse) GetCaps() map[string]string

func (*CapabilitiesResponse) ProtoMessage

func (*CapabilitiesResponse) ProtoMessage()

func (*CapabilitiesResponse) ProtoReflect

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

func (*CapabilitiesResponse) Reset

func (x *CapabilitiesResponse) Reset()

func (*CapabilitiesResponse) String

func (x *CapabilitiesResponse) String() string

type Duration

type Duration struct {
	Nsecs    int64 `protobuf:"varint,1,opt,name=nsecs,proto3" json:"nsecs,omitempty"`
	Months   int64 `protobuf:"varint,2,opt,name=months,proto3" json:"months,omitempty"`
	Negative bool  `protobuf:"varint,3,opt,name=negative,proto3" json:"negative,omitempty"`
	// contains filtered or unexported fields
}

func (*Duration) Descriptor deprecated

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

Deprecated: Use Duration.ProtoReflect.Descriptor instead.

func (*Duration) GetMonths

func (x *Duration) GetMonths() int64

func (*Duration) GetNegative

func (x *Duration) GetNegative() bool

func (*Duration) GetNsecs

func (x *Duration) GetNsecs() int64

func (*Duration) ProtoMessage

func (*Duration) ProtoMessage()

func (*Duration) ProtoReflect

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

func (*Duration) Reset

func (x *Duration) Reset()

func (*Duration) String

func (x *Duration) String() string

type HintFlags

type HintFlags uint32

func (HintFlags) HintSchemaAllTime

func (h HintFlags) HintSchemaAllTime() bool

func (HintFlags) NoPoints

func (h HintFlags) NoPoints() bool

func (HintFlags) NoSeries

func (h HintFlags) NoSeries() bool

func (*HintFlags) SetHintSchemaAllTime

func (h *HintFlags) SetHintSchemaAllTime()

func (*HintFlags) SetNoPoints

func (h *HintFlags) SetNoPoints()

func (*HintFlags) SetNoSeries

func (h *HintFlags) SetNoSeries()

func (HintFlags) String

func (h HintFlags) String() string

type Node

type Node struct {
	NodeType Node_Type `protobuf:"varint,1,opt,name=node_type,json=nodeType,proto3,enum=cnosdb.platform.storage.Node_Type" json:"node_type,omitempty"`
	Children []*Node   `protobuf:"bytes,2,rep,name=children,proto3" json:"children,omitempty"`
	// Types that are assignable to Value:
	//	*Node_StringValue
	//	*Node_BooleanValue
	//	*Node_IntegerValue
	//	*Node_UnsignedValue
	//	*Node_FloatValue
	//	*Node_RegexValue
	//	*Node_TagRefValue
	//	*Node_FieldRefValue
	//	*Node_Logical_
	//	*Node_Comparison_
	Value isNode_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Node) Descriptor deprecated

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

func (*Node) GetBooleanValue

func (x *Node) GetBooleanValue() bool

func (*Node) GetChildren

func (x *Node) GetChildren() []*Node

func (*Node) GetComparison

func (x *Node) GetComparison() Node_Comparison

func (*Node) GetFieldRefValue

func (x *Node) GetFieldRefValue() string

func (*Node) GetFloatValue

func (x *Node) GetFloatValue() float64

func (*Node) GetIntegerValue

func (x *Node) GetIntegerValue() int64

func (*Node) GetLogical

func (x *Node) GetLogical() Node_Logical

func (*Node) GetNodeType

func (x *Node) GetNodeType() Node_Type

func (*Node) GetRegexValue

func (x *Node) GetRegexValue() string

func (*Node) GetStringValue

func (x *Node) GetStringValue() string

func (*Node) GetTagRefValue

func (x *Node) GetTagRefValue() []byte

func (*Node) GetUnsignedValue

func (x *Node) GetUnsignedValue() uint64

func (*Node) GetValue

func (m *Node) GetValue() isNode_Value

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) ProtoReflect

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

func (*Node) Reset

func (x *Node) Reset()

func (*Node) String

func (x *Node) String() string

type Node_BooleanValue

type Node_BooleanValue struct {
	BooleanValue bool `protobuf:"varint,4,opt,name=BooleanValue,proto3,oneof"`
}

type Node_Comparison

type Node_Comparison int32
const (
	Node_ComparisonEqual        Node_Comparison = 0
	Node_ComparisonNotEqual     Node_Comparison = 1
	Node_ComparisonStartsWith   Node_Comparison = 2
	Node_ComparisonRegex        Node_Comparison = 3
	Node_ComparisonNotRegex     Node_Comparison = 4
	Node_ComparisonLess         Node_Comparison = 5
	Node_ComparisonLessEqual    Node_Comparison = 6
	Node_ComparisonGreater      Node_Comparison = 7
	Node_ComparisonGreaterEqual Node_Comparison = 8
)

func (Node_Comparison) Descriptor

func (Node_Comparison) Enum

func (x Node_Comparison) Enum() *Node_Comparison

func (Node_Comparison) EnumDescriptor deprecated

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

Deprecated: Use Node_Comparison.Descriptor instead.

func (Node_Comparison) Number

func (Node_Comparison) String

func (x Node_Comparison) String() string

func (Node_Comparison) Type

type Node_Comparison_

type Node_Comparison_ struct {
	Comparison Node_Comparison `protobuf:"varint,12,opt,name=comparison,proto3,enum=cnosdb.platform.storage.Node_Comparison,oneof"`
}

type Node_FieldRefValue

type Node_FieldRefValue struct {
	FieldRefValue string `protobuf:"bytes,10,opt,name=FieldRefValue,proto3,oneof"`
}

type Node_FloatValue

type Node_FloatValue struct {
	FloatValue float64 `protobuf:"fixed64,7,opt,name=FloatValue,proto3,oneof"`
}

type Node_IntegerValue

type Node_IntegerValue struct {
	IntegerValue int64 `protobuf:"varint,5,opt,name=IntegerValue,proto3,oneof"`
}

type Node_Logical

type Node_Logical int32

Logical operators apply to boolean values and combine to produce a single boolean result.

const (
	Node_LogicalAnd Node_Logical = 0
	Node_LogicalOr  Node_Logical = 1
)

func (Node_Logical) Descriptor

func (Node_Logical) Enum

func (x Node_Logical) Enum() *Node_Logical

func (Node_Logical) EnumDescriptor deprecated

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

Deprecated: Use Node_Logical.Descriptor instead.

func (Node_Logical) Number

func (Node_Logical) String

func (x Node_Logical) String() string

func (Node_Logical) Type

type Node_Logical_

type Node_Logical_ struct {
	Logical Node_Logical `protobuf:"varint,11,opt,name=logical,proto3,enum=cnosdb.platform.storage.Node_Logical,oneof"`
}

type Node_RegexValue

type Node_RegexValue struct {
	RegexValue string `protobuf:"bytes,8,opt,name=RegexValue,proto3,oneof"`
}

type Node_StringValue

type Node_StringValue struct {
	StringValue string `protobuf:"bytes,3,opt,name=StringValue,proto3,oneof"`
}

type Node_TagRefValue

type Node_TagRefValue struct {
	TagRefValue []byte `protobuf:"bytes,9,opt,name=TagRefValue,proto3,oneof"`
}

type Node_Type

type Node_Type int32
const (
	Node_TypeLogicalExpression    Node_Type = 0
	Node_TypeComparisonExpression Node_Type = 1
	Node_TypeParenExpression      Node_Type = 2
	Node_TypeTagRef               Node_Type = 3
	Node_TypeLiteral              Node_Type = 4
	Node_TypeFieldRef             Node_Type = 5
)

func (Node_Type) Descriptor

func (Node_Type) Descriptor() protoreflect.EnumDescriptor

func (Node_Type) Enum

func (x Node_Type) Enum() *Node_Type

func (Node_Type) EnumDescriptor deprecated

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

Deprecated: Use Node_Type.Descriptor instead.

func (Node_Type) Number

func (x Node_Type) Number() protoreflect.EnumNumber

func (Node_Type) String

func (x Node_Type) String() string

func (Node_Type) Type

type Node_UnsignedValue

type Node_UnsignedValue struct {
	UnsignedValue uint64 `protobuf:"varint,6,opt,name=UnsignedValue,proto3,oneof"`
}

type Predicate

type Predicate struct {
	Root *Node `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
	// contains filtered or unexported fields
}

func (*Predicate) Descriptor deprecated

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

Deprecated: Use Predicate.ProtoReflect.Descriptor instead.

func (*Predicate) GetRoot

func (x *Predicate) GetRoot() *Node

func (*Predicate) ProtoMessage

func (*Predicate) ProtoMessage()

func (*Predicate) ProtoReflect

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

func (*Predicate) Reset

func (x *Predicate) Reset()

func (*Predicate) String

func (x *Predicate) String() string

type ReadFilterRequest

type ReadFilterRequest struct {
	ReadSource *anypb.Any      `protobuf:"bytes,1,opt,name=ReadSource,proto3" json:"ReadSource,omitempty"`
	Range      *TimestampRange `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	Predicate  *Predicate      `protobuf:"bytes,3,opt,name=predicate,proto3" json:"predicate,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadFilterRequest) Descriptor deprecated

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

Deprecated: Use ReadFilterRequest.ProtoReflect.Descriptor instead.

func (*ReadFilterRequest) GetPredicate

func (x *ReadFilterRequest) GetPredicate() *Predicate

func (*ReadFilterRequest) GetRange

func (x *ReadFilterRequest) GetRange() *TimestampRange

func (*ReadFilterRequest) GetReadSource

func (x *ReadFilterRequest) GetReadSource() *anypb.Any

func (*ReadFilterRequest) ProtoMessage

func (*ReadFilterRequest) ProtoMessage()

func (*ReadFilterRequest) ProtoReflect

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

func (*ReadFilterRequest) Reset

func (x *ReadFilterRequest) Reset()

func (*ReadFilterRequest) String

func (x *ReadFilterRequest) String() string

type ReadGroupRequest

type ReadGroupRequest struct {
	ReadSource *anypb.Any      `protobuf:"bytes,1,opt,name=ReadSource,proto3" json:"ReadSource,omitempty"`
	Range      *TimestampRange `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	Predicate  *Predicate      `protobuf:"bytes,3,opt,name=predicate,proto3" json:"predicate,omitempty"`
	// GroupKeys specifies a list of tag keys used to order the data.
	// It is dependent on the Group property to determine its behavior.
	GroupKeys []string               `protobuf:"bytes,4,rep,name=GroupKeys,proto3" json:"GroupKeys,omitempty"`
	Group     ReadGroupRequest_Group `protobuf:"varint,5,opt,name=group,proto3,enum=cnosdb.platform.storage.ReadGroupRequest_Group" json:"group,omitempty"`
	Aggregate *Aggregate             `protobuf:"bytes,6,opt,name=aggregate,proto3" json:"aggregate,omitempty"`
	Hints     uint32                 `protobuf:"fixed32,7,opt,name=Hints,proto3" json:"Hints,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadGroupRequest) Descriptor deprecated

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

Deprecated: Use ReadGroupRequest.ProtoReflect.Descriptor instead.

func (*ReadGroupRequest) GetAggregate

func (x *ReadGroupRequest) GetAggregate() *Aggregate

func (*ReadGroupRequest) GetGroup

func (*ReadGroupRequest) GetGroupKeys

func (x *ReadGroupRequest) GetGroupKeys() []string

func (*ReadGroupRequest) GetHints

func (x *ReadGroupRequest) GetHints() uint32

func (*ReadGroupRequest) GetPredicate

func (x *ReadGroupRequest) GetPredicate() *Predicate

func (*ReadGroupRequest) GetRange

func (x *ReadGroupRequest) GetRange() *TimestampRange

func (*ReadGroupRequest) GetReadSource

func (x *ReadGroupRequest) GetReadSource() *anypb.Any

func (*ReadGroupRequest) ProtoMessage

func (*ReadGroupRequest) ProtoMessage()

func (*ReadGroupRequest) ProtoReflect

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

func (*ReadGroupRequest) Reset

func (x *ReadGroupRequest) Reset()

func (*ReadGroupRequest) String

func (x *ReadGroupRequest) String() string

type ReadGroupRequest_Group

type ReadGroupRequest_Group int32
const (
	// GroupNone returns all series as a single group.
	// The single GroupFrame.TagKeys will be the union of all tag keys.
	ReadGroupRequest_GroupNone ReadGroupRequest_Group = 0
	// GroupBy returns a group for each unique value of the specified GroupKeys.
	ReadGroupRequest_GroupBy ReadGroupRequest_Group = 2
)

func (ReadGroupRequest_Group) Descriptor

func (ReadGroupRequest_Group) Enum

func (ReadGroupRequest_Group) EnumDescriptor deprecated

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

Deprecated: Use ReadGroupRequest_Group.Descriptor instead.

func (ReadGroupRequest_Group) Number

func (ReadGroupRequest_Group) String

func (x ReadGroupRequest_Group) String() string

func (ReadGroupRequest_Group) Type

type ReadGroupRequest_HintFlags

type ReadGroupRequest_HintFlags int32

TODO(jlapacik): This field is only used in unit tests. Specifically the two tests in group_resultset_test.go. This field should be removed and the tests that depend on it refactored.

const (
	ReadGroupRequest_HintNone     ReadGroupRequest_HintFlags = 0
	ReadGroupRequest_HintNoPoints ReadGroupRequest_HintFlags = 1
	ReadGroupRequest_HintNoSeries ReadGroupRequest_HintFlags = 2
	// HintSchemaAllTime performs schema queries without using time ranges
	ReadGroupRequest_HintSchemaAllTime ReadGroupRequest_HintFlags = 4
)

func (ReadGroupRequest_HintFlags) Descriptor

func (ReadGroupRequest_HintFlags) Enum

func (ReadGroupRequest_HintFlags) EnumDescriptor deprecated

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

Deprecated: Use ReadGroupRequest_HintFlags.Descriptor instead.

func (ReadGroupRequest_HintFlags) Number

func (ReadGroupRequest_HintFlags) String

func (ReadGroupRequest_HintFlags) Type

type ReadResponse

type ReadResponse struct {
	Frames []*ReadResponse_Frame `protobuf:"bytes,1,rep,name=frames,proto3" json:"frames,omitempty"`
	// contains filtered or unexported fields
}

Response message for ReadFilter and ReadGroup

func (*ReadResponse) Descriptor deprecated

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

Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.

func (*ReadResponse) GetFrames

func (x *ReadResponse) GetFrames() []*ReadResponse_Frame

func (*ReadResponse) ProtoMessage

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) ProtoReflect

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

func (*ReadResponse) Reset

func (x *ReadResponse) Reset()

func (*ReadResponse) String

func (x *ReadResponse) String() string

type ReadResponse_AnyPoints

type ReadResponse_AnyPoints struct {

	// Types that are assignable to Data:
	//	*ReadResponse_AnyPoints_Floats
	//	*ReadResponse_AnyPoints_Integers
	//	*ReadResponse_AnyPoints_Unsigneds
	//	*ReadResponse_AnyPoints_Booleans
	//	*ReadResponse_AnyPoints_Strings
	Data isReadResponse_AnyPoints_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*ReadResponse_AnyPoints) Descriptor deprecated

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

Deprecated: Use ReadResponse_AnyPoints.ProtoReflect.Descriptor instead.

func (*ReadResponse_AnyPoints) GetBooleans

func (*ReadResponse_AnyPoints) GetData

func (m *ReadResponse_AnyPoints) GetData() isReadResponse_AnyPoints_Data

func (*ReadResponse_AnyPoints) GetFloats

func (*ReadResponse_AnyPoints) GetIntegers

func (*ReadResponse_AnyPoints) GetStrings

func (*ReadResponse_AnyPoints) GetUnsigneds

func (*ReadResponse_AnyPoints) ProtoMessage

func (*ReadResponse_AnyPoints) ProtoMessage()

func (*ReadResponse_AnyPoints) ProtoReflect

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

func (*ReadResponse_AnyPoints) Reset

func (x *ReadResponse_AnyPoints) Reset()

func (*ReadResponse_AnyPoints) String

func (x *ReadResponse_AnyPoints) String() string

type ReadResponse_AnyPoints_Booleans

type ReadResponse_AnyPoints_Booleans struct {
	Booleans *ReadResponse_BooleanValues `protobuf:"bytes,4,opt,name=booleans,proto3,oneof"`
}

type ReadResponse_AnyPoints_Floats

type ReadResponse_AnyPoints_Floats struct {
	Floats *ReadResponse_FloatValues `protobuf:"bytes,1,opt,name=floats,proto3,oneof"`
}

type ReadResponse_AnyPoints_Integers

type ReadResponse_AnyPoints_Integers struct {
	Integers *ReadResponse_IntegerValues `protobuf:"bytes,2,opt,name=integers,proto3,oneof"`
}

type ReadResponse_AnyPoints_Strings

type ReadResponse_AnyPoints_Strings struct {
	Strings *ReadResponse_StringValues `protobuf:"bytes,5,opt,name=strings,proto3,oneof"`
}

type ReadResponse_AnyPoints_Unsigneds

type ReadResponse_AnyPoints_Unsigneds struct {
	Unsigneds *ReadResponse_UnsignedValues `protobuf:"bytes,3,opt,name=unsigneds,proto3,oneof"`
}

type ReadResponse_BooleanPointsFrame

type ReadResponse_BooleanPointsFrame struct {
	Timestamps []int64 `protobuf:"fixed64,1,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"`
	Values     []bool  `protobuf:"varint,2,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse_BooleanPointsFrame) Descriptor deprecated

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

Deprecated: Use ReadResponse_BooleanPointsFrame.ProtoReflect.Descriptor instead.

func (*ReadResponse_BooleanPointsFrame) GetTimestamps

func (x *ReadResponse_BooleanPointsFrame) GetTimestamps() []int64

func (*ReadResponse_BooleanPointsFrame) GetValues

func (x *ReadResponse_BooleanPointsFrame) GetValues() []bool

func (*ReadResponse_BooleanPointsFrame) ProtoMessage

func (*ReadResponse_BooleanPointsFrame) ProtoMessage()

func (*ReadResponse_BooleanPointsFrame) ProtoReflect

func (*ReadResponse_BooleanPointsFrame) Reset

func (*ReadResponse_BooleanPointsFrame) String

type ReadResponse_BooleanValues

type ReadResponse_BooleanValues struct {
	Values []bool `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse_BooleanValues) Descriptor deprecated

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

Deprecated: Use ReadResponse_BooleanValues.ProtoReflect.Descriptor instead.

func (*ReadResponse_BooleanValues) GetValues

func (x *ReadResponse_BooleanValues) GetValues() []bool

func (*ReadResponse_BooleanValues) ProtoMessage

func (*ReadResponse_BooleanValues) ProtoMessage()

func (*ReadResponse_BooleanValues) ProtoReflect

func (*ReadResponse_BooleanValues) Reset

func (x *ReadResponse_BooleanValues) Reset()

func (*ReadResponse_BooleanValues) String

func (x *ReadResponse_BooleanValues) String() string

type ReadResponse_DataType

type ReadResponse_DataType int32
const (
	ReadResponse_DataTypeFloat    ReadResponse_DataType = 0
	ReadResponse_DataTypeInteger  ReadResponse_DataType = 1
	ReadResponse_DataTypeUnsigned ReadResponse_DataType = 2
	ReadResponse_DataTypeBoolean  ReadResponse_DataType = 3
	ReadResponse_DataTypeString   ReadResponse_DataType = 4
	ReadResponse_DataTypeMulti    ReadResponse_DataType = 5
)

func (ReadResponse_DataType) Descriptor

func (ReadResponse_DataType) Enum

func (ReadResponse_DataType) EnumDescriptor deprecated

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

Deprecated: Use ReadResponse_DataType.Descriptor instead.

func (ReadResponse_DataType) Number

func (ReadResponse_DataType) String

func (x ReadResponse_DataType) String() string

func (ReadResponse_DataType) Type

type ReadResponse_FloatPointsFrame

type ReadResponse_FloatPointsFrame struct {
	Timestamps []int64   `protobuf:"fixed64,1,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"`
	Values     []float64 `protobuf:"fixed64,2,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse_FloatPointsFrame) Descriptor deprecated

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

Deprecated: Use ReadResponse_FloatPointsFrame.ProtoReflect.Descriptor instead.

func (*ReadResponse_FloatPointsFrame) GetTimestamps

func (x *ReadResponse_FloatPointsFrame) GetTimestamps() []int64

func (*ReadResponse_FloatPointsFrame) GetValues

func (x *ReadResponse_FloatPointsFrame) GetValues() []float64

func (*ReadResponse_FloatPointsFrame) ProtoMessage

func (*ReadResponse_FloatPointsFrame) ProtoMessage()

func (*ReadResponse_FloatPointsFrame) ProtoReflect

func (*ReadResponse_FloatPointsFrame) Reset

func (x *ReadResponse_FloatPointsFrame) Reset()

func (*ReadResponse_FloatPointsFrame) String

type ReadResponse_FloatValues

type ReadResponse_FloatValues struct {
	Values []float64 `protobuf:"fixed64,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse_FloatValues) Descriptor deprecated

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

Deprecated: Use ReadResponse_FloatValues.ProtoReflect.Descriptor instead.

func (*ReadResponse_FloatValues) GetValues

func (x *ReadResponse_FloatValues) GetValues() []float64

func (*ReadResponse_FloatValues) ProtoMessage

func (*ReadResponse_FloatValues) ProtoMessage()

func (*ReadResponse_FloatValues) ProtoReflect

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

func (*ReadResponse_FloatValues) Reset

func (x *ReadResponse_FloatValues) Reset()

func (*ReadResponse_FloatValues) String

func (x *ReadResponse_FloatValues) String() string

type ReadResponse_Frame

type ReadResponse_Frame struct {

	// Types that are assignable to Data:
	//	*ReadResponse_Frame_Group
	//	*ReadResponse_Frame_Series
	//	*ReadResponse_Frame_FloatPoints
	//	*ReadResponse_Frame_IntegerPoints
	//	*ReadResponse_Frame_UnsignedPoints
	//	*ReadResponse_Frame_BooleanPoints
	//	*ReadResponse_Frame_StringPoints
	//	*ReadResponse_Frame_MultiPoints
	Data isReadResponse_Frame_Data `protobuf_oneof:"data"`
	// contains filtered or unexported fields
}

func (*ReadResponse_Frame) Descriptor deprecated

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

Deprecated: Use ReadResponse_Frame.ProtoReflect.Descriptor instead.

func (*ReadResponse_Frame) GetBooleanPoints

func (x *ReadResponse_Frame) GetBooleanPoints() *ReadResponse_BooleanPointsFrame

func (*ReadResponse_Frame) GetData

func (m *ReadResponse_Frame) GetData() isReadResponse_Frame_Data

func (*ReadResponse_Frame) GetFloatPoints

func (*ReadResponse_Frame) GetGroup

func (*ReadResponse_Frame) GetIntegerPoints

func (x *ReadResponse_Frame) GetIntegerPoints() *ReadResponse_IntegerPointsFrame

func (*ReadResponse_Frame) GetMultiPoints

func (*ReadResponse_Frame) GetSeries

func (*ReadResponse_Frame) GetStringPoints

func (x *ReadResponse_Frame) GetStringPoints() *ReadResponse_StringPointsFrame

func (*ReadResponse_Frame) GetUnsignedPoints

func (x *ReadResponse_Frame) GetUnsignedPoints() *ReadResponse_UnsignedPointsFrame

func (*ReadResponse_Frame) ProtoMessage

func (*ReadResponse_Frame) ProtoMessage()

func (*ReadResponse_Frame) ProtoReflect

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

func (*ReadResponse_Frame) Reset

func (x *ReadResponse_Frame) Reset()

func (*ReadResponse_Frame) String

func (x *ReadResponse_Frame) String() string

type ReadResponse_FrameType

type ReadResponse_FrameType int32
const (
	ReadResponse_FrameTypeSeries ReadResponse_FrameType = 0
	ReadResponse_FrameTypePoints ReadResponse_FrameType = 1
)

func (ReadResponse_FrameType) Descriptor

func (ReadResponse_FrameType) Enum

func (ReadResponse_FrameType) EnumDescriptor deprecated

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

Deprecated: Use ReadResponse_FrameType.Descriptor instead.

func (ReadResponse_FrameType) Number

func (ReadResponse_FrameType) String

func (x ReadResponse_FrameType) String() string

func (ReadResponse_FrameType) Type

type ReadResponse_Frame_BooleanPoints

type ReadResponse_Frame_BooleanPoints struct {
	BooleanPoints *ReadResponse_BooleanPointsFrame `protobuf:"bytes,5,opt,name=BooleanPoints,proto3,oneof"`
}

type ReadResponse_Frame_FloatPoints

type ReadResponse_Frame_FloatPoints struct {
	FloatPoints *ReadResponse_FloatPointsFrame `protobuf:"bytes,2,opt,name=FloatPoints,proto3,oneof"`
}

type ReadResponse_Frame_Group

type ReadResponse_Frame_Group struct {
	Group *ReadResponse_GroupFrame `protobuf:"bytes,7,opt,name=group,proto3,oneof"`
}

type ReadResponse_Frame_IntegerPoints

type ReadResponse_Frame_IntegerPoints struct {
	IntegerPoints *ReadResponse_IntegerPointsFrame `protobuf:"bytes,3,opt,name=IntegerPoints,proto3,oneof"`
}

type ReadResponse_Frame_MultiPoints

type ReadResponse_Frame_MultiPoints struct {
	MultiPoints *ReadResponse_MultiPointsFrame `protobuf:"bytes,8,opt,name=MultiPoints,proto3,oneof"`
}

type ReadResponse_Frame_Series

type ReadResponse_Frame_Series struct {
	Series *ReadResponse_SeriesFrame `protobuf:"bytes,1,opt,name=series,proto3,oneof"`
}

type ReadResponse_Frame_StringPoints

type ReadResponse_Frame_StringPoints struct {
	StringPoints *ReadResponse_StringPointsFrame `protobuf:"bytes,6,opt,name=StringPoints,proto3,oneof"`
}

type ReadResponse_Frame_UnsignedPoints

type ReadResponse_Frame_UnsignedPoints struct {
	UnsignedPoints *ReadResponse_UnsignedPointsFrame `protobuf:"bytes,4,opt,name=UnsignedPoints,proto3,oneof"`
}

type ReadResponse_GroupFrame

type ReadResponse_GroupFrame struct {

	// TagKeys
	TagKeys [][]byte `protobuf:"bytes,1,rep,name=TagKeys,proto3" json:"TagKeys,omitempty"`
	// PartitionKeyVals is the values of the partition key for this group, order matching ReadGroupRequest.GroupKeys
	PartitionKeyVals [][]byte `protobuf:"bytes,2,rep,name=PartitionKeyVals,proto3" json:"PartitionKeyVals,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse_GroupFrame) Descriptor deprecated

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

Deprecated: Use ReadResponse_GroupFrame.ProtoReflect.Descriptor instead.

func (*ReadResponse_GroupFrame) GetPartitionKeyVals

func (x *ReadResponse_GroupFrame) GetPartitionKeyVals() [][]byte

func (*ReadResponse_GroupFrame) GetTagKeys

func (x *ReadResponse_GroupFrame) GetTagKeys() [][]byte

func (*ReadResponse_GroupFrame) ProtoMessage

func (*ReadResponse_GroupFrame) ProtoMessage()

func (*ReadResponse_GroupFrame) ProtoReflect

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

func (*ReadResponse_GroupFrame) Reset

func (x *ReadResponse_GroupFrame) Reset()

func (*ReadResponse_GroupFrame) String

func (x *ReadResponse_GroupFrame) String() string

type ReadResponse_IntegerPointsFrame

type ReadResponse_IntegerPointsFrame struct {
	Timestamps []int64 `protobuf:"fixed64,1,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"`
	Values     []int64 `protobuf:"varint,2,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse_IntegerPointsFrame) Descriptor deprecated

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

Deprecated: Use ReadResponse_IntegerPointsFrame.ProtoReflect.Descriptor instead.

func (*ReadResponse_IntegerPointsFrame) GetTimestamps

func (x *ReadResponse_IntegerPointsFrame) GetTimestamps() []int64

func (*ReadResponse_IntegerPointsFrame) GetValues

func (x *ReadResponse_IntegerPointsFrame) GetValues() []int64

func (*ReadResponse_IntegerPointsFrame) ProtoMessage

func (*ReadResponse_IntegerPointsFrame) ProtoMessage()

func (*ReadResponse_IntegerPointsFrame) ProtoReflect

func (*ReadResponse_IntegerPointsFrame) Reset

func (*ReadResponse_IntegerPointsFrame) String

type ReadResponse_IntegerValues

type ReadResponse_IntegerValues struct {
	Values []int64 `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse_IntegerValues) Descriptor deprecated

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

Deprecated: Use ReadResponse_IntegerValues.ProtoReflect.Descriptor instead.

func (*ReadResponse_IntegerValues) GetValues

func (x *ReadResponse_IntegerValues) GetValues() []int64

func (*ReadResponse_IntegerValues) ProtoMessage

func (*ReadResponse_IntegerValues) ProtoMessage()

func (*ReadResponse_IntegerValues) ProtoReflect

func (*ReadResponse_IntegerValues) Reset

func (x *ReadResponse_IntegerValues) Reset()

func (*ReadResponse_IntegerValues) String

func (x *ReadResponse_IntegerValues) String() string

type ReadResponse_MultiPointsFrame

type ReadResponse_MultiPointsFrame struct {
	Timestamps  []int64                   `protobuf:"fixed64,1,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"`
	ValueArrays []*ReadResponse_AnyPoints `protobuf:"bytes,2,rep,name=value_arrays,json=valueArrays,proto3" json:"value_arrays,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse_MultiPointsFrame) Descriptor deprecated

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

Deprecated: Use ReadResponse_MultiPointsFrame.ProtoReflect.Descriptor instead.

func (*ReadResponse_MultiPointsFrame) GetTimestamps

func (x *ReadResponse_MultiPointsFrame) GetTimestamps() []int64

func (*ReadResponse_MultiPointsFrame) GetValueArrays

func (*ReadResponse_MultiPointsFrame) ProtoMessage

func (*ReadResponse_MultiPointsFrame) ProtoMessage()

func (*ReadResponse_MultiPointsFrame) ProtoReflect

func (*ReadResponse_MultiPointsFrame) Reset

func (x *ReadResponse_MultiPointsFrame) Reset()

func (*ReadResponse_MultiPointsFrame) String

type ReadResponse_SeriesFrame

type ReadResponse_SeriesFrame struct {
	Tags     []*Tag                `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
	DataType ReadResponse_DataType `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReadResponse_SeriesFrame) Descriptor deprecated

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

Deprecated: Use ReadResponse_SeriesFrame.ProtoReflect.Descriptor instead.

func (*ReadResponse_SeriesFrame) GetDataType

func (*ReadResponse_SeriesFrame) GetTags

func (x *ReadResponse_SeriesFrame) GetTags() []*Tag

func (*ReadResponse_SeriesFrame) ProtoMessage

func (*ReadResponse_SeriesFrame) ProtoMessage()

func (*ReadResponse_SeriesFrame) ProtoReflect

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

func (*ReadResponse_SeriesFrame) Reset

func (x *ReadResponse_SeriesFrame) Reset()

func (*ReadResponse_SeriesFrame) String

func (x *ReadResponse_SeriesFrame) String() string

type ReadResponse_StringPointsFrame

type ReadResponse_StringPointsFrame struct {
	Timestamps []int64  `protobuf:"fixed64,1,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"`
	Values     []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse_StringPointsFrame) Descriptor deprecated

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

Deprecated: Use ReadResponse_StringPointsFrame.ProtoReflect.Descriptor instead.

func (*ReadResponse_StringPointsFrame) GetTimestamps

func (x *ReadResponse_StringPointsFrame) GetTimestamps() []int64

func (*ReadResponse_StringPointsFrame) GetValues

func (x *ReadResponse_StringPointsFrame) GetValues() []string

func (*ReadResponse_StringPointsFrame) ProtoMessage

func (*ReadResponse_StringPointsFrame) ProtoMessage()

func (*ReadResponse_StringPointsFrame) ProtoReflect

func (*ReadResponse_StringPointsFrame) Reset

func (x *ReadResponse_StringPointsFrame) Reset()

func (*ReadResponse_StringPointsFrame) String

type ReadResponse_StringValues

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

func (*ReadResponse_StringValues) Descriptor deprecated

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

Deprecated: Use ReadResponse_StringValues.ProtoReflect.Descriptor instead.

func (*ReadResponse_StringValues) GetValues

func (x *ReadResponse_StringValues) GetValues() []string

func (*ReadResponse_StringValues) ProtoMessage

func (*ReadResponse_StringValues) ProtoMessage()

func (*ReadResponse_StringValues) ProtoReflect

func (*ReadResponse_StringValues) Reset

func (x *ReadResponse_StringValues) Reset()

func (*ReadResponse_StringValues) String

func (x *ReadResponse_StringValues) String() string

type ReadResponse_UnsignedPointsFrame

type ReadResponse_UnsignedPointsFrame struct {
	Timestamps []int64  `protobuf:"fixed64,1,rep,packed,name=timestamps,proto3" json:"timestamps,omitempty"`
	Values     []uint64 `protobuf:"varint,2,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse_UnsignedPointsFrame) Descriptor deprecated

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

Deprecated: Use ReadResponse_UnsignedPointsFrame.ProtoReflect.Descriptor instead.

func (*ReadResponse_UnsignedPointsFrame) GetTimestamps

func (x *ReadResponse_UnsignedPointsFrame) GetTimestamps() []int64

func (*ReadResponse_UnsignedPointsFrame) GetValues

func (x *ReadResponse_UnsignedPointsFrame) GetValues() []uint64

func (*ReadResponse_UnsignedPointsFrame) ProtoMessage

func (*ReadResponse_UnsignedPointsFrame) ProtoMessage()

func (*ReadResponse_UnsignedPointsFrame) ProtoReflect

func (*ReadResponse_UnsignedPointsFrame) Reset

func (*ReadResponse_UnsignedPointsFrame) String

type ReadResponse_UnsignedValues

type ReadResponse_UnsignedValues struct {
	Values []uint64 `protobuf:"varint,1,rep,packed,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadResponse_UnsignedValues) Descriptor deprecated

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

Deprecated: Use ReadResponse_UnsignedValues.ProtoReflect.Descriptor instead.

func (*ReadResponse_UnsignedValues) GetValues

func (x *ReadResponse_UnsignedValues) GetValues() []uint64

func (*ReadResponse_UnsignedValues) ProtoMessage

func (*ReadResponse_UnsignedValues) ProtoMessage()

func (*ReadResponse_UnsignedValues) ProtoReflect

func (*ReadResponse_UnsignedValues) Reset

func (x *ReadResponse_UnsignedValues) Reset()

func (*ReadResponse_UnsignedValues) String

func (x *ReadResponse_UnsignedValues) String() string

type ReadWindowAggregateRequest

type ReadWindowAggregateRequest struct {
	ReadSource  *anypb.Any      `protobuf:"bytes,1,opt,name=ReadSource,proto3" json:"ReadSource,omitempty"`
	Range       *TimestampRange `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	Predicate   *Predicate      `protobuf:"bytes,3,opt,name=predicate,proto3" json:"predicate,omitempty"`
	WindowEvery int64           `protobuf:"varint,4,opt,name=WindowEvery,proto3" json:"WindowEvery,omitempty"`
	Offset      int64           `protobuf:"varint,6,opt,name=Offset,proto3" json:"Offset,omitempty"`
	Aggregate   []*Aggregate    `protobuf:"bytes,5,rep,name=aggregate,proto3" json:"aggregate,omitempty"`
	Window      *Window         `protobuf:"bytes,7,opt,name=window,proto3" json:"window,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadWindowAggregateRequest) Descriptor deprecated

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

Deprecated: Use ReadWindowAggregateRequest.ProtoReflect.Descriptor instead.

func (*ReadWindowAggregateRequest) GetAggregate

func (x *ReadWindowAggregateRequest) GetAggregate() []*Aggregate

func (*ReadWindowAggregateRequest) GetOffset

func (x *ReadWindowAggregateRequest) GetOffset() int64

func (*ReadWindowAggregateRequest) GetPredicate

func (x *ReadWindowAggregateRequest) GetPredicate() *Predicate

func (*ReadWindowAggregateRequest) GetRange

func (*ReadWindowAggregateRequest) GetReadSource

func (x *ReadWindowAggregateRequest) GetReadSource() *anypb.Any

func (*ReadWindowAggregateRequest) GetWindow

func (x *ReadWindowAggregateRequest) GetWindow() *Window

func (*ReadWindowAggregateRequest) GetWindowEvery

func (x *ReadWindowAggregateRequest) GetWindowEvery() int64

func (*ReadWindowAggregateRequest) ProtoMessage

func (*ReadWindowAggregateRequest) ProtoMessage()

func (*ReadWindowAggregateRequest) ProtoReflect

func (*ReadWindowAggregateRequest) Reset

func (x *ReadWindowAggregateRequest) Reset()

func (*ReadWindowAggregateRequest) String

func (x *ReadWindowAggregateRequest) String() string

type StringValuesResponse

type StringValuesResponse struct {
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

Response message for Storage.TagKeys and Storage.TagValues.

func (*StringValuesResponse) Descriptor deprecated

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

Deprecated: Use StringValuesResponse.ProtoReflect.Descriptor instead.

func (*StringValuesResponse) GetValues

func (x *StringValuesResponse) GetValues() [][]byte

func (*StringValuesResponse) ProtoMessage

func (*StringValuesResponse) ProtoMessage()

func (*StringValuesResponse) ProtoReflect

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

func (*StringValuesResponse) Reset

func (x *StringValuesResponse) Reset()

func (*StringValuesResponse) String

func (x *StringValuesResponse) String() string

type Tag

type Tag struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Tag) Descriptor deprecated

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

Deprecated: Use Tag.ProtoReflect.Descriptor instead.

func (*Tag) GetKey

func (x *Tag) GetKey() []byte

func (*Tag) GetValue

func (x *Tag) GetValue() []byte

func (*Tag) ProtoMessage

func (*Tag) ProtoMessage()

func (*Tag) ProtoReflect

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

func (*Tag) Reset

func (x *Tag) Reset()

func (*Tag) String

func (x *Tag) String() string

type TagKeysRequest

type TagKeysRequest struct {
	TagsSource *anypb.Any      `protobuf:"bytes,1,opt,name=TagsSource,proto3" json:"TagsSource,omitempty"`
	Range      *TimestampRange `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	Predicate  *Predicate      `protobuf:"bytes,3,opt,name=predicate,proto3" json:"predicate,omitempty"`
	// contains filtered or unexported fields
}

TagKeysRequest is the request message for Storage.TagKeys.

func (*TagKeysRequest) Descriptor deprecated

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

Deprecated: Use TagKeysRequest.ProtoReflect.Descriptor instead.

func (*TagKeysRequest) GetPredicate

func (x *TagKeysRequest) GetPredicate() *Predicate

func (*TagKeysRequest) GetRange

func (x *TagKeysRequest) GetRange() *TimestampRange

func (*TagKeysRequest) GetTagsSource

func (x *TagKeysRequest) GetTagsSource() *anypb.Any

func (*TagKeysRequest) ProtoMessage

func (*TagKeysRequest) ProtoMessage()

func (*TagKeysRequest) ProtoReflect

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

func (*TagKeysRequest) Reset

func (x *TagKeysRequest) Reset()

func (*TagKeysRequest) String

func (x *TagKeysRequest) String() string

type TagValuesRequest

type TagValuesRequest struct {
	TagsSource *anypb.Any      `protobuf:"bytes,1,opt,name=TagsSource,proto3" json:"TagsSource,omitempty"`
	Range      *TimestampRange `protobuf:"bytes,2,opt,name=range,proto3" json:"range,omitempty"`
	Predicate  *Predicate      `protobuf:"bytes,3,opt,name=predicate,proto3" json:"predicate,omitempty"`
	TagKey     string          `protobuf:"bytes,4,opt,name=tag_key,json=tagKey,proto3" json:"tag_key,omitempty"`
	// contains filtered or unexported fields
}

TagValuesRequest is the request message for Storage.TagValues.

func (*TagValuesRequest) Descriptor deprecated

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

Deprecated: Use TagValuesRequest.ProtoReflect.Descriptor instead.

func (*TagValuesRequest) GetPredicate

func (x *TagValuesRequest) GetPredicate() *Predicate

func (*TagValuesRequest) GetRange

func (x *TagValuesRequest) GetRange() *TimestampRange

func (*TagValuesRequest) GetTagKey

func (x *TagValuesRequest) GetTagKey() string

func (*TagValuesRequest) GetTagsSource

func (x *TagValuesRequest) GetTagsSource() *anypb.Any

func (*TagValuesRequest) ProtoMessage

func (*TagValuesRequest) ProtoMessage()

func (*TagValuesRequest) ProtoReflect

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

func (*TagValuesRequest) Reset

func (x *TagValuesRequest) Reset()

func (*TagValuesRequest) String

func (x *TagValuesRequest) String() string

type TimestampRange

type TimestampRange struct {

	// Start defines the inclusive lower bound.
	Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	// End defines the exclusive upper bound.
	End int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// contains filtered or unexported fields
}

Specifies a continuous range of nanosecond timestamps.

func (*TimestampRange) Descriptor deprecated

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

Deprecated: Use TimestampRange.ProtoReflect.Descriptor instead.

func (*TimestampRange) GetEnd

func (x *TimestampRange) GetEnd() int64

func (*TimestampRange) GetStart

func (x *TimestampRange) GetStart() int64

func (*TimestampRange) ProtoMessage

func (*TimestampRange) ProtoMessage()

func (*TimestampRange) ProtoReflect

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

func (*TimestampRange) Reset

func (x *TimestampRange) Reset()

func (*TimestampRange) String

func (x *TimestampRange) String() string

type Window

type Window struct {
	Every  *Duration `protobuf:"bytes,1,opt,name=every,proto3" json:"every,omitempty"`
	Offset *Duration `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*Window) Descriptor deprecated

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

Deprecated: Use Window.ProtoReflect.Descriptor instead.

func (*Window) GetEvery

func (x *Window) GetEvery() *Duration

func (*Window) GetOffset

func (x *Window) GetOffset() *Duration

func (*Window) ProtoMessage

func (*Window) ProtoMessage()

func (*Window) ProtoReflect

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

func (*Window) Reset

func (x *Window) Reset()

func (*Window) String

func (x *Window) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL