rpcpb

package
v0.4.6 Latest Latest
Warning

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

 Go to latest Published: Oct 5, 2018 License: Apache-2.0 Imports: 7 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: 

FetchRequest
TagMatchers
TagMatcher
FetchResponse
Series
SeriesMetadata
DecompressedSeries
Datapoint
Tag
M3CompressedSeries
M3CompressedValuesReplica
M3Segments
M3Segment

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 MatcherType_name = map[int32]string{
	0: "EQUAL",
	1: "NOTEQUAL",
	2: "REGEXP",
	3: "NOTREGEXP",
	4: "EXISTS",
	5: "NOTEXISTS",
}
View Source 
var MatcherType_value = map[string]int32{
	"EQUAL":     0,
	"NOTEQUAL":  1,
	"REGEXP":    2,
	"NOTREGEXP": 3,
	"EXISTS":    4,
	"NOTEXISTS": 5,
}

Functions

func RegisterQueryServer 

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

Types

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 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"`
}

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) 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"`
}

func (*FetchResponse) Descriptor added in v0.4.5 

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

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 M3CompressedSeries added in v0.4.5 

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

func (*M3CompressedSeries) Descriptor added in v0.4.5 

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

func (*M3CompressedSeries) GetCompressedTags added in v0.4.5 

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

func (*M3CompressedSeries) GetReplicas added in v0.4.5 

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

func (*M3CompressedSeries) Marshal added in v0.4.5 

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

func (*M3CompressedSeries) MarshalTo added in v0.4.5 

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

func (*M3CompressedSeries) ProtoMessage added in v0.4.5 

func (*M3CompressedSeries) ProtoMessage()

func (*M3CompressedSeries) Reset added in v0.4.5 

func (m *M3CompressedSeries) Reset()

func (*M3CompressedSeries) Size added in v0.4.5 

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

func (*M3CompressedSeries) String added in v0.4.5 

func (m *M3CompressedSeries) String() string

func (*M3CompressedSeries) Unmarshal added in v0.4.5 

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

type M3CompressedValuesReplica added in v0.4.5 

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

func (*M3CompressedValuesReplica) Descriptor added in v0.4.5 

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

func (*M3CompressedValuesReplica) GetSegments added in v0.4.5 

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

func (*M3CompressedValuesReplica) Marshal added in v0.4.5 

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

func (*M3CompressedValuesReplica) MarshalTo added in v0.4.5 

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

func (*M3CompressedValuesReplica) ProtoMessage added in v0.4.5 

func (*M3CompressedValuesReplica) ProtoMessage()

func (*M3CompressedValuesReplica) Reset added in v0.4.5 

func (m *M3CompressedValuesReplica) Reset()

func (*M3CompressedValuesReplica) Size added in v0.4.5 

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

func (*M3CompressedValuesReplica) String added in v0.4.5 

func (m *M3CompressedValuesReplica) String() string

func (*M3CompressedValuesReplica) Unmarshal added in v0.4.5 

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

type M3Segment added in v0.4.5 

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

func (*M3Segment) Descriptor added in v0.4.5 

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

func (*M3Segment) GetBlockSize added in v0.4.5 

func (m *M3Segment) GetBlockSize() int64

func (*M3Segment) GetHead added in v0.4.5 

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

func (*M3Segment) GetStartTime added in v0.4.5 

func (m *M3Segment) GetStartTime() int64

func (*M3Segment) GetTail added in v0.4.5 

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

func (*M3Segment) Marshal added in v0.4.5 

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

func (*M3Segment) MarshalTo added in v0.4.5 

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

func (*M3Segment) ProtoMessage added in v0.4.5 

func (*M3Segment) ProtoMessage()

func (*M3Segment) Reset added in v0.4.5 

func (m *M3Segment) Reset()

func (*M3Segment) Size added in v0.4.5 

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

func (*M3Segment) String added in v0.4.5 

func (m *M3Segment) String() string

func (*M3Segment) Unmarshal added in v0.4.5 

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

type M3Segments added in v0.4.5 

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

func (*M3Segments) Descriptor added in v0.4.5 

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

func (*M3Segments) GetMerged added in v0.4.5 

func (m *M3Segments) GetMerged() *M3Segment

func (*M3Segments) GetUnmerged added in v0.4.5 

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

func (*M3Segments) Marshal added in v0.4.5 

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

func (*M3Segments) MarshalTo added in v0.4.5 

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

func (*M3Segments) ProtoMessage added in v0.4.5 

func (*M3Segments) ProtoMessage()

func (*M3Segments) Reset added in v0.4.5 

func (m *M3Segments) Reset()

func (*M3Segments) Size added in v0.4.5 

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

func (*M3Segments) String added in v0.4.5 

func (m *M3Segments) String() string

func (*M3Segments) Unmarshal added in v0.4.5 

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

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

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 QueryClient 

type QueryClient interface {
	Fetch(ctx context.Context, in *FetchRequest, opts ...grpc.CallOption) (Query_FetchClient, error)
}

func NewQueryClient 

func NewQueryClient(cc *grpc.ClientConn) QueryClient

type QueryServer 

type QueryServer interface {
	Fetch(*FetchRequest, Query_FetchServer) error
}

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

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.