Documentation ¶
Index ¶
- Variables
- func RegisterStorageServer(s *grpc.Server, srv StorageServer)
- type Aggregate
- func (*Aggregate) Descriptor() ([]byte, []int)
- func (m *Aggregate) Marshal() (dAtA []byte, err error)
- func (m *Aggregate) MarshalTo(dAtA []byte) (int, error)
- func (*Aggregate) ProtoMessage()
- func (m *Aggregate) Reset()
- func (m *Aggregate) Size() (n int)
- func (m *Aggregate) String() string
- func (m *Aggregate) Unmarshal(dAtA []byte) error
- func (m *Aggregate) XXX_DiscardUnknown()
- func (m *Aggregate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Aggregate) XXX_Merge(src proto.Message)
- func (m *Aggregate) XXX_Size() int
- func (m *Aggregate) XXX_Unmarshal(b []byte) error
- type Aggregate_AggregateType
- type CapabilitiesResponse
- func (*CapabilitiesResponse) Descriptor() ([]byte, []int)
- func (m *CapabilitiesResponse) Marshal() (dAtA []byte, err error)
- func (m *CapabilitiesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*CapabilitiesResponse) ProtoMessage()
- func (m *CapabilitiesResponse) Reset()
- func (m *CapabilitiesResponse) Size() (n int)
- func (m *CapabilitiesResponse) String() string
- func (m *CapabilitiesResponse) Unmarshal(dAtA []byte) error
- func (m *CapabilitiesResponse) XXX_DiscardUnknown()
- func (m *CapabilitiesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CapabilitiesResponse) XXX_Merge(src proto.Message)
- func (m *CapabilitiesResponse) XXX_Size() int
- func (m *CapabilitiesResponse) XXX_Unmarshal(b []byte) error
- type HintFlags
- type Node
- func (*Node) Descriptor() ([]byte, []int)
- func (m *Node) GetBooleanValue() bool
- func (m *Node) GetChildren() []*Node
- func (m *Node) GetComparison() Node_Comparison
- func (m *Node) GetFieldRefValue() string
- func (m *Node) GetFloatValue() float64
- func (m *Node) GetIntegerValue() int64
- func (m *Node) GetLogical() Node_Logical
- func (m *Node) GetNodeType() Node_Type
- func (m *Node) GetRegexValue() string
- func (m *Node) GetStringValue() string
- func (m *Node) GetTagRefValue() string
- func (m *Node) GetUnsignedValue() uint64
- func (m *Node) GetValue() isNode_Value
- func (m *Node) Marshal() (dAtA []byte, err error)
- func (m *Node) MarshalTo(dAtA []byte) (int, error)
- func (*Node) ProtoMessage()
- func (m *Node) Reset()
- func (m *Node) Size() (n int)
- func (m *Node) String() string
- func (m *Node) Unmarshal(dAtA []byte) error
- func (m *Node) XXX_DiscardUnknown()
- func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Node) XXX_Merge(src proto.Message)
- func (*Node) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *Node) XXX_Size() int
- func (m *Node) XXX_Unmarshal(b []byte) error
- type Node_BooleanValue
- type Node_Comparison
- type Node_Comparison_
- type Node_FieldRefValue
- type Node_FloatValue
- type Node_IntegerValue
- type Node_Logical
- type Node_Logical_
- type Node_RegexValue
- type Node_StringValue
- type Node_TagRefValue
- type Node_Type
- type Node_UnsignedValue
- type Predicate
- func (*Predicate) Descriptor() ([]byte, []int)
- func (m *Predicate) GetRoot() *Node
- func (m *Predicate) Marshal() (dAtA []byte, err error)
- func (m *Predicate) MarshalTo(dAtA []byte) (int, error)
- func (*Predicate) ProtoMessage()
- func (m *Predicate) Reset()
- func (m *Predicate) Size() (n int)
- func (m *Predicate) String() string
- func (m *Predicate) Unmarshal(dAtA []byte) error
- func (m *Predicate) XXX_DiscardUnknown()
- func (m *Predicate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Predicate) XXX_Merge(src proto.Message)
- func (m *Predicate) XXX_Size() int
- func (m *Predicate) XXX_Unmarshal(b []byte) error
- type ReadFilterRequest
- func (*ReadFilterRequest) Descriptor() ([]byte, []int)
- func (m *ReadFilterRequest) Marshal() (dAtA []byte, err error)
- func (m *ReadFilterRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ReadFilterRequest) ProtoMessage()
- func (m *ReadFilterRequest) Reset()
- func (m *ReadFilterRequest) Size() (n int)
- func (m *ReadFilterRequest) String() string
- func (m *ReadFilterRequest) Unmarshal(dAtA []byte) error
- func (m *ReadFilterRequest) XXX_DiscardUnknown()
- func (m *ReadFilterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadFilterRequest) XXX_Merge(src proto.Message)
- func (m *ReadFilterRequest) XXX_Size() int
- func (m *ReadFilterRequest) XXX_Unmarshal(b []byte) error
- type ReadGroupRequest
- func (*ReadGroupRequest) Descriptor() ([]byte, []int)
- func (m *ReadGroupRequest) Marshal() (dAtA []byte, err error)
- func (m *ReadGroupRequest) MarshalTo(dAtA []byte) (int, error)
- func (*ReadGroupRequest) ProtoMessage()
- func (m *ReadGroupRequest) Reset()
- func (m *ReadGroupRequest) Size() (n int)
- func (m *ReadGroupRequest) String() string
- func (m *ReadGroupRequest) Unmarshal(dAtA []byte) error
- func (m *ReadGroupRequest) XXX_DiscardUnknown()
- func (m *ReadGroupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadGroupRequest) XXX_Merge(src proto.Message)
- func (m *ReadGroupRequest) XXX_Size() int
- func (m *ReadGroupRequest) XXX_Unmarshal(b []byte) error
- type ReadGroupRequest_Group
- type ReadGroupRequest_HintFlags
- type ReadResponse
- func (*ReadResponse) Descriptor() ([]byte, []int)
- func (m *ReadResponse) Marshal() (dAtA []byte, err error)
- func (m *ReadResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ReadResponse) ProtoMessage()
- func (m *ReadResponse) Reset()
- func (m *ReadResponse) Size() (n int)
- func (m *ReadResponse) String() string
- func (m *ReadResponse) Unmarshal(dAtA []byte) error
- func (m *ReadResponse) XXX_DiscardUnknown()
- func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadResponse) XXX_Merge(src proto.Message)
- func (m *ReadResponse) XXX_Size() int
- func (m *ReadResponse) XXX_Unmarshal(b []byte) error
- type ReadResponse_BooleanPointsFrame
- func (*ReadResponse_BooleanPointsFrame) Descriptor() ([]byte, []int)
- func (m *ReadResponse_BooleanPointsFrame) Marshal() (dAtA []byte, err error)
- func (m *ReadResponse_BooleanPointsFrame) MarshalTo(dAtA []byte) (int, error)
- func (*ReadResponse_BooleanPointsFrame) ProtoMessage()
- func (m *ReadResponse_BooleanPointsFrame) Reset()
- func (m *ReadResponse_BooleanPointsFrame) Size() (n int)
- func (m *ReadResponse_BooleanPointsFrame) String() string
- func (m *ReadResponse_BooleanPointsFrame) Unmarshal(dAtA []byte) error
- func (m *ReadResponse_BooleanPointsFrame) XXX_DiscardUnknown()
- func (m *ReadResponse_BooleanPointsFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadResponse_BooleanPointsFrame) XXX_Merge(src proto.Message)
- func (m *ReadResponse_BooleanPointsFrame) XXX_Size() int
- func (m *ReadResponse_BooleanPointsFrame) XXX_Unmarshal(b []byte) error
- type ReadResponse_DataType
- type ReadResponse_FloatPointsFrame
- func (*ReadResponse_FloatPointsFrame) Descriptor() ([]byte, []int)
- func (m *ReadResponse_FloatPointsFrame) Marshal() (dAtA []byte, err error)
- func (m *ReadResponse_FloatPointsFrame) MarshalTo(dAtA []byte) (int, error)
- func (*ReadResponse_FloatPointsFrame) ProtoMessage()
- func (m *ReadResponse_FloatPointsFrame) Reset()
- func (m *ReadResponse_FloatPointsFrame) Size() (n int)
- func (m *ReadResponse_FloatPointsFrame) String() string
- func (m *ReadResponse_FloatPointsFrame) Unmarshal(dAtA []byte) error
- func (m *ReadResponse_FloatPointsFrame) XXX_DiscardUnknown()
- func (m *ReadResponse_FloatPointsFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadResponse_FloatPointsFrame) XXX_Merge(src proto.Message)
- func (m *ReadResponse_FloatPointsFrame) XXX_Size() int
- func (m *ReadResponse_FloatPointsFrame) XXX_Unmarshal(b []byte) error
- type ReadResponse_Frame
- func (*ReadResponse_Frame) Descriptor() ([]byte, []int)
- func (m *ReadResponse_Frame) GetBooleanPoints() *ReadResponse_BooleanPointsFrame
- func (m *ReadResponse_Frame) GetData() isReadResponse_Frame_Data
- func (m *ReadResponse_Frame) GetFloatPoints() *ReadResponse_FloatPointsFrame
- func (m *ReadResponse_Frame) GetGroup() *ReadResponse_GroupFrame
- func (m *ReadResponse_Frame) GetIntegerPoints() *ReadResponse_IntegerPointsFrame
- func (m *ReadResponse_Frame) GetSeries() *ReadResponse_SeriesFrame
- func (m *ReadResponse_Frame) GetStringPoints() *ReadResponse_StringPointsFrame
- func (m *ReadResponse_Frame) GetUnsignedPoints() *ReadResponse_UnsignedPointsFrame
- func (m *ReadResponse_Frame) Marshal() (dAtA []byte, err error)
- func (m *ReadResponse_Frame) MarshalTo(dAtA []byte) (int, error)
- func (*ReadResponse_Frame) ProtoMessage()
- func (m *ReadResponse_Frame) Reset()
- func (m *ReadResponse_Frame) Size() (n int)
- func (m *ReadResponse_Frame) String() string
- func (m *ReadResponse_Frame) Unmarshal(dAtA []byte) error
- func (m *ReadResponse_Frame) XXX_DiscardUnknown()
- func (m *ReadResponse_Frame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadResponse_Frame) XXX_Merge(src proto.Message)
- func (*ReadResponse_Frame) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- func (m *ReadResponse_Frame) XXX_Size() int
- func (m *ReadResponse_Frame) XXX_Unmarshal(b []byte) error
- type ReadResponse_FrameType
- type ReadResponse_Frame_BooleanPoints
- type ReadResponse_Frame_FloatPoints
- type ReadResponse_Frame_Group
- type ReadResponse_Frame_IntegerPoints
- type ReadResponse_Frame_Series
- type ReadResponse_Frame_StringPoints
- type ReadResponse_Frame_UnsignedPoints
- type ReadResponse_GroupFrame
- func (*ReadResponse_GroupFrame) Descriptor() ([]byte, []int)
- func (m *ReadResponse_GroupFrame) Marshal() (dAtA []byte, err error)
- func (m *ReadResponse_GroupFrame) MarshalTo(dAtA []byte) (int, error)
- func (*ReadResponse_GroupFrame) ProtoMessage()
- func (m *ReadResponse_GroupFrame) Reset()
- func (m *ReadResponse_GroupFrame) Size() (n int)
- func (m *ReadResponse_GroupFrame) String() string
- func (m *ReadResponse_GroupFrame) Unmarshal(dAtA []byte) error
- func (m *ReadResponse_GroupFrame) XXX_DiscardUnknown()
- func (m *ReadResponse_GroupFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadResponse_GroupFrame) XXX_Merge(src proto.Message)
- func (m *ReadResponse_GroupFrame) XXX_Size() int
- func (m *ReadResponse_GroupFrame) XXX_Unmarshal(b []byte) error
- type ReadResponse_IntegerPointsFrame
- func (*ReadResponse_IntegerPointsFrame) Descriptor() ([]byte, []int)
- func (m *ReadResponse_IntegerPointsFrame) Marshal() (dAtA []byte, err error)
- func (m *ReadResponse_IntegerPointsFrame) MarshalTo(dAtA []byte) (int, error)
- func (*ReadResponse_IntegerPointsFrame) ProtoMessage()
- func (m *ReadResponse_IntegerPointsFrame) Reset()
- func (m *ReadResponse_IntegerPointsFrame) Size() (n int)
- func (m *ReadResponse_IntegerPointsFrame) String() string
- func (m *ReadResponse_IntegerPointsFrame) Unmarshal(dAtA []byte) error
- func (m *ReadResponse_IntegerPointsFrame) XXX_DiscardUnknown()
- func (m *ReadResponse_IntegerPointsFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadResponse_IntegerPointsFrame) XXX_Merge(src proto.Message)
- func (m *ReadResponse_IntegerPointsFrame) XXX_Size() int
- func (m *ReadResponse_IntegerPointsFrame) XXX_Unmarshal(b []byte) error
- type ReadResponse_SeriesFrame
- func (*ReadResponse_SeriesFrame) Descriptor() ([]byte, []int)
- func (m *ReadResponse_SeriesFrame) Marshal() (dAtA []byte, err error)
- func (m *ReadResponse_SeriesFrame) MarshalTo(dAtA []byte) (int, error)
- func (*ReadResponse_SeriesFrame) ProtoMessage()
- func (m *ReadResponse_SeriesFrame) Reset()
- func (m *ReadResponse_SeriesFrame) Size() (n int)
- func (m *ReadResponse_SeriesFrame) String() string
- func (m *ReadResponse_SeriesFrame) Unmarshal(dAtA []byte) error
- func (m *ReadResponse_SeriesFrame) XXX_DiscardUnknown()
- func (m *ReadResponse_SeriesFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadResponse_SeriesFrame) XXX_Merge(src proto.Message)
- func (m *ReadResponse_SeriesFrame) XXX_Size() int
- func (m *ReadResponse_SeriesFrame) XXX_Unmarshal(b []byte) error
- type ReadResponse_StringPointsFrame
- func (*ReadResponse_StringPointsFrame) Descriptor() ([]byte, []int)
- func (m *ReadResponse_StringPointsFrame) Marshal() (dAtA []byte, err error)
- func (m *ReadResponse_StringPointsFrame) MarshalTo(dAtA []byte) (int, error)
- func (*ReadResponse_StringPointsFrame) ProtoMessage()
- func (m *ReadResponse_StringPointsFrame) Reset()
- func (m *ReadResponse_StringPointsFrame) Size() (n int)
- func (m *ReadResponse_StringPointsFrame) String() string
- func (m *ReadResponse_StringPointsFrame) Unmarshal(dAtA []byte) error
- func (m *ReadResponse_StringPointsFrame) XXX_DiscardUnknown()
- func (m *ReadResponse_StringPointsFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadResponse_StringPointsFrame) XXX_Merge(src proto.Message)
- func (m *ReadResponse_StringPointsFrame) XXX_Size() int
- func (m *ReadResponse_StringPointsFrame) XXX_Unmarshal(b []byte) error
- type ReadResponse_UnsignedPointsFrame
- func (*ReadResponse_UnsignedPointsFrame) Descriptor() ([]byte, []int)
- func (m *ReadResponse_UnsignedPointsFrame) Marshal() (dAtA []byte, err error)
- func (m *ReadResponse_UnsignedPointsFrame) MarshalTo(dAtA []byte) (int, error)
- func (*ReadResponse_UnsignedPointsFrame) ProtoMessage()
- func (m *ReadResponse_UnsignedPointsFrame) Reset()
- func (m *ReadResponse_UnsignedPointsFrame) Size() (n int)
- func (m *ReadResponse_UnsignedPointsFrame) String() string
- func (m *ReadResponse_UnsignedPointsFrame) Unmarshal(dAtA []byte) error
- func (m *ReadResponse_UnsignedPointsFrame) XXX_DiscardUnknown()
- func (m *ReadResponse_UnsignedPointsFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadResponse_UnsignedPointsFrame) XXX_Merge(src proto.Message)
- func (m *ReadResponse_UnsignedPointsFrame) XXX_Size() int
- func (m *ReadResponse_UnsignedPointsFrame) XXX_Unmarshal(b []byte) error
- type StorageClient
- type StorageServer
- type Storage_ReadFilterClient
- type Storage_ReadFilterServer
- type Storage_ReadGroupClient
- type Storage_ReadGroupServer
- type Storage_TagKeysClient
- type Storage_TagKeysServer
- type Storage_TagValuesClient
- type Storage_TagValuesServer
- type StringValuesResponse
- func (*StringValuesResponse) Descriptor() ([]byte, []int)
- func (m *StringValuesResponse) Marshal() (dAtA []byte, err error)
- func (m *StringValuesResponse) MarshalTo(dAtA []byte) (int, error)
- func (*StringValuesResponse) ProtoMessage()
- func (m *StringValuesResponse) Reset()
- func (m *StringValuesResponse) Size() (n int)
- func (m *StringValuesResponse) String() string
- func (m *StringValuesResponse) Unmarshal(dAtA []byte) error
- func (m *StringValuesResponse) XXX_DiscardUnknown()
- func (m *StringValuesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *StringValuesResponse) XXX_Merge(src proto.Message)
- func (m *StringValuesResponse) XXX_Size() int
- func (m *StringValuesResponse) XXX_Unmarshal(b []byte) error
- type Tag
- func (*Tag) Descriptor() ([]byte, []int)
- func (m *Tag) Marshal() (dAtA []byte, err error)
- func (m *Tag) MarshalTo(dAtA []byte) (int, error)
- func (*Tag) ProtoMessage()
- func (m *Tag) Reset()
- func (m *Tag) Size() (n int)
- func (m *Tag) String() string
- func (m *Tag) Unmarshal(dAtA []byte) error
- func (m *Tag) XXX_DiscardUnknown()
- func (m *Tag) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Tag) XXX_Merge(src proto.Message)
- func (m *Tag) XXX_Size() int
- func (m *Tag) XXX_Unmarshal(b []byte) error
- type TagKeysRequest
- func (*TagKeysRequest) Descriptor() ([]byte, []int)
- func (m *TagKeysRequest) Marshal() (dAtA []byte, err error)
- func (m *TagKeysRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TagKeysRequest) ProtoMessage()
- func (m *TagKeysRequest) Reset()
- func (m *TagKeysRequest) Size() (n int)
- func (m *TagKeysRequest) String() string
- func (m *TagKeysRequest) Unmarshal(dAtA []byte) error
- func (m *TagKeysRequest) XXX_DiscardUnknown()
- func (m *TagKeysRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TagKeysRequest) XXX_Merge(src proto.Message)
- func (m *TagKeysRequest) XXX_Size() int
- func (m *TagKeysRequest) XXX_Unmarshal(b []byte) error
- type TagValuesRequest
- func (*TagValuesRequest) Descriptor() ([]byte, []int)
- func (m *TagValuesRequest) Marshal() (dAtA []byte, err error)
- func (m *TagValuesRequest) MarshalTo(dAtA []byte) (int, error)
- func (*TagValuesRequest) ProtoMessage()
- func (m *TagValuesRequest) Reset()
- func (m *TagValuesRequest) Size() (n int)
- func (m *TagValuesRequest) String() string
- func (m *TagValuesRequest) Unmarshal(dAtA []byte) error
- func (m *TagValuesRequest) XXX_DiscardUnknown()
- func (m *TagValuesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TagValuesRequest) XXX_Merge(src proto.Message)
- func (m *TagValuesRequest) XXX_Size() int
- func (m *TagValuesRequest) XXX_Unmarshal(b []byte) error
- type TimestampRange
- func (*TimestampRange) Descriptor() ([]byte, []int)
- func (m *TimestampRange) Marshal() (dAtA []byte, err error)
- func (m *TimestampRange) MarshalTo(dAtA []byte) (int, error)
- func (*TimestampRange) ProtoMessage()
- func (m *TimestampRange) Reset()
- func (m *TimestampRange) Size() (n int)
- func (m *TimestampRange) String() string
- func (m *TimestampRange) Unmarshal(dAtA []byte) error
- func (m *TimestampRange) XXX_DiscardUnknown()
- func (m *TimestampRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TimestampRange) XXX_Merge(src proto.Message)
- func (m *TimestampRange) XXX_Size() int
- func (m *TimestampRange) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthPredicate = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowPredicate = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthStorageCommon = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowStorageCommon = fmt.Errorf("proto: integer overflow") )
var Aggregate_AggregateType_name = map[int32]string{
0: "NONE",
1: "SUM",
2: "COUNT",
}
var Aggregate_AggregateType_value = map[string]int32{
"NONE": 0,
"SUM": 1,
"COUNT": 2,
}
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",
}
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,
}
var Node_Logical_name = map[int32]string{
0: "AND",
1: "OR",
}
var Node_Logical_value = map[string]int32{
"AND": 0,
"OR": 1,
}
var Node_Type_name = map[int32]string{
0: "LOGICAL_EXPRESSION",
1: "COMPARISON_EXPRESSION",
2: "PAREN_EXPRESSION",
3: "TAG_REF",
4: "LITERAL",
5: "FIELD_REF",
}
var Node_Type_value = map[string]int32{
"LOGICAL_EXPRESSION": 0,
"COMPARISON_EXPRESSION": 1,
"PAREN_EXPRESSION": 2,
"TAG_REF": 3,
"LITERAL": 4,
"FIELD_REF": 5,
}
var ReadGroupRequest_Group_name = map[int32]string{
0: "GROUP_NONE",
2: "GROUP_BY",
}
var ReadGroupRequest_Group_value = map[string]int32{
"GROUP_NONE": 0,
"GROUP_BY": 2,
}
var ReadGroupRequest_HintFlags_name = map[int32]string{
0: "HINT_NONE",
1: "HINT_NO_POINTS",
2: "HINT_NO_SERIES",
4: "HINT_SCHEMA_ALL_TIME",
}
var ReadGroupRequest_HintFlags_value = map[string]int32{
"HINT_NONE": 0,
"HINT_NO_POINTS": 1,
"HINT_NO_SERIES": 2,
"HINT_SCHEMA_ALL_TIME": 4,
}
var ReadResponse_DataType_name = map[int32]string{
0: "FLOAT",
1: "INTEGER",
2: "UNSIGNED",
3: "BOOLEAN",
4: "STRING",
}
var ReadResponse_DataType_value = map[string]int32{
"FLOAT": 0,
"INTEGER": 1,
"UNSIGNED": 2,
"BOOLEAN": 3,
"STRING": 4,
}
var ReadResponse_FrameType_name = map[int32]string{
0: "SERIES",
1: "POINTS",
}
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) ProtoMessage ¶
func (*Aggregate) ProtoMessage()
func (*Aggregate) XXX_DiscardUnknown ¶
func (m *Aggregate) XXX_DiscardUnknown()
func (*Aggregate) XXX_Marshal ¶
func (*Aggregate) XXX_Unmarshal ¶
type Aggregate_AggregateType ¶
type Aggregate_AggregateType int32
const ( AggregateTypeNone Aggregate_AggregateType = 0 AggregateTypeSum Aggregate_AggregateType = 1 AggregateTypeCount Aggregate_AggregateType = 2 )
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) 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 HintFlags ¶
type HintFlags uint32
func (HintFlags) HintSchemaAllTime ¶
func (*HintFlags) SetHintSchemaAllTime ¶
func (h *HintFlags) SetHintSchemaAllTime()
func (*HintFlags) SetNoPoints ¶
func (h *HintFlags) SetNoPoints()
func (*HintFlags) SetNoSeries ¶
func (h *HintFlags) SetNoSeries()
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) GetBooleanValue ¶
func (*Node) GetChildren ¶
func (*Node) GetComparison ¶
func (m *Node) GetComparison() Node_Comparison
func (*Node) GetFieldRefValue ¶
func (*Node) GetFloatValue ¶
func (*Node) GetIntegerValue ¶
func (*Node) GetLogical ¶
func (m *Node) GetLogical() Node_Logical
func (*Node) GetNodeType ¶
func (*Node) GetRegexValue ¶
func (*Node) GetStringValue ¶
func (*Node) GetTagRefValue ¶
func (*Node) GetUnsignedValue ¶
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) XXX_DiscardUnknown ¶
func (m *Node) XXX_DiscardUnknown()
func (*Node) XXX_OneofFuncs ¶
func (*Node) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
func (*Node) XXX_Unmarshal ¶
type Node_BooleanValue ¶
type Node_BooleanValue struct {
BooleanValue bool `protobuf:"varint,4,opt,name=bool_value,json=boolValue,proto3,oneof"`
}
func (*Node_BooleanValue) MarshalTo ¶
func (m *Node_BooleanValue) MarshalTo(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 `protobuf:"varint,12,opt,name=comparison,proto3,enum=influxdata.platform.storage.Node_Comparison,oneof"`
}
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"`
}
func (*Node_FieldRefValue) MarshalTo ¶
func (m *Node_FieldRefValue) MarshalTo(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"`
}
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"`
}
func (*Node_IntegerValue) MarshalTo ¶
func (m *Node_IntegerValue) MarshalTo(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"`
}
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"`
}
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"`
}
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"`
}
func (*Node_TagRefValue) Size ¶
func (m *Node_TagRefValue) Size() (n int)
type Node_UnsignedValue ¶
type Node_UnsignedValue struct {
UnsignedValue uint64 `protobuf:"varint,6,opt,name=uint_value,json=uintValue,proto3,oneof"`
}
func (*Node_UnsignedValue) MarshalTo ¶
func (m *Node_UnsignedValue) MarshalTo(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) ProtoMessage ¶
func (*Predicate) ProtoMessage()
func (*Predicate) XXX_DiscardUnknown ¶
func (m *Predicate) XXX_DiscardUnknown()
func (*Predicate) XXX_Marshal ¶
func (*Predicate) XXX_Unmarshal ¶
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) 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) 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
func (x ReadGroupRequest_HintFlags) String() string
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) 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_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) ProtoMessage ¶
func (*ReadResponse_BooleanPointsFrame) ProtoMessage()
func (*ReadResponse_BooleanPointsFrame) Reset ¶
func (m *ReadResponse_BooleanPointsFrame) Reset()
func (*ReadResponse_BooleanPointsFrame) Size ¶
func (m *ReadResponse_BooleanPointsFrame) Size() (n int)
func (*ReadResponse_BooleanPointsFrame) String ¶
func (m *ReadResponse_BooleanPointsFrame) String() 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_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 )
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) 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 (m *ReadResponse_FloatPointsFrame) String() 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_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 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 (m *ReadResponse_Frame) GetFloatPoints() *ReadResponse_FloatPointsFrame
func (*ReadResponse_Frame) GetGroup ¶
func (m *ReadResponse_Frame) GetGroup() *ReadResponse_GroupFrame
func (*ReadResponse_Frame) GetIntegerPoints ¶
func (m *ReadResponse_Frame) GetIntegerPoints() *ReadResponse_IntegerPointsFrame
func (*ReadResponse_Frame) GetSeries ¶
func (m *ReadResponse_Frame) GetSeries() *ReadResponse_SeriesFrame
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) 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_OneofFuncs ¶
func (*ReadResponse_Frame) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs 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"`
}
func (*ReadResponse_Frame_BooleanPoints) MarshalTo ¶
func (m *ReadResponse_Frame_BooleanPoints) MarshalTo(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"`
}
func (*ReadResponse_Frame_FloatPoints) MarshalTo ¶
func (m *ReadResponse_Frame_FloatPoints) MarshalTo(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"`
}
func (*ReadResponse_Frame_Group) MarshalTo ¶
func (m *ReadResponse_Frame_Group) MarshalTo(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"`
}
func (*ReadResponse_Frame_IntegerPoints) MarshalTo ¶
func (m *ReadResponse_Frame_IntegerPoints) MarshalTo(dAtA []byte) (int, error)
func (*ReadResponse_Frame_IntegerPoints) Size ¶
func (m *ReadResponse_Frame_IntegerPoints) Size() (n int)
type ReadResponse_Frame_Series ¶
type ReadResponse_Frame_Series struct {
Series *ReadResponse_SeriesFrame `protobuf:"bytes,1,opt,name=series,proto3,oneof"`
}
func (*ReadResponse_Frame_Series) MarshalTo ¶
func (m *ReadResponse_Frame_Series) MarshalTo(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"`
}
func (*ReadResponse_Frame_StringPoints) MarshalTo ¶
func (m *ReadResponse_Frame_StringPoints) MarshalTo(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"`
}
func (*ReadResponse_Frame_UnsignedPoints) MarshalTo ¶
func (m *ReadResponse_Frame_UnsignedPoints) MarshalTo(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) 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) ProtoMessage ¶
func (*ReadResponse_IntegerPointsFrame) ProtoMessage()
func (*ReadResponse_IntegerPointsFrame) Reset ¶
func (m *ReadResponse_IntegerPointsFrame) Reset()
func (*ReadResponse_IntegerPointsFrame) Size ¶
func (m *ReadResponse_IntegerPointsFrame) Size() (n int)
func (*ReadResponse_IntegerPointsFrame) String ¶
func (m *ReadResponse_IntegerPointsFrame) String() 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_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) 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) 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 (m *ReadResponse_StringPointsFrame) String() 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_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) ProtoMessage ¶
func (*ReadResponse_UnsignedPointsFrame) ProtoMessage()
func (*ReadResponse_UnsignedPointsFrame) Reset ¶
func (m *ReadResponse_UnsignedPointsFrame) Reset()
func (*ReadResponse_UnsignedPointsFrame) Size ¶
func (m *ReadResponse_UnsignedPointsFrame) Size() (n int)
func (*ReadResponse_UnsignedPointsFrame) String ¶
func (m *ReadResponse_UnsignedPointsFrame) String() 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 (m *ReadResponse_UnsignedPointsFrame) XXX_Merge(src proto.Message)
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 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) // 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 // 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_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) 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) ProtoMessage ¶
func (*Tag) ProtoMessage()
func (*Tag) XXX_DiscardUnknown ¶
func (m *Tag) XXX_DiscardUnknown()
func (*Tag) XXX_Unmarshal ¶
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) 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) 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 inclusive 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) 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