Versions in this module Expand all Collapse all v1 v1.7.9 Oct 27, 2019 Changes in this version + var Aggregate_AggregateType_name = map[int32]string + var Aggregate_AggregateType_value = map[string]int32 + var ErrIntOverflowPredicate = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowStorageCommon = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthPredicate = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthStorageCommon = fmt.Errorf("proto: negative length found during unmarshaling") + var Node_Comparison_name = map[int32]string + var Node_Comparison_value = map[string]int32 + var Node_Logical_name = map[int32]string + var Node_Logical_value = map[string]int32 + var Node_Type_name = map[int32]string + var Node_Type_value = map[string]int32 + var ReadGroupRequest_Group_name = map[int32]string + var ReadGroupRequest_Group_value = map[string]int32 + var ReadGroupRequest_HintFlags_name = map[int32]string + var ReadGroupRequest_HintFlags_value = map[string]int32 + var ReadResponse_DataType_name = map[int32]string + var ReadResponse_DataType_value = map[string]int32 + var ReadResponse_FrameType_name = map[int32]string + var ReadResponse_FrameType_value = map[string]int32 + func RegisterStorageServer(s *grpc.Server, srv StorageServer) + type Aggregate struct + Type Aggregate_AggregateType + func (*Aggregate) Descriptor() ([]byte, []int) + func (*Aggregate) ProtoMessage() + func (m *Aggregate) Marshal() (dAtA []byte, err error) + func (m *Aggregate) MarshalTo(dAtA []byte) (int, error) + 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 int32 + const AggregateTypeCount + const AggregateTypeNone + const AggregateTypeSum + func (Aggregate_AggregateType) EnumDescriptor() ([]byte, []int) + func (x Aggregate_AggregateType) String() string + type CapabilitiesResponse struct + Caps map[string]string + func (*CapabilitiesResponse) Descriptor() ([]byte, []int) + func (*CapabilitiesResponse) ProtoMessage() + func (m *CapabilitiesResponse) Marshal() (dAtA []byte, err error) + func (m *CapabilitiesResponse) MarshalTo(dAtA []byte) (int, error) + 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 uint32 + func (h *HintFlags) SetHintSchemaAllTime() + func (h *HintFlags) SetNoPoints() + func (h *HintFlags) SetNoSeries() + func (h HintFlags) HintSchemaAllTime() bool + func (h HintFlags) NoPoints() bool + func (h HintFlags) NoSeries() bool + func (h HintFlags) String() string + type Node struct + Children []*Node + NodeType Node_Type + Value isNode_Value + func (*Node) Descriptor() ([]byte, []int) + func (*Node) ProtoMessage() + func (*Node) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + 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 (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 (m *Node) XXX_Size() int + func (m *Node) XXX_Unmarshal(b []byte) error + type Node_BooleanValue struct + BooleanValue bool + func (m *Node_BooleanValue) MarshalTo(dAtA []byte) (int, error) + func (m *Node_BooleanValue) Size() (n int) + type Node_Comparison int32 + const ComparisonEqual + const ComparisonGreater + const ComparisonGreaterEqual + const ComparisonLess + const ComparisonLessEqual + const ComparisonNotEqual + const ComparisonNotRegex + const ComparisonRegex + const ComparisonStartsWith + func (Node_Comparison) EnumDescriptor() ([]byte, []int) + func (x Node_Comparison) String() string + type Node_Comparison_ struct + Comparison Node_Comparison + func (m *Node_Comparison_) MarshalTo(dAtA []byte) (int, error) + func (m *Node_Comparison_) Size() (n int) + type Node_FieldRefValue struct + FieldRefValue string + func (m *Node_FieldRefValue) MarshalTo(dAtA []byte) (int, error) + func (m *Node_FieldRefValue) Size() (n int) + type Node_FloatValue struct + FloatValue float64 + func (m *Node_FloatValue) MarshalTo(dAtA []byte) (int, error) + func (m *Node_FloatValue) Size() (n int) + type Node_IntegerValue struct + IntegerValue int64 + func (m *Node_IntegerValue) MarshalTo(dAtA []byte) (int, error) + func (m *Node_IntegerValue) Size() (n int) + type Node_Logical int32 + const LogicalAnd + const LogicalOr + func (Node_Logical) EnumDescriptor() ([]byte, []int) + func (x Node_Logical) String() string + type Node_Logical_ struct + Logical Node_Logical + func (m *Node_Logical_) MarshalTo(dAtA []byte) (int, error) + func (m *Node_Logical_) Size() (n int) + type Node_RegexValue struct + RegexValue string + func (m *Node_RegexValue) MarshalTo(dAtA []byte) (int, error) + func (m *Node_RegexValue) Size() (n int) + type Node_StringValue struct + StringValue string + func (m *Node_StringValue) MarshalTo(dAtA []byte) (int, error) + func (m *Node_StringValue) Size() (n int) + type Node_TagRefValue struct + TagRefValue string + func (m *Node_TagRefValue) MarshalTo(dAtA []byte) (int, error) + func (m *Node_TagRefValue) Size() (n int) + type Node_Type int32 + const NodeTypeComparisonExpression + const NodeTypeFieldRef + const NodeTypeLiteral + const NodeTypeLogicalExpression + const NodeTypeParenExpression + const NodeTypeTagRef + func (Node_Type) EnumDescriptor() ([]byte, []int) + func (x Node_Type) String() string + type Node_UnsignedValue struct + UnsignedValue uint64 + func (m *Node_UnsignedValue) MarshalTo(dAtA []byte) (int, error) + func (m *Node_UnsignedValue) Size() (n int) + type Predicate struct + Root *Node + func (*Predicate) Descriptor() ([]byte, []int) + func (*Predicate) ProtoMessage() + func (m *Predicate) GetRoot() *Node + func (m *Predicate) Marshal() (dAtA []byte, err error) + func (m *Predicate) MarshalTo(dAtA []byte) (int, error) + 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 struct + Predicate *Predicate + Range TimestampRange + ReadSource *types.Any + func (*ReadFilterRequest) Descriptor() ([]byte, []int) + func (*ReadFilterRequest) ProtoMessage() + func (m *ReadFilterRequest) Marshal() (dAtA []byte, err error) + func (m *ReadFilterRequest) MarshalTo(dAtA []byte) (int, error) + 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 struct + Aggregate *Aggregate + Group ReadGroupRequest_Group + GroupKeys []string + Hints HintFlags + Predicate *Predicate + Range TimestampRange + ReadSource *types.Any + func (*ReadGroupRequest) Descriptor() ([]byte, []int) + func (*ReadGroupRequest) ProtoMessage() + func (m *ReadGroupRequest) Marshal() (dAtA []byte, err error) + func (m *ReadGroupRequest) MarshalTo(dAtA []byte) (int, error) + 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 int32 + const GroupBy + const GroupNone + func (ReadGroupRequest_Group) EnumDescriptor() ([]byte, []int) + func (x ReadGroupRequest_Group) String() string + type ReadGroupRequest_HintFlags int32 + const HintNoPoints + const HintNoSeries + const HintNone + const HintSchemaAllTime + func (ReadGroupRequest_HintFlags) EnumDescriptor() ([]byte, []int) + func (x ReadGroupRequest_HintFlags) String() string + type ReadResponse struct + Frames []ReadResponse_Frame + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (m *ReadResponse) Marshal() (dAtA []byte, err error) + func (m *ReadResponse) MarshalTo(dAtA []byte) (int, error) + 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 struct + Timestamps []int64 + Values []bool + func (*ReadResponse_BooleanPointsFrame) Descriptor() ([]byte, []int) + func (*ReadResponse_BooleanPointsFrame) ProtoMessage() + func (m *ReadResponse_BooleanPointsFrame) Marshal() (dAtA []byte, err error) + func (m *ReadResponse_BooleanPointsFrame) MarshalTo(dAtA []byte) (int, error) + 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 int32 + const DataTypeBoolean + const DataTypeFloat + const DataTypeInteger + const DataTypeString + const DataTypeUnsigned + func (ReadResponse_DataType) EnumDescriptor() ([]byte, []int) + func (x ReadResponse_DataType) String() string + type ReadResponse_FloatPointsFrame struct + Timestamps []int64 + Values []float64 + func (*ReadResponse_FloatPointsFrame) Descriptor() ([]byte, []int) + func (*ReadResponse_FloatPointsFrame) ProtoMessage() + func (m *ReadResponse_FloatPointsFrame) Marshal() (dAtA []byte, err error) + func (m *ReadResponse_FloatPointsFrame) MarshalTo(dAtA []byte) (int, error) + 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 struct + Data isReadResponse_Frame_Data + func (*ReadResponse_Frame) Descriptor() ([]byte, []int) + func (*ReadResponse_Frame) ProtoMessage() + func (*ReadResponse_Frame) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...) + 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 (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 (m *ReadResponse_Frame) XXX_Size() int + func (m *ReadResponse_Frame) XXX_Unmarshal(b []byte) error + type ReadResponse_FrameType int32 + const FrameTypePoints + const FrameTypeSeries + func (ReadResponse_FrameType) EnumDescriptor() ([]byte, []int) + func (x ReadResponse_FrameType) String() string + type ReadResponse_Frame_BooleanPoints struct + BooleanPoints *ReadResponse_BooleanPointsFrame + func (m *ReadResponse_Frame_BooleanPoints) MarshalTo(dAtA []byte) (int, error) + func (m *ReadResponse_Frame_BooleanPoints) Size() (n int) + type ReadResponse_Frame_FloatPoints struct + FloatPoints *ReadResponse_FloatPointsFrame + func (m *ReadResponse_Frame_FloatPoints) MarshalTo(dAtA []byte) (int, error) + func (m *ReadResponse_Frame_FloatPoints) Size() (n int) + type ReadResponse_Frame_Group struct + Group *ReadResponse_GroupFrame + func (m *ReadResponse_Frame_Group) MarshalTo(dAtA []byte) (int, error) + func (m *ReadResponse_Frame_Group) Size() (n int) + type ReadResponse_Frame_IntegerPoints struct + IntegerPoints *ReadResponse_IntegerPointsFrame + func (m *ReadResponse_Frame_IntegerPoints) MarshalTo(dAtA []byte) (int, error) + func (m *ReadResponse_Frame_IntegerPoints) Size() (n int) + type ReadResponse_Frame_Series struct + Series *ReadResponse_SeriesFrame + func (m *ReadResponse_Frame_Series) MarshalTo(dAtA []byte) (int, error) + func (m *ReadResponse_Frame_Series) Size() (n int) + type ReadResponse_Frame_StringPoints struct + StringPoints *ReadResponse_StringPointsFrame + func (m *ReadResponse_Frame_StringPoints) MarshalTo(dAtA []byte) (int, error) + func (m *ReadResponse_Frame_StringPoints) Size() (n int) + type ReadResponse_Frame_UnsignedPoints struct + UnsignedPoints *ReadResponse_UnsignedPointsFrame + func (m *ReadResponse_Frame_UnsignedPoints) MarshalTo(dAtA []byte) (int, error) + func (m *ReadResponse_Frame_UnsignedPoints) Size() (n int) + type ReadResponse_GroupFrame struct + PartitionKeyVals [][]byte + TagKeys [][]byte + func (*ReadResponse_GroupFrame) Descriptor() ([]byte, []int) + func (*ReadResponse_GroupFrame) ProtoMessage() + func (m *ReadResponse_GroupFrame) Marshal() (dAtA []byte, err error) + func (m *ReadResponse_GroupFrame) MarshalTo(dAtA []byte) (int, error) + 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 struct + Timestamps []int64 + Values []int64 + func (*ReadResponse_IntegerPointsFrame) Descriptor() ([]byte, []int) + func (*ReadResponse_IntegerPointsFrame) ProtoMessage() + func (m *ReadResponse_IntegerPointsFrame) Marshal() (dAtA []byte, err error) + func (m *ReadResponse_IntegerPointsFrame) MarshalTo(dAtA []byte) (int, error) + 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 struct + DataType ReadResponse_DataType + Tags []Tag + func (*ReadResponse_SeriesFrame) Descriptor() ([]byte, []int) + func (*ReadResponse_SeriesFrame) ProtoMessage() + func (m *ReadResponse_SeriesFrame) Marshal() (dAtA []byte, err error) + func (m *ReadResponse_SeriesFrame) MarshalTo(dAtA []byte) (int, error) + 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 struct + Timestamps []int64 + Values []string + func (*ReadResponse_StringPointsFrame) Descriptor() ([]byte, []int) + func (*ReadResponse_StringPointsFrame) ProtoMessage() + func (m *ReadResponse_StringPointsFrame) Marshal() (dAtA []byte, err error) + func (m *ReadResponse_StringPointsFrame) MarshalTo(dAtA []byte) (int, error) + 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 struct + Timestamps []int64 + Values []uint64 + func (*ReadResponse_UnsignedPointsFrame) Descriptor() ([]byte, []int) + func (*ReadResponse_UnsignedPointsFrame) ProtoMessage() + func (m *ReadResponse_UnsignedPointsFrame) Marshal() (dAtA []byte, err error) + func (m *ReadResponse_UnsignedPointsFrame) MarshalTo(dAtA []byte) (int, error) + 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 interface + Capabilities func(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*CapabilitiesResponse, error) + ReadFilter func(ctx context.Context, in *ReadFilterRequest, opts ...grpc.CallOption) (Storage_ReadFilterClient, error) + ReadGroup func(ctx context.Context, in *ReadGroupRequest, opts ...grpc.CallOption) (Storage_ReadGroupClient, error) + TagKeys func(ctx context.Context, in *TagKeysRequest, opts ...grpc.CallOption) (Storage_TagKeysClient, error) + TagValues func(ctx context.Context, in *TagValuesRequest, opts ...grpc.CallOption) (Storage_TagValuesClient, error) + func NewStorageClient(cc *grpc.ClientConn) StorageClient + type StorageServer interface + Capabilities func(context.Context, *types.Empty) (*CapabilitiesResponse, error) + ReadFilter func(*ReadFilterRequest, Storage_ReadFilterServer) error + ReadGroup func(*ReadGroupRequest, Storage_ReadGroupServer) error + TagKeys func(*TagKeysRequest, Storage_TagKeysServer) error + TagValues func(*TagValuesRequest, Storage_TagValuesServer) error + type Storage_ReadFilterClient interface + Recv func() (*ReadResponse, error) + type Storage_ReadFilterServer interface + Send func(*ReadResponse) error + type Storage_ReadGroupClient interface + Recv func() (*ReadResponse, error) + type Storage_ReadGroupServer interface + Send func(*ReadResponse) error + type Storage_TagKeysClient interface + Recv func() (*StringValuesResponse, error) + type Storage_TagKeysServer interface + Send func(*StringValuesResponse) error + type Storage_TagValuesClient interface + Recv func() (*StringValuesResponse, error) + type Storage_TagValuesServer interface + Send func(*StringValuesResponse) error + type StringValuesResponse struct + Values [][]byte + func (*StringValuesResponse) Descriptor() ([]byte, []int) + func (*StringValuesResponse) ProtoMessage() + func (m *StringValuesResponse) Marshal() (dAtA []byte, err error) + func (m *StringValuesResponse) MarshalTo(dAtA []byte) (int, error) + 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 struct + Key []byte + Value []byte + func (*Tag) Descriptor() ([]byte, []int) + func (*Tag) ProtoMessage() + func (m *Tag) Marshal() (dAtA []byte, err error) + func (m *Tag) MarshalTo(dAtA []byte) (int, error) + 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 struct + Predicate *Predicate + Range TimestampRange + TagsSource *types.Any + func (*TagKeysRequest) Descriptor() ([]byte, []int) + func (*TagKeysRequest) ProtoMessage() + func (m *TagKeysRequest) Marshal() (dAtA []byte, err error) + func (m *TagKeysRequest) MarshalTo(dAtA []byte) (int, error) + 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 struct + Predicate *Predicate + Range TimestampRange + TagKey string + TagsSource *types.Any + func (*TagValuesRequest) Descriptor() ([]byte, []int) + func (*TagValuesRequest) ProtoMessage() + func (m *TagValuesRequest) Marshal() (dAtA []byte, err error) + func (m *TagValuesRequest) MarshalTo(dAtA []byte) (int, error) + 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 struct + End int64 + Start int64 + func (*TimestampRange) Descriptor() ([]byte, []int) + func (*TimestampRange) ProtoMessage() + func (m *TimestampRange) Marshal() (dAtA []byte, err error) + func (m *TimestampRange) MarshalTo(dAtA []byte) (int, error) + 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