rpcpb

package
v0.14.3 Latest Latest
Warning

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

 Go to latest Published: Apr 22, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package rpcpb is a generated protocol buffer package.

It is generated from these files: 

github.com/m3db/m3/src/query/generated/proto/rpcpb/query.proto

It has these top-level messages: 

HealthRequest
HealthResponse
FetchRequest
TagMatchers
TagMatcher
FetchOptions
RestrictFetchOptions
FetchResponse
Series
SeriesMetadata
DecompressedSeries
Datapoint
Tag
M3CompressedSeries
M3CompressedValuesReplica
M3Segments
M3Segment
SearchRequest
M3TagProperty
M3TagProperties
TagProperty
TagProperties
SearchResponse
CompleteTagsRequestOptions
CompleteTagsRequest
TagNames
TagValue
TagValues
CompleteTagsResponse
ResultMetadata
Warning

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery   = fmt.Errorf("proto: integer overflow")
)
View Source 
var CompleteTagsType_name = map[int32]string{
	0: "DEFAULT",
	1: "TAGNAME",
}
View Source 
var CompleteTagsType_value = map[string]int32{
	"DEFAULT": 0,
	"TAGNAME": 1,
}
View Source 
var FanoutOption_name = map[int32]string{
	0: "DEFAULT_OPTION",
	1: "FORCE_ENABLED",
	2: "FORCE_DISABLED",
}
View Source 
var FanoutOption_value = map[string]int32{
	"DEFAULT_OPTION": 0,
	"FORCE_ENABLED":  1,
	"FORCE_DISABLED": 2,
}
View Source 
var MatcherType_name = map[int32]string{
	0: "EQUAL",
	1: "NOTEQUAL",
	2: "REGEXP",
	3: "NOTREGEXP",
	4: "EXISTS",
	5: "NOTEXISTS",
	6: "ALL",
}
View Source 
var MatcherType_value = map[string]int32{
	"EQUAL":     0,
	"NOTEQUAL":  1,
	"REGEXP":    2,
	"NOTREGEXP": 3,
	"EXISTS":    4,
	"NOTEXISTS": 5,
	"ALL":       6,
}
View Source 
var MetricsType_name = map[int32]string{
	0: "UNKNOWN_METRICS_TYPE",
	1: "UNAGGREGATED_METRICS_TYPE",
	2: "AGGREGATED_METRICS_TYPE",
}
View Source 
var MetricsType_value = map[string]int32{
	"UNKNOWN_METRICS_TYPE":      0,
	"UNAGGREGATED_METRICS_TYPE": 1,
	"AGGREGATED_METRICS_TYPE":   2,
}

Functions

func RegisterQueryServer 

func RegisterQueryServer(s *grpc.Server, srv QueryServer)

Types

type CompleteTagsRequest added in v0.4.8 

type CompleteTagsRequest struct {
	// Types that are valid to be assigned to Matchers:
	//	*CompleteTagsRequest_TagMatchers
	Matchers isCompleteTagsRequest_Matchers `protobuf_oneof:"matchers"`
	Options  *CompleteTagsRequestOptions    `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"`
}

func (*CompleteTagsRequest) Descriptor added in v0.4.8 

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

func (*CompleteTagsRequest) GetMatchers added in v0.4.8 

func (m *CompleteTagsRequest) GetMatchers() isCompleteTagsRequest_Matchers

func (*CompleteTagsRequest) GetOptions added in v0.4.8 

func (m *CompleteTagsRequest) GetOptions() *CompleteTagsRequestOptions

func (*CompleteTagsRequest) GetTagMatchers added in v0.4.8 

func (m *CompleteTagsRequest) GetTagMatchers() *TagMatchers

func (*CompleteTagsRequest) Marshal added in v0.4.8 

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

func (*CompleteTagsRequest) MarshalTo added in v0.4.8 

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

func (*CompleteTagsRequest) ProtoMessage added in v0.4.8 

func (*CompleteTagsRequest) ProtoMessage()

func (*CompleteTagsRequest) Reset added in v0.4.8 

func (m *CompleteTagsRequest) Reset()

func (*CompleteTagsRequest) Size added in v0.4.8 

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

func (*CompleteTagsRequest) String added in v0.4.8 

func (m *CompleteTagsRequest) String() string

func (*CompleteTagsRequest) Unmarshal added in v0.4.8 

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

func (*CompleteTagsRequest) XXX_OneofFuncs added in v0.4.8 

func (*CompleteTagsRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type CompleteTagsRequestOptions added in v0.4.8 

type CompleteTagsRequestOptions struct {
	Type           CompleteTagsType `protobuf:"varint,1,opt,name=type,proto3,enum=rpc.CompleteTagsType" json:"type,omitempty"`
	FilterNameTags [][]byte         `protobuf:"bytes,2,rep,name=filterNameTags" json:"filterNameTags,omitempty"`
	Start          int64            `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"`
	End            int64            `protobuf:"varint,4,opt,name=end,proto3" json:"end,omitempty"`
	Options        *FetchOptions    `protobuf:"bytes,5,opt,name=options" json:"options,omitempty"`
}

func (*CompleteTagsRequestOptions) Descriptor added in v0.4.8 

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

func (*CompleteTagsRequestOptions) GetEnd added in v0.9.4 

func (m *CompleteTagsRequestOptions) GetEnd() int64

func (*CompleteTagsRequestOptions) GetFilterNameTags added in v0.4.8 

func (m *CompleteTagsRequestOptions) GetFilterNameTags() [][]byte

func (*CompleteTagsRequestOptions) GetOptions added in v0.14.0 

func (m *CompleteTagsRequestOptions) GetOptions() *FetchOptions

func (*CompleteTagsRequestOptions) GetStart added in v0.9.4 

func (m *CompleteTagsRequestOptions) GetStart() int64

func (*CompleteTagsRequestOptions) GetType added in v0.4.8 

func (m *CompleteTagsRequestOptions) GetType() CompleteTagsType

func (*CompleteTagsRequestOptions) Marshal added in v0.4.8 

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

func (*CompleteTagsRequestOptions) MarshalTo added in v0.4.8 

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

func (*CompleteTagsRequestOptions) ProtoMessage added in v0.4.8 

func (*CompleteTagsRequestOptions) ProtoMessage()

func (*CompleteTagsRequestOptions) Reset added in v0.4.8 

func (m *CompleteTagsRequestOptions) Reset()

func (*CompleteTagsRequestOptions) Size added in v0.4.8 

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

func (*CompleteTagsRequestOptions) String added in v0.4.8 

func (m *CompleteTagsRequestOptions) String() string

func (*CompleteTagsRequestOptions) Unmarshal added in v0.4.8 

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

type CompleteTagsRequest_TagMatchers added in v0.4.8 

type CompleteTagsRequest_TagMatchers struct {
	TagMatchers *TagMatchers `protobuf:"bytes,1,opt,name=tagMatchers,oneof"`
}

func (*CompleteTagsRequest_TagMatchers) MarshalTo added in v0.4.8 

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

func (*CompleteTagsRequest_TagMatchers) Size added in v0.4.8 

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

type CompleteTagsResponse added in v0.4.8 

type CompleteTagsResponse struct {
	// Types that are valid to be assigned to Value:
	//	*CompleteTagsResponse_Default
	//	*CompleteTagsResponse_NamesOnly
	Value isCompleteTagsResponse_Value `protobuf_oneof:"value"`
	Meta  *ResultMetadata              `protobuf:"bytes,3,opt,name=meta" json:"meta,omitempty"`
}

func (*CompleteTagsResponse) Descriptor added in v0.4.8 

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

func (*CompleteTagsResponse) GetDefault added in v0.4.8 

func (m *CompleteTagsResponse) GetDefault() *TagValues

func (*CompleteTagsResponse) GetMeta added in v0.14.0 

func (m *CompleteTagsResponse) GetMeta() *ResultMetadata

func (*CompleteTagsResponse) GetNamesOnly added in v0.4.8 

func (m *CompleteTagsResponse) GetNamesOnly() *TagNames

func (*CompleteTagsResponse) GetValue added in v0.4.8 

func (m *CompleteTagsResponse) GetValue() isCompleteTagsResponse_Value

func (*CompleteTagsResponse) Marshal added in v0.4.8 

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

func (*CompleteTagsResponse) MarshalTo added in v0.4.8 

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

func (*CompleteTagsResponse) ProtoMessage added in v0.4.8 

func (*CompleteTagsResponse) ProtoMessage()

func (*CompleteTagsResponse) Reset added in v0.4.8 

func (m *CompleteTagsResponse) Reset()

func (*CompleteTagsResponse) Size added in v0.4.8 

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

func (*CompleteTagsResponse) String added in v0.4.8 

func (m *CompleteTagsResponse) String() string

func (*CompleteTagsResponse) Unmarshal added in v0.4.8 

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

func (*CompleteTagsResponse) XXX_OneofFuncs added in v0.4.8 

func (*CompleteTagsResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type CompleteTagsResponse_Default added in v0.4.8 

type CompleteTagsResponse_Default struct {
	Default *TagValues `protobuf:"bytes,1,opt,name=default,oneof"`
}

func (*CompleteTagsResponse_Default) MarshalTo added in v0.4.8 

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

func (*CompleteTagsResponse_Default) Size added in v0.4.8 

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

type CompleteTagsResponse_NamesOnly added in v0.4.8 

type CompleteTagsResponse_NamesOnly struct {
	NamesOnly *TagNames `protobuf:"bytes,2,opt,name=namesOnly,oneof"`
}

func (*CompleteTagsResponse_NamesOnly) MarshalTo added in v0.4.8 

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

func (*CompleteTagsResponse_NamesOnly) Size added in v0.4.8 

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

type CompleteTagsType added in v0.4.8 

type CompleteTagsType int32
const (
	// Requests tag names and values
	CompleteTagsType_DEFAULT CompleteTagsType = 0
	// Requests tag names only
	CompleteTagsType_TAGNAME CompleteTagsType = 1
)

func (CompleteTagsType) EnumDescriptor added in v0.4.8 

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

func (CompleteTagsType) String added in v0.4.8 

func (x CompleteTagsType) String() string

type Datapoint 

type Datapoint struct {
	Timestamp int64   `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Value     float64 `protobuf:"fixed64,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Datapoint) Descriptor 

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

func (*Datapoint) GetTimestamp 

func (m *Datapoint) GetTimestamp() int64

func (*Datapoint) GetValue 

func (m *Datapoint) GetValue() float64

func (*Datapoint) Marshal 

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

func (*Datapoint) MarshalTo 

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

func (*Datapoint) ProtoMessage 

func (*Datapoint) ProtoMessage()

func (*Datapoint) Reset 

func (m *Datapoint) Reset()

func (*Datapoint) Size 

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

func (*Datapoint) String 

func (m *Datapoint) String() string

func (*Datapoint) Unmarshal 

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

type DecompressedSeries added in v0.4.5 

type DecompressedSeries struct {
	Datapoints []*Datapoint `protobuf:"bytes,1,rep,name=datapoints" json:"datapoints,omitempty"`
	Tags       []*Tag       `protobuf:"bytes,2,rep,name=tags" json:"tags,omitempty"`
}

func (*DecompressedSeries) Descriptor added in v0.4.5 

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

func (*DecompressedSeries) GetDatapoints added in v0.4.5 

func (m *DecompressedSeries) GetDatapoints() []*Datapoint

func (*DecompressedSeries) GetTags added in v0.4.5 

func (m *DecompressedSeries) GetTags() []*Tag

func (*DecompressedSeries) Marshal added in v0.4.5 

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

func (*DecompressedSeries) MarshalTo added in v0.4.5 

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

func (*DecompressedSeries) ProtoMessage added in v0.4.5 

func (*DecompressedSeries) ProtoMessage()

func (*DecompressedSeries) Reset added in v0.4.5 

func (m *DecompressedSeries) Reset()

func (*DecompressedSeries) Size added in v0.4.5 

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

func (*DecompressedSeries) String added in v0.4.5 

func (m *DecompressedSeries) String() string

func (*DecompressedSeries) Unmarshal added in v0.4.5 

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

type FanoutOption added in v0.14.0 

type FanoutOption int32
const (
	FanoutOption_DEFAULT_OPTION FanoutOption = 0
	FanoutOption_FORCE_ENABLED  FanoutOption = 1
	FanoutOption_FORCE_DISABLED FanoutOption = 2
)

func (FanoutOption) EnumDescriptor added in v0.14.0 

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

func (FanoutOption) String added in v0.14.0 

func (x FanoutOption) String() string

type FetchOptions 

type FetchOptions struct {
	Limit               int64                 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Restrict            *RestrictFetchOptions `protobuf:"bytes,2,opt,name=restrict" json:"restrict,omitempty"`
	LookbackDuration    int64                 `protobuf:"varint,3,opt,name=lookbackDuration,proto3" json:"lookbackDuration,omitempty"`
	Unaggregated        FanoutOption          `protobuf:"varint,4,opt,name=unaggregated,proto3,enum=rpc.FanoutOption" json:"unaggregated,omitempty"`
	Aggregated          FanoutOption          `protobuf:"varint,5,opt,name=aggregated,proto3,enum=rpc.FanoutOption" json:"aggregated,omitempty"`
	AggregatedOptimized FanoutOption          `protobuf:"varint,6,opt,name=aggregatedOptimized,proto3,enum=rpc.FanoutOption" json:"aggregatedOptimized,omitempty"`
	IncludeResolution   bool                  `protobuf:"varint,7,opt,name=includeResolution,proto3" json:"includeResolution,omitempty"`
}

func (*FetchOptions) Descriptor 

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

func (*FetchOptions) GetAggregated added in v0.14.0 

func (m *FetchOptions) GetAggregated() FanoutOption

func (*FetchOptions) GetAggregatedOptimized added in v0.14.0 

func (m *FetchOptions) GetAggregatedOptimized() FanoutOption

func (*FetchOptions) GetIncludeResolution added in v0.14.0 

func (m *FetchOptions) GetIncludeResolution() bool

func (*FetchOptions) GetLimit added in v0.11.0 

func (m *FetchOptions) GetLimit() int64

func (*FetchOptions) GetLookbackDuration added in v0.11.0 

func (m *FetchOptions) GetLookbackDuration() int64

func (*FetchOptions) GetRestrict added in v0.11.0 

func (m *FetchOptions) GetRestrict() *RestrictFetchOptions

func (*FetchOptions) GetUnaggregated added in v0.14.0 

func (m *FetchOptions) GetUnaggregated() FanoutOption

func (*FetchOptions) Marshal 

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

func (*FetchOptions) MarshalTo 

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

func (*FetchOptions) ProtoMessage 

func (*FetchOptions) ProtoMessage()

func (*FetchOptions) Reset 

func (m *FetchOptions) Reset()

func (*FetchOptions) Size 

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

func (*FetchOptions) String 

func (m *FetchOptions) String() string

func (*FetchOptions) Unmarshal 

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

type FetchRequest added in v0.4.5 

type FetchRequest struct {
	Start int64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"`
	End   int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
	// Types that are valid to be assigned to Matchers:
	//	*FetchRequest_TagMatchers
	Matchers isFetchRequest_Matchers `protobuf_oneof:"matchers"`
	Options  *FetchOptions           `protobuf:"bytes,4,opt,name=options" json:"options,omitempty"`
}

func (*FetchRequest) Descriptor added in v0.4.5 

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

func (*FetchRequest) GetEnd added in v0.4.5 

func (m *FetchRequest) GetEnd() int64

func (*FetchRequest) GetMatchers added in v0.4.5 

func (m *FetchRequest) GetMatchers() isFetchRequest_Matchers

func (*FetchRequest) GetOptions added in v0.11.0 

func (m *FetchRequest) GetOptions() *FetchOptions

func (*FetchRequest) GetStart added in v0.4.5 

func (m *FetchRequest) GetStart() int64

func (*FetchRequest) GetTagMatchers added in v0.4.5 

func (m *FetchRequest) GetTagMatchers() *TagMatchers

func (*FetchRequest) Marshal added in v0.4.5 

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

func (*FetchRequest) MarshalTo added in v0.4.5 

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

func (*FetchRequest) ProtoMessage added in v0.4.5 

func (*FetchRequest) ProtoMessage()

func (*FetchRequest) Reset added in v0.4.5 

func (m *FetchRequest) Reset()

func (*FetchRequest) Size added in v0.4.5 

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

func (*FetchRequest) String added in v0.4.5 

func (m *FetchRequest) String() string

func (*FetchRequest) Unmarshal added in v0.4.5 

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

func (*FetchRequest) XXX_OneofFuncs added in v0.4.5 

func (*FetchRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type FetchRequest_TagMatchers added in v0.4.5 

type FetchRequest_TagMatchers struct {
	TagMatchers *TagMatchers `protobuf:"bytes,3,opt,name=tagMatchers,oneof"`
}

func (*FetchRequest_TagMatchers) MarshalTo added in v0.4.5 

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

func (*FetchRequest_TagMatchers) Size added in v0.4.5 

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

type FetchResponse added in v0.4.5 

type FetchResponse struct {
	Series []*Series       `protobuf:"bytes,1,rep,name=series" json:"series,omitempty"`
	Meta   *ResultMetadata `protobuf:"bytes,2,opt,name=meta" json:"meta,omitempty"`
}

func (*FetchResponse) Descriptor added in v0.4.5 

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

func (*FetchResponse) GetMeta added in v0.14.0 

func (m *FetchResponse) GetMeta() *ResultMetadata

func (*FetchResponse) GetSeries added in v0.4.5 

func (m *FetchResponse) GetSeries() []*Series

func (*FetchResponse) Marshal added in v0.4.5 

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

func (*FetchResponse) MarshalTo added in v0.4.5 

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

func (*FetchResponse) ProtoMessage added in v0.4.5 

func (*FetchResponse) ProtoMessage()

func (*FetchResponse) Reset added in v0.4.5 

func (m *FetchResponse) Reset()

func (*FetchResponse) Size added in v0.4.5 

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

func (*FetchResponse) String added in v0.4.5 

func (m *FetchResponse) String() string

func (*FetchResponse) Unmarshal added in v0.4.5 

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

type HealthRequest added in v0.13.0 

type HealthRequest struct {
}

func (*HealthRequest) Descriptor added in v0.13.0 

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

func (*HealthRequest) Marshal added in v0.13.0 

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

func (*HealthRequest) MarshalTo added in v0.13.0 

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

func (*HealthRequest) ProtoMessage added in v0.13.0 

func (*HealthRequest) ProtoMessage()

func (*HealthRequest) Reset added in v0.13.0 

func (m *HealthRequest) Reset()

func (*HealthRequest) Size added in v0.13.0 

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

func (*HealthRequest) String added in v0.13.0 

func (m *HealthRequest) String() string

func (*HealthRequest) Unmarshal added in v0.13.0 

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

type HealthResponse added in v0.13.0 

type HealthResponse struct {
	UptimeDuration    string `protobuf:"bytes,1,opt,name=uptimeDuration,proto3" json:"uptimeDuration,omitempty"`
	UptimeNanoseconds int64  `protobuf:"varint,2,opt,name=uptimeNanoseconds,proto3" json:"uptimeNanoseconds,omitempty"`
}

func (*HealthResponse) Descriptor added in v0.13.0 

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

func (*HealthResponse) GetUptimeDuration added in v0.13.0 

func (m *HealthResponse) GetUptimeDuration() string

func (*HealthResponse) GetUptimeNanoseconds added in v0.13.0 

func (m *HealthResponse) GetUptimeNanoseconds() int64

func (*HealthResponse) Marshal added in v0.13.0 

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

func (*HealthResponse) MarshalTo added in v0.13.0 

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

func (*HealthResponse) ProtoMessage added in v0.13.0 

func (*HealthResponse) ProtoMessage()

func (*HealthResponse) Reset added in v0.13.0 

func (m *HealthResponse) Reset()

func (*HealthResponse) Size added in v0.13.0 

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

func (*HealthResponse) String added in v0.13.0 

func (m *HealthResponse) String() string

func (*HealthResponse) Unmarshal added in v0.13.0 

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

type M3CompressedSeries added in v0.4.5 

type M3CompressedSeries struct {
	CompressedTags []byte                       `protobuf:"bytes,1,opt,name=compressedTags,proto3" json:"compressedTags,omitempty"`
	Replicas       []*M3CompressedValuesReplica `protobuf:"bytes,2,rep,name=replicas" json:"replicas,omitempty"`
}

func (*M3CompressedSeries) Descriptor added in v0.4.5 

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

func (*M3CompressedSeries) GetCompressedTags added in v0.4.5 

func (m *M3CompressedSeries) GetCompressedTags() []byte

func (*M3CompressedSeries) GetReplicas added in v0.4.5 

func (m *M3CompressedSeries) GetReplicas() []*M3CompressedValuesReplica

func (*M3CompressedSeries) Marshal added in v0.4.5 

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

func (*M3CompressedSeries) MarshalTo added in v0.4.5 

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

func (*M3CompressedSeries) ProtoMessage added in v0.4.5 

func (*M3CompressedSeries) ProtoMessage()

func (*M3CompressedSeries) Reset added in v0.4.5 

func (m *M3CompressedSeries) Reset()

func (*M3CompressedSeries) Size added in v0.4.5 

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

func (*M3CompressedSeries) String added in v0.4.5 

func (m *M3CompressedSeries) String() string

func (*M3CompressedSeries) Unmarshal added in v0.4.5 

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

type M3CompressedValuesReplica added in v0.4.5 

type M3CompressedValuesReplica struct {
	Segments []*M3Segments `protobuf:"bytes,1,rep,name=segments" json:"segments,omitempty"`
}

func (*M3CompressedValuesReplica) Descriptor added in v0.4.5 

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

func (*M3CompressedValuesReplica) GetSegments added in v0.4.5 

func (m *M3CompressedValuesReplica) GetSegments() []*M3Segments

func (*M3CompressedValuesReplica) Marshal added in v0.4.5 

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

func (*M3CompressedValuesReplica) MarshalTo added in v0.4.5 

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

func (*M3CompressedValuesReplica) ProtoMessage added in v0.4.5 

func (*M3CompressedValuesReplica) ProtoMessage()

func (*M3CompressedValuesReplica) Reset added in v0.4.5 

func (m *M3CompressedValuesReplica) Reset()

func (*M3CompressedValuesReplica) Size added in v0.4.5 

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

func (*M3CompressedValuesReplica) String added in v0.4.5 

func (m *M3CompressedValuesReplica) String() string

func (*M3CompressedValuesReplica) Unmarshal added in v0.4.5 

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

type M3Segment added in v0.4.5 

type M3Segment struct {
	Head      []byte `protobuf:"bytes,1,opt,name=head,proto3" json:"head,omitempty"`
	Tail      []byte `protobuf:"bytes,2,opt,name=tail,proto3" json:"tail,omitempty"`
	StartTime int64  `protobuf:"varint,3,opt,name=startTime,proto3" json:"startTime,omitempty"`
	BlockSize int64  `protobuf:"varint,4,opt,name=blockSize,proto3" json:"blockSize,omitempty"`
}

func (*M3Segment) Descriptor added in v0.4.5 

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

func (*M3Segment) GetBlockSize added in v0.4.5 

func (m *M3Segment) GetBlockSize() int64

func (*M3Segment) GetHead added in v0.4.5 

func (m *M3Segment) GetHead() []byte

func (*M3Segment) GetStartTime added in v0.4.5 

func (m *M3Segment) GetStartTime() int64

func (*M3Segment) GetTail added in v0.4.5 

func (m *M3Segment) GetTail() []byte

func (*M3Segment) Marshal added in v0.4.5 

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

func (*M3Segment) MarshalTo added in v0.4.5 

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

func (*M3Segment) ProtoMessage added in v0.4.5 

func (*M3Segment) ProtoMessage()

func (*M3Segment) Reset added in v0.4.5 

func (m *M3Segment) Reset()

func (*M3Segment) Size added in v0.4.5 

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

func (*M3Segment) String added in v0.4.5 

func (m *M3Segment) String() string

func (*M3Segment) Unmarshal added in v0.4.5 

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

type M3Segments added in v0.4.5 

type M3Segments struct {
	Merged   *M3Segment   `protobuf:"bytes,1,opt,name=merged" json:"merged,omitempty"`
	Unmerged []*M3Segment `protobuf:"bytes,2,rep,name=unmerged" json:"unmerged,omitempty"`
}

func (*M3Segments) Descriptor added in v0.4.5 

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

func (*M3Segments) GetMerged added in v0.4.5 

func (m *M3Segments) GetMerged() *M3Segment

func (*M3Segments) GetUnmerged added in v0.4.5 

func (m *M3Segments) GetUnmerged() []*M3Segment

func (*M3Segments) Marshal added in v0.4.5 

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

func (*M3Segments) MarshalTo added in v0.4.5 

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

func (*M3Segments) ProtoMessage added in v0.4.5 

func (*M3Segments) ProtoMessage()

func (*M3Segments) Reset added in v0.4.5 

func (m *M3Segments) Reset()

func (*M3Segments) Size added in v0.4.5 

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

func (*M3Segments) String added in v0.4.5 

func (m *M3Segments) String() string

func (*M3Segments) Unmarshal added in v0.4.5 

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

type M3TagProperties added in v0.4.8 

type M3TagProperties struct {
	Properties []*M3TagProperty `protobuf:"bytes,1,rep,name=properties" json:"properties,omitempty"`
}

func (*M3TagProperties) Descriptor added in v0.4.8 

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

func (*M3TagProperties) GetProperties added in v0.4.8 

func (m *M3TagProperties) GetProperties() []*M3TagProperty

func (*M3TagProperties) Marshal added in v0.4.8 

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

func (*M3TagProperties) MarshalTo added in v0.4.8 

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

func (*M3TagProperties) ProtoMessage added in v0.4.8 

func (*M3TagProperties) ProtoMessage()

func (*M3TagProperties) Reset added in v0.4.8 

func (m *M3TagProperties) Reset()

func (*M3TagProperties) Size added in v0.4.8 

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

func (*M3TagProperties) String added in v0.4.8 

func (m *M3TagProperties) String() string

func (*M3TagProperties) Unmarshal added in v0.4.8 

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

type M3TagProperty added in v0.4.8 

type M3TagProperty struct {
	Id             []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CompressedTags []byte `protobuf:"bytes,2,opt,name=compressedTags,proto3" json:"compressedTags,omitempty"`
}

func (*M3TagProperty) Descriptor added in v0.4.8 

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

func (*M3TagProperty) GetCompressedTags added in v0.4.8 

func (m *M3TagProperty) GetCompressedTags() []byte

func (*M3TagProperty) GetId added in v0.4.8 

func (m *M3TagProperty) GetId() []byte

func (*M3TagProperty) Marshal added in v0.4.8 

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

func (*M3TagProperty) MarshalTo added in v0.4.8 

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

func (*M3TagProperty) ProtoMessage added in v0.4.8 

func (*M3TagProperty) ProtoMessage()

func (*M3TagProperty) Reset added in v0.4.8 

func (m *M3TagProperty) Reset()

func (*M3TagProperty) Size added in v0.4.8 

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

func (*M3TagProperty) String added in v0.4.8 

func (m *M3TagProperty) String() string

func (*M3TagProperty) Unmarshal added in v0.4.8 

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

type MatcherType added in v0.4.5 

type MatcherType int32
const (
	MatcherType_EQUAL     MatcherType = 0
	MatcherType_NOTEQUAL  MatcherType = 1
	MatcherType_REGEXP    MatcherType = 2
	MatcherType_NOTREGEXP MatcherType = 3
	// EXISTS and NOTEXISTS apply only to
	// matcher name rather than value.
	MatcherType_EXISTS    MatcherType = 4
	MatcherType_NOTEXISTS MatcherType = 5
	// ALL supercedes other matcher types
	// and does no filtering.
	MatcherType_ALL MatcherType = 6
)

func (MatcherType) EnumDescriptor added in v0.4.5 

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

func (MatcherType) String added in v0.4.5 

func (x MatcherType) String() string

type MetricsType added in v0.11.0 

type MetricsType int32
const (
	MetricsType_UNKNOWN_METRICS_TYPE      MetricsType = 0
	MetricsType_UNAGGREGATED_METRICS_TYPE MetricsType = 1
	MetricsType_AGGREGATED_METRICS_TYPE   MetricsType = 2
)

func (MetricsType) EnumDescriptor added in v0.11.0 

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

func (MetricsType) String added in v0.11.0 

func (x MetricsType) String() string

type QueryClient 

type QueryClient interface {
	Health(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error)
	Fetch(ctx context.Context, in *FetchRequest, opts ...grpc.CallOption) (Query_FetchClient, error)
	Search(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (Query_SearchClient, error)
	CompleteTags(ctx context.Context, in *CompleteTagsRequest, opts ...grpc.CallOption) (Query_CompleteTagsClient, error)
}

func NewQueryClient 

func NewQueryClient(cc *grpc.ClientConn) QueryClient

type QueryServer 

type QueryServer interface {
	Health(context.Context, *HealthRequest) (*HealthResponse, error)
	Fetch(*FetchRequest, Query_FetchServer) error
	Search(*SearchRequest, Query_SearchServer) error
	CompleteTags(*CompleteTagsRequest, Query_CompleteTagsServer) error
}

type Query_CompleteTagsClient added in v0.4.8 

type Query_CompleteTagsClient interface {
	Recv() (*CompleteTagsResponse, error)
	grpc.ClientStream
}

type Query_CompleteTagsServer added in v0.4.8 

type Query_CompleteTagsServer interface {
	Send(*CompleteTagsResponse) error
	grpc.ServerStream
}

type Query_FetchClient 

type Query_FetchClient interface {
	Recv() (*FetchResponse, error)
	grpc.ClientStream
}

type Query_FetchServer 

type Query_FetchServer interface {
	Send(*FetchResponse) error
	grpc.ServerStream
}

type Query_SearchClient added in v0.4.8 

type Query_SearchClient interface {
	Recv() (*SearchResponse, error)
	grpc.ClientStream
}

type Query_SearchServer added in v0.4.8 

type Query_SearchServer interface {
	Send(*SearchResponse) error
	grpc.ServerStream
}

type RestrictFetchOptions added in v0.11.0 

type RestrictFetchOptions struct {
	MetricsType          MetricsType             `protobuf:"varint,1,opt,name=metricsType,proto3,enum=rpc.MetricsType" json:"metricsType,omitempty"`
	MetricsStoragePolicy *policypb.StoragePolicy `protobuf:"bytes,2,opt,name=metricsStoragePolicy" json:"metricsStoragePolicy,omitempty"`
}

func (*RestrictFetchOptions) Descriptor added in v0.11.0 

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

func (*RestrictFetchOptions) GetMetricsStoragePolicy added in v0.11.0 

func (m *RestrictFetchOptions) GetMetricsStoragePolicy() *policypb.StoragePolicy

func (*RestrictFetchOptions) GetMetricsType added in v0.11.0 

func (m *RestrictFetchOptions) GetMetricsType() MetricsType

func (*RestrictFetchOptions) Marshal added in v0.11.0 

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

func (*RestrictFetchOptions) MarshalTo added in v0.11.0 

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

func (*RestrictFetchOptions) ProtoMessage added in v0.11.0 

func (*RestrictFetchOptions) ProtoMessage()

func (*RestrictFetchOptions) Reset added in v0.11.0 

func (m *RestrictFetchOptions) Reset()

func (*RestrictFetchOptions) Size added in v0.11.0 

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

func (*RestrictFetchOptions) String added in v0.11.0 

func (m *RestrictFetchOptions) String() string

func (*RestrictFetchOptions) Unmarshal added in v0.11.0 

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

type ResultMetadata added in v0.14.0 

type ResultMetadata struct {
	Exhaustive  bool       `protobuf:"varint,1,opt,name=exhaustive,proto3" json:"exhaustive,omitempty"`
	Warnings    []*Warning `protobuf:"bytes,2,rep,name=warnings" json:"warnings,omitempty"`
	Resolutions []int64    `protobuf:"varint,3,rep,packed,name=resolutions" json:"resolutions,omitempty"`
}

func (*ResultMetadata) Descriptor added in v0.14.0 

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

func (*ResultMetadata) GetExhaustive added in v0.14.0 

func (m *ResultMetadata) GetExhaustive() bool

func (*ResultMetadata) GetResolutions added in v0.14.0 

func (m *ResultMetadata) GetResolutions() []int64

func (*ResultMetadata) GetWarnings added in v0.14.0 

func (m *ResultMetadata) GetWarnings() []*Warning

func (*ResultMetadata) Marshal added in v0.14.0 

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

func (*ResultMetadata) MarshalTo added in v0.14.0 

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

func (*ResultMetadata) ProtoMessage added in v0.14.0 

func (*ResultMetadata) ProtoMessage()

func (*ResultMetadata) Reset added in v0.14.0 

func (m *ResultMetadata) Reset()

func (*ResultMetadata) Size added in v0.14.0 

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

func (*ResultMetadata) String added in v0.14.0 

func (m *ResultMetadata) String() string

func (*ResultMetadata) Unmarshal added in v0.14.0 

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

type SearchRequest added in v0.4.8 

type SearchRequest struct {
	// Types that are valid to be assigned to Matchers:
	//	*SearchRequest_TagMatchers
	Matchers isSearchRequest_Matchers `protobuf_oneof:"matchers"`
	Start    int64                    `protobuf:"varint,2,opt,name=start,proto3" json:"start,omitempty"`
	End      int64                    `protobuf:"varint,3,opt,name=end,proto3" json:"end,omitempty"`
	Options  *FetchOptions            `protobuf:"bytes,4,opt,name=options" json:"options,omitempty"`
}

func (*SearchRequest) Descriptor added in v0.4.8 

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

func (*SearchRequest) GetEnd added in v0.14.0 

func (m *SearchRequest) GetEnd() int64

func (*SearchRequest) GetMatchers added in v0.4.8 

func (m *SearchRequest) GetMatchers() isSearchRequest_Matchers

func (*SearchRequest) GetOptions added in v0.14.0 

func (m *SearchRequest) GetOptions() *FetchOptions

func (*SearchRequest) GetStart added in v0.14.0 

func (m *SearchRequest) GetStart() int64

func (*SearchRequest) GetTagMatchers added in v0.4.8 

func (m *SearchRequest) GetTagMatchers() *TagMatchers

func (*SearchRequest) Marshal added in v0.4.8 

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

func (*SearchRequest) MarshalTo added in v0.4.8 

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

func (*SearchRequest) ProtoMessage added in v0.4.8 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset added in v0.4.8 

func (m *SearchRequest) Reset()

func (*SearchRequest) Size added in v0.4.8 

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

func (*SearchRequest) String added in v0.4.8 

func (m *SearchRequest) String() string

func (*SearchRequest) Unmarshal added in v0.4.8 

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

func (*SearchRequest) XXX_OneofFuncs added in v0.4.8 

func (*SearchRequest) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type SearchRequest_TagMatchers added in v0.4.8 

type SearchRequest_TagMatchers struct {
	TagMatchers *TagMatchers `protobuf:"bytes,1,opt,name=tagMatchers,oneof"`
}

func (*SearchRequest_TagMatchers) MarshalTo added in v0.4.8 

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

func (*SearchRequest_TagMatchers) Size added in v0.4.8 

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

type SearchResponse added in v0.4.8 

type SearchResponse struct {
	// Types that are valid to be assigned to Value:
	//	*SearchResponse_Decompressed
	//	*SearchResponse_Compressed
	Value isSearchResponse_Value `protobuf_oneof:"value"`
	Meta  *ResultMetadata        `protobuf:"bytes,3,opt,name=meta" json:"meta,omitempty"`
}

func (*SearchResponse) Descriptor added in v0.4.8 

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

func (*SearchResponse) GetCompressed added in v0.4.8 

func (m *SearchResponse) GetCompressed() *M3TagProperties

func (*SearchResponse) GetDecompressed added in v0.4.8 

func (m *SearchResponse) GetDecompressed() *TagProperties

func (*SearchResponse) GetMeta added in v0.14.0 

func (m *SearchResponse) GetMeta() *ResultMetadata

func (*SearchResponse) GetValue added in v0.4.8 

func (m *SearchResponse) GetValue() isSearchResponse_Value

func (*SearchResponse) Marshal added in v0.4.8 

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

func (*SearchResponse) MarshalTo added in v0.4.8 

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

func (*SearchResponse) ProtoMessage added in v0.4.8 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) Reset added in v0.4.8 

func (m *SearchResponse) Reset()

func (*SearchResponse) Size added in v0.4.8 

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

func (*SearchResponse) String added in v0.4.8 

func (m *SearchResponse) String() string

func (*SearchResponse) Unmarshal added in v0.4.8 

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

func (*SearchResponse) XXX_OneofFuncs added in v0.4.8 

func (*SearchResponse) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type SearchResponse_Compressed added in v0.4.8 

type SearchResponse_Compressed struct {
	Compressed *M3TagProperties `protobuf:"bytes,2,opt,name=compressed,oneof"`
}

func (*SearchResponse_Compressed) MarshalTo added in v0.4.8 

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

func (*SearchResponse_Compressed) Size added in v0.4.8 

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

type SearchResponse_Decompressed added in v0.4.8 

type SearchResponse_Decompressed struct {
	Decompressed *TagProperties `protobuf:"bytes,1,opt,name=decompressed,oneof"`
}

func (*SearchResponse_Decompressed) MarshalTo added in v0.4.8 

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

func (*SearchResponse_Decompressed) Size added in v0.4.8 

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

type Series 

type Series struct {
	Meta *SeriesMetadata `protobuf:"bytes,1,opt,name=meta" json:"meta,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*Series_Decompressed
	//	*Series_Compressed
	Value isSeries_Value `protobuf_oneof:"value"`
}

func (*Series) Descriptor 

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

func (*Series) GetCompressed 

func (m *Series) GetCompressed() *M3CompressedSeries

func (*Series) GetDecompressed added in v0.4.5 

func (m *Series) GetDecompressed() *DecompressedSeries

func (*Series) GetMeta added in v0.4.5 

func (m *Series) GetMeta() *SeriesMetadata

func (*Series) GetValue added in v0.4.5 

func (m *Series) GetValue() isSeries_Value

func (*Series) Marshal 

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

func (*Series) MarshalTo 

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

func (*Series) ProtoMessage 

func (*Series) ProtoMessage()

func (*Series) Reset 

func (m *Series) Reset()

func (*Series) Size 

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

func (*Series) String 

func (m *Series) String() string

func (*Series) Unmarshal 

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

func (*Series) XXX_OneofFuncs added in v0.4.5 

func (*Series) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type SeriesMetadata added in v0.4.5 

type SeriesMetadata struct {
	Id        []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	StartTime int64  `protobuf:"varint,2,opt,name=startTime,proto3" json:"startTime,omitempty"`
	EndTime   int64  `protobuf:"varint,3,opt,name=endTime,proto3" json:"endTime,omitempty"`
}

func (*SeriesMetadata) Descriptor added in v0.4.5 

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

func (*SeriesMetadata) GetEndTime added in v0.4.5 

func (m *SeriesMetadata) GetEndTime() int64

func (*SeriesMetadata) GetId added in v0.4.5 

func (m *SeriesMetadata) GetId() []byte

func (*SeriesMetadata) GetStartTime added in v0.4.5 

func (m *SeriesMetadata) GetStartTime() int64

func (*SeriesMetadata) Marshal added in v0.4.5 

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

func (*SeriesMetadata) MarshalTo added in v0.4.5 

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

func (*SeriesMetadata) ProtoMessage added in v0.4.5 

func (*SeriesMetadata) ProtoMessage()

func (*SeriesMetadata) Reset added in v0.4.5 

func (m *SeriesMetadata) Reset()

func (*SeriesMetadata) Size added in v0.4.5 

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

func (*SeriesMetadata) String added in v0.4.5 

func (m *SeriesMetadata) String() string

func (*SeriesMetadata) Unmarshal added in v0.4.5 

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

type Series_Compressed added in v0.4.5 

type Series_Compressed struct {
	Compressed *M3CompressedSeries `protobuf:"bytes,3,opt,name=compressed,oneof"`
}

func (*Series_Compressed) MarshalTo added in v0.4.5 

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

func (*Series_Compressed) Size added in v0.4.5 

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

type Series_Decompressed added in v0.4.5 

type Series_Decompressed struct {
	Decompressed *DecompressedSeries `protobuf:"bytes,2,opt,name=decompressed,oneof"`
}

func (*Series_Decompressed) MarshalTo added in v0.4.5 

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

func (*Series_Decompressed) Size added in v0.4.5 

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

type Tag 

type Tag struct {
	Name  []byte `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*Tag) Descriptor 

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

func (*Tag) GetName 

func (m *Tag) GetName() []byte

func (*Tag) GetValue 

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

func (*Tag) Marshal 

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

func (*Tag) MarshalTo 

func (m *Tag) MarshalTo(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

type TagMatcher added in v0.4.5 

type TagMatcher struct {
	Name  []byte      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value []byte      `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Type  MatcherType `protobuf:"varint,3,opt,name=type,proto3,enum=rpc.MatcherType" json:"type,omitempty"`
}

func (*TagMatcher) Descriptor added in v0.4.5 

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

func (*TagMatcher) GetName added in v0.4.5 

func (m *TagMatcher) GetName() []byte

func (*TagMatcher) GetType added in v0.4.5 

func (m *TagMatcher) GetType() MatcherType

func (*TagMatcher) GetValue added in v0.4.5 

func (m *TagMatcher) GetValue() []byte

func (*TagMatcher) Marshal added in v0.4.5 

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

func (*TagMatcher) MarshalTo added in v0.4.5 

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

func (*TagMatcher) ProtoMessage added in v0.4.5 

func (*TagMatcher) ProtoMessage()

func (*TagMatcher) Reset added in v0.4.5 

func (m *TagMatcher) Reset()

func (*TagMatcher) Size added in v0.4.5 

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

func (*TagMatcher) String added in v0.4.5 

func (m *TagMatcher) String() string

func (*TagMatcher) Unmarshal added in v0.4.5 

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

type TagMatchers added in v0.4.5 

type TagMatchers struct {
	TagMatchers []*TagMatcher `protobuf:"bytes,1,rep,name=tagMatchers" json:"tagMatchers,omitempty"`
}

func (*TagMatchers) Descriptor added in v0.4.5 

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

func (*TagMatchers) GetTagMatchers added in v0.4.5 

func (m *TagMatchers) GetTagMatchers() []*TagMatcher

func (*TagMatchers) Marshal added in v0.4.5 

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

func (*TagMatchers) MarshalTo added in v0.4.5 

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

func (*TagMatchers) ProtoMessage added in v0.4.5 

func (*TagMatchers) ProtoMessage()

func (*TagMatchers) Reset added in v0.4.5 

func (m *TagMatchers) Reset()

func (*TagMatchers) Size added in v0.4.5 

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

func (*TagMatchers) String added in v0.4.5 

func (m *TagMatchers) String() string

func (*TagMatchers) Unmarshal added in v0.4.5 

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

type TagNames added in v0.4.8 

type TagNames struct {
	Names [][]byte `protobuf:"bytes,1,rep,name=names" json:"names,omitempty"`
}

func (*TagNames) Descriptor added in v0.4.8 

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

func (*TagNames) GetNames added in v0.4.8 

func (m *TagNames) GetNames() [][]byte

func (*TagNames) Marshal added in v0.4.8 

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

func (*TagNames) MarshalTo added in v0.4.8 

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

func (*TagNames) ProtoMessage added in v0.4.8 

func (*TagNames) ProtoMessage()

func (*TagNames) Reset added in v0.4.8 

func (m *TagNames) Reset()

func (*TagNames) Size added in v0.4.8 

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

func (*TagNames) String added in v0.4.8 

func (m *TagNames) String() string

func (*TagNames) Unmarshal added in v0.4.8 

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

type TagProperties added in v0.4.8 

type TagProperties struct {
	Properties []*TagProperty `protobuf:"bytes,1,rep,name=properties" json:"properties,omitempty"`
}

func (*TagProperties) Descriptor added in v0.4.8 

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

func (*TagProperties) GetProperties added in v0.4.8 

func (m *TagProperties) GetProperties() []*TagProperty

func (*TagProperties) Marshal added in v0.4.8 

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

func (*TagProperties) MarshalTo added in v0.4.8 

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

func (*TagProperties) ProtoMessage added in v0.4.8 

func (*TagProperties) ProtoMessage()

func (*TagProperties) Reset added in v0.4.8 

func (m *TagProperties) Reset()

func (*TagProperties) Size added in v0.4.8 

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

func (*TagProperties) String added in v0.4.8 

func (m *TagProperties) String() string

func (*TagProperties) Unmarshal added in v0.4.8 

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

type TagProperty added in v0.4.8 

type TagProperty struct {
	Key    []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values []byte `protobuf:"bytes,2,opt,name=values,proto3" json:"values,omitempty"`
}

func (*TagProperty) Descriptor added in v0.4.8 

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

func (*TagProperty) GetKey added in v0.4.8 

func (m *TagProperty) GetKey() []byte

func (*TagProperty) GetValues added in v0.4.8 

func (m *TagProperty) GetValues() []byte

func (*TagProperty) Marshal added in v0.4.8 

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

func (*TagProperty) MarshalTo added in v0.4.8 

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

func (*TagProperty) ProtoMessage added in v0.4.8 

func (*TagProperty) ProtoMessage()

func (*TagProperty) Reset added in v0.4.8 

func (m *TagProperty) Reset()

func (*TagProperty) Size added in v0.4.8 

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

func (*TagProperty) String added in v0.4.8 

func (m *TagProperty) String() string

func (*TagProperty) Unmarshal added in v0.4.8 

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

type TagValue added in v0.4.8 

type TagValue struct {
	Key    []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Values [][]byte `protobuf:"bytes,2,rep,name=values" json:"values,omitempty"`
}

func (*TagValue) Descriptor added in v0.4.8 

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

func (*TagValue) GetKey added in v0.4.8 

func (m *TagValue) GetKey() []byte

func (*TagValue) GetValues added in v0.4.8 

func (m *TagValue) GetValues() [][]byte

func (*TagValue) Marshal added in v0.4.8 

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

func (*TagValue) MarshalTo added in v0.4.8 

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

func (*TagValue) ProtoMessage added in v0.4.8 

func (*TagValue) ProtoMessage()

func (*TagValue) Reset added in v0.4.8 

func (m *TagValue) Reset()

func (*TagValue) Size added in v0.4.8 

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

func (*TagValue) String added in v0.4.8 

func (m *TagValue) String() string

func (*TagValue) Unmarshal added in v0.4.8 

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

type TagValues added in v0.4.8 

type TagValues struct {
	Values []*TagValue `protobuf:"bytes,1,rep,name=values" json:"values,omitempty"`
}

func (*TagValues) Descriptor added in v0.4.8 

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

func (*TagValues) GetValues added in v0.4.8 

func (m *TagValues) GetValues() []*TagValue

func (*TagValues) Marshal added in v0.4.8 

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

func (*TagValues) MarshalTo added in v0.4.8 

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

func (*TagValues) ProtoMessage added in v0.4.8 

func (*TagValues) ProtoMessage()

func (*TagValues) Reset added in v0.4.8 

func (m *TagValues) Reset()

func (*TagValues) Size added in v0.4.8 

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

func (*TagValues) String added in v0.4.8 

func (m *TagValues) String() string

func (*TagValues) Unmarshal added in v0.4.8 

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

type Warning added in v0.14.0 

type Warning struct {
	Name    []byte `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Message []byte `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

func (*Warning) Descriptor added in v0.14.0 

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

func (*Warning) GetMessage added in v0.14.0 

func (m *Warning) GetMessage() []byte

func (*Warning) GetName added in v0.14.0 

func (m *Warning) GetName() []byte

func (*Warning) Marshal added in v0.14.0 

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

func (*Warning) MarshalTo added in v0.14.0 

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

func (*Warning) ProtoMessage added in v0.14.0 

func (*Warning) ProtoMessage()

func (*Warning) Reset added in v0.14.0 

func (m *Warning) Reset()

func (*Warning) Size added in v0.14.0 

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

func (*Warning) String added in v0.14.0 

func (m *Warning) String() string

func (*Warning) Unmarshal added in v0.14.0 

func (m *Warning) Unmarshal(dAtA []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.