datatypes

package
v1.9.2 Latest Latest
Warning

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

Go to latest
Published: Jun 8, 2021 License: MIT Imports: 13 Imported by: 19

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthPredicate        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPredicate          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPredicate = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthStorageCommon        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStorageCommon          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStorageCommon = fmt.Errorf("proto: unexpected end of group")
)
View Source
var Aggregate_AggregateType_name = map[int32]string{
	0: "NONE",
	1: "SUM",
	2: "COUNT",
	3: "MIN",
	4: "MAX",
	5: "FIRST",
	6: "LAST",
	7: "MEAN",
}
View Source
var Aggregate_AggregateType_value = map[string]int32{
	"NONE":  0,
	"SUM":   1,
	"COUNT": 2,
	"MIN":   3,
	"MAX":   4,
	"FIRST": 5,
	"LAST":  6,
	"MEAN":  7,
}
View Source
var Node_Comparison_name = map[int32]string{
	0: "EQUAL",
	1: "NOT_EQUAL",
	2: "STARTS_WITH",
	3: "REGEX",
	4: "NOT_REGEX",
	5: "LT",
	6: "LTE",
	7: "GT",
	8: "GTE",
}
View Source
var Node_Comparison_value = map[string]int32{
	"EQUAL":       0,
	"NOT_EQUAL":   1,
	"STARTS_WITH": 2,
	"REGEX":       3,
	"NOT_REGEX":   4,
	"LT":          5,
	"LTE":         6,
	"GT":          7,
	"GTE":         8,
}
View Source
var Node_Logical_name = map[int32]string{
	0: "AND",
	1: "OR",
}
View Source
var Node_Logical_value = map[string]int32{
	"AND": 0,
	"OR":  1,
}
View Source
var Node_Type_name = map[int32]string{
	0: "LOGICAL_EXPRESSION",
	1: "COMPARISON_EXPRESSION",
	2: "PAREN_EXPRESSION",
	3: "TAG_REF",
	4: "LITERAL",
	5: "FIELD_REF",
}
View Source
var Node_Type_value = map[string]int32{
	"LOGICAL_EXPRESSION":    0,
	"COMPARISON_EXPRESSION": 1,
	"PAREN_EXPRESSION":      2,
	"TAG_REF":               3,
	"LITERAL":               4,
	"FIELD_REF":             5,
}
View Source
var ReadGroupRequest_Group_name = map[int32]string{
	0: "GROUP_NONE",
	2: "GROUP_BY",
}
View Source
var ReadGroupRequest_Group_value = map[string]int32{
	"GROUP_NONE": 0,
	"GROUP_BY":   2,
}
View Source
var ReadGroupRequest_HintFlags_name = map[int32]string{
	0: "HINT_NONE",
	1: "HINT_NO_POINTS",
	2: "HINT_NO_SERIES",
	4: "HINT_SCHEMA_ALL_TIME",
}
View Source
var ReadGroupRequest_HintFlags_value = map[string]int32{
	"HINT_NONE":            0,
	"HINT_NO_POINTS":       1,
	"HINT_NO_SERIES":       2,
	"HINT_SCHEMA_ALL_TIME": 4,
}
View Source
var ReadResponse_DataType_name = map[int32]string{
	0: "FLOAT",
	1: "INTEGER",
	2: "UNSIGNED",
	3: "BOOLEAN",
	4: "STRING",
	5: "MULTI",
}
View Source
var ReadResponse_DataType_value = map[string]int32{
	"FLOAT":    0,
	"INTEGER":  1,
	"UNSIGNED": 2,
	"BOOLEAN":  3,
	"STRING":   4,
	"MULTI":    5,
}
View Source
var ReadResponse_FrameType_name = map[int32]string{
	0: "SERIES",
	1: "POINTS",
}
View Source
var ReadResponse_FrameType_value = map[string]int32{
	"SERIES": 0,
	"POINTS": 1,
}

Functions

func RegisterStorageServer

func RegisterStorageServer(s *grpc.Server, srv StorageServer)

Types

type Aggregate

type Aggregate struct {
	Type Aggregate_AggregateType `protobuf:"varint,1,opt,name=type,proto3,enum=influxdata.platform.storage.Aggregate_AggregateType" json:"type,omitempty"`
}

func (*Aggregate) Descriptor

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

func (*Aggregate) Marshal

func (m *Aggregate) Marshal() (dAtA []byte, err error)

func (*Aggregate) MarshalTo

func (m *Aggregate) MarshalTo(dAtA []byte) (int, error)

func (*Aggregate) MarshalToSizedBuffer added in v1.8.7

func (m *Aggregate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Aggregate) ProtoMessage

func (*Aggregate) ProtoMessage()

func (*Aggregate) Reset

func (m *Aggregate) Reset()

func (*Aggregate) Size

func (m *Aggregate) Size() (n int)

func (*Aggregate) String

func (m *Aggregate) String() string

func (*Aggregate) Unmarshal

func (m *Aggregate) Unmarshal(dAtA []byte) error

func (*Aggregate) XXX_DiscardUnknown

func (m *Aggregate) XXX_DiscardUnknown()

func (*Aggregate) XXX_Marshal

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

func (*Aggregate) XXX_Merge

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

func (*Aggregate) XXX_Size

func (m *Aggregate) XXX_Size() int

func (*Aggregate) XXX_Unmarshal

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

type Aggregate_AggregateType

type Aggregate_AggregateType int32
const (
	AggregateTypeNone  Aggregate_AggregateType = 0
	AggregateTypeSum   Aggregate_AggregateType = 1
	AggregateTypeCount Aggregate_AggregateType = 2
	AggregateTypeMin   Aggregate_AggregateType = 3
	AggregateTypeMax   Aggregate_AggregateType = 4
	AggregateTypeFirst Aggregate_AggregateType = 5
	AggregateTypeLast  Aggregate_AggregateType = 6
	AggregateTypeMean  Aggregate_AggregateType = 7
)

func (Aggregate_AggregateType) EnumDescriptor

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

func (Aggregate_AggregateType) String

func (x Aggregate_AggregateType) String() string

type CapabilitiesResponse

type CapabilitiesResponse struct {
	Caps map[string]string `` /* 149-byte string literal not displayed */
}

func (*CapabilitiesResponse) Descriptor

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

func (*CapabilitiesResponse) Marshal

func (m *CapabilitiesResponse) Marshal() (dAtA []byte, err error)

func (*CapabilitiesResponse) MarshalTo

func (m *CapabilitiesResponse) MarshalTo(dAtA []byte) (int, error)

func (*CapabilitiesResponse) MarshalToSizedBuffer added in v1.8.7

func (m *CapabilitiesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CapabilitiesResponse) ProtoMessage

func (*CapabilitiesResponse) ProtoMessage()

func (*CapabilitiesResponse) Reset

func (m *CapabilitiesResponse) Reset()

func (*CapabilitiesResponse) Size

func (m *CapabilitiesResponse) Size() (n int)

func (*CapabilitiesResponse) String

func (m *CapabilitiesResponse) String() string

func (*CapabilitiesResponse) Unmarshal

func (m *CapabilitiesResponse) Unmarshal(dAtA []byte) error

func (*CapabilitiesResponse) XXX_DiscardUnknown

func (m *CapabilitiesResponse) XXX_DiscardUnknown()

func (*CapabilitiesResponse) XXX_Marshal

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

func (*CapabilitiesResponse) XXX_Merge

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

func (*CapabilitiesResponse) XXX_Size

func (m *CapabilitiesResponse) XXX_Size() int

func (*CapabilitiesResponse) XXX_Unmarshal

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

type Duration added in v1.9.0

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"`
}

func (*Duration) Descriptor added in v1.9.0

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

func (*Duration) Marshal added in v1.9.0

func (m *Duration) Marshal() (dAtA []byte, err error)

func (*Duration) MarshalTo added in v1.9.0

func (m *Duration) MarshalTo(dAtA []byte) (int, error)

func (*Duration) MarshalToSizedBuffer added in v1.9.0

func (m *Duration) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Duration) ProtoMessage added in v1.9.0

func (*Duration) ProtoMessage()

func (*Duration) Reset added in v1.9.0

func (m *Duration) Reset()

func (*Duration) Size added in v1.9.0

func (m *Duration) Size() (n int)

func (*Duration) String added in v1.9.0

func (m *Duration) String() string

func (*Duration) Unmarshal added in v1.9.0

func (m *Duration) Unmarshal(dAtA []byte) error

func (*Duration) XXX_DiscardUnknown added in v1.9.0

func (m *Duration) XXX_DiscardUnknown()

func (*Duration) XXX_Marshal added in v1.9.0

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

func (*Duration) XXX_Merge added in v1.9.0

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

func (*Duration) XXX_Size added in v1.9.0

func (m *Duration) XXX_Size() int

func (*Duration) XXX_Unmarshal added in v1.9.0

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

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=influxdata.platform.storage.Node_Type" json:"nodeType"`
	Children []*Node   `protobuf:"bytes,2,rep,name=children,proto3" json:"children,omitempty"`
	// Types that are valid to be assigned 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"`
}

func (*Node) Descriptor

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

func (*Node) GetBooleanValue

func (m *Node) GetBooleanValue() bool

func (*Node) GetChildren

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

func (*Node) GetComparison

func (m *Node) GetComparison() Node_Comparison

func (*Node) GetFieldRefValue

func (m *Node) GetFieldRefValue() string

func (*Node) GetFloatValue

func (m *Node) GetFloatValue() float64

func (*Node) GetIntegerValue

func (m *Node) GetIntegerValue() int64

func (*Node) GetLogical

func (m *Node) GetLogical() Node_Logical

func (*Node) GetNodeType

func (m *Node) GetNodeType() Node_Type

func (*Node) GetRegexValue

func (m *Node) GetRegexValue() string

func (*Node) GetStringValue

func (m *Node) GetStringValue() string

func (*Node) GetTagRefValue

func (m *Node) GetTagRefValue() string

func (*Node) GetUnsignedValue

func (m *Node) GetUnsignedValue() uint64

func (*Node) GetValue

func (m *Node) GetValue() isNode_Value

func (*Node) Marshal

func (m *Node) Marshal() (dAtA []byte, err error)

func (*Node) MarshalTo

func (m *Node) MarshalTo(dAtA []byte) (int, error)

func (*Node) MarshalToSizedBuffer added in v1.8.7

func (m *Node) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) Reset

func (m *Node) Reset()

func (*Node) Size

func (m *Node) Size() (n int)

func (*Node) String

func (m *Node) String() string

func (*Node) Unmarshal

func (m *Node) Unmarshal(dAtA []byte) error

func (*Node) XXX_DiscardUnknown

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal

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

func (*Node) XXX_Merge

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

func (*Node) XXX_OneofWrappers added in v1.8.7

func (*Node) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Node) XXX_Size

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal

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

type Node_BooleanValue

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

func (*Node_BooleanValue) MarshalTo

func (m *Node_BooleanValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_BooleanValue) MarshalToSizedBuffer added in v1.8.7

func (m *Node_BooleanValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node_BooleanValue) Size

func (m *Node_BooleanValue) Size() (n int)

type Node_Comparison

type Node_Comparison int32
const (
	ComparisonEqual        Node_Comparison = 0
	ComparisonNotEqual     Node_Comparison = 1
	ComparisonStartsWith   Node_Comparison = 2
	ComparisonRegex        Node_Comparison = 3
	ComparisonNotRegex     Node_Comparison = 4
	ComparisonLess         Node_Comparison = 5
	ComparisonLessEqual    Node_Comparison = 6
	ComparisonGreater      Node_Comparison = 7
	ComparisonGreaterEqual Node_Comparison = 8
)

func (Node_Comparison) EnumDescriptor

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

func (Node_Comparison) String

func (x Node_Comparison) String() string

type Node_Comparison_

type Node_Comparison_ struct {
	Comparison Node_Comparison `` /* 130-byte string literal not displayed */
}

func (*Node_Comparison_) MarshalTo

func (m *Node_Comparison_) MarshalTo(dAtA []byte) (int, error)

func (*Node_Comparison_) MarshalToSizedBuffer added in v1.8.7

func (m *Node_Comparison_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node_Comparison_) Size

func (m *Node_Comparison_) Size() (n int)

type Node_FieldRefValue

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

func (*Node_FieldRefValue) MarshalTo

func (m *Node_FieldRefValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_FieldRefValue) MarshalToSizedBuffer added in v1.8.7

func (m *Node_FieldRefValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node_FieldRefValue) Size

func (m *Node_FieldRefValue) Size() (n int)

type Node_FloatValue

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

func (*Node_FloatValue) MarshalTo

func (m *Node_FloatValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_FloatValue) MarshalToSizedBuffer added in v1.8.7

func (m *Node_FloatValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node_FloatValue) Size

func (m *Node_FloatValue) Size() (n int)

type Node_IntegerValue

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

func (*Node_IntegerValue) MarshalTo

func (m *Node_IntegerValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_IntegerValue) MarshalToSizedBuffer added in v1.8.7

func (m *Node_IntegerValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node_IntegerValue) Size

func (m *Node_IntegerValue) Size() (n int)

type Node_Logical

type Node_Logical int32

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

const (
	LogicalAnd Node_Logical = 0
	LogicalOr  Node_Logical = 1
)

func (Node_Logical) EnumDescriptor

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

func (Node_Logical) String

func (x Node_Logical) String() string

type Node_Logical_

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

func (*Node_Logical_) MarshalTo

func (m *Node_Logical_) MarshalTo(dAtA []byte) (int, error)

func (*Node_Logical_) MarshalToSizedBuffer added in v1.8.7

func (m *Node_Logical_) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node_Logical_) Size

func (m *Node_Logical_) Size() (n int)

type Node_RegexValue

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

func (*Node_RegexValue) MarshalTo

func (m *Node_RegexValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_RegexValue) MarshalToSizedBuffer added in v1.8.7

func (m *Node_RegexValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node_RegexValue) Size

func (m *Node_RegexValue) Size() (n int)

type Node_StringValue

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

func (*Node_StringValue) MarshalTo

func (m *Node_StringValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_StringValue) MarshalToSizedBuffer added in v1.8.7

func (m *Node_StringValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node_StringValue) Size

func (m *Node_StringValue) Size() (n int)

type Node_TagRefValue

type Node_TagRefValue struct {
	TagRefValue string `protobuf:"bytes,9,opt,name=tag_ref_value,json=tagRefValue,proto3,oneof" json:"tag_ref_value,omitempty"`
}

func (*Node_TagRefValue) MarshalTo

func (m *Node_TagRefValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_TagRefValue) MarshalToSizedBuffer added in v1.8.7

func (m *Node_TagRefValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node_TagRefValue) Size

func (m *Node_TagRefValue) Size() (n int)

type Node_Type

type Node_Type int32
const (
	NodeTypeLogicalExpression    Node_Type = 0
	NodeTypeComparisonExpression Node_Type = 1
	NodeTypeParenExpression      Node_Type = 2
	NodeTypeTagRef               Node_Type = 3
	NodeTypeLiteral              Node_Type = 4
	NodeTypeFieldRef             Node_Type = 5
)

func (Node_Type) EnumDescriptor

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

func (Node_Type) String

func (x Node_Type) String() string

type Node_UnsignedValue

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

func (*Node_UnsignedValue) MarshalTo

func (m *Node_UnsignedValue) MarshalTo(dAtA []byte) (int, error)

func (*Node_UnsignedValue) MarshalToSizedBuffer added in v1.8.7

func (m *Node_UnsignedValue) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Node_UnsignedValue) Size

func (m *Node_UnsignedValue) Size() (n int)

type Predicate

type Predicate struct {
	Root *Node `protobuf:"bytes,1,opt,name=root,proto3" json:"root,omitempty"`
}

func (*Predicate) Descriptor

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

func (*Predicate) GetRoot

func (m *Predicate) GetRoot() *Node

func (*Predicate) Marshal

func (m *Predicate) Marshal() (dAtA []byte, err error)

func (*Predicate) MarshalTo

func (m *Predicate) MarshalTo(dAtA []byte) (int, error)

func (*Predicate) MarshalToSizedBuffer added in v1.8.7

func (m *Predicate) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Predicate) ProtoMessage

func (*Predicate) ProtoMessage()

func (*Predicate) Reset

func (m *Predicate) Reset()

func (*Predicate) Size

func (m *Predicate) Size() (n int)

func (*Predicate) String

func (m *Predicate) String() string

func (*Predicate) Unmarshal

func (m *Predicate) Unmarshal(dAtA []byte) error

func (*Predicate) XXX_DiscardUnknown

func (m *Predicate) XXX_DiscardUnknown()

func (*Predicate) XXX_Marshal

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

func (*Predicate) XXX_Merge

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

func (*Predicate) XXX_Size

func (m *Predicate) XXX_Size() int

func (*Predicate) XXX_Unmarshal

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

type ReadFilterRequest added in v1.7.8

type ReadFilterRequest struct {
	ReadSource *types.Any     `protobuf:"bytes,1,opt,name=read_source,json=readSource,proto3" json:"read_source,omitempty"`
	Range      TimestampRange `protobuf:"bytes,2,opt,name=range,proto3" json:"range"`
	Predicate  *Predicate     `protobuf:"bytes,3,opt,name=predicate,proto3" json:"predicate,omitempty"`
}

func (*ReadFilterRequest) Descriptor added in v1.7.8

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

func (*ReadFilterRequest) Marshal added in v1.7.8

func (m *ReadFilterRequest) Marshal() (dAtA []byte, err error)

func (*ReadFilterRequest) MarshalTo added in v1.7.8

func (m *ReadFilterRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReadFilterRequest) MarshalToSizedBuffer added in v1.8.7

func (m *ReadFilterRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadFilterRequest) ProtoMessage added in v1.7.8

func (*ReadFilterRequest) ProtoMessage()

func (*ReadFilterRequest) Reset added in v1.7.8

func (m *ReadFilterRequest) Reset()

func (*ReadFilterRequest) Size added in v1.7.8

func (m *ReadFilterRequest) Size() (n int)

func (*ReadFilterRequest) String added in v1.7.8

func (m *ReadFilterRequest) String() string

func (*ReadFilterRequest) Unmarshal added in v1.7.8

func (m *ReadFilterRequest) Unmarshal(dAtA []byte) error

func (*ReadFilterRequest) XXX_DiscardUnknown added in v1.7.8

func (m *ReadFilterRequest) XXX_DiscardUnknown()

func (*ReadFilterRequest) XXX_Marshal added in v1.7.8

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

func (*ReadFilterRequest) XXX_Merge added in v1.7.8

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

func (*ReadFilterRequest) XXX_Size added in v1.7.8

func (m *ReadFilterRequest) XXX_Size() int

func (*ReadFilterRequest) XXX_Unmarshal added in v1.7.8

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

type ReadGroupRequest added in v1.7.8

type ReadGroupRequest struct {
	ReadSource *types.Any     `protobuf:"bytes,1,opt,name=read_source,json=readSource,proto3" json:"read_source,omitempty"`
	Range      TimestampRange `protobuf:"bytes,2,opt,name=range,proto3" json:"range"`
	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=group_keys,json=groupKeys,proto3" json:"group_keys,omitempty"`
	Group     ReadGroupRequest_Group `protobuf:"varint,5,opt,name=group,proto3,enum=influxdata.platform.storage.ReadGroupRequest_Group" json:"group,omitempty"`
	Aggregate *Aggregate             `protobuf:"bytes,6,opt,name=aggregate,proto3" json:"aggregate,omitempty"`
	Hints     HintFlags              `protobuf:"fixed32,7,opt,name=hints,proto3,casttype=HintFlags" json:"hints,omitempty"`
}

func (*ReadGroupRequest) Descriptor added in v1.7.8

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

func (*ReadGroupRequest) Marshal added in v1.7.8

func (m *ReadGroupRequest) Marshal() (dAtA []byte, err error)

func (*ReadGroupRequest) MarshalTo added in v1.7.8

func (m *ReadGroupRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReadGroupRequest) MarshalToSizedBuffer added in v1.8.7

func (m *ReadGroupRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadGroupRequest) ProtoMessage added in v1.7.8

func (*ReadGroupRequest) ProtoMessage()

func (*ReadGroupRequest) Reset added in v1.7.8

func (m *ReadGroupRequest) Reset()

func (*ReadGroupRequest) Size added in v1.7.8

func (m *ReadGroupRequest) Size() (n int)

func (*ReadGroupRequest) String added in v1.7.8

func (m *ReadGroupRequest) String() string

func (*ReadGroupRequest) Unmarshal added in v1.7.8

func (m *ReadGroupRequest) Unmarshal(dAtA []byte) error

func (*ReadGroupRequest) XXX_DiscardUnknown added in v1.7.8

func (m *ReadGroupRequest) XXX_DiscardUnknown()

func (*ReadGroupRequest) XXX_Marshal added in v1.7.8

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

func (*ReadGroupRequest) XXX_Merge added in v1.7.8

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

func (*ReadGroupRequest) XXX_Size added in v1.7.8

func (m *ReadGroupRequest) XXX_Size() int

func (*ReadGroupRequest) XXX_Unmarshal added in v1.7.8

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

type ReadGroupRequest_Group added in v1.7.8

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.
	GroupNone ReadGroupRequest_Group = 0
	// GroupBy returns a group for each unique value of the specified GroupKeys.
	GroupBy ReadGroupRequest_Group = 2
)

func (ReadGroupRequest_Group) EnumDescriptor added in v1.7.8

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

func (ReadGroupRequest_Group) String added in v1.7.8

func (x ReadGroupRequest_Group) String() string

type ReadGroupRequest_HintFlags added in v1.7.8

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 (
	HintNone     ReadGroupRequest_HintFlags = 0
	HintNoPoints ReadGroupRequest_HintFlags = 1
	HintNoSeries ReadGroupRequest_HintFlags = 2
	// HintSchemaAllTime performs schema queries without using time ranges
	HintSchemaAllTime ReadGroupRequest_HintFlags = 4
)

func (ReadGroupRequest_HintFlags) EnumDescriptor added in v1.7.8

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

func (ReadGroupRequest_HintFlags) String added in v1.7.8

type ReadResponse

type ReadResponse struct {
	Frames []ReadResponse_Frame `protobuf:"bytes,1,rep,name=frames,proto3" json:"frames"`
}

Response message for ReadFilter and ReadGroup

func (*ReadResponse) Descriptor

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

func (*ReadResponse) Marshal

func (m *ReadResponse) Marshal() (dAtA []byte, err error)

func (*ReadResponse) MarshalTo

func (m *ReadResponse) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse) ProtoMessage

func (*ReadResponse) ProtoMessage()

func (*ReadResponse) Reset

func (m *ReadResponse) Reset()

func (*ReadResponse) Size

func (m *ReadResponse) Size() (n int)

func (*ReadResponse) String

func (m *ReadResponse) String() string

func (*ReadResponse) Unmarshal

func (m *ReadResponse) Unmarshal(dAtA []byte) error

func (*ReadResponse) XXX_DiscardUnknown

func (m *ReadResponse) XXX_DiscardUnknown()

func (*ReadResponse) XXX_Marshal

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

func (*ReadResponse) XXX_Merge

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

func (*ReadResponse) XXX_Size

func (m *ReadResponse) XXX_Size() int

func (*ReadResponse) XXX_Unmarshal

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

type ReadResponse_AnyPoints added in v1.9.0

type ReadResponse_AnyPoints struct {
	// Types that are valid to be assigned to Data:
	//	*ReadResponse_AnyPoints_Floats
	//	*ReadResponse_AnyPoints_Integers
	//	*ReadResponse_AnyPoints_Unsigneds
	//	*ReadResponse_AnyPoints_Booleans
	//	*ReadResponse_AnyPoints_Strings
	Data isReadResponse_AnyPoints_Data `protobuf_oneof:"data"`
}

func (*ReadResponse_AnyPoints) Descriptor added in v1.9.0

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

func (*ReadResponse_AnyPoints) GetBooleans added in v1.9.0

func (*ReadResponse_AnyPoints) GetData added in v1.9.0

func (m *ReadResponse_AnyPoints) GetData() isReadResponse_AnyPoints_Data

func (*ReadResponse_AnyPoints) GetFloats added in v1.9.0

func (*ReadResponse_AnyPoints) GetIntegers added in v1.9.0

func (*ReadResponse_AnyPoints) GetStrings added in v1.9.0

func (*ReadResponse_AnyPoints) GetUnsigneds added in v1.9.0

func (*ReadResponse_AnyPoints) Marshal added in v1.9.0

func (m *ReadResponse_AnyPoints) Marshal() (dAtA []byte, err error)

func (*ReadResponse_AnyPoints) MarshalTo added in v1.9.0

func (m *ReadResponse_AnyPoints) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_AnyPoints) MarshalToSizedBuffer added in v1.9.0

func (m *ReadResponse_AnyPoints) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_AnyPoints) ProtoMessage added in v1.9.0

func (*ReadResponse_AnyPoints) ProtoMessage()

func (*ReadResponse_AnyPoints) Reset added in v1.9.0

func (m *ReadResponse_AnyPoints) Reset()

func (*ReadResponse_AnyPoints) Size added in v1.9.0

func (m *ReadResponse_AnyPoints) Size() (n int)

func (*ReadResponse_AnyPoints) String added in v1.9.0

func (m *ReadResponse_AnyPoints) String() string

func (*ReadResponse_AnyPoints) Unmarshal added in v1.9.0

func (m *ReadResponse_AnyPoints) Unmarshal(dAtA []byte) error

func (*ReadResponse_AnyPoints) XXX_DiscardUnknown added in v1.9.0

func (m *ReadResponse_AnyPoints) XXX_DiscardUnknown()

func (*ReadResponse_AnyPoints) XXX_Marshal added in v1.9.0

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

func (*ReadResponse_AnyPoints) XXX_Merge added in v1.9.0

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

func (*ReadResponse_AnyPoints) XXX_OneofWrappers added in v1.9.0

func (*ReadResponse_AnyPoints) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ReadResponse_AnyPoints) XXX_Size added in v1.9.0

func (m *ReadResponse_AnyPoints) XXX_Size() int

func (*ReadResponse_AnyPoints) XXX_Unmarshal added in v1.9.0

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

type ReadResponse_AnyPoints_Booleans added in v1.9.0

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

func (*ReadResponse_AnyPoints_Booleans) MarshalTo added in v1.9.0

func (m *ReadResponse_AnyPoints_Booleans) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_AnyPoints_Booleans) MarshalToSizedBuffer added in v1.9.0

func (m *ReadResponse_AnyPoints_Booleans) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_AnyPoints_Booleans) Size added in v1.9.0

func (m *ReadResponse_AnyPoints_Booleans) Size() (n int)

type ReadResponse_AnyPoints_Floats added in v1.9.0

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

func (*ReadResponse_AnyPoints_Floats) MarshalTo added in v1.9.0

func (m *ReadResponse_AnyPoints_Floats) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_AnyPoints_Floats) MarshalToSizedBuffer added in v1.9.0

func (m *ReadResponse_AnyPoints_Floats) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_AnyPoints_Floats) Size added in v1.9.0

func (m *ReadResponse_AnyPoints_Floats) Size() (n int)

type ReadResponse_AnyPoints_Integers added in v1.9.0

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

func (*ReadResponse_AnyPoints_Integers) MarshalTo added in v1.9.0

func (m *ReadResponse_AnyPoints_Integers) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_AnyPoints_Integers) MarshalToSizedBuffer added in v1.9.0

func (m *ReadResponse_AnyPoints_Integers) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_AnyPoints_Integers) Size added in v1.9.0

func (m *ReadResponse_AnyPoints_Integers) Size() (n int)

type ReadResponse_AnyPoints_Strings added in v1.9.0

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

func (*ReadResponse_AnyPoints_Strings) MarshalTo added in v1.9.0

func (m *ReadResponse_AnyPoints_Strings) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_AnyPoints_Strings) MarshalToSizedBuffer added in v1.9.0

func (m *ReadResponse_AnyPoints_Strings) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_AnyPoints_Strings) Size added in v1.9.0

func (m *ReadResponse_AnyPoints_Strings) Size() (n int)

type ReadResponse_AnyPoints_Unsigneds added in v1.9.0

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

func (*ReadResponse_AnyPoints_Unsigneds) MarshalTo added in v1.9.0

func (m *ReadResponse_AnyPoints_Unsigneds) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_AnyPoints_Unsigneds) MarshalToSizedBuffer added in v1.9.0

func (m *ReadResponse_AnyPoints_Unsigneds) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_AnyPoints_Unsigneds) Size added in v1.9.0

func (m *ReadResponse_AnyPoints_Unsigneds) Size() (n int)

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"`
}

func (*ReadResponse_BooleanPointsFrame) Descriptor

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

func (*ReadResponse_BooleanPointsFrame) Marshal

func (m *ReadResponse_BooleanPointsFrame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_BooleanPointsFrame) MarshalTo

func (m *ReadResponse_BooleanPointsFrame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_BooleanPointsFrame) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_BooleanPointsFrame) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_BooleanPointsFrame) ProtoMessage

func (*ReadResponse_BooleanPointsFrame) ProtoMessage()

func (*ReadResponse_BooleanPointsFrame) Reset

func (*ReadResponse_BooleanPointsFrame) Size

func (m *ReadResponse_BooleanPointsFrame) Size() (n int)

func (*ReadResponse_BooleanPointsFrame) String

func (*ReadResponse_BooleanPointsFrame) Unmarshal

func (m *ReadResponse_BooleanPointsFrame) Unmarshal(dAtA []byte) error

func (*ReadResponse_BooleanPointsFrame) XXX_DiscardUnknown

func (m *ReadResponse_BooleanPointsFrame) XXX_DiscardUnknown()

func (*ReadResponse_BooleanPointsFrame) XXX_Marshal

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

func (*ReadResponse_BooleanPointsFrame) XXX_Merge

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

func (*ReadResponse_BooleanPointsFrame) XXX_Size

func (m *ReadResponse_BooleanPointsFrame) XXX_Size() int

func (*ReadResponse_BooleanPointsFrame) XXX_Unmarshal

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

type ReadResponse_BooleanValues added in v1.9.0

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

func (*ReadResponse_BooleanValues) Descriptor added in v1.9.0

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

func (*ReadResponse_BooleanValues) Marshal added in v1.9.0

func (m *ReadResponse_BooleanValues) Marshal() (dAtA []byte, err error)

func (*ReadResponse_BooleanValues) MarshalTo added in v1.9.0

func (m *ReadResponse_BooleanValues) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_BooleanValues) MarshalToSizedBuffer added in v1.9.0

func (m *ReadResponse_BooleanValues) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_BooleanValues) ProtoMessage added in v1.9.0

func (*ReadResponse_BooleanValues) ProtoMessage()

func (*ReadResponse_BooleanValues) Reset added in v1.9.0

func (m *ReadResponse_BooleanValues) Reset()

func (*ReadResponse_BooleanValues) Size added in v1.9.0

func (m *ReadResponse_BooleanValues) Size() (n int)

func (*ReadResponse_BooleanValues) String added in v1.9.0

func (m *ReadResponse_BooleanValues) String() string

func (*ReadResponse_BooleanValues) Unmarshal added in v1.9.0

func (m *ReadResponse_BooleanValues) Unmarshal(dAtA []byte) error

func (*ReadResponse_BooleanValues) XXX_DiscardUnknown added in v1.9.0

func (m *ReadResponse_BooleanValues) XXX_DiscardUnknown()

func (*ReadResponse_BooleanValues) XXX_Marshal added in v1.9.0

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

func (*ReadResponse_BooleanValues) XXX_Merge added in v1.9.0

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

func (*ReadResponse_BooleanValues) XXX_Size added in v1.9.0

func (m *ReadResponse_BooleanValues) XXX_Size() int

func (*ReadResponse_BooleanValues) XXX_Unmarshal added in v1.9.0

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

type ReadResponse_DataType

type ReadResponse_DataType int32
const (
	DataTypeFloat    ReadResponse_DataType = 0
	DataTypeInteger  ReadResponse_DataType = 1
	DataTypeUnsigned ReadResponse_DataType = 2
	DataTypeBoolean  ReadResponse_DataType = 3
	DataTypeString   ReadResponse_DataType = 4
	DataTypeMulti    ReadResponse_DataType = 5
)

func (ReadResponse_DataType) EnumDescriptor

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

func (ReadResponse_DataType) String

func (x ReadResponse_DataType) String() string

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"`
}

func (*ReadResponse_FloatPointsFrame) Descriptor

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

func (*ReadResponse_FloatPointsFrame) Marshal

func (m *ReadResponse_FloatPointsFrame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_FloatPointsFrame) MarshalTo

func (m *ReadResponse_FloatPointsFrame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_FloatPointsFrame) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_FloatPointsFrame) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_FloatPointsFrame) ProtoMessage

func (*ReadResponse_FloatPointsFrame) ProtoMessage()

func (*ReadResponse_FloatPointsFrame) Reset

func (m *ReadResponse_FloatPointsFrame) Reset()

func (*ReadResponse_FloatPointsFrame) Size

func (m *ReadResponse_FloatPointsFrame) Size() (n int)

func (*ReadResponse_FloatPointsFrame) String

func (*ReadResponse_FloatPointsFrame) Unmarshal

func (m *ReadResponse_FloatPointsFrame) Unmarshal(dAtA []byte) error

func (*ReadResponse_FloatPointsFrame) XXX_DiscardUnknown

func (m *ReadResponse_FloatPointsFrame) XXX_DiscardUnknown()

func (*ReadResponse_FloatPointsFrame) XXX_Marshal

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

func (*ReadResponse_FloatPointsFrame) XXX_Merge

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

func (*ReadResponse_FloatPointsFrame) XXX_Size

func (m *ReadResponse_FloatPointsFrame) XXX_Size() int

func (*ReadResponse_FloatPointsFrame) XXX_Unmarshal

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

type ReadResponse_FloatValues added in v1.9.0

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

func (*ReadResponse_FloatValues) Descriptor added in v1.9.0

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

func (*ReadResponse_FloatValues) Marshal added in v1.9.0

func (m *ReadResponse_FloatValues) Marshal() (dAtA []byte, err error)

func (*ReadResponse_FloatValues) MarshalTo added in v1.9.0

func (m *ReadResponse_FloatValues) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_FloatValues) MarshalToSizedBuffer added in v1.9.0

func (m *ReadResponse_FloatValues) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_FloatValues) ProtoMessage added in v1.9.0

func (*ReadResponse_FloatValues) ProtoMessage()

func (*ReadResponse_FloatValues) Reset added in v1.9.0

func (m *ReadResponse_FloatValues) Reset()

func (*ReadResponse_FloatValues) Size added in v1.9.0

func (m *ReadResponse_FloatValues) Size() (n int)

func (*ReadResponse_FloatValues) String added in v1.9.0

func (m *ReadResponse_FloatValues) String() string

func (*ReadResponse_FloatValues) Unmarshal added in v1.9.0

func (m *ReadResponse_FloatValues) Unmarshal(dAtA []byte) error

func (*ReadResponse_FloatValues) XXX_DiscardUnknown added in v1.9.0

func (m *ReadResponse_FloatValues) XXX_DiscardUnknown()

func (*ReadResponse_FloatValues) XXX_Marshal added in v1.9.0

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

func (*ReadResponse_FloatValues) XXX_Merge added in v1.9.0

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

func (*ReadResponse_FloatValues) XXX_Size added in v1.9.0

func (m *ReadResponse_FloatValues) XXX_Size() int

func (*ReadResponse_FloatValues) XXX_Unmarshal added in v1.9.0

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

type ReadResponse_Frame

type ReadResponse_Frame struct {
	// Types that are valid to be assigned 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"`
}

func (*ReadResponse_Frame) Descriptor

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

func (*ReadResponse_Frame) GetBooleanPoints

func (m *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 (m *ReadResponse_Frame) GetIntegerPoints() *ReadResponse_IntegerPointsFrame

func (*ReadResponse_Frame) GetMultiPoints added in v1.9.0

func (*ReadResponse_Frame) GetSeries

func (*ReadResponse_Frame) GetStringPoints

func (m *ReadResponse_Frame) GetStringPoints() *ReadResponse_StringPointsFrame

func (*ReadResponse_Frame) GetUnsignedPoints

func (m *ReadResponse_Frame) GetUnsignedPoints() *ReadResponse_UnsignedPointsFrame

func (*ReadResponse_Frame) Marshal

func (m *ReadResponse_Frame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_Frame) MarshalTo

func (m *ReadResponse_Frame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_Frame) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_Frame) ProtoMessage

func (*ReadResponse_Frame) ProtoMessage()

func (*ReadResponse_Frame) Reset

func (m *ReadResponse_Frame) Reset()

func (*ReadResponse_Frame) Size

func (m *ReadResponse_Frame) Size() (n int)

func (*ReadResponse_Frame) String

func (m *ReadResponse_Frame) String() string

func (*ReadResponse_Frame) Unmarshal

func (m *ReadResponse_Frame) Unmarshal(dAtA []byte) error

func (*ReadResponse_Frame) XXX_DiscardUnknown

func (m *ReadResponse_Frame) XXX_DiscardUnknown()

func (*ReadResponse_Frame) XXX_Marshal

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

func (*ReadResponse_Frame) XXX_Merge

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

func (*ReadResponse_Frame) XXX_OneofWrappers added in v1.8.7

func (*ReadResponse_Frame) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ReadResponse_Frame) XXX_Size

func (m *ReadResponse_Frame) XXX_Size() int

func (*ReadResponse_Frame) XXX_Unmarshal

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

type ReadResponse_FrameType

type ReadResponse_FrameType int32
const (
	FrameTypeSeries ReadResponse_FrameType = 0
	FrameTypePoints ReadResponse_FrameType = 1
)

func (ReadResponse_FrameType) EnumDescriptor

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

func (ReadResponse_FrameType) String

func (x ReadResponse_FrameType) String() string

type ReadResponse_Frame_BooleanPoints

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

func (*ReadResponse_Frame_BooleanPoints) MarshalTo

func (m *ReadResponse_Frame_BooleanPoints) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame_BooleanPoints) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_Frame_BooleanPoints) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_Frame_BooleanPoints) Size

func (m *ReadResponse_Frame_BooleanPoints) Size() (n int)

type ReadResponse_Frame_FloatPoints

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

func (*ReadResponse_Frame_FloatPoints) MarshalTo

func (m *ReadResponse_Frame_FloatPoints) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame_FloatPoints) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_Frame_FloatPoints) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_Frame_FloatPoints) Size

func (m *ReadResponse_Frame_FloatPoints) Size() (n int)

type ReadResponse_Frame_Group

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

func (*ReadResponse_Frame_Group) MarshalTo

func (m *ReadResponse_Frame_Group) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame_Group) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_Frame_Group) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_Frame_Group) Size

func (m *ReadResponse_Frame_Group) Size() (n int)

type ReadResponse_Frame_IntegerPoints

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

func (*ReadResponse_Frame_IntegerPoints) MarshalTo

func (m *ReadResponse_Frame_IntegerPoints) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame_IntegerPoints) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_Frame_IntegerPoints) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_Frame_IntegerPoints) Size

func (m *ReadResponse_Frame_IntegerPoints) Size() (n int)

type ReadResponse_Frame_MultiPoints added in v1.9.0

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

func (*ReadResponse_Frame_MultiPoints) MarshalTo added in v1.9.0

func (m *ReadResponse_Frame_MultiPoints) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame_MultiPoints) MarshalToSizedBuffer added in v1.9.0

func (m *ReadResponse_Frame_MultiPoints) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_Frame_MultiPoints) Size added in v1.9.0

func (m *ReadResponse_Frame_MultiPoints) Size() (n int)

type ReadResponse_Frame_Series

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

func (*ReadResponse_Frame_Series) MarshalTo

func (m *ReadResponse_Frame_Series) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame_Series) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_Frame_Series) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_Frame_Series) Size

func (m *ReadResponse_Frame_Series) Size() (n int)

type ReadResponse_Frame_StringPoints

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

func (*ReadResponse_Frame_StringPoints) MarshalTo

func (m *ReadResponse_Frame_StringPoints) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame_StringPoints) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_Frame_StringPoints) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_Frame_StringPoints) Size

func (m *ReadResponse_Frame_StringPoints) Size() (n int)

type ReadResponse_Frame_UnsignedPoints

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

func (*ReadResponse_Frame_UnsignedPoints) MarshalTo

func (m *ReadResponse_Frame_UnsignedPoints) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_Frame_UnsignedPoints) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_Frame_UnsignedPoints) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_Frame_UnsignedPoints) Size

func (m *ReadResponse_Frame_UnsignedPoints) Size() (n int)

type ReadResponse_GroupFrame

type ReadResponse_GroupFrame struct {
	// TagKeys
	TagKeys [][]byte `protobuf:"bytes,1,rep,name=tag_keys,json=tagKeys,proto3" json:"tag_keys,omitempty"`
	// PartitionKeyVals is the values of the partition key for this group, order matching ReadGroupRequest.GroupKeys
	PartitionKeyVals [][]byte `protobuf:"bytes,2,rep,name=partition_key_vals,json=partitionKeyVals,proto3" json:"partition_key_vals,omitempty"`
}

func (*ReadResponse_GroupFrame) Descriptor

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

func (*ReadResponse_GroupFrame) Marshal

func (m *ReadResponse_GroupFrame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_GroupFrame) MarshalTo

func (m *ReadResponse_GroupFrame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_GroupFrame) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_GroupFrame) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_GroupFrame) ProtoMessage

func (*ReadResponse_GroupFrame) ProtoMessage()

func (*ReadResponse_GroupFrame) Reset

func (m *ReadResponse_GroupFrame) Reset()

func (*ReadResponse_GroupFrame) Size

func (m *ReadResponse_GroupFrame) Size() (n int)

func (*ReadResponse_GroupFrame) String

func (m *ReadResponse_GroupFrame) String() string

func (*ReadResponse_GroupFrame) Unmarshal

func (m *ReadResponse_GroupFrame) Unmarshal(dAtA []byte) error

func (*ReadResponse_GroupFrame) XXX_DiscardUnknown

func (m *ReadResponse_GroupFrame) XXX_DiscardUnknown()

func (*ReadResponse_GroupFrame) XXX_Marshal

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

func (*ReadResponse_GroupFrame) XXX_Merge

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

func (*ReadResponse_GroupFrame) XXX_Size

func (m *ReadResponse_GroupFrame) XXX_Size() int

func (*ReadResponse_GroupFrame) XXX_Unmarshal

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

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"`
}

func (*ReadResponse_IntegerPointsFrame) Descriptor

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

func (*ReadResponse_IntegerPointsFrame) Marshal

func (m *ReadResponse_IntegerPointsFrame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_IntegerPointsFrame) MarshalTo

func (m *ReadResponse_IntegerPointsFrame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_IntegerPointsFrame) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_IntegerPointsFrame) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_IntegerPointsFrame) ProtoMessage

func (*ReadResponse_IntegerPointsFrame) ProtoMessage()

func (*ReadResponse_IntegerPointsFrame) Reset

func (*ReadResponse_IntegerPointsFrame) Size

func (m *ReadResponse_IntegerPointsFrame) Size() (n int)

func (*ReadResponse_IntegerPointsFrame) String

func (*ReadResponse_IntegerPointsFrame) Unmarshal

func (m *ReadResponse_IntegerPointsFrame) Unmarshal(dAtA []byte) error

func (*ReadResponse_IntegerPointsFrame) XXX_DiscardUnknown

func (m *ReadResponse_IntegerPointsFrame) XXX_DiscardUnknown()

func (*ReadResponse_IntegerPointsFrame) XXX_Marshal

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

func (*ReadResponse_IntegerPointsFrame) XXX_Merge

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

func (*ReadResponse_IntegerPointsFrame) XXX_Size

func (m *ReadResponse_IntegerPointsFrame) XXX_Size() int

func (*ReadResponse_IntegerPointsFrame) XXX_Unmarshal

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

type ReadResponse_IntegerValues added in v1.9.0

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

func (*ReadResponse_IntegerValues) Descriptor added in v1.9.0

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

func (*ReadResponse_IntegerValues) Marshal added in v1.9.0

func (m *ReadResponse_IntegerValues) Marshal() (dAtA []byte, err error)

func (*ReadResponse_IntegerValues) MarshalTo added in v1.9.0

func (m *ReadResponse_IntegerValues) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_IntegerValues) MarshalToSizedBuffer added in v1.9.0

func (m *ReadResponse_IntegerValues) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_IntegerValues) ProtoMessage added in v1.9.0

func (*ReadResponse_IntegerValues) ProtoMessage()

func (*ReadResponse_IntegerValues) Reset added in v1.9.0

func (m *ReadResponse_IntegerValues) Reset()

func (*ReadResponse_IntegerValues) Size added in v1.9.0

func (m *ReadResponse_IntegerValues) Size() (n int)

func (*ReadResponse_IntegerValues) String added in v1.9.0

func (m *ReadResponse_IntegerValues) String() string

func (*ReadResponse_IntegerValues) Unmarshal added in v1.9.0

func (m *ReadResponse_IntegerValues) Unmarshal(dAtA []byte) error

func (*ReadResponse_IntegerValues) XXX_DiscardUnknown added in v1.9.0

func (m *ReadResponse_IntegerValues) XXX_DiscardUnknown()

func (*ReadResponse_IntegerValues) XXX_Marshal added in v1.9.0

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

func (*ReadResponse_IntegerValues) XXX_Merge added in v1.9.0

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

func (*ReadResponse_IntegerValues) XXX_Size added in v1.9.0

func (m *ReadResponse_IntegerValues) XXX_Size() int

func (*ReadResponse_IntegerValues) XXX_Unmarshal added in v1.9.0

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

type ReadResponse_MultiPointsFrame added in v1.9.0

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"`
}

func (*ReadResponse_MultiPointsFrame) Descriptor added in v1.9.0

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

func (*ReadResponse_MultiPointsFrame) Marshal added in v1.9.0

func (m *ReadResponse_MultiPointsFrame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_MultiPointsFrame) MarshalTo added in v1.9.0

func (m *ReadResponse_MultiPointsFrame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_MultiPointsFrame) MarshalToSizedBuffer added in v1.9.0

func (m *ReadResponse_MultiPointsFrame) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_MultiPointsFrame) ProtoMessage added in v1.9.0

func (*ReadResponse_MultiPointsFrame) ProtoMessage()

func (*ReadResponse_MultiPointsFrame) Reset added in v1.9.0

func (m *ReadResponse_MultiPointsFrame) Reset()

func (*ReadResponse_MultiPointsFrame) Size added in v1.9.0

func (m *ReadResponse_MultiPointsFrame) Size() (n int)

func (*ReadResponse_MultiPointsFrame) String added in v1.9.0

func (*ReadResponse_MultiPointsFrame) Unmarshal added in v1.9.0

func (m *ReadResponse_MultiPointsFrame) Unmarshal(dAtA []byte) error

func (*ReadResponse_MultiPointsFrame) XXX_DiscardUnknown added in v1.9.0

func (m *ReadResponse_MultiPointsFrame) XXX_DiscardUnknown()

func (*ReadResponse_MultiPointsFrame) XXX_Marshal added in v1.9.0

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

func (*ReadResponse_MultiPointsFrame) XXX_Merge added in v1.9.0

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

func (*ReadResponse_MultiPointsFrame) XXX_Size added in v1.9.0

func (m *ReadResponse_MultiPointsFrame) XXX_Size() int

func (*ReadResponse_MultiPointsFrame) XXX_Unmarshal added in v1.9.0

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

type ReadResponse_SeriesFrame

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

func (*ReadResponse_SeriesFrame) Descriptor

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

func (*ReadResponse_SeriesFrame) Marshal

func (m *ReadResponse_SeriesFrame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_SeriesFrame) MarshalTo

func (m *ReadResponse_SeriesFrame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_SeriesFrame) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_SeriesFrame) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_SeriesFrame) ProtoMessage

func (*ReadResponse_SeriesFrame) ProtoMessage()

func (*ReadResponse_SeriesFrame) Reset

func (m *ReadResponse_SeriesFrame) Reset()

func (*ReadResponse_SeriesFrame) Size

func (m *ReadResponse_SeriesFrame) Size() (n int)

func (*ReadResponse_SeriesFrame) String

func (m *ReadResponse_SeriesFrame) String() string

func (*ReadResponse_SeriesFrame) Unmarshal

func (m *ReadResponse_SeriesFrame) Unmarshal(dAtA []byte) error

func (*ReadResponse_SeriesFrame) XXX_DiscardUnknown

func (m *ReadResponse_SeriesFrame) XXX_DiscardUnknown()

func (*ReadResponse_SeriesFrame) XXX_Marshal

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

func (*ReadResponse_SeriesFrame) XXX_Merge

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

func (*ReadResponse_SeriesFrame) XXX_Size

func (m *ReadResponse_SeriesFrame) XXX_Size() int

func (*ReadResponse_SeriesFrame) XXX_Unmarshal

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

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"`
}

func (*ReadResponse_StringPointsFrame) Descriptor

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

func (*ReadResponse_StringPointsFrame) Marshal

func (m *ReadResponse_StringPointsFrame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_StringPointsFrame) MarshalTo

func (m *ReadResponse_StringPointsFrame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_StringPointsFrame) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_StringPointsFrame) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_StringPointsFrame) ProtoMessage

func (*ReadResponse_StringPointsFrame) ProtoMessage()

func (*ReadResponse_StringPointsFrame) Reset

func (m *ReadResponse_StringPointsFrame) Reset()

func (*ReadResponse_StringPointsFrame) Size

func (m *ReadResponse_StringPointsFrame) Size() (n int)

func (*ReadResponse_StringPointsFrame) String

func (*ReadResponse_StringPointsFrame) Unmarshal

func (m *ReadResponse_StringPointsFrame) Unmarshal(dAtA []byte) error

func (*ReadResponse_StringPointsFrame) XXX_DiscardUnknown

func (m *ReadResponse_StringPointsFrame) XXX_DiscardUnknown()

func (*ReadResponse_StringPointsFrame) XXX_Marshal

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

func (*ReadResponse_StringPointsFrame) XXX_Merge

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

func (*ReadResponse_StringPointsFrame) XXX_Size

func (m *ReadResponse_StringPointsFrame) XXX_Size() int

func (*ReadResponse_StringPointsFrame) XXX_Unmarshal

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

type ReadResponse_StringValues added in v1.9.0

type ReadResponse_StringValues struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
}

func (*ReadResponse_StringValues) Descriptor added in v1.9.0

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

func (*ReadResponse_StringValues) Marshal added in v1.9.0

func (m *ReadResponse_StringValues) Marshal() (dAtA []byte, err error)

func (*ReadResponse_StringValues) MarshalTo added in v1.9.0

func (m *ReadResponse_StringValues) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_StringValues) MarshalToSizedBuffer added in v1.9.0

func (m *ReadResponse_StringValues) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_StringValues) ProtoMessage added in v1.9.0

func (*ReadResponse_StringValues) ProtoMessage()

func (*ReadResponse_StringValues) Reset added in v1.9.0

func (m *ReadResponse_StringValues) Reset()

func (*ReadResponse_StringValues) Size added in v1.9.0

func (m *ReadResponse_StringValues) Size() (n int)

func (*ReadResponse_StringValues) String added in v1.9.0

func (m *ReadResponse_StringValues) String() string

func (*ReadResponse_StringValues) Unmarshal added in v1.9.0

func (m *ReadResponse_StringValues) Unmarshal(dAtA []byte) error

func (*ReadResponse_StringValues) XXX_DiscardUnknown added in v1.9.0

func (m *ReadResponse_StringValues) XXX_DiscardUnknown()

func (*ReadResponse_StringValues) XXX_Marshal added in v1.9.0

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

func (*ReadResponse_StringValues) XXX_Merge added in v1.9.0

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

func (*ReadResponse_StringValues) XXX_Size added in v1.9.0

func (m *ReadResponse_StringValues) XXX_Size() int

func (*ReadResponse_StringValues) XXX_Unmarshal added in v1.9.0

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

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"`
}

func (*ReadResponse_UnsignedPointsFrame) Descriptor

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

func (*ReadResponse_UnsignedPointsFrame) Marshal

func (m *ReadResponse_UnsignedPointsFrame) Marshal() (dAtA []byte, err error)

func (*ReadResponse_UnsignedPointsFrame) MarshalTo

func (m *ReadResponse_UnsignedPointsFrame) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_UnsignedPointsFrame) MarshalToSizedBuffer added in v1.8.7

func (m *ReadResponse_UnsignedPointsFrame) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_UnsignedPointsFrame) ProtoMessage

func (*ReadResponse_UnsignedPointsFrame) ProtoMessage()

func (*ReadResponse_UnsignedPointsFrame) Reset

func (*ReadResponse_UnsignedPointsFrame) Size

func (m *ReadResponse_UnsignedPointsFrame) Size() (n int)

func (*ReadResponse_UnsignedPointsFrame) String

func (*ReadResponse_UnsignedPointsFrame) Unmarshal

func (m *ReadResponse_UnsignedPointsFrame) Unmarshal(dAtA []byte) error

func (*ReadResponse_UnsignedPointsFrame) XXX_DiscardUnknown

func (m *ReadResponse_UnsignedPointsFrame) XXX_DiscardUnknown()

func (*ReadResponse_UnsignedPointsFrame) XXX_Marshal

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

func (*ReadResponse_UnsignedPointsFrame) XXX_Merge

func (*ReadResponse_UnsignedPointsFrame) XXX_Size

func (m *ReadResponse_UnsignedPointsFrame) XXX_Size() int

func (*ReadResponse_UnsignedPointsFrame) XXX_Unmarshal

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

type ReadResponse_UnsignedValues added in v1.9.0

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

func (*ReadResponse_UnsignedValues) Descriptor added in v1.9.0

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

func (*ReadResponse_UnsignedValues) Marshal added in v1.9.0

func (m *ReadResponse_UnsignedValues) Marshal() (dAtA []byte, err error)

func (*ReadResponse_UnsignedValues) MarshalTo added in v1.9.0

func (m *ReadResponse_UnsignedValues) MarshalTo(dAtA []byte) (int, error)

func (*ReadResponse_UnsignedValues) MarshalToSizedBuffer added in v1.9.0

func (m *ReadResponse_UnsignedValues) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadResponse_UnsignedValues) ProtoMessage added in v1.9.0

func (*ReadResponse_UnsignedValues) ProtoMessage()

func (*ReadResponse_UnsignedValues) Reset added in v1.9.0

func (m *ReadResponse_UnsignedValues) Reset()

func (*ReadResponse_UnsignedValues) Size added in v1.9.0

func (m *ReadResponse_UnsignedValues) Size() (n int)

func (*ReadResponse_UnsignedValues) String added in v1.9.0

func (m *ReadResponse_UnsignedValues) String() string

func (*ReadResponse_UnsignedValues) Unmarshal added in v1.9.0

func (m *ReadResponse_UnsignedValues) Unmarshal(dAtA []byte) error

func (*ReadResponse_UnsignedValues) XXX_DiscardUnknown added in v1.9.0

func (m *ReadResponse_UnsignedValues) XXX_DiscardUnknown()

func (*ReadResponse_UnsignedValues) XXX_Marshal added in v1.9.0

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

func (*ReadResponse_UnsignedValues) XXX_Merge added in v1.9.0

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

func (*ReadResponse_UnsignedValues) XXX_Size added in v1.9.0

func (m *ReadResponse_UnsignedValues) XXX_Size() int

func (*ReadResponse_UnsignedValues) XXX_Unmarshal added in v1.9.0

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

type ReadWindowAggregateRequest added in v1.9.0

type ReadWindowAggregateRequest struct {
	ReadSource  *types.Any     `protobuf:"bytes,1,opt,name=read_source,json=readSource,proto3" json:"read_source,omitempty"`
	Range       TimestampRange `protobuf:"bytes,2,opt,name=range,proto3" json:"range"`
	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"`
}

func (*ReadWindowAggregateRequest) Descriptor added in v1.9.0

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

func (*ReadWindowAggregateRequest) Marshal added in v1.9.0

func (m *ReadWindowAggregateRequest) Marshal() (dAtA []byte, err error)

func (*ReadWindowAggregateRequest) MarshalTo added in v1.9.0

func (m *ReadWindowAggregateRequest) MarshalTo(dAtA []byte) (int, error)

func (*ReadWindowAggregateRequest) MarshalToSizedBuffer added in v1.9.0

func (m *ReadWindowAggregateRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ReadWindowAggregateRequest) ProtoMessage added in v1.9.0

func (*ReadWindowAggregateRequest) ProtoMessage()

func (*ReadWindowAggregateRequest) Reset added in v1.9.0

func (m *ReadWindowAggregateRequest) Reset()

func (*ReadWindowAggregateRequest) Size added in v1.9.0

func (m *ReadWindowAggregateRequest) Size() (n int)

func (*ReadWindowAggregateRequest) String added in v1.9.0

func (m *ReadWindowAggregateRequest) String() string

func (*ReadWindowAggregateRequest) Unmarshal added in v1.9.0

func (m *ReadWindowAggregateRequest) Unmarshal(dAtA []byte) error

func (*ReadWindowAggregateRequest) XXX_DiscardUnknown added in v1.9.0

func (m *ReadWindowAggregateRequest) XXX_DiscardUnknown()

func (*ReadWindowAggregateRequest) XXX_Marshal added in v1.9.0

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

func (*ReadWindowAggregateRequest) XXX_Merge added in v1.9.0

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

func (*ReadWindowAggregateRequest) XXX_Size added in v1.9.0

func (m *ReadWindowAggregateRequest) XXX_Size() int

func (*ReadWindowAggregateRequest) XXX_Unmarshal added in v1.9.0

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

type StorageClient

type StorageClient interface {
	// ReadFilter performs a filter operation at storage
	ReadFilter(ctx context.Context, in *ReadFilterRequest, opts ...grpc.CallOption) (Storage_ReadFilterClient, error)
	// ReadGroup performs a group operation at storage
	ReadGroup(ctx context.Context, in *ReadGroupRequest, opts ...grpc.CallOption) (Storage_ReadGroupClient, error)
	ReadWindowAggregate(ctx context.Context, in *ReadWindowAggregateRequest, opts ...grpc.CallOption) (Storage_ReadWindowAggregateClient, error)
	// TagKeys performs a read operation for tag keys
	TagKeys(ctx context.Context, in *TagKeysRequest, opts ...grpc.CallOption) (Storage_TagKeysClient, error)
	// TagValues performs a read operation for tag values
	TagValues(ctx context.Context, in *TagValuesRequest, opts ...grpc.CallOption) (Storage_TagValuesClient, error)
	// Capabilities returns a map of keys and values identifying the capabilities supported by the storage engine
	Capabilities(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*CapabilitiesResponse, error)
}

StorageClient is the client API for Storage service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewStorageClient

func NewStorageClient(cc *grpc.ClientConn) StorageClient

type StorageServer

type StorageServer interface {
	// ReadFilter performs a filter operation at storage
	ReadFilter(*ReadFilterRequest, Storage_ReadFilterServer) error
	// ReadGroup performs a group operation at storage
	ReadGroup(*ReadGroupRequest, Storage_ReadGroupServer) error
	ReadWindowAggregate(*ReadWindowAggregateRequest, Storage_ReadWindowAggregateServer) error
	// TagKeys performs a read operation for tag keys
	TagKeys(*TagKeysRequest, Storage_TagKeysServer) error
	// TagValues performs a read operation for tag values
	TagValues(*TagValuesRequest, Storage_TagValuesServer) error
	// Capabilities returns a map of keys and values identifying the capabilities supported by the storage engine
	Capabilities(context.Context, *types.Empty) (*CapabilitiesResponse, error)
}

StorageServer is the server API for Storage service.

type Storage_ReadFilterClient added in v1.7.8

type Storage_ReadFilterClient interface {
	Recv() (*ReadResponse, error)
	grpc.ClientStream
}

type Storage_ReadFilterServer added in v1.7.8

type Storage_ReadFilterServer interface {
	Send(*ReadResponse) error
	grpc.ServerStream
}

type Storage_ReadGroupClient added in v1.7.8

type Storage_ReadGroupClient interface {
	Recv() (*ReadResponse, error)
	grpc.ClientStream
}

type Storage_ReadGroupServer added in v1.7.8

type Storage_ReadGroupServer interface {
	Send(*ReadResponse) error
	grpc.ServerStream
}

type Storage_ReadWindowAggregateClient added in v1.9.0

type Storage_ReadWindowAggregateClient interface {
	Recv() (*ReadResponse, error)
	grpc.ClientStream
}

type Storage_ReadWindowAggregateServer added in v1.9.0

type Storage_ReadWindowAggregateServer interface {
	Send(*ReadResponse) error
	grpc.ServerStream
}

type Storage_TagKeysClient added in v1.7.8

type Storage_TagKeysClient interface {
	Recv() (*StringValuesResponse, error)
	grpc.ClientStream
}

type Storage_TagKeysServer added in v1.7.8

type Storage_TagKeysServer interface {
	Send(*StringValuesResponse) error
	grpc.ServerStream
}

type Storage_TagValuesClient added in v1.7.8

type Storage_TagValuesClient interface {
	Recv() (*StringValuesResponse, error)
	grpc.ClientStream
}

type Storage_TagValuesServer added in v1.7.8

type Storage_TagValuesServer interface {
	Send(*StringValuesResponse) error
	grpc.ServerStream
}

type StringValuesResponse added in v1.7.8

type StringValuesResponse struct {
	Values [][]byte `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
}

Response message for Storage.TagKeys and Storage.TagValues.

func (*StringValuesResponse) Descriptor added in v1.7.8

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

func (*StringValuesResponse) Marshal added in v1.7.8

func (m *StringValuesResponse) Marshal() (dAtA []byte, err error)

func (*StringValuesResponse) MarshalTo added in v1.7.8

func (m *StringValuesResponse) MarshalTo(dAtA []byte) (int, error)

func (*StringValuesResponse) MarshalToSizedBuffer added in v1.8.7

func (m *StringValuesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StringValuesResponse) ProtoMessage added in v1.7.8

func (*StringValuesResponse) ProtoMessage()

func (*StringValuesResponse) Reset added in v1.7.8

func (m *StringValuesResponse) Reset()

func (*StringValuesResponse) Size added in v1.7.8

func (m *StringValuesResponse) Size() (n int)

func (*StringValuesResponse) String added in v1.7.8

func (m *StringValuesResponse) String() string

func (*StringValuesResponse) Unmarshal added in v1.7.8

func (m *StringValuesResponse) Unmarshal(dAtA []byte) error

func (*StringValuesResponse) XXX_DiscardUnknown added in v1.7.8

func (m *StringValuesResponse) XXX_DiscardUnknown()

func (*StringValuesResponse) XXX_Marshal added in v1.7.8

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

func (*StringValuesResponse) XXX_Merge added in v1.7.8

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

func (*StringValuesResponse) XXX_Size added in v1.7.8

func (m *StringValuesResponse) XXX_Size() int

func (*StringValuesResponse) XXX_Unmarshal added in v1.7.8

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

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"`
}

func (*Tag) Descriptor

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

func (*Tag) Marshal

func (m *Tag) Marshal() (dAtA []byte, err error)

func (*Tag) MarshalTo

func (m *Tag) MarshalTo(dAtA []byte) (int, error)

func (*Tag) MarshalToSizedBuffer added in v1.8.7

func (m *Tag) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Tag) ProtoMessage

func (*Tag) ProtoMessage()

func (*Tag) Reset

func (m *Tag) Reset()

func (*Tag) Size

func (m *Tag) Size() (n int)

func (*Tag) String

func (m *Tag) String() string

func (*Tag) Unmarshal

func (m *Tag) Unmarshal(dAtA []byte) error

func (*Tag) XXX_DiscardUnknown

func (m *Tag) XXX_DiscardUnknown()

func (*Tag) XXX_Marshal

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

func (*Tag) XXX_Merge

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

func (*Tag) XXX_Size

func (m *Tag) XXX_Size() int

func (*Tag) XXX_Unmarshal

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

type TagKeysRequest added in v1.7.8

type TagKeysRequest struct {
	TagsSource *types.Any     `protobuf:"bytes,1,opt,name=tags_source,json=tagsSource,proto3" json:"tags_source,omitempty"`
	Range      TimestampRange `protobuf:"bytes,2,opt,name=range,proto3" json:"range"`
	Predicate  *Predicate     `protobuf:"bytes,3,opt,name=predicate,proto3" json:"predicate,omitempty"`
}

TagKeysRequest is the request message for Storage.TagKeys.

func (*TagKeysRequest) Descriptor added in v1.7.8

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

func (*TagKeysRequest) Marshal added in v1.7.8

func (m *TagKeysRequest) Marshal() (dAtA []byte, err error)

func (*TagKeysRequest) MarshalTo added in v1.7.8

func (m *TagKeysRequest) MarshalTo(dAtA []byte) (int, error)

func (*TagKeysRequest) MarshalToSizedBuffer added in v1.8.7

func (m *TagKeysRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TagKeysRequest) ProtoMessage added in v1.7.8

func (*TagKeysRequest) ProtoMessage()

func (*TagKeysRequest) Reset added in v1.7.8

func (m *TagKeysRequest) Reset()

func (*TagKeysRequest) Size added in v1.7.8

func (m *TagKeysRequest) Size() (n int)

func (*TagKeysRequest) String added in v1.7.8

func (m *TagKeysRequest) String() string

func (*TagKeysRequest) Unmarshal added in v1.7.8

func (m *TagKeysRequest) Unmarshal(dAtA []byte) error

func (*TagKeysRequest) XXX_DiscardUnknown added in v1.7.8

func (m *TagKeysRequest) XXX_DiscardUnknown()

func (*TagKeysRequest) XXX_Marshal added in v1.7.8

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

func (*TagKeysRequest) XXX_Merge added in v1.7.8

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

func (*TagKeysRequest) XXX_Size added in v1.7.8

func (m *TagKeysRequest) XXX_Size() int

func (*TagKeysRequest) XXX_Unmarshal added in v1.7.8

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

type TagValuesRequest added in v1.7.8

type TagValuesRequest struct {
	TagsSource *types.Any     `protobuf:"bytes,1,opt,name=tags_source,json=tagsSource,proto3" json:"tags_source,omitempty"`
	Range      TimestampRange `protobuf:"bytes,2,opt,name=range,proto3" json:"range"`
	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"`
}

TagValuesRequest is the request message for Storage.TagValues.

func (*TagValuesRequest) Descriptor added in v1.7.8

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

func (*TagValuesRequest) Marshal added in v1.7.8

func (m *TagValuesRequest) Marshal() (dAtA []byte, err error)

func (*TagValuesRequest) MarshalTo added in v1.7.8

func (m *TagValuesRequest) MarshalTo(dAtA []byte) (int, error)

func (*TagValuesRequest) MarshalToSizedBuffer added in v1.8.7

func (m *TagValuesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TagValuesRequest) ProtoMessage added in v1.7.8

func (*TagValuesRequest) ProtoMessage()

func (*TagValuesRequest) Reset added in v1.7.8

func (m *TagValuesRequest) Reset()

func (*TagValuesRequest) Size added in v1.7.8

func (m *TagValuesRequest) Size() (n int)

func (*TagValuesRequest) String added in v1.7.8

func (m *TagValuesRequest) String() string

func (*TagValuesRequest) Unmarshal added in v1.7.8

func (m *TagValuesRequest) Unmarshal(dAtA []byte) error

func (*TagValuesRequest) XXX_DiscardUnknown added in v1.7.8

func (m *TagValuesRequest) XXX_DiscardUnknown()

func (*TagValuesRequest) XXX_Marshal added in v1.7.8

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

func (*TagValuesRequest) XXX_Merge added in v1.7.8

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

func (*TagValuesRequest) XXX_Size added in v1.7.8

func (m *TagValuesRequest) XXX_Size() int

func (*TagValuesRequest) XXX_Unmarshal added in v1.7.8

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

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"`
}

Specifies a continuous range of nanosecond timestamps.

func (*TimestampRange) Descriptor

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

func (*TimestampRange) Marshal

func (m *TimestampRange) Marshal() (dAtA []byte, err error)

func (*TimestampRange) MarshalTo

func (m *TimestampRange) MarshalTo(dAtA []byte) (int, error)

func (*TimestampRange) MarshalToSizedBuffer added in v1.8.7

func (m *TimestampRange) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TimestampRange) ProtoMessage

func (*TimestampRange) ProtoMessage()

func (*TimestampRange) Reset

func (m *TimestampRange) Reset()

func (*TimestampRange) Size

func (m *TimestampRange) Size() (n int)

func (*TimestampRange) String

func (m *TimestampRange) String() string

func (*TimestampRange) Unmarshal

func (m *TimestampRange) Unmarshal(dAtA []byte) error

func (*TimestampRange) XXX_DiscardUnknown

func (m *TimestampRange) XXX_DiscardUnknown()

func (*TimestampRange) XXX_Marshal

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

func (*TimestampRange) XXX_Merge

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

func (*TimestampRange) XXX_Size

func (m *TimestampRange) XXX_Size() int

func (*TimestampRange) XXX_Unmarshal

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

type UnimplementedStorageServer added in v1.8.7

type UnimplementedStorageServer struct {
}

UnimplementedStorageServer can be embedded to have forward compatible implementations.

func (*UnimplementedStorageServer) Capabilities added in v1.8.7

func (*UnimplementedStorageServer) ReadFilter added in v1.8.7

func (*UnimplementedStorageServer) ReadGroup added in v1.8.7

func (*UnimplementedStorageServer) ReadWindowAggregate added in v1.9.0

func (*UnimplementedStorageServer) TagKeys added in v1.8.7

func (*UnimplementedStorageServer) TagValues added in v1.8.7

type Window added in v1.9.0

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"`
}

func (*Window) Descriptor added in v1.9.0

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

func (*Window) Marshal added in v1.9.0

func (m *Window) Marshal() (dAtA []byte, err error)

func (*Window) MarshalTo added in v1.9.0

func (m *Window) MarshalTo(dAtA []byte) (int, error)

func (*Window) MarshalToSizedBuffer added in v1.9.0

func (m *Window) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Window) ProtoMessage added in v1.9.0

func (*Window) ProtoMessage()

func (*Window) Reset added in v1.9.0

func (m *Window) Reset()

func (*Window) Size added in v1.9.0

func (m *Window) Size() (n int)

func (*Window) String added in v1.9.0

func (m *Window) String() string

func (*Window) Unmarshal added in v1.9.0

func (m *Window) Unmarshal(dAtA []byte) error

func (*Window) XXX_DiscardUnknown added in v1.9.0

func (m *Window) XXX_DiscardUnknown()

func (*Window) XXX_Marshal added in v1.9.0

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

func (*Window) XXX_Merge added in v1.9.0

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

func (*Window) XXX_Size added in v1.9.0

func (m *Window) XXX_Size() int

func (*Window) XXX_Unmarshal added in v1.9.0

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

Jump to

Keyboard shortcuts

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