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

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.