rpc

Documentation

Index

• Constants
• Variables
• func GetNeedStep(startTime int64, step int, realStep int) int
• func HandleItems(items []*dataobj.TsdbItem) error
• func Start()
• type Tsdb
  • func (g *Tsdb) GetRRD(param dataobj.RRDFileQuery, resp *dataobj.RRDFileResp) (err error)
  • func (t *Tsdb) Ping(req dataobj.NullRpcRequest, resp *dataobj.SimpleRpcResponse) error
  • func (g *Tsdb) Query(param dataobj.TsdbQueryParam, resp *dataobj.TsdbQueryResponse) error
  • func (t *Tsdb) Send(items []*dataobj.TsdbItem, resp *dataobj.SimpleRpcResponse) error

Constants

const MaxRRAPointCnt = 730 // 每次查询最多返回的点数

Variables

var Close_chan, Close_done_chan chan int

Functions

func GetNeedStep

func GetNeedStep(startTime int64, step int, realStep int) int

func HandleItems

func HandleItems(items []*dataobj.TsdbItem) error

供外部调用、处理接收到的数据 的接口

func Start

func Start()

Types

type Tsdb

type Tsdb int

func (*Tsdb) GetRRD

func (g *Tsdb) GetRRD(param dataobj.RRDFileQuery, resp *dataobj.RRDFileResp) (err error)

func (*Tsdb) Ping

func (t *Tsdb) Ping(req dataobj.NullRpcRequest, resp *dataobj.SimpleRpcResponse) error

func (*Tsdb) Query

func (g *Tsdb) Query(param dataobj.TsdbQueryParam, resp *dataobj.TsdbQueryResponse) error

func (*Tsdb) Send

func (t *Tsdb) Send(items []*dataobj.TsdbItem, resp *dataobj.SimpleRpcResponse) error