proto

Documentation

Overview

Package proto is a generated protocol buffer package.

It is generated from these files:

timeseries.proto

It has these top-level messages:

TSResponse
Point
Query
Meta
Tag
MetaFound

Index

• func RegisterTimeseriesServer(s *grpc.Server, srv TimeseriesServer)
• type Meta
  • func (*Meta) Descriptor() ([]byte, []int)
  • func (m *Meta) GetKsid() string
  • func (m *Meta) GetMetric() string
  • func (m *Meta) GetTags() []*Tag
  • func (m *Meta) GetTsid() string
  • func (*Meta) ProtoMessage()
  • func (m *Meta) Reset()
  • func (m *Meta) String() string
• type MetaFound
  • func (*MetaFound) Descriptor() ([]byte, []int)
  • func (m *MetaFound) GetOk() bool
  • func (*MetaFound) ProtoMessage()
  • func (m *MetaFound) Reset()
  • func (m *MetaFound) String() string
• type Point
  • func (*Point) Descriptor() ([]byte, []int)
  • func (m *Point) GetDate() int64
  • func (m *Point) GetEmpty() bool
  • func (m *Point) GetKsid() string
  • func (m *Point) GetTsid() string
  • func (m *Point) GetValue() float32
  • func (*Point) ProtoMessage()
  • func (m *Point) Reset()
  • func (m *Point) String() string
• type Query
  • func (*Query) Descriptor() ([]byte, []int)
  • func (m *Query) GetEnd() int64
  • func (m *Query) GetKsid() string
  • func (m *Query) GetStart() int64
  • func (m *Query) GetTsid() string
  • func (*Query) ProtoMessage()
  • func (m *Query) Reset()
  • func (m *Query) String() string
• type TSResponse
  • func (*TSResponse) Descriptor() ([]byte, []int)
  • func (m *TSResponse) GetOk() bool
  • func (*TSResponse) ProtoMessage()
  • func (m *TSResponse) Reset()
  • func (m *TSResponse) String() string
• type Tag
  • func (*Tag) Descriptor() ([]byte, []int)
  • func (m *Tag) GetKey() string
  • func (m *Tag) GetValue() string
  • func (*Tag) ProtoMessage()
  • func (m *Tag) Reset()
  • func (m *Tag) String() string
• type TimeseriesClient
  • func NewTimeseriesClient(cc *grpc.ClientConn) TimeseriesClient
• type TimeseriesServer
• type Timeseries_ReadClient
• type Timeseries_ReadServer
• type Timeseries_WriteClient
• type Timeseries_WriteMetaClient
• type Timeseries_WriteMetaServer
• type Timeseries_WriteServer

Functions

func RegisterTimeseriesServer

func RegisterTimeseriesServer(s *grpc.Server, srv TimeseriesServer)

Types

type Meta

type Meta struct {
	Ksid   string `protobuf:"bytes,1,opt,name=ksid" json:"ksid,omitempty"`
	Tsid   string `protobuf:"bytes,2,opt,name=tsid" json:"tsid,omitempty"`
	Metric string `protobuf:"bytes,3,opt,name=metric" json:"metric,omitempty"`
	Tags   []*Tag `protobuf:"bytes,4,rep,name=tags" json:"tags,omitempty"`
}

func (*Meta) Descriptor

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

func (*Meta) GetKsid

func (m *Meta) GetKsid() string

func (*Meta) GetMetric

func (m *Meta) GetMetric() string

func (*Meta) GetTags

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

func (*Meta) GetTsid

func (m *Meta) GetTsid() string

func (*Meta) ProtoMessage

func (*Meta) ProtoMessage()

func (*Meta) Reset

func (m *Meta) Reset()

func (*Meta) String

func (m *Meta) String() string

type MetaFound

type MetaFound struct {
	Ok bool `protobuf:"varint,1,opt,name=ok" json:"ok,omitempty"`
}

func (*MetaFound) Descriptor

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

func (*MetaFound) GetOk

func (m *MetaFound) GetOk() bool

func (*MetaFound) ProtoMessage

func (*MetaFound) ProtoMessage()

func (*MetaFound) Reset

func (m *MetaFound) Reset()

func (*MetaFound) String

func (m *MetaFound) String() string

type Point

type Point struct {
	Ksid  string  `protobuf:"bytes,1,opt,name=ksid" json:"ksid,omitempty"`
	Tsid  string  `protobuf:"bytes,2,opt,name=tsid" json:"tsid,omitempty"`
	Value float32 `protobuf:"fixed32,3,opt,name=value" json:"value,omitempty"`
	Date  int64   `protobuf:"varint,4,opt,name=date" json:"date,omitempty"`
	Empty bool    `protobuf:"varint,5,opt,name=empty" json:"empty,omitempty"`
}

func (*Point) Descriptor

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

func (*Point) GetDate

func (m *Point) GetDate() int64

func (*Point) GetEmpty

func (m *Point) GetEmpty() bool

func (*Point) GetKsid

func (m *Point) GetKsid() string

func (*Point) GetTsid

func (m *Point) GetTsid() string

func (*Point) GetValue

func (m *Point) GetValue() float32

func (*Point) ProtoMessage

func (*Point) ProtoMessage()

func (*Point) Reset

func (m *Point) Reset()

func (*Point) String

func (m *Point) String() string

type Query

type Query struct {
	Ksid  string `protobuf:"bytes,1,opt,name=ksid" json:"ksid,omitempty"`
	Tsid  string `protobuf:"bytes,2,opt,name=tsid" json:"tsid,omitempty"`
	Start int64  `protobuf:"varint,3,opt,name=start" json:"start,omitempty"`
	End   int64  `protobuf:"varint,4,opt,name=end" json:"end,omitempty"`
}

func (*Query) Descriptor

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

func (*Query) GetEnd

func (m *Query) GetEnd() int64

func (*Query) GetKsid

func (m *Query) GetKsid() string

func (*Query) GetStart

func (m *Query) GetStart() int64

func (*Query) GetTsid

func (m *Query) GetTsid() string

func (*Query) ProtoMessage

func (*Query) ProtoMessage()

func (*Query) Reset

func (m *Query) Reset()

func (*Query) String

func (m *Query) String() string

type TSResponse

type TSResponse struct {
	Ok bool `protobuf:"varint,1,opt,name=ok" json:"ok,omitempty"`
}

func (*TSResponse) Descriptor

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

func (*TSResponse) GetOk

func (m *TSResponse) GetOk() bool

func (*TSResponse) ProtoMessage

func (*TSResponse) ProtoMessage()

func (*TSResponse) Reset

func (m *TSResponse) Reset()

func (*TSResponse) String

func (m *TSResponse) String() string

type Tag

type Tag struct {
	Key   string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
}

func (*Tag) Descriptor

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

func (*Tag) GetKey

func (m *Tag) GetKey() string

func (*Tag) GetValue

func (m *Tag) GetValue() string

func (*Tag) ProtoMessage

func (*Tag) ProtoMessage()

func (*Tag) Reset

func (m *Tag) Reset()

func (*Tag) String

func (m *Tag) String() string

type TimeseriesClient

type TimeseriesClient interface {
	Write(ctx context.Context, opts ...grpc.CallOption) (Timeseries_WriteClient, error)
	Read(ctx context.Context, in *Query, opts ...grpc.CallOption) (Timeseries_ReadClient, error)
	WriteMeta(ctx context.Context, opts ...grpc.CallOption) (Timeseries_WriteMetaClient, error)
}

func NewTimeseriesClient

func NewTimeseriesClient(cc *grpc.ClientConn) TimeseriesClient

type TimeseriesServer

type TimeseriesServer interface {
	Write(Timeseries_WriteServer) error
	Read(*Query, Timeseries_ReadServer) error
	WriteMeta(Timeseries_WriteMetaServer) error
}

type Timeseries_ReadClient

type Timeseries_ReadClient interface {
	Recv() (*Point, error)
	grpc.ClientStream
}

type Timeseries_ReadServer

type Timeseries_ReadServer interface {
	Send(*Point) error
	grpc.ServerStream
}

type Timeseries_WriteClient

type Timeseries_WriteClient interface {
	Send(*Point) error
	CloseAndRecv() (*TSResponse, error)
	grpc.ClientStream
}

type Timeseries_WriteMetaClient

type Timeseries_WriteMetaClient interface {
	Send(*Meta) error
	CloseAndRecv() (*MetaFound, error)
	grpc.ClientStream
}

type Timeseries_WriteMetaServer

type Timeseries_WriteMetaServer interface {
	SendAndClose(*MetaFound) error
	Recv() (*Meta, error)
	grpc.ServerStream
}

type Timeseries_WriteServer

type Timeseries_WriteServer interface {
	SendAndClose(*TSResponse) error
	Recv() (*Point, error)
	grpc.ServerStream
}