rpcpb

package
v0.0.0-...-9649366 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2019 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 

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 

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

func (*CompleteTagsRequest) GetMatchers 

func (m *CompleteTagsRequest) GetMatchers() isCompleteTagsRequest_Matchers

func (*CompleteTagsRequest) GetOptions 

func (m *CompleteTagsRequest) GetOptions() *CompleteTagsRequestOptions

func (*CompleteTagsRequest) GetTagMatchers 

func (m *CompleteTagsRequest) GetTagMatchers() *TagMatchers

func (*CompleteTagsRequest) Marshal 

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

func (*CompleteTagsRequest) MarshalTo 

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

func (*CompleteTagsRequest) ProtoMessage 

func (*CompleteTagsRequest) ProtoMessage()

func (*CompleteTagsRequest) Reset 

func (m *CompleteTagsRequest) Reset()

func (*CompleteTagsRequest) Size 

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

func (*CompleteTagsRequest) String 

func (m *CompleteTagsRequest) String() string

func (*CompleteTagsRequest) Unmarshal 

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

func (*CompleteTagsRequest) XXX_OneofFuncs 

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 

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 

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

func (*CompleteTagsRequestOptions) GetEnd 

func (m *CompleteTagsRequestOptions) GetEnd() int64

func (*CompleteTagsRequestOptions) GetFilterNameTags 

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

func (*CompleteTagsRequestOptions) GetOptions 

func (m *CompleteTagsRequestOptions) GetOptions() *FetchOptions

func (*CompleteTagsRequestOptions) GetStart 

func (m *CompleteTagsRequestOptions) GetStart() int64

func (*CompleteTagsRequestOptions) GetType 

func (m *CompleteTagsRequestOptions) GetType() CompleteTagsType

func (*CompleteTagsRequestOptions) Marshal 

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

func (*CompleteTagsRequestOptions) MarshalTo 

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

func (*CompleteTagsRequestOptions) ProtoMessage 

func (*CompleteTagsRequestOptions) ProtoMessage()

func (*CompleteTagsRequestOptions) Reset 

func (m *CompleteTagsRequestOptions) Reset()

func (*CompleteTagsRequestOptions) Size 

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

func (*CompleteTagsRequestOptions) String 

func (m *CompleteTagsRequestOptions) String() string

func (*CompleteTagsRequestOptions) Unmarshal 

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

type CompleteTagsRequest_TagMatchers 

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

func (*CompleteTagsRequest_TagMatchers) MarshalTo 

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

func (*CompleteTagsRequest_TagMatchers) Size 

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

type CompleteTagsResponse 

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 

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

func (*CompleteTagsResponse) GetDefault 

func (m *CompleteTagsResponse) GetDefault() *TagValues

func (*CompleteTagsResponse) GetMeta 

func (m *CompleteTagsResponse) GetMeta() *ResultMetadata

func (*CompleteTagsResponse) GetNamesOnly 

func (m *CompleteTagsResponse) GetNamesOnly() *TagNames

func (*CompleteTagsResponse) GetValue 

func (m *CompleteTagsResponse) GetValue() isCompleteTagsResponse_Value

func (*CompleteTagsResponse) Marshal 

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

func (*CompleteTagsResponse) MarshalTo 

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

func (*CompleteTagsResponse) ProtoMessage 

func (*CompleteTagsResponse) ProtoMessage()

func (*CompleteTagsResponse) Reset 

func (m *CompleteTagsResponse) Reset()

func (*CompleteTagsResponse) Size 

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

func (*CompleteTagsResponse) String 

func (m *CompleteTagsResponse) String() string

func (*CompleteTagsResponse) Unmarshal 

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

func (*CompleteTagsResponse) XXX_OneofFuncs 

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 

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

func (*CompleteTagsResponse_Default) MarshalTo 

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

func (*CompleteTagsResponse_Default) Size 

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

type CompleteTagsResponse_NamesOnly 

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

func (*CompleteTagsResponse_NamesOnly) MarshalTo 

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

func (*CompleteTagsResponse_NamesOnly) Size 

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

type CompleteTagsType 

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

func (CompleteTagsType) EnumDescriptor 

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

func (CompleteTagsType) String 

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 

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 

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

func (*DecompressedSeries) GetDatapoints 

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

func (*DecompressedSeries) GetTags 

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

func (*DecompressedSeries) Marshal 

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

func (*DecompressedSeries) MarshalTo 

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

func (*DecompressedSeries) ProtoMessage 

func (*DecompressedSeries) ProtoMessage()

func (*DecompressedSeries) Reset 

func (m *DecompressedSeries) Reset()

func (*DecompressedSeries) Size 

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

func (*DecompressedSeries) String 

func (m *DecompressedSeries) String() string

func (*DecompressedSeries) Unmarshal 

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

type FanoutOption 

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

func (FanoutOption) EnumDescriptor 

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

func (FanoutOption) String 

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 

func (m *FetchOptions) GetAggregated() FanoutOption

func (*FetchOptions) GetAggregatedOptimized 

func (m *FetchOptions) GetAggregatedOptimized() FanoutOption

func (*FetchOptions) GetIncludeResolution 

func (m *FetchOptions) GetIncludeResolution() bool

func (*FetchOptions) GetLimit 

func (m *FetchOptions) GetLimit() int64

func (*FetchOptions) GetLookbackDuration 

func (m *FetchOptions) GetLookbackDuration() int64

func (*FetchOptions) GetRestrict 

func (m *FetchOptions) GetRestrict() *RestrictFetchOptions

func (*FetchOptions) GetUnaggregated 

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 

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 

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

func (*FetchRequest) GetEnd 

func (m *FetchRequest) GetEnd() int64

func (*FetchRequest) GetMatchers 

func (m *FetchRequest) GetMatchers() isFetchRequest_Matchers

func (*FetchRequest) GetOptions 

func (m *FetchRequest) GetOptions() *FetchOptions

func (*FetchRequest) GetStart 

func (m *FetchRequest) GetStart() int64

func (*FetchRequest) GetTagMatchers 

func (m *FetchRequest) GetTagMatchers() *TagMatchers

func (*FetchRequest) Marshal 

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

func (*FetchRequest) MarshalTo 

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

func (*FetchRequest) ProtoMessage 

func (*FetchRequest) ProtoMessage()

func (*FetchRequest) Reset 

func (m *FetchRequest) Reset()

func (*FetchRequest) Size 

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

func (*FetchRequest) String 

func (m *FetchRequest) String() string

func (*FetchRequest) Unmarshal 

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

func (*FetchRequest) XXX_OneofFuncs 

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 

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

func (*FetchRequest_TagMatchers) MarshalTo 

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

func (*FetchRequest_TagMatchers) Size 

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

type FetchResponse 

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 

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

func (*FetchResponse) GetMeta 

func (m *FetchResponse) GetMeta() *ResultMetadata

func (*FetchResponse) GetSeries 

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

func (*FetchResponse) Marshal 

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

func (*FetchResponse) MarshalTo 

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

func (*FetchResponse) ProtoMessage 

func (*FetchResponse) ProtoMessage()

func (*FetchResponse) Reset 

func (m *FetchResponse) Reset()

func (*FetchResponse) Size 

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

func (*FetchResponse) String 

func (m *FetchResponse) String() string

func (*FetchResponse) Unmarshal 

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

type HealthRequest 

type HealthRequest struct {
}

func (*HealthRequest) Descriptor 

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

func (*HealthRequest) Marshal 

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

func (*HealthRequest) MarshalTo 

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

func (*HealthRequest) ProtoMessage 

func (*HealthRequest) ProtoMessage()

func (*HealthRequest) Reset 

func (m *HealthRequest) Reset()

func (*HealthRequest) Size 

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

func (*HealthRequest) String 

func (m *HealthRequest) String() string

func (*HealthRequest) Unmarshal 

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

type HealthResponse 

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 

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

func (*HealthResponse) GetUptimeDuration 

func (m *HealthResponse) GetUptimeDuration() string

func (*HealthResponse) GetUptimeNanoseconds 

func (m *HealthResponse) GetUptimeNanoseconds() int64

func (*HealthResponse) Marshal 

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

func (*HealthResponse) MarshalTo 

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

func (*HealthResponse) ProtoMessage 

func (*HealthResponse) ProtoMessage()

func (*HealthResponse) Reset 

func (m *HealthResponse) Reset()

func (*HealthResponse) Size 

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

func (*HealthResponse) String 

func (m *HealthResponse) String() string

func (*HealthResponse) Unmarshal 

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

type M3CompressedSeries 

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 

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

func (*M3CompressedSeries) GetCompressedTags 

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

func (*M3CompressedSeries) GetReplicas 

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

func (*M3CompressedSeries) Marshal 

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

func (*M3CompressedSeries) MarshalTo 

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

func (*M3CompressedSeries) ProtoMessage 

func (*M3CompressedSeries) ProtoMessage()

func (*M3CompressedSeries) Reset 

func (m *M3CompressedSeries) Reset()

func (*M3CompressedSeries) Size 

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

func (*M3CompressedSeries) String 

func (m *M3CompressedSeries) String() string

func (*M3CompressedSeries) Unmarshal 

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

type M3CompressedValuesReplica 

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

func (*M3CompressedValuesReplica) Descriptor 

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

func (*M3CompressedValuesReplica) GetSegments 

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

func (*M3CompressedValuesReplica) Marshal 

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

func (*M3CompressedValuesReplica) MarshalTo 

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

func (*M3CompressedValuesReplica) ProtoMessage 

func (*M3CompressedValuesReplica) ProtoMessage()

func (*M3CompressedValuesReplica) Reset 

func (m *M3CompressedValuesReplica) Reset()

func (*M3CompressedValuesReplica) Size 

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

func (*M3CompressedValuesReplica) String 

func (m *M3CompressedValuesReplica) String() string

func (*M3CompressedValuesReplica) Unmarshal 

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

type M3Segment 

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 

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

func (*M3Segment) GetBlockSize 

func (m *M3Segment) GetBlockSize() int64

func (*M3Segment) GetHead 

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

func (*M3Segment) GetStartTime 

func (m *M3Segment) GetStartTime() int64

func (*M3Segment) GetTail 

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

func (*M3Segment) Marshal 

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

func (*M3Segment) MarshalTo 

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

func (*M3Segment) ProtoMessage 

func (*M3Segment) ProtoMessage()

func (*M3Segment) Reset 

func (m *M3Segment) Reset()

func (*M3Segment) Size 

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

func (*M3Segment) String 

func (m *M3Segment) String() string

func (*M3Segment) Unmarshal 

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

type M3Segments 

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 

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

func (*M3Segments) GetMerged 

func (m *M3Segments) GetMerged() *M3Segment

func (*M3Segments) GetUnmerged 

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

func (*M3Segments) Marshal 

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

func (*M3Segments) MarshalTo 

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

func (*M3Segments) ProtoMessage 

func (*M3Segments) ProtoMessage()

func (*M3Segments) Reset 

func (m *M3Segments) Reset()

func (*M3Segments) Size 

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

func (*M3Segments) String 

func (m *M3Segments) String() string

func (*M3Segments) Unmarshal 

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

type M3TagProperties 

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

func (*M3TagProperties) Descriptor 

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

func (*M3TagProperties) GetProperties 

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

func (*M3TagProperties) Marshal 

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

func (*M3TagProperties) MarshalTo 

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

func (*M3TagProperties) ProtoMessage 

func (*M3TagProperties) ProtoMessage()

func (*M3TagProperties) Reset 

func (m *M3TagProperties) Reset()

func (*M3TagProperties) Size 

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

func (*M3TagProperties) String 

func (m *M3TagProperties) String() string

func (*M3TagProperties) Unmarshal 

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

type M3TagProperty 

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 

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

func (*M3TagProperty) GetCompressedTags 

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

func (*M3TagProperty) GetId 

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

func (*M3TagProperty) Marshal 

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

func (*M3TagProperty) MarshalTo 

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

func (*M3TagProperty) ProtoMessage 

func (*M3TagProperty) ProtoMessage()

func (*M3TagProperty) Reset 

func (m *M3TagProperty) Reset()

func (*M3TagProperty) Size 

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

func (*M3TagProperty) String 

func (m *M3TagProperty) String() string

func (*M3TagProperty) Unmarshal 

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

type MatcherType 

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 

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

func (MatcherType) String 

func (x MatcherType) String() string

type MetricsType 

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 

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

func (MetricsType) String 

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 

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

type Query_CompleteTagsServer 

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 

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

type Query_SearchServer 

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

type RestrictFetchOptions 

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 

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

func (*RestrictFetchOptions) GetMetricsStoragePolicy 

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

func (*RestrictFetchOptions) GetMetricsType 

func (m *RestrictFetchOptions) GetMetricsType() MetricsType

func (*RestrictFetchOptions) Marshal 

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

func (*RestrictFetchOptions) MarshalTo 

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

func (*RestrictFetchOptions) ProtoMessage 

func (*RestrictFetchOptions) ProtoMessage()

func (*RestrictFetchOptions) Reset 

func (m *RestrictFetchOptions) Reset()

func (*RestrictFetchOptions) Size 

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

func (*RestrictFetchOptions) String 

func (m *RestrictFetchOptions) String() string

func (*RestrictFetchOptions) Unmarshal 

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

type ResultMetadata 

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 

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

func (*ResultMetadata) GetExhaustive 

func (m *ResultMetadata) GetExhaustive() bool

func (*ResultMetadata) GetResolutions 

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

func (*ResultMetadata) GetWarnings 

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

func (*ResultMetadata) Marshal 

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

func (*ResultMetadata) MarshalTo 

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

func (*ResultMetadata) ProtoMessage 

func (*ResultMetadata) ProtoMessage()

func (*ResultMetadata) Reset 

func (m *ResultMetadata) Reset()

func (*ResultMetadata) Size 

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

func (*ResultMetadata) String 

func (m *ResultMetadata) String() string

func (*ResultMetadata) Unmarshal 

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

type SearchRequest 

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 

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

func (*SearchRequest) GetEnd 

func (m *SearchRequest) GetEnd() int64

func (*SearchRequest) GetMatchers 

func (m *SearchRequest) GetMatchers() isSearchRequest_Matchers

func (*SearchRequest) GetOptions 

func (m *SearchRequest) GetOptions() *FetchOptions

func (*SearchRequest) GetStart 

func (m *SearchRequest) GetStart() int64

func (*SearchRequest) GetTagMatchers 

func (m *SearchRequest) GetTagMatchers() *TagMatchers

func (*SearchRequest) Marshal 

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

func (*SearchRequest) MarshalTo 

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

func (*SearchRequest) ProtoMessage 

func (*SearchRequest) ProtoMessage()

func (*SearchRequest) Reset 

func (m *SearchRequest) Reset()

func (*SearchRequest) Size 

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

func (*SearchRequest) String 

func (m *SearchRequest) String() string

func (*SearchRequest) Unmarshal 

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

func (*SearchRequest) XXX_OneofFuncs 

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 

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

func (*SearchRequest_TagMatchers) MarshalTo 

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

func (*SearchRequest_TagMatchers) Size 

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

type SearchResponse 

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 

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

func (*SearchResponse) GetCompressed 

func (m *SearchResponse) GetCompressed() *M3TagProperties

func (*SearchResponse) GetDecompressed 

func (m *SearchResponse) GetDecompressed() *TagProperties

func (*SearchResponse) GetMeta 

func (m *SearchResponse) GetMeta() *ResultMetadata

func (*SearchResponse) GetValue 

func (m *SearchResponse) GetValue() isSearchResponse_Value

func (*SearchResponse) Marshal 

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

func (*SearchResponse) MarshalTo 

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

func (*SearchResponse) ProtoMessage 

func (*SearchResponse) ProtoMessage()

func (*SearchResponse) Reset 

func (m *SearchResponse) Reset()

func (*SearchResponse) Size 

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

func (*SearchResponse) String 

func (m *SearchResponse) String() string

func (*SearchResponse) Unmarshal 

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

func (*SearchResponse) XXX_OneofFuncs 

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 

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

func (*SearchResponse_Compressed) MarshalTo 

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

func (*SearchResponse_Compressed) Size 

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

type SearchResponse_Decompressed 

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

func (*SearchResponse_Decompressed) MarshalTo 

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

func (*SearchResponse_Decompressed) Size 

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 

func (m *Series) GetDecompressed() *DecompressedSeries

func (*Series) GetMeta 

func (m *Series) GetMeta() *SeriesMetadata

func (*Series) GetValue 

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 

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 

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 

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

func (*SeriesMetadata) GetEndTime 

func (m *SeriesMetadata) GetEndTime() int64

func (*SeriesMetadata) GetId 

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

func (*SeriesMetadata) GetStartTime 

func (m *SeriesMetadata) GetStartTime() int64

func (*SeriesMetadata) Marshal 

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

func (*SeriesMetadata) MarshalTo 

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

func (*SeriesMetadata) ProtoMessage 

func (*SeriesMetadata) ProtoMessage()

func (*SeriesMetadata) Reset 

func (m *SeriesMetadata) Reset()

func (*SeriesMetadata) Size 

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

func (*SeriesMetadata) String 

func (m *SeriesMetadata) String() string

func (*SeriesMetadata) Unmarshal 

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

type Series_Compressed 

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

func (*Series_Compressed) MarshalTo 

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

func (*Series_Compressed) Size 

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

type Series_Decompressed 

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

func (*Series_Decompressed) MarshalTo 

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

func (*Series_Decompressed) Size 

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 

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 

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

func (*TagMatcher) GetName 

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

func (*TagMatcher) GetType 

func (m *TagMatcher) GetType() MatcherType

func (*TagMatcher) GetValue 

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

func (*TagMatcher) Marshal 

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

func (*TagMatcher) MarshalTo 

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

func (*TagMatcher) ProtoMessage 

func (*TagMatcher) ProtoMessage()

func (*TagMatcher) Reset 

func (m *TagMatcher) Reset()

func (*TagMatcher) Size 

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

func (*TagMatcher) String 

func (m *TagMatcher) String() string

func (*TagMatcher) Unmarshal 

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

type TagMatchers 

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

func (*TagMatchers) Descriptor 

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

func (*TagMatchers) GetTagMatchers 

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

func (*TagMatchers) Marshal 

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

func (*TagMatchers) MarshalTo 

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

func (*TagMatchers) ProtoMessage 

func (*TagMatchers) ProtoMessage()

func (*TagMatchers) Reset 

func (m *TagMatchers) Reset()

func (*TagMatchers) Size 

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

func (*TagMatchers) String 

func (m *TagMatchers) String() string

func (*TagMatchers) Unmarshal 

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

type TagNames 

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

func (*TagNames) Descriptor 

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

func (*TagNames) GetNames 

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

func (*TagNames) Marshal 

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

func (*TagNames) MarshalTo 

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

func (*TagNames) ProtoMessage 

func (*TagNames) ProtoMessage()

func (*TagNames) Reset 

func (m *TagNames) Reset()

func (*TagNames) Size 

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

func (*TagNames) String 

func (m *TagNames) String() string

func (*TagNames) Unmarshal 

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

type TagProperties 

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

func (*TagProperties) Descriptor 

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

func (*TagProperties) GetProperties 

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

func (*TagProperties) Marshal 

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

func (*TagProperties) MarshalTo 

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

func (*TagProperties) ProtoMessage 

func (*TagProperties) ProtoMessage()

func (*TagProperties) Reset 

func (m *TagProperties) Reset()

func (*TagProperties) Size 

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

func (*TagProperties) String 

func (m *TagProperties) String() string

func (*TagProperties) Unmarshal 

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

type TagProperty 

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 

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

func (*TagProperty) GetKey 

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

func (*TagProperty) GetValues 

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

func (*TagProperty) Marshal 

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

func (*TagProperty) MarshalTo 

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

func (*TagProperty) ProtoMessage 

func (*TagProperty) ProtoMessage()

func (*TagProperty) Reset 

func (m *TagProperty) Reset()

func (*TagProperty) Size 

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

func (*TagProperty) String 

func (m *TagProperty) String() string

func (*TagProperty) Unmarshal 

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

type TagValue 

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 

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

func (*TagValue) GetKey 

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

func (*TagValue) GetValues 

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

func (*TagValue) Marshal 

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

func (*TagValue) MarshalTo 

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

func (*TagValue) ProtoMessage 

func (*TagValue) ProtoMessage()

func (*TagValue) Reset 

func (m *TagValue) Reset()

func (*TagValue) Size 

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

func (*TagValue) String 

func (m *TagValue) String() string

func (*TagValue) Unmarshal 

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

type TagValues 

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

func (*TagValues) Descriptor 

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

func (*TagValues) GetValues 

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

func (*TagValues) Marshal 

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

func (*TagValues) MarshalTo 

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

func (*TagValues) ProtoMessage 

func (*TagValues) ProtoMessage()

func (*TagValues) Reset 

func (m *TagValues) Reset()

func (*TagValues) Size 

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

func (*TagValues) String 

func (m *TagValues) String() string

func (*TagValues) Unmarshal 

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

type Warning 

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 

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

func (*Warning) GetMessage 

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

func (*Warning) GetName 

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

func (*Warning) Marshal 

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

func (*Warning) MarshalTo 

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

func (*Warning) ProtoMessage 

func (*Warning) ProtoMessage()

func (*Warning) Reset 

func (m *Warning) Reset()

func (*Warning) Size 

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

func (*Warning) String 

func (m *Warning) String() string

func (*Warning) Unmarshal 

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.