rpc

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: May 24, 2018 License: Apache-2.0, MIT Imports: 7 Imported by: 0

Documentation

Overview

Package rpc is a generated protocol buffer package.

It is generated from these files: 

query.proto

It has these top-level messages: 

WriteMessage
WriteQuery
WriteOptions
Datapoint
Datapoints
Error
FetchMessage
FetchQuery
FetchOptions
Matcher
FetchResult
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 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 Series 

type Series struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Values *Datapoints       `protobuf:"bytes,2,opt,name=values" json:"values,omitempty"`
	Tags   map[string]string `` /* 142-byte string literal not displayed */
}

func (*Series) Descriptor 

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

func (*Series) GetName 

func (m *Series) GetName() string

func (*Series) GetTags 

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

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