devices

package
v0.0.0-...-ae4999c Latest Latest
Warning

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

Go to latest
Published: Jan 10, 2022 License: MIT Imports: 19 Imported by: 0

Documentation

Index

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) Close

func (adapter *Adapter) Close()

func (*Adapter) IsAlive

func (adapter *Adapter) IsAlive() bool

func (*Adapter) IsDone

func (adapter *Adapter) IsDone() bool

func (*Adapter) OnDevicePerfChanged

func (adapter *Adapter) OnDevicePerfChanged(perf map[string]interface{})

func (*Adapter) OnDeviceStatusChanged

func (adapter *Adapter) OnDeviceStatusChanged(index lang.StrIndex)

func (*Adapter) OnMeasureAlarm

func (adapter *Adapter) OnMeasureAlarm(data *measure.Data)

func (*Adapter) OnMeasureDiscovered

func (adapter *Adapter) OnMeasureDiscovered(tagName, title string)

type Runner

type Runner struct {
	RestartMainFN func()
	// contains filtered or unexported fields
}

func New

func New() *Runner

func (*Runner) Active

func (runner *Runner) Active(conf *json_rpc.Conf) error

func (*Runner) Close

func (runner *Runner) Close()

func (*Runner) GetBaseInfo

func (runner *Runner) GetBaseInfo(uid string) (map[string]interface{}, error)

func (*Runner) GetRealtimeData

func (runner *Runner) GetRealtimeData(uid string) ([]map[string]interface{}, error)

func (*Runner) GetValue

func (runner *Runner) GetValue(ch *json_rpc.CH) (retVal interface{}, err error)

func (*Runner) InitInfluxDB

func (runner *Runner) InitInfluxDB(conf *json_rpc.Conf) (influx.Client, error)

func (*Runner) Remove

func (runner *Runner) Remove(uid string)

func (*Runner) Reset

func (runner *Runner) Reset(uid string)

func (*Runner) Restart

func (runner *Runner) Restart()

func (*Runner) Serve

func (runner *Runner) Serve(adapter *Adapter) (err error)

func (*Runner) SetValue

func (runner *Runner) SetValue(val *json_rpc.Value) error

func (*Runner) StartInverseServer

func (runner *Runner) StartInverseServer(conf *json_rpc.InverseConf) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL