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:

Points
Point
SaveErrors
PointError
Expression
Tss
Tsdata
PV

Index

• func RegisterTimeseriesServer(s *grpc.Server, srv TimeseriesServer)
• type Expression
  • func (*Expression) Descriptor() ([]byte, []int)
  • func (*Expression) ProtoMessage()
  • func (m *Expression) Reset()
  • func (m *Expression) String() string
• type PV
  • func (*PV) Descriptor() ([]byte, []int)
  • func (*PV) ProtoMessage()
  • func (m *PV) Reset()
  • func (m *PV) String() string
• type Point
  • func (*Point) Descriptor() ([]byte, []int)
  • func (m *Point) GetTags() map[string]string
  • func (*Point) ProtoMessage()
  • func (m *Point) Reset()
  • func (m *Point) String() string
• type PointError
  • func (*PointError) Descriptor() ([]byte, []int)
  • func (m *PointError) GetDatapoint() *Point
  • func (*PointError) ProtoMessage()
  • func (m *PointError) Reset()
  • func (m *PointError) String() string
• type Points
  • func (*Points) Descriptor() ([]byte, []int)
  • func (m *Points) GetPoints() []*Point
  • func (*Points) ProtoMessage()
  • func (m *Points) Reset()
  • func (m *Points) String() string
• type SaveErrors
  • func (*SaveErrors) Descriptor() ([]byte, []int)
  • func (m *SaveErrors) GetErrors() []*PointError
  • func (*SaveErrors) ProtoMessage()
  • func (m *SaveErrors) Reset()
  • func (m *SaveErrors) String() string
• type TimeseriesClient
  • func NewTimeseriesClient(cc *grpc.ClientConn) TimeseriesClient
• type TimeseriesServer
• type Tsdata
  • func (*Tsdata) Descriptor() ([]byte, []int)
  • func (m *Tsdata) GetDps() map[string]*PV
  • func (m *Tsdata) GetTags() map[string]string
  • func (*Tsdata) ProtoMessage()
  • func (m *Tsdata) Reset()
  • func (m *Tsdata) String() string
• type Tss
  • func (*Tss) Descriptor() ([]byte, []int)
  • func (m *Tss) GetTss() []*Tsdata
  • func (*Tss) ProtoMessage()
  • func (m *Tss) Reset()
  • func (m *Tss) String() string

Functions

func RegisterTimeseriesServer

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

Types

type Expression

type Expression struct {
	Expression string `protobuf:"bytes,1,opt,name=expression" json:"expression,omitempty"`
}

func (*Expression) Descriptor

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

func (*Expression) ProtoMessage

func (*Expression) ProtoMessage()

func (*Expression) Reset

func (m *Expression) Reset()

func (*Expression) String

func (m *Expression) String() string

type PV

type PV struct {
	Value   float64 `protobuf:"fixed64,1,opt,name=value" json:"value,omitempty"`
	Nullval bool    `protobuf:"varint,2,opt,name=nullval" json:"nullval,omitempty"`
}

func (*PV) Descriptor

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

func (*PV) ProtoMessage

func (*PV) ProtoMessage()

func (*PV) Reset

func (m *PV) Reset()

func (*PV) String

func (m *PV) String() string

type Point

type Point struct {
	Metric    string            `protobuf:"bytes,1,opt,name=metric" json:"metric,omitempty"`
	Tags      map[string]string `` /* 128-byte string literal not displayed */
	Value     float64           `protobuf:"fixed64,3,opt,name=value" json:"value,omitempty"`
	Text      string            `protobuf:"bytes,4,opt,name=text" json:"text,omitempty"`
	Timestamp int64             `protobuf:"varint,5,opt,name=timestamp" json:"timestamp,omitempty"`
}

func (*Point) Descriptor

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

func (*Point) GetTags

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

func (*Point) ProtoMessage

func (*Point) ProtoMessage()

func (*Point) Reset

func (m *Point) Reset()

func (*Point) String

func (m *Point) String() string

type PointError

type PointError struct {
	Datapoint *Point `protobuf:"bytes,1,opt,name=datapoint" json:"datapoint,omitempty"`
	Error     string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

func (*PointError) Descriptor

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

func (*PointError) GetDatapoint

func (m *PointError) GetDatapoint() *Point

func (*PointError) ProtoMessage

func (*PointError) ProtoMessage()

func (*PointError) Reset

func (m *PointError) Reset()

func (*PointError) String

func (m *PointError) String() string

type Points

type Points struct {
	Points []*Point `protobuf:"bytes,1,rep,name=points" json:"points,omitempty"`
}

func (*Points) Descriptor

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

func (*Points) GetPoints

func (m *Points) GetPoints() []*Point

func (*Points) ProtoMessage

func (*Points) ProtoMessage()

func (*Points) Reset

func (m *Points) Reset()

func (*Points) String

func (m *Points) String() string

type SaveErrors

type SaveErrors struct {
	Errors []*PointError `protobuf:"bytes,1,rep,name=errors" json:"errors,omitempty"`
}

func (*SaveErrors) Descriptor

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

func (*SaveErrors) GetErrors

func (m *SaveErrors) GetErrors() []*PointError

func (*SaveErrors) ProtoMessage

func (*SaveErrors) ProtoMessage()

func (*SaveErrors) Reset

func (m *SaveErrors) Reset()

func (*SaveErrors) String

func (m *SaveErrors) String() string

type TimeseriesClient

type TimeseriesClient interface {
	SavePoints(ctx context.Context, in *Points, opts ...grpc.CallOption) (*SaveErrors, error)
	QueryExpression(ctx context.Context, in *Expression, opts ...grpc.CallOption) (*Tsdata, error)
}

func NewTimeseriesClient

func NewTimeseriesClient(cc *grpc.ClientConn) TimeseriesClient

type TimeseriesServer

type TimeseriesServer interface {
	SavePoints(context.Context, *Points) (*SaveErrors, error)
	QueryExpression(context.Context, *Expression) (*Tsdata, error)
}

type Tsdata

type Tsdata struct {
	Metric         string            `protobuf:"bytes,1,opt,name=metric" json:"metric,omitempty"`
	Tags           map[string]string `` /* 128-byte string literal not displayed */
	AggregatedTags []string          `protobuf:"bytes,3,rep,name=aggregatedTags" json:"aggregatedTags,omitempty"`
	Tsuids         []string          `protobuf:"bytes,4,rep,name=tsuids" json:"tsuids,omitempty"`
	Dps            map[string]*PV    `` /* 126-byte string literal not displayed */
}

func (*Tsdata) Descriptor

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

func (*Tsdata) GetDps

func (m *Tsdata) GetDps() map[string]*PV

func (*Tsdata) GetTags

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

func (*Tsdata) ProtoMessage

func (*Tsdata) ProtoMessage()

func (*Tsdata) Reset

func (m *Tsdata) Reset()

func (*Tsdata) String

func (m *Tsdata) String() string

type Tss

type Tss struct {
	Tss []*Tsdata `protobuf:"bytes,1,rep,name=tss" json:"tss,omitempty"`
}

func (*Tss) Descriptor

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

func (*Tss) GetTss

func (m *Tss) GetTss() []*Tsdata

func (*Tss) ProtoMessage

func (*Tss) ProtoMessage()

func (*Tss) Reset

func (m *Tss) Reset()

func (*Tss) String

func (m *Tss) String() string