rpc

package
v0.3.0 Latest Latest
Warning

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

Go to latest
Published: Jul 16, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package rpc is a generated protocol buffer package.

It is generated from these files:

github.com/m3db/m3db/src/coordinator/generated/proto/rpc/query.proto

It has these top-level messages:

WriteMessage
WriteQuery
WriteOptions
Datapoint
Datapoints
Error
FetchMessage
FetchQuery
FetchOptions
Matcher
FetchResult
Segment
Segments
CompressedValuesReplica
CompressedDatapoints
Tag
Series

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

Functions

func RegisterQueryServer

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

Types

type CompressedDatapoints added in v0.3.0

type CompressedDatapoints struct {
	Namespace      []byte                     `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,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"`
	CompressedTags []byte                     `protobuf:"bytes,4,opt,name=compressedTags,proto3" json:"compressedTags,omitempty"`
	Replicas       []*CompressedValuesReplica `protobuf:"bytes,5,rep,name=replicas" json:"replicas,omitempty"`
}

func (*CompressedDatapoints) Descriptor added in v0.3.0

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

func (*CompressedDatapoints) GetCompressedTags added in v0.3.0

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

func (*CompressedDatapoints) GetEndTime added in v0.3.0

func (m *CompressedDatapoints) GetEndTime() int64

func (*CompressedDatapoints) GetNamespace added in v0.3.0

func (m *CompressedDatapoints) GetNamespace() []byte

func (*CompressedDatapoints) GetReplicas added in v0.3.0

func (m *CompressedDatapoints) GetReplicas() []*CompressedValuesReplica

func (*CompressedDatapoints) GetStartTime added in v0.3.0

func (m *CompressedDatapoints) GetStartTime() int64

func (*CompressedDatapoints) Marshal added in v0.3.0

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

func (*CompressedDatapoints) MarshalTo added in v0.3.0

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

func (*CompressedDatapoints) ProtoMessage added in v0.3.0

func (*CompressedDatapoints) ProtoMessage()

func (*CompressedDatapoints) Reset added in v0.3.0

func (m *CompressedDatapoints) Reset()

func (*CompressedDatapoints) Size added in v0.3.0

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

func (*CompressedDatapoints) String added in v0.3.0

func (m *CompressedDatapoints) String() string

func (*CompressedDatapoints) Unmarshal added in v0.3.0

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

type CompressedValuesReplica added in v0.3.0

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

func (*CompressedValuesReplica) Descriptor added in v0.3.0

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

func (*CompressedValuesReplica) GetSegments added in v0.3.0

func (m *CompressedValuesReplica) GetSegments() []*Segments

func (*CompressedValuesReplica) Marshal added in v0.3.0

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

func (*CompressedValuesReplica) MarshalTo added in v0.3.0

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

func (*CompressedValuesReplica) ProtoMessage added in v0.3.0

func (*CompressedValuesReplica) ProtoMessage()

func (*CompressedValuesReplica) Reset added in v0.3.0

func (m *CompressedValuesReplica) Reset()

func (*CompressedValuesReplica) Size added in v0.3.0

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

func (*CompressedValuesReplica) String added in v0.3.0

func (m *CompressedValuesReplica) String() string

func (*CompressedValuesReplica) Unmarshal added in v0.3.0

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

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 Datapoints

type Datapoints struct {
	Datapoints      []*Datapoint `protobuf:"bytes,1,rep,name=datapoints" json:"datapoints,omitempty"`
	FixedResolution bool         `protobuf:"varint,2,opt,name=fixedResolution,proto3" json:"fixedResolution,omitempty"`
}

func (*Datapoints) Descriptor

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

func (*Datapoints) GetDatapoints

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

func (*Datapoints) GetFixedResolution

func (m *Datapoints) GetFixedResolution() bool

func (*Datapoints) Marshal

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

func (*Datapoints) MarshalTo

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

func (*Datapoints) ProtoMessage

func (*Datapoints) ProtoMessage()

func (*Datapoints) Reset

func (m *Datapoints) Reset()

func (*Datapoints) Size

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

func (*Datapoints) String

func (m *Datapoints) String() string

func (*Datapoints) Unmarshal

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

type Error

type Error struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
}

func (*Error) Descriptor

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

func (*Error) GetError

func (m *Error) GetError() string

func (*Error) Marshal

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

func (*Error) MarshalTo

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

func (*Error) ProtoMessage

func (*Error) ProtoMessage()

func (*Error) Reset

func (m *Error) Reset()

func (*Error) Size

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

func (*Error) String

func (m *Error) String() string

func (*Error) Unmarshal

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

type FetchMessage

type FetchMessage struct {
	Query   *FetchQuery   `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
	Options *FetchOptions `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"`
}

func (*FetchMessage) Descriptor

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

func (*FetchMessage) GetOptions

func (m *FetchMessage) GetOptions() *FetchOptions

func (*FetchMessage) GetQuery

func (m *FetchMessage) GetQuery() *FetchQuery

func (*FetchMessage) Marshal

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

func (*FetchMessage) MarshalTo

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

func (*FetchMessage) ProtoMessage

func (*FetchMessage) ProtoMessage()

func (*FetchMessage) Reset

func (m *FetchMessage) Reset()

func (*FetchMessage) Size

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

func (*FetchMessage) String

func (m *FetchMessage) String() string

func (*FetchMessage) Unmarshal

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

type FetchOptions

type FetchOptions struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*FetchOptions) Descriptor

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

func (*FetchOptions) GetId

func (m *FetchOptions) GetId() string

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 FetchQuery

type FetchQuery 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"`
	TagMatchers []*Matcher `protobuf:"bytes,3,rep,name=tagMatchers" json:"tagMatchers,omitempty"`
}

func (*FetchQuery) Descriptor

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

func (*FetchQuery) GetEnd

func (m *FetchQuery) GetEnd() int64

func (*FetchQuery) GetStart

func (m *FetchQuery) GetStart() int64

func (*FetchQuery) GetTagMatchers

func (m *FetchQuery) GetTagMatchers() []*Matcher

func (*FetchQuery) Marshal

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

func (*FetchQuery) MarshalTo

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

func (*FetchQuery) ProtoMessage

func (*FetchQuery) ProtoMessage()

func (*FetchQuery) Reset

func (m *FetchQuery) Reset()

func (*FetchQuery) Size

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

func (*FetchQuery) String

func (m *FetchQuery) String() string

func (*FetchQuery) Unmarshal

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

type FetchResult

type FetchResult struct {
	Series []*Series `protobuf:"bytes,1,rep,name=series" json:"series,omitempty"`
}

func (*FetchResult) Descriptor

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

func (*FetchResult) GetSeries

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

func (*FetchResult) Marshal

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

func (*FetchResult) MarshalTo

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

func (*FetchResult) ProtoMessage

func (*FetchResult) ProtoMessage()

func (*FetchResult) Reset

func (m *FetchResult) Reset()

func (*FetchResult) Size

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

func (*FetchResult) String

func (m *FetchResult) String() string

func (*FetchResult) Unmarshal

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

type Matcher

type Matcher struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Type  int64  `protobuf:"varint,3,opt,name=type,proto3" json:"type,omitempty"`
}

func (*Matcher) Descriptor

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

func (*Matcher) GetName

func (m *Matcher) GetName() string

func (*Matcher) GetType

func (m *Matcher) GetType() int64

func (*Matcher) GetValue

func (m *Matcher) GetValue() string

func (*Matcher) Marshal

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

func (*Matcher) MarshalTo

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

func (*Matcher) ProtoMessage

func (*Matcher) ProtoMessage()

func (*Matcher) Reset

func (m *Matcher) Reset()

func (*Matcher) Size

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

func (*Matcher) String

func (m *Matcher) String() string

func (*Matcher) Unmarshal

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

type QueryClient

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

func NewQueryClient

func NewQueryClient(cc *grpc.ClientConn) QueryClient

type QueryServer

type QueryServer interface {
	Fetch(*FetchMessage, Query_FetchServer) error
	Write(Query_WriteServer) error
}

type Query_FetchClient

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

type Query_FetchServer

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

type Query_WriteClient

type Query_WriteClient interface {
	Send(*WriteMessage) error
	CloseAndRecv() (*Error, error)
	grpc.ClientStream
}

type Query_WriteServer

type Query_WriteServer interface {
	SendAndClose(*Error) error
	Recv() (*WriteMessage, error)
	grpc.ServerStream
}

type Segment added in v0.3.0

type Segment 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 (*Segment) Descriptor added in v0.3.0

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

func (*Segment) GetBlockSize added in v0.3.0

func (m *Segment) GetBlockSize() int64

func (*Segment) GetHead added in v0.3.0

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

func (*Segment) GetStartTime added in v0.3.0

func (m *Segment) GetStartTime() int64

func (*Segment) GetTail added in v0.3.0

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

func (*Segment) Marshal added in v0.3.0

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

func (*Segment) MarshalTo added in v0.3.0

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

func (*Segment) ProtoMessage added in v0.3.0

func (*Segment) ProtoMessage()

func (*Segment) Reset added in v0.3.0

func (m *Segment) Reset()

func (*Segment) Size added in v0.3.0

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

func (*Segment) String added in v0.3.0

func (m *Segment) String() string

func (*Segment) Unmarshal added in v0.3.0

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

type Segments added in v0.3.0

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

func (*Segments) Descriptor added in v0.3.0

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

func (*Segments) GetMerged added in v0.3.0

func (m *Segments) GetMerged() *Segment

func (*Segments) GetUnmerged added in v0.3.0

func (m *Segments) GetUnmerged() []*Segment

func (*Segments) Marshal added in v0.3.0

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

func (*Segments) MarshalTo added in v0.3.0

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

func (*Segments) ProtoMessage added in v0.3.0

func (*Segments) ProtoMessage()

func (*Segments) Reset added in v0.3.0

func (m *Segments) Reset()

func (*Segments) Size added in v0.3.0

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

func (*Segments) String added in v0.3.0

func (m *Segments) String() string

func (*Segments) Unmarshal added in v0.3.0

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

type Series

type Series struct {
	Id         []byte                `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Values     *Datapoints           `protobuf:"bytes,2,opt,name=values" json:"values,omitempty"`
	Tags       []*Tag                `protobuf:"bytes,3,rep,name=tags" json:"tags,omitempty"`
	Compressed *CompressedDatapoints `protobuf:"bytes,4,opt,name=compressed" json:"compressed,omitempty"`
}

func (*Series) Descriptor

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

func (*Series) GetCompressed added in v0.3.0

func (m *Series) GetCompressed() *CompressedDatapoints

func (*Series) GetId added in v0.3.0

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

func (*Series) GetTags

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

func (*Series) GetValues

func (m *Series) GetValues() *Datapoints

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

type Tag added in v0.3.0

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

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

func (*Tag) GetName added in v0.3.0

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

func (*Tag) GetValue added in v0.3.0

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

func (*Tag) Marshal added in v0.3.0

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

func (*Tag) MarshalTo added in v0.3.0

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

func (*Tag) ProtoMessage added in v0.3.0

func (*Tag) ProtoMessage()

func (*Tag) Reset added in v0.3.0

func (m *Tag) Reset()

func (*Tag) Size added in v0.3.0

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

func (*Tag) String added in v0.3.0

func (m *Tag) String() string

func (*Tag) Unmarshal added in v0.3.0

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

type WriteMessage

type WriteMessage struct {
	Query   *WriteQuery   `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
	Options *WriteOptions `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"`
}

func (*WriteMessage) Descriptor

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

func (*WriteMessage) GetOptions

func (m *WriteMessage) GetOptions() *WriteOptions

func (*WriteMessage) GetQuery

func (m *WriteMessage) GetQuery() *WriteQuery

func (*WriteMessage) Marshal

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

func (*WriteMessage) MarshalTo

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

func (*WriteMessage) ProtoMessage

func (*WriteMessage) ProtoMessage()

func (*WriteMessage) Reset

func (m *WriteMessage) Reset()

func (*WriteMessage) Size

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

func (*WriteMessage) String

func (m *WriteMessage) String() string

func (*WriteMessage) Unmarshal

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

type WriteOptions

type WriteOptions struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*WriteOptions) Descriptor

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

func (*WriteOptions) GetId

func (m *WriteOptions) GetId() string

func (*WriteOptions) Marshal

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

func (*WriteOptions) MarshalTo

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

func (*WriteOptions) ProtoMessage

func (*WriteOptions) ProtoMessage()

func (*WriteOptions) Reset

func (m *WriteOptions) Reset()

func (*WriteOptions) Size

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

func (*WriteOptions) String

func (m *WriteOptions) String() string

func (*WriteOptions) Unmarshal

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

type WriteQuery

type WriteQuery struct {
	Unit       int32             `protobuf:"varint,1,opt,name=unit,proto3" json:"unit,omitempty"`
	Annotation []byte            `protobuf:"bytes,2,opt,name=annotation,proto3" json:"annotation,omitempty"`
	Datapoints []*Datapoint      `protobuf:"bytes,3,rep,name=datapoints" json:"datapoints,omitempty"`
	Tags       map[string]string `` /* 142-byte string literal not displayed */
}

func (*WriteQuery) Descriptor

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

func (*WriteQuery) GetAnnotation

func (m *WriteQuery) GetAnnotation() []byte

func (*WriteQuery) GetDatapoints

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

func (*WriteQuery) GetTags

func (m *WriteQuery) GetTags() map[string]string

func (*WriteQuery) GetUnit

func (m *WriteQuery) GetUnit() int32

func (*WriteQuery) Marshal

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

func (*WriteQuery) MarshalTo

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

func (*WriteQuery) ProtoMessage

func (*WriteQuery) ProtoMessage()

func (*WriteQuery) Reset

func (m *WriteQuery) Reset()

func (*WriteQuery) Size

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

func (*WriteQuery) String

func (m *WriteQuery) String() string

func (*WriteQuery) Unmarshal

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL