Documentation ¶
Index ¶
- type Adapter
- func (adapter *Adapter) Close()
- func (adapter *Adapter) IsAlive() bool
- func (adapter *Adapter) IsDone() bool
- func (adapter *Adapter) OnDevicePerfChanged(perf map[string]interface{})
- func (adapter *Adapter) OnDeviceStatusChanged(index lang.StrIndex)
- func (adapter *Adapter) OnMeasureAlarm(data *measure.Data)
- func (adapter *Adapter) OnMeasureDiscovered(tagName, title string)
- type Runner
- func (runner *Runner) Active(conf *json_rpc.Conf) error
- func (runner *Runner) Close()
- func (runner *Runner) GetBaseInfo(uid string) (map[string]interface{}, error)
- func (runner *Runner) GetRealtimeData(uid string) ([]map[string]interface{}, error)
- func (runner *Runner) GetValue(ch *json_rpc.CH) (retVal interface{}, err error)
- func (runner *Runner) InitInfluxDB(conf *json_rpc.Conf) (influx.Client, error)
- func (runner *Runner) Remove(uid string)
- func (runner *Runner) Reset(uid string)
- func (runner *Runner) Restart()
- func (runner *Runner) Serve(adapter *Adapter) (err error)
- func (runner *Runner) SetValue(val *json_rpc.Value) error
- func (runner *Runner) StartInverseServer(conf *json_rpc.InverseConf) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Adapter ¶
type Adapter struct {
// contains filtered or unexported fields
}
func (*Adapter) OnDevicePerfChanged ¶
func (*Adapter) OnDeviceStatusChanged ¶
func (*Adapter) OnMeasureAlarm ¶
func (*Adapter) OnMeasureDiscovered ¶
type Runner ¶
type Runner struct { RestartMainFN func() // contains filtered or unexported fields }
func (*Runner) GetBaseInfo ¶
func (*Runner) GetRealtimeData ¶
func (*Runner) InitInfluxDB ¶
func (*Runner) StartInverseServer ¶
func (runner *Runner) StartInverseServer(conf *json_rpc.InverseConf) error
Click to show internal directories.
Click to hide internal directories.