rpcpb

package
v1.5.0 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2022 License: Apache-2.0 Imports: 8 Imported by: 4

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
RestrictQueryOptions
RestrictQueryType
RestrictQueryTags
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            *RestrictQueryOptions `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"`
	// Deprecated: all requests will include resolution.
	IncludeResolution bool   `protobuf:"varint,7,opt,name=includeResolution,proto3" json:"includeResolution,omitempty"`
	Source            []byte `protobuf:"bytes,8,opt,name=source,proto3" json:"source,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() *RestrictQueryOptions

func (*FetchOptions) GetSource ¶ added in v1.0.1 

func (m *FetchOptions) GetSource() []byte

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"`
	Checksum  uint32 `protobuf:"varint,5,opt,name=checksum,proto3" json:"checksum,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) GetChecksum ¶ added in v0.15.0 

func (m *M3Segment) GetChecksum() uint32

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 RestrictQueryOptions ¶ added in v0.15.0 

type RestrictQueryOptions struct {
	RestrictQueryType *RestrictQueryType `protobuf:"bytes,3,opt,name=restrictQueryType" json:"restrictQueryType,omitempty"`
	RestrictQueryTags *RestrictQueryTags `protobuf:"bytes,4,opt,name=restrictQueryTags" json:"restrictQueryTags,omitempty"`
}

func (*RestrictQueryOptions) Descriptor ¶ added in v0.15.0 

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

func (*RestrictQueryOptions) GetRestrictQueryTags ¶ added in v0.15.0 

func (m *RestrictQueryOptions) GetRestrictQueryTags() *RestrictQueryTags

func (*RestrictQueryOptions) GetRestrictQueryType ¶ added in v0.15.0 

func (m *RestrictQueryOptions) GetRestrictQueryType() *RestrictQueryType

func (*RestrictQueryOptions) Marshal ¶ added in v0.15.0 

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

func (*RestrictQueryOptions) MarshalTo ¶ added in v0.15.0 

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

func (*RestrictQueryOptions) ProtoMessage ¶ added in v0.15.0 

func (*RestrictQueryOptions) ProtoMessage()

func (*RestrictQueryOptions) Reset ¶ added in v0.15.0 

func (m *RestrictQueryOptions) Reset()

func (*RestrictQueryOptions) Size ¶ added in v0.15.0 

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

func (*RestrictQueryOptions) String ¶ added in v0.15.0 

func (m *RestrictQueryOptions) String() string

func (*RestrictQueryOptions) Unmarshal ¶ added in v0.15.0 

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

type RestrictQueryTags ¶ added in v0.15.0 

type RestrictQueryTags struct {
	Restrict *TagMatchers `protobuf:"bytes,1,opt,name=restrict" json:"restrict,omitempty"`
	Strip    [][]byte     `protobuf:"bytes,2,rep,name=strip" json:"strip,omitempty"`
}

func (*RestrictQueryTags) Descriptor ¶ added in v0.15.0 

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

func (*RestrictQueryTags) GetRestrict ¶ added in v0.15.0 

func (m *RestrictQueryTags) GetRestrict() *TagMatchers

func (*RestrictQueryTags) GetStrip ¶ added in v0.15.0 

func (m *RestrictQueryTags) GetStrip() [][]byte

func (*RestrictQueryTags) Marshal ¶ added in v0.15.0 

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

func (*RestrictQueryTags) MarshalTo ¶ added in v0.15.0 

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

func (*RestrictQueryTags) ProtoMessage ¶ added in v0.15.0 

func (*RestrictQueryTags) ProtoMessage()

func (*RestrictQueryTags) Reset ¶ added in v0.15.0 

func (m *RestrictQueryTags) Reset()

func (*RestrictQueryTags) Size ¶ added in v0.15.0 

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

func (*RestrictQueryTags) String ¶ added in v0.15.0 

func (m *RestrictQueryTags) String() string

func (*RestrictQueryTags) Unmarshal ¶ added in v0.15.0 

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

type RestrictQueryType ¶ added in v0.15.0 

type RestrictQueryType 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 (*RestrictQueryType) Descriptor ¶ added in v0.15.0 

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

func (*RestrictQueryType) GetMetricsStoragePolicy ¶ added in v0.15.0 

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

func (*RestrictQueryType) GetMetricsType ¶ added in v0.15.0 

func (m *RestrictQueryType) GetMetricsType() MetricsType

func (*RestrictQueryType) Marshal ¶ added in v0.15.0 

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

func (*RestrictQueryType) MarshalTo ¶ added in v0.15.0 

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

func (*RestrictQueryType) ProtoMessage ¶ added in v0.15.0 

func (*RestrictQueryType) ProtoMessage()

func (*RestrictQueryType) Reset ¶ added in v0.15.0 

func (m *RestrictQueryType) Reset()

func (*RestrictQueryType) Size ¶ added in v0.15.0 

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

func (*RestrictQueryType) String ¶ added in v0.15.0 

func (m *RestrictQueryType) String() string

func (*RestrictQueryType) Unmarshal ¶ added in v0.15.0 

func (m *RestrictQueryType) 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.