datatypes

package
v2.0.6 Latest Latest
Warning

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

 Go to latest Published: Apr 29, 2021 License: MIT Imports: 9 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	FieldKey       = "_field"
	MeasurementKey = "_measurement"
	ValueKey       = "_value"
)

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 MeasurementFieldsResponse_FieldType_name = map[int32]string{
	0: "FLOAT",
	1: "INTEGER",
	2: "UNSIGNED",
	3: "STRING",
	4: "BOOLEAN",
	5: "UNDEFINED",
}
View Source 
var MeasurementFieldsResponse_FieldType_value = map[string]int32{
	"FLOAT":     0,
	"INTEGER":   1,
	"UNSIGNED":  2,
	"STRING":    3,
	"BOOLEAN":   4,
	"UNDEFINED": 5,
}
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",
}
View Source 
var ReadResponse_DataType_value = map[string]int32{
	"FLOAT":    0,
	"INTEGER":  1,
	"UNSIGNED": 2,
	"BOOLEAN":  3,
	"STRING":   4,
}
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

This section is empty.

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 

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 {
	// Capabilities contains the set of capabilities supported
	// by the storage engine. It is a map of method names to
	// the detailed capability information for the method.
	Caps map[string]*Capability `` /* 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 

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 Capability 

type Capability struct {
	// Features contains the specific features supported
	// by this capability.
	Features []string `protobuf:"bytes,1,rep,name=features,proto3" json:"features,omitempty"`
}

func (*Capability) Descriptor 

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

func (*Capability) Marshal 

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

func (*Capability) MarshalTo 

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

func (*Capability) MarshalToSizedBuffer 

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

func (*Capability) ProtoMessage 

func (*Capability) ProtoMessage()

func (*Capability) Reset 

func (m *Capability) Reset()

func (*Capability) Size 

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

func (*Capability) String 

func (m *Capability) String() string

func (*Capability) Unmarshal 

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

func (*Capability) XXX_DiscardUnknown 

func (m *Capability) XXX_DiscardUnknown()

func (*Capability) XXX_Marshal 

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

func (*Capability) XXX_Merge 

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

func (*Capability) XXX_Size 

func (m *Capability) XXX_Size() int

func (*Capability) XXX_Unmarshal 

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

type Duration 

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

func (*Duration) Descriptor 

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

func (*Duration) Marshal 

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

func (*Duration) MarshalTo 

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

func (*Duration) MarshalToSizedBuffer 

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

func (*Duration) ProtoMessage 

func (*Duration) ProtoMessage()

func (*Duration) Reset 

func (m *Duration) Reset()

func (*Duration) Size 

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

func (*Duration) String 

func (m *Duration) String() string

func (*Duration) Unmarshal 

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

func (*Duration) XXX_DiscardUnknown 

func (m *Duration) XXX_DiscardUnknown()

func (*Duration) XXX_Marshal 

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

func (*Duration) XXX_Merge 

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

func (*Duration) XXX_Size 

func (m *Duration) XXX_Size() int

func (*Duration) XXX_Unmarshal 

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 MeasurementFieldsRequest 

type MeasurementFieldsRequest struct {
	Source      *types.Any     `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Measurement string         `protobuf:"bytes,2,opt,name=measurement,proto3" json:"measurement,omitempty"`
	Range       TimestampRange `protobuf:"bytes,3,opt,name=range,proto3" json:"range"`
	Predicate   *Predicate     `protobuf:"bytes,4,opt,name=predicate,proto3" json:"predicate,omitempty"`
}

MeasurementFieldsRequest is the request message for Storage.MeasurementFields.

func (*MeasurementFieldsRequest) Descriptor 

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

func (*MeasurementFieldsRequest) Marshal 

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

func (*MeasurementFieldsRequest) MarshalTo 

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

func (*MeasurementFieldsRequest) MarshalToSizedBuffer 

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

func (*MeasurementFieldsRequest) ProtoMessage 

func (*MeasurementFieldsRequest) ProtoMessage()

func (*MeasurementFieldsRequest) Reset 

func (m *MeasurementFieldsRequest) Reset()

func (*MeasurementFieldsRequest) Size 

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

func (*MeasurementFieldsRequest) String 

func (m *MeasurementFieldsRequest) String() string

func (*MeasurementFieldsRequest) Unmarshal 

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

func (*MeasurementFieldsRequest) XXX_DiscardUnknown 

func (m *MeasurementFieldsRequest) XXX_DiscardUnknown()

func (*MeasurementFieldsRequest) XXX_Marshal 

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

func (*MeasurementFieldsRequest) XXX_Merge 

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

func (*MeasurementFieldsRequest) XXX_Size 

func (m *MeasurementFieldsRequest) XXX_Size() int

func (*MeasurementFieldsRequest) XXX_Unmarshal 

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

type MeasurementFieldsResponse 

type MeasurementFieldsResponse struct {
	Fields []MeasurementFieldsResponse_MessageField `protobuf:"bytes,1,rep,name=fields,proto3" json:"fields"`
}

MeasurementFieldsResponse is the response message for Storage.MeasurementFields.

func (*MeasurementFieldsResponse) Descriptor 

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

func (*MeasurementFieldsResponse) Marshal 

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

func (*MeasurementFieldsResponse) MarshalTo 

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

func (*MeasurementFieldsResponse) MarshalToSizedBuffer 

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

func (*MeasurementFieldsResponse) ProtoMessage 

func (*MeasurementFieldsResponse) ProtoMessage()

func (*MeasurementFieldsResponse) Reset 

func (m *MeasurementFieldsResponse) Reset()

func (*MeasurementFieldsResponse) Size 

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

func (*MeasurementFieldsResponse) String 

func (m *MeasurementFieldsResponse) String() string

func (*MeasurementFieldsResponse) Unmarshal 

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

func (*MeasurementFieldsResponse) XXX_DiscardUnknown 

func (m *MeasurementFieldsResponse) XXX_DiscardUnknown()

func (*MeasurementFieldsResponse) XXX_Marshal 

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

func (*MeasurementFieldsResponse) XXX_Merge 

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

func (*MeasurementFieldsResponse) XXX_Size 

func (m *MeasurementFieldsResponse) XXX_Size() int

func (*MeasurementFieldsResponse) XXX_Unmarshal 

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

type MeasurementFieldsResponse_FieldType 

type MeasurementFieldsResponse_FieldType int32
const (
	FieldTypeFloat     MeasurementFieldsResponse_FieldType = 0
	FieldTypeInteger   MeasurementFieldsResponse_FieldType = 1
	FieldTypeUnsigned  MeasurementFieldsResponse_FieldType = 2
	FieldTypeString    MeasurementFieldsResponse_FieldType = 3
	FieldTypeBoolean   MeasurementFieldsResponse_FieldType = 4
	FieldTypeUndefined MeasurementFieldsResponse_FieldType = 5
)

func (MeasurementFieldsResponse_FieldType) EnumDescriptor 

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

func (MeasurementFieldsResponse_FieldType) String 

func (x MeasurementFieldsResponse_FieldType) String() string

type MeasurementFieldsResponse_MessageField 

type MeasurementFieldsResponse_MessageField struct {
	Key       string                              `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Type      MeasurementFieldsResponse_FieldType `` /* 131-byte string literal not displayed */
	Timestamp int64                               `protobuf:"fixed64,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*MeasurementFieldsResponse_MessageField) Descriptor 

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

func (*MeasurementFieldsResponse_MessageField) Marshal 

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

func (*MeasurementFieldsResponse_MessageField) MarshalTo 

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

func (*MeasurementFieldsResponse_MessageField) MarshalToSizedBuffer 

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

func (*MeasurementFieldsResponse_MessageField) ProtoMessage 

func (*MeasurementFieldsResponse_MessageField) ProtoMessage()

func (*MeasurementFieldsResponse_MessageField) Reset 

func (m *MeasurementFieldsResponse_MessageField) Reset()

func (*MeasurementFieldsResponse_MessageField) Size 

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

func (*MeasurementFieldsResponse_MessageField) String 

func (m *MeasurementFieldsResponse_MessageField) String() string

func (*MeasurementFieldsResponse_MessageField) Unmarshal 

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

func (*MeasurementFieldsResponse_MessageField) XXX_DiscardUnknown 

func (m *MeasurementFieldsResponse_MessageField) XXX_DiscardUnknown()

func (*MeasurementFieldsResponse_MessageField) XXX_Marshal 

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

func (*MeasurementFieldsResponse_MessageField) XXX_Merge 

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

func (*MeasurementFieldsResponse_MessageField) XXX_Size 

func (m *MeasurementFieldsResponse_MessageField) XXX_Size() int

func (*MeasurementFieldsResponse_MessageField) XXX_Unmarshal 

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

type MeasurementNamesRequest 

type MeasurementNamesRequest struct {
	Source    *types.Any     `protobuf:"bytes,1,opt,name=source,proto3" json:"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"`
}

MeasurementNamesRequest is the request message for Storage.MeasurementNames.

func (*MeasurementNamesRequest) Descriptor 

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

func (*MeasurementNamesRequest) Marshal 

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

func (*MeasurementNamesRequest) MarshalTo 

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

func (*MeasurementNamesRequest) MarshalToSizedBuffer 

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

func (*MeasurementNamesRequest) ProtoMessage 

func (*MeasurementNamesRequest) ProtoMessage()

func (*MeasurementNamesRequest) Reset 

func (m *MeasurementNamesRequest) Reset()

func (*MeasurementNamesRequest) Size 

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

func (*MeasurementNamesRequest) String 

func (m *MeasurementNamesRequest) String() string

func (*MeasurementNamesRequest) Unmarshal 

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

func (*MeasurementNamesRequest) XXX_DiscardUnknown 

func (m *MeasurementNamesRequest) XXX_DiscardUnknown()

func (*MeasurementNamesRequest) XXX_Marshal 

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

func (*MeasurementNamesRequest) XXX_Merge 

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

func (*MeasurementNamesRequest) XXX_Size 

func (m *MeasurementNamesRequest) XXX_Size() int

func (*MeasurementNamesRequest) XXX_Unmarshal 

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

type MeasurementTagKeysRequest 

type MeasurementTagKeysRequest struct {
	Source      *types.Any     `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Measurement string         `protobuf:"bytes,2,opt,name=measurement,proto3" json:"measurement,omitempty"`
	Range       TimestampRange `protobuf:"bytes,3,opt,name=range,proto3" json:"range"`
	Predicate   *Predicate     `protobuf:"bytes,4,opt,name=predicate,proto3" json:"predicate,omitempty"`
}

MeasurementTagKeysRequest is the request message for Storage.MeasurementTagKeys.

func (*MeasurementTagKeysRequest) Descriptor 

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

func (*MeasurementTagKeysRequest) Marshal 

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

func (*MeasurementTagKeysRequest) MarshalTo 

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

func (*MeasurementTagKeysRequest) MarshalToSizedBuffer 

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

func (*MeasurementTagKeysRequest) ProtoMessage 

func (*MeasurementTagKeysRequest) ProtoMessage()

func (*MeasurementTagKeysRequest) Reset 

func (m *MeasurementTagKeysRequest) Reset()

func (*MeasurementTagKeysRequest) Size 

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

func (*MeasurementTagKeysRequest) String 

func (m *MeasurementTagKeysRequest) String() string

func (*MeasurementTagKeysRequest) Unmarshal 

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

func (*MeasurementTagKeysRequest) XXX_DiscardUnknown 

func (m *MeasurementTagKeysRequest) XXX_DiscardUnknown()

func (*MeasurementTagKeysRequest) XXX_Marshal 

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

func (*MeasurementTagKeysRequest) XXX_Merge 

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

func (*MeasurementTagKeysRequest) XXX_Size 

func (m *MeasurementTagKeysRequest) XXX_Size() int

func (*MeasurementTagKeysRequest) XXX_Unmarshal 

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

type MeasurementTagValuesRequest 

type MeasurementTagValuesRequest struct {
	Source      *types.Any     `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	Measurement string         `protobuf:"bytes,2,opt,name=measurement,proto3" json:"measurement,omitempty"`
	TagKey      string         `protobuf:"bytes,3,opt,name=tag_key,json=tagKey,proto3" json:"tag_key,omitempty"`
	Range       TimestampRange `protobuf:"bytes,4,opt,name=range,proto3" json:"range"`
	Predicate   *Predicate     `protobuf:"bytes,5,opt,name=predicate,proto3" json:"predicate,omitempty"`
}

MeasurementTagValuesRequest is the request message for Storage.MeasurementTagValues.

func (*MeasurementTagValuesRequest) Descriptor 

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

func (*MeasurementTagValuesRequest) Marshal 

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

func (*MeasurementTagValuesRequest) MarshalTo 

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

func (*MeasurementTagValuesRequest) MarshalToSizedBuffer 

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

func (*MeasurementTagValuesRequest) ProtoMessage 

func (*MeasurementTagValuesRequest) ProtoMessage()

func (*MeasurementTagValuesRequest) Reset 

func (m *MeasurementTagValuesRequest) Reset()

func (*MeasurementTagValuesRequest) Size 

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

func (*MeasurementTagValuesRequest) String 

func (m *MeasurementTagValuesRequest) String() string

func (*MeasurementTagValuesRequest) Unmarshal 

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

func (*MeasurementTagValuesRequest) XXX_DiscardUnknown 

func (m *MeasurementTagValuesRequest) XXX_DiscardUnknown()

func (*MeasurementTagValuesRequest) XXX_Marshal 

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

func (*MeasurementTagValuesRequest) XXX_Merge 

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

func (*MeasurementTagValuesRequest) XXX_Size 

func (m *MeasurementTagValuesRequest) XXX_Size() int

func (*MeasurementTagValuesRequest) XXX_Unmarshal 

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

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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 

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

func (*ReadFilterRequest) Marshal 

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

func (*ReadFilterRequest) MarshalTo 

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

func (*ReadFilterRequest) MarshalToSizedBuffer 

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

func (*ReadFilterRequest) ProtoMessage 

func (*ReadFilterRequest) ProtoMessage()

func (*ReadFilterRequest) Reset 

func (m *ReadFilterRequest) Reset()

func (*ReadFilterRequest) Size 

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

func (*ReadFilterRequest) String 

func (m *ReadFilterRequest) String() string

func (*ReadFilterRequest) Unmarshal 

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

func (*ReadFilterRequest) XXX_DiscardUnknown 

func (m *ReadFilterRequest) XXX_DiscardUnknown()

func (*ReadFilterRequest) XXX_Marshal 

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

func (*ReadFilterRequest) XXX_Merge 

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

func (*ReadFilterRequest) XXX_Size 

func (m *ReadFilterRequest) XXX_Size() int

func (*ReadFilterRequest) XXX_Unmarshal 

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

type ReadGroupRequest 

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 

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

func (*ReadGroupRequest) Marshal 

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

func (*ReadGroupRequest) MarshalTo 

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

func (*ReadGroupRequest) MarshalToSizedBuffer 

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

func (*ReadGroupRequest) ProtoMessage 

func (*ReadGroupRequest) ProtoMessage()

func (*ReadGroupRequest) Reset 

func (m *ReadGroupRequest) Reset()

func (*ReadGroupRequest) Size 

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

func (*ReadGroupRequest) String 

func (m *ReadGroupRequest) String() string

func (*ReadGroupRequest) Unmarshal 

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

func (*ReadGroupRequest) XXX_DiscardUnknown 

func (m *ReadGroupRequest) XXX_DiscardUnknown()

func (*ReadGroupRequest) XXX_Marshal 

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

func (*ReadGroupRequest) XXX_Merge 

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

func (*ReadGroupRequest) XXX_Size 

func (m *ReadGroupRequest) XXX_Size() int

func (*ReadGroupRequest) XXX_Unmarshal 

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

type ReadGroupRequest_Group 

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

func (ReadGroupRequest_Group) EnumDescriptor 

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

func (ReadGroupRequest_Group) String 

func (x ReadGroupRequest_Group) String() string

type ReadGroupRequest_HintFlags 

type ReadGroupRequest_HintFlags int32

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

const (
	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 

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

func (ReadGroupRequest_HintFlags) String 

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) MarshalTo 

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

func (*ReadResponse) MarshalToSizedBuffer 

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_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 

func (m *ReadResponse_BooleanPointsFrame) MarshalToSizedBuffer(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) MarshalToSizedBuffer 

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 (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) MarshalToSizedBuffer 

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 

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 

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 

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 

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 

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_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 

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 

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 

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 

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 

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

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 

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 (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) MarshalToSizedBuffer 

func (m *ReadResponse_UnsignedPointsFrame) MarshalToSizedBuffer(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 ReadWindowAggregateRequest 

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 

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

func (*ReadWindowAggregateRequest) Marshal 

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

func (*ReadWindowAggregateRequest) MarshalTo 

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

func (*ReadWindowAggregateRequest) MarshalToSizedBuffer 

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

func (*ReadWindowAggregateRequest) ProtoMessage 

func (*ReadWindowAggregateRequest) ProtoMessage()

func (*ReadWindowAggregateRequest) Reset 

func (m *ReadWindowAggregateRequest) Reset()

func (*ReadWindowAggregateRequest) Size 

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

func (*ReadWindowAggregateRequest) String 

func (m *ReadWindowAggregateRequest) String() string

func (*ReadWindowAggregateRequest) Unmarshal 

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

func (*ReadWindowAggregateRequest) XXX_DiscardUnknown 

func (m *ReadWindowAggregateRequest) XXX_DiscardUnknown()

func (*ReadWindowAggregateRequest) XXX_Marshal 

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

func (*ReadWindowAggregateRequest) XXX_Merge 

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

func (*ReadWindowAggregateRequest) XXX_Size 

func (m *ReadWindowAggregateRequest) XXX_Size() int

func (*ReadWindowAggregateRequest) XXX_Unmarshal 

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

type StringValuesResponse 

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

Response message for Storage.TagKeys, Storage.TagValues Storage.MeasurementNames, Storage.MeasurementTagKeys and Storage.MeasurementTagValues.

func (*StringValuesResponse) Descriptor 

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

func (*StringValuesResponse) Marshal 

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

func (*StringValuesResponse) MarshalTo 

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

func (*StringValuesResponse) MarshalToSizedBuffer 

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

func (*StringValuesResponse) ProtoMessage 

func (*StringValuesResponse) ProtoMessage()

func (*StringValuesResponse) Reset 

func (m *StringValuesResponse) Reset()

func (*StringValuesResponse) Size 

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

func (*StringValuesResponse) String 

func (m *StringValuesResponse) String() string

func (*StringValuesResponse) Unmarshal 

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

func (*StringValuesResponse) XXX_DiscardUnknown 

func (m *StringValuesResponse) XXX_DiscardUnknown()

func (*StringValuesResponse) XXX_Marshal 

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

func (*StringValuesResponse) XXX_Merge 

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

func (*StringValuesResponse) XXX_Size 

func (m *StringValuesResponse) XXX_Size() int

func (*StringValuesResponse) XXX_Unmarshal 

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 

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 

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 

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

func (*TagKeysRequest) Marshal 

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

func (*TagKeysRequest) MarshalTo 

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

func (*TagKeysRequest) MarshalToSizedBuffer 

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

func (*TagKeysRequest) ProtoMessage 

func (*TagKeysRequest) ProtoMessage()

func (*TagKeysRequest) Reset 

func (m *TagKeysRequest) Reset()

func (*TagKeysRequest) Size 

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

func (*TagKeysRequest) String 

func (m *TagKeysRequest) String() string

func (*TagKeysRequest) Unmarshal 

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

func (*TagKeysRequest) XXX_DiscardUnknown 

func (m *TagKeysRequest) XXX_DiscardUnknown()

func (*TagKeysRequest) XXX_Marshal 

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

func (*TagKeysRequest) XXX_Merge 

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

func (*TagKeysRequest) XXX_Size 

func (m *TagKeysRequest) XXX_Size() int

func (*TagKeysRequest) XXX_Unmarshal 

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

type TagValuesRequest 

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 

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

func (*TagValuesRequest) Marshal 

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

func (*TagValuesRequest) MarshalTo 

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

func (*TagValuesRequest) MarshalToSizedBuffer 

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

func (*TagValuesRequest) ProtoMessage 

func (*TagValuesRequest) ProtoMessage()

func (*TagValuesRequest) Reset 

func (m *TagValuesRequest) Reset()

func (*TagValuesRequest) Size 

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

func (*TagValuesRequest) String 

func (m *TagValuesRequest) String() string

func (*TagValuesRequest) Unmarshal 

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

func (*TagValuesRequest) XXX_DiscardUnknown 

func (m *TagValuesRequest) XXX_DiscardUnknown()

func (*TagValuesRequest) XXX_Marshal 

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

func (*TagValuesRequest) XXX_Merge 

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

func (*TagValuesRequest) XXX_Size 

func (m *TagValuesRequest) XXX_Size() int

func (*TagValuesRequest) XXX_Unmarshal 

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 

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 Window 

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

func (*Window) Descriptor 

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

func (*Window) Marshal 

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

func (*Window) MarshalTo 

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

func (*Window) MarshalToSizedBuffer 

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

func (*Window) ProtoMessage 

func (*Window) ProtoMessage()

func (*Window) Reset 

func (m *Window) Reset()

func (*Window) Size 

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

func (*Window) String 

func (m *Window) String() string

func (*Window) Unmarshal 

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

func (*Window) XXX_DiscardUnknown 

func (m *Window) XXX_DiscardUnknown()

func (*Window) XXX_Marshal 

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

func (*Window) XXX_Merge 

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

func (*Window) XXX_Size 

func (m *Window) XXX_Size() int

func (*Window) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.