client

Aug 4, 2025

Changes in this version

+ type Browser struct

+ DebugPort string

+ DefaultDialogs bool

+ Description string

+ DialogColor string

+ DisableSandbox bool

+ Disabled bool

+ DisplayCard string

+ ExceptionURL string

+ Fullscreen bool

+ ID string

+ IgnoreCertErr bool

+ KeyboardScale bool

+ Parent string

+ RetryInterval int

+ Rotate int

+ ScreenResolution string

+ TouchQuirk bool

+ URL string

+ type BrowserClient struct

+ func (c *BrowserClient) EdgePoints(nodeID, parentID string, points []data.Point)

+ func (c *BrowserClient) Points(nodeID string, points []data.Point)

+ func (c *BrowserClient) Run() error

+ func (c *BrowserClient) Stop(error)

+ func (c *BrowserClient) ValidatePoints()

+ type BrowserConfigFile struct

+ DebugPort string

+ DefaultDialogs bool

+ DialogColor string

+ DisableSandbox bool

+ ExceptionURL string

+ Fullscreen bool

+ IgnoreCertErr bool

+ KeyboardScale bool

+ QtQpaPlatform string

+ RetryInterval int

+ Rotate int

+ TouchQuirk bool

+ URL string

+ XAuthority string

type Client

+ func NewBrowserClient(nc *nats.Conn, config Browser) Client

+ type EGLFSConfigFile struct

+ Device *string

+ HwCursor *bool

+ Outputs *[]EGLSFSOutputs

+ Pbuffers *bool

+ type EGLSFSOutputs struct

+ Mode *string

+ Name *string

type ShellyIo

+ func (sio *ShellyIo) HasPM() bool

Nov 20, 2024

Changes in this version

type ShellyIo

+ Controlled bool

Nov 8, 2024

Changes in this version

type Client

+ func NewFileClient(nc *nats.Conn, config File) Client

type File

+ Binary bool

+ Hash string

+ Size string

+ func (f *File) GetContents() ([]byte, error)

+ type FileClient struct

+ func (f *FileClient) EdgePoints(_ string, _ string, _ []data.Point)

+ func (f *FileClient) Points(nodeID string, points []data.Point)

+ func (f *FileClient) Run() error

+ func (f *FileClient) Stop(error)

type Group

+ Description string

+ ID string

+ Parent string

+ type RunGroup struct

+ func NewRunGroup(name string) *RunGroup

+ func (g *RunGroup) Add(client RunStop)

+ func (g *RunGroup) Run() error

+ func (g *RunGroup) Stop(_ error)

type SerialDev

+ Download string

+ Files []File

+ Progress int

Aug 5, 2024

Changes in this version

type Action

+ Disabled bool

+ PointKey string

type ActionInactive

+ PointKey string

type Condition

+ Disabled bool

May 12, 2024

Changes in this version

+ const InfluxMeasurement

type Client

+ func NewUpdateClient(nc *nats.Conn, config Update) Client

+ type Update struct

+ AutoDownload bool

+ AutoReboot bool

+ Description string

+ Directory string

+ DiscardDownload string

+ DownloadOS string

+ ID string

+ OSDownloaded string

+ OSUpdates []string

+ Parent string

+ PollPeriod int

+ Prefix string

+ Refresh bool

+ URI string

+ VersionOS string

+ type UpdateClient struct

+ func (m *UpdateClient) EdgePoints(nodeID, parentID string, points []data.Point)

+ func (m *UpdateClient) Points(nodeID string, points []data.Point)

+ func (m *UpdateClient) Run() error

+ func (m *UpdateClient) Stop(_ error)

Mar 19, 2024

Changes in this version

type Db

+ TagPointTypes []string

type NetworkManager — linux/amd64

+ Description string

type SignalGenerator

+ Tags map[string]string

Jan 9, 2024

Changes in this version

type NetworkManager — linux/amd64

+ Disabled bool

type Particle

+ Disabled bool

type Rule

+ Disabled bool

type SerialDev

+ Disabled bool

type Shelly

+ Disabled bool

type ShellyIo

+ Disabled bool

type SignalGenerator

+ Disabled bool

type Sync

+ Disabled bool

Nov 29, 2023

Changes in this version

+ type Destination struct

+ HighRate bool

+ NodeID string

+ Parent bool

+ PointKey string

+ PointType string

+ func (sd Destination) Subject(originID string, parentID string) string

type IPv4Config — linux/amd64

+ func (c IPv4Config) Equal(c2 IPv4Config) bool

+ func (c IPv4Config) Method() string

type IPv6Config — linux/amd64

+ func (c IPv6Config) Equal(c2 IPv6Config) bool

+ func (c IPv6Config) Method() string

type NetworkManagerConn — linux/amd64

+ Description string

+ Error string

type SignalGenerator

+ Destination Destination

Nov 14, 2023

Changes in this version

+ const BatchSizeLimit

+ const RescanTimeoutSeconds — linux/amd64

+ func ExportNodes(nc *nats.Conn, id string) ([]byte, error)

+ func ImportNodes(nc *nats.Conn, parent string, yamlData []byte, origin string, preserveIDs bool) error

+ func ReplaceIDs(nodes *data.NodeEdgeChildren, parent string)

+ type AccessPoint struct — linux/amd64

+ BSSID string

+ Flags uint32

+ RSNFlags uint32

+ SSID string

+ Strength uint8

+ WPAFlags uint32

+ func ResolveAccessPoint(ap nm.AccessPoint) (apOut AccessPoint, err error)

+ func (ap AccessPoint) MarshallJSON() ([]byte, error)

type Client — darwin/amd64, linux/amd64, windows/amd64

+ func NewNetworkManagerClient(nc *nats.Conn, config NetworkManager) Client

+ type IPv4Address string — linux/amd64

+ func IPv4AddressUint32(n uint32, order binary.ByteOrder) IPv4Address

+ func (addr IPv4Address) String() string

+ func (addr IPv4Address) Uint32(order binary.ByteOrder) uint32

+ func (addr IPv4Address) Valid() bool

+ type IPv4Config struct — linux/amd64

+ Address IPv4Address

+ DNSServer1 IPv4Address

+ DNSServer2 IPv4Address

+ Gateway IPv4Address

+ Netmask IPv4Netmask

+ StaticIP bool

+ func ResolveIPv4Config(settings map[string]any) IPv4Config

+ func (c IPv4Config) DBus() map[string]any

+ type IPv4Netmask IPv4Address — linux/amd64

+ func IPv4NetmaskPrefix(prefix uint8) IPv4Netmask

+ func (str IPv4Netmask) Prefix() uint32

+ func (str IPv4Netmask) Valid() bool

+ type IPv6Address string — linux/amd64

+ func NewIPv6Address(bs []byte) IPv6Address

+ func (addr IPv6Address) Bytes() []byte

+ func (addr IPv6Address) String() string

+ func (addr IPv6Address) Valid() bool

+ type IPv6Config struct — linux/amd64

+ Address IPv6Address

+ DNSServer1 IPv6Address

+ DNSServer2 IPv6Address

+ Gateway IPv6Address

+ Prefix uint8

+ StaticIP bool

+ func ResolveIPv6Config(settings map[string]any) IPv6Config

+ func (c IPv6Config) DBus() map[string]any

+ type NetworkManager struct — darwin/amd64, windows/amd64

+ type NetworkManager struct — linux/amd64

+ Connections []NetworkManagerConn

+ Devices []NetworkManagerDevice

+ Disable bool

+ Hostname string

+ ID string

+ NetworkingEnabled *bool

+ Parent string

+ RequestWiFiScan bool

+ WirelessEnabled *bool

+ WirelessHardwareEnabled *bool

+ type NetworkManagerClient struct — darwin/amd64, linux/amd64, windows/amd64

+ func (c *NetworkManagerClient) EdgePoints(_ string, _ string, _ []data.Point)

+ func (c *NetworkManagerClient) Points(_ string, _ []data.Point)

+ func (c *NetworkManagerClient) Points(nodeID string, points []data.Point)

+ func (c *NetworkManagerClient) Run() error

+ func (c *NetworkManagerClient) Stop(error)

+ func (c *NetworkManagerClient) SyncConnections() (errs []error, fatal error)

+ func (c *NetworkManagerClient) SyncDevices() (errs []error, fatal error)

+ func (c *NetworkManagerClient) SyncHostname() (errs []error, fatal error)

+ func (c *NetworkManagerClient) WifiScan() error

+ type NetworkManagerConn struct — linux/amd64

+ AutoConnect bool

+ AutoConnectPriority int32

+ Disabled bool

+ ID string

+ IPv4Config IPv4Config

+ IPv6Config IPv6Config

+ InterfaceName string

+ LastActivated uint64

+ Parent string

+ Type string

+ UUID string

+ WiFiConfig WiFiConfig

+ func ResolveNetworkManagerConn(settings nm.ConnectionSettings) NetworkManagerConn

+ func (c NetworkManagerConn) DBus() nm.ConnectionSettings

+ func (c NetworkManagerConn) Equal(c2 NetworkManagerConn) bool

+ func (c NetworkManagerConn) Managed() bool

+ type NetworkManagerDevice struct — linux/amd64

+ AccessPoints []string

+ ActiveAccessPoint *AccessPoint

+ DeviceType string

+ HardwareAddress string

+ ID string

+ IPv4Addresses []IPv4Address

+ IPv4Gateway IPv4Address

+ IPv4Nameservers []IPv4Address

+ IPv4Netmasks []IPv4Netmask

+ IPv6Addresses []IPv6Address

+ IPv6Gateway IPv6Address

+ IPv6Nameservers []IPv6Address

+ IPv6Prefixes []uint8

+ Interface string

+ Managed bool

+ Parent string

+ Path string

+ State string

+ func ResolveDevice(parent string, device nm.Device) (dev NetworkManagerDevice, err error)

type SerialDev

+ HRDestNode string

+ SyncParent bool

type SignalGenerator

+ InitialValue float64

+ MaxIncrement float64

+ MaxValue float64

+ MinIncrement float64

+ MinValue float64

+ RoundTo float64

+ SignalType string

+ type SiotExport struct

+ Nodes []data.NodeEdgeChildren

+ type WiFiConfig struct — linux/amd64

+ KeyManagement string

+ PSK string

+ SSID string

Oct 4, 2023

Changes in this version

type SerialDev

+ ErrorCountHR int

+ ErrorCountResetHR bool

+ RateHR bool

Sep 13, 2023

Changes in this version

+ const NTPConfigPath

type Client

+ func NewNTPClient(nc *nats.Conn, config NTP) Client

+ type NTP struct

+ FallbackServers []string

+ ID string

+ Parent string

+ Servers []string

+ type NTPClient struct

+ func (c *NTPClient) EdgePoints(_ string, _ string, _ []data.Point)

+ func (c *NTPClient) Points(nodeID string, points []data.Point)

+ func (c *NTPClient) Run() error

+ func (c *NTPClient) Stop(error)

+ func (c *NTPClient) UpdateConfig() error

Aug 25, 2023

Changes in this version

type File

+ Description string

+ ID string

+ Parent string

Jul 21, 2023

Changes in this version

type Action

+ Error string

type Condition

+ Dates []string

+ Error string

type Rule

+ Error string

Jun 14, 2023

Changes in this version

type ShellyIo

+ Disable bool

+ Input []bool

+ Light []bool

+ LightSet []bool

+ Switch []bool

+ SwitchSet []bool

Jun 8, 2023

Changes in this version

type SerialDev

+ HrRx int64

+ HrRxReset bool

May 23, 2023

Changes in this version

type Condition

+ End string

+ Start string

type SerialDev

+ Connected bool

May 15, 2023

Changes in this version

type ShellyIo

+ Control bool

Apr 28, 2023

Changes in this version

type Client

+ func NewShellyClient(nc *nats.Conn, config Shelly) Client

+ func NewShellyIOClient(nc *nats.Conn, config ShellyIo) Client

+ type Shelly struct

+ Description string

+ Disable bool

+ ID string

+ IOs []ShellyIo

+ Parent string

+ type ShellyClient struct

+ func (sc *ShellyClient) EdgePoints(nodeID, parentID string, points []data.Point)

+ func (sc *ShellyClient) Points(nodeID string, points []data.Point)

+ func (sc *ShellyClient) Run() error

+ func (sc *ShellyClient) Stop(_ error)

+ type ShellyGen int

+ const ShellyGen1

+ const ShellyGen2

+ const ShellyGenUnknown

+ type ShellyIOClient struct

+ func (sioc *ShellyIOClient) EdgePoints(nodeID, parentID string, points []data.Point)

+ func (sioc *ShellyIOClient) Points(nodeID string, points []data.Point)

+ func (sioc *ShellyIOClient) Run() error

+ func (sioc *ShellyIOClient) Stop(_ error)

+ type ShellyIOConfig struct

+ Name string

+ type ShellyIo struct

+ Description string

+ DeviceID string

+ ID string

+ IP string

+ Offline bool

+ Parent string

+ Type string

+ Value float64

+ ValueSet float64

+ func (sio *ShellyIo) Desc() string

+ func (sio *ShellyIo) Gen() ShellyGen

+ func (sio *ShellyIo) GetConfig() (ShellyIOConfig, error)

+ func (sio *ShellyIo) GetStatus() (data.Points, error)

+ func (sio *ShellyIo) IsSettableOnOff() bool

+ func (sio *ShellyIo) SetName(name string) error

+ func (sio *ShellyIo) SetOnOff(on bool) (data.Points, error)

type SignalGenerator

+ BatchPeriod int

+ HighRate bool

Feb 28, 2023

Changes in this version

type Client

+ func NewParticleClient(nc *nats.Conn, config Particle) Client

+ type Particle struct

+ AuthToken string

+ Description string

+ Disable bool

+ ID string

+ Parent string

+ type ParticleClient struct

+ func (pc *ParticleClient) EdgePoints(nodeID, parentID string, points []data.Point)

+ func (pc *ParticleClient) Points(nodeID string, points []data.Point)

+ func (pc *ParticleClient) Run() error

+ func (pc *ParticleClient) Stop(err error)

+ type ParticleEvent struct

+ CoreID string

+ Data string

+ TTL uint32

+ Timestamp time.Time

type SerialDev

+ Rate bool

Jan 27, 2023

Changes in this version

type Client

+ func NewMetricsClient(nc *nats.Conn, config Metrics) Client

+ type Metrics struct

+ Description string

+ ID string

+ Name string

+ Parent string

+ Period int

+ Type string

+ type MetricsClient struct

+ func (m *MetricsClient) EdgePoints(nodeID, parentID string, points []data.Point)

+ func (m *MetricsClient) Points(nodeID string, points []data.Point)

+ func (m *MetricsClient) Run() error

+ func (m *MetricsClient) Stop(err error)

Jan 2, 2023

Changes in this version

type CanBus

+ BitRate string

type CanBusClient

+ func (cb *CanBusClient) Run() error

type DbClient

+ func (dbc *DbClient) Run() error

type Group

+ func (g *Group) Run() error

type Manager

+ func (m *Manager[T]) Run() error

type RuleClient

+ func (rc *RuleClient) Run() error

+ type RunStop interface

+ Run func() error

+ Stop func(error)

type SerialDevClient

+ func (sd *SerialDevClient) Run() error

type SignalGeneratorClient

+ func (sgc *SignalGeneratorClient) Run() error

type SyncClient

+ func (up *SyncClient) Run() error

Dec 9, 2022

Changes in this version

+ type CanBus struct

+ Databases []File

+ Description string

+ Device string

+ ID string

+ MsgsInDb int

+ MsgsRecvdDb int

+ MsgsRecvdDbReset bool

+ MsgsRecvdOther int

+ MsgsRecvdOtherReset bool

+ Parent string

+ SignalsInDb int

+ type CanBusClient struct

+ func (cb *CanBusClient) EdgePoints(nodeID, parentID string, points []data.Point)

+ func (cb *CanBusClient) Points(nodeID string, points []data.Point)

+ func (cb *CanBusClient) Start() error

+ func (cb *CanBusClient) Stop(err error)

type Client

+ func NewCanBusClient(nc *nats.Conn, config CanBus) Client

+ type File struct

+ Data string

+ Name string

Dec 1, 2022

Changes in this version

type Sync

+ Period int

Nov 15, 2022

Changes in this version

+ func AdminStoreMaint(nc *nats.Conn) error

+ func AdminStoreVerify(nc *nats.Conn) error

+ func DecodeUpEdgePointsMsg(msg *nats.Msg) (string, string, string, []data.Point, error)

+ func DecodeUpNodePointsMsg(msg *nats.Msg) (string, string, []data.Point, error)

+ func GetNatsURI(nc *nats.Conn) (string, string, error)

+ func GetNodes(nc *nats.Conn, parent, id, typ string, includeDel bool) ([]data.NodeEdge, error)

+ func GetNodesType(nc *nats.Conn, parent, id string) ([]T, error)

+ func GetRootNode(nc *nats.Conn) (data.NodeEdge, error)

type Client

+ func NewSyncClient(nc *nats.Conn, config Sync) Client

+ type Device struct

+ Description string

+ ID string

+ Parent string

type EdgeOptions

+ Connected func()

+ type Sync struct

+ AuthToken string

+ Description string

+ Disable bool

+ ID string

+ Parent string

+ SyncCount int

+ SyncCountReset bool

+ URI string

+ type SyncClient struct

+ func (up *SyncClient) EdgePoints(nodeID, parentID string, points []data.Point)

+ func (up *SyncClient) Points(nodeID string, points []data.Point)

+ func (up *SyncClient) Start() error

+ func (up *SyncClient) Stop(err error)

Oct 31, 2022

Changes in this version

type SerialDev

+ MaxMessageLength int

Oct 28, 2022

Changes in this version

type CobsWrapper

+ func (cw *CobsWrapper) SetDebug(debug int)

Oct 26, 2022

Changes in this version

+ func Log(natsServer, authToken string)

+ type Group struct

+ func DefaultClients(nc *nats.Conn) (*Group, error)

+ func NewGroup() *Group

+ func (g *Group) Add(client StartStop)

+ func (g *Group) Start() error

+ func (g *Group) Stop(err error)

+ type StartStop interface

+ Start func() error

+ Stop func(error)

Oct 12, 2022

Changes in this version

+ func NatsSendFileFromHTTP(nc *nats.Conn, deviceID string, url string, callback func(int)) error

+ func SubjectNodeHRPoints(nodeID string) string

type Client

+ func NewSignalGeneratorClient(nc *nats.Conn, config SignalGenerator) Client

+ type SignalGenerator struct

+ Amplitude float64

+ Description string

+ Disable bool

+ Frequency float64

+ ID string

+ Offset float64

+ Parent string

+ SampleRate float64

+ Units string

+ Value float64

+ type SignalGeneratorClient struct

+ func (sgc *SignalGeneratorClient) EdgePoints(nodeID, parentID string, points []data.Point)

+ func (sgc *SignalGeneratorClient) Points(nodeID string, points []data.Point)

+ func (sgc *SignalGeneratorClient) Start() error

+ func (sgc *SignalGeneratorClient) Stop(err error)

+ type User struct

+ Email string

+ FirstName string

+ ID string

+ LastName string

+ Parent string

+ Pass string

+ Phone string

Sep 20, 2022

Changes in this version

+ type Action struct

+ Action string

+ Active bool

+ Description string

+ ID string

+ NodeID string

+ Parent string

+ PointChannel int

+ PointDevice string

+ PointFilePath string

+ PointType string

+ Value float64

+ ValueText string

+ ValueType string

+ func (a Action) String() string

+ type ActionInactive struct

+ Action string

+ Active bool

+ Description string

+ ID string

+ NodeID string

+ Parent string

+ PointChannel int

+ PointDevice string

+ PointFilePath string

+ PointType string

+ Value float64

+ ValueText string

+ ValueType string

type Client

+ func NewDbClient(nc *nats.Conn, config Db) Client

+ func NewRuleClient(nc *nats.Conn, config Rule) Client

+ type Condition struct

+ Active bool

+ ConditionType string

+ Description string

+ EndTime string

+ ID string

+ MinActive float64

+ NodeID string

+ Operator string

+ Parent string

+ PointIndex int

+ PointKey string

+ PointType string

+ StartTime string

+ Value float64

+ ValueText string

+ ValueType string

+ Weekdays []time.Weekday

+ func (c Condition) String() string

+ type Db struct

+ AuthToken string

+ Bucket string

+ Description string

+ ID string

+ Org string

+ Parent string

+ URI string

+ type DbClient struct

+ func (dbc *DbClient) EdgePoints(nodeID, parentID string, points []data.Point)

+ func (dbc *DbClient) Points(nodeID string, points []data.Point)

+ func (dbc *DbClient) Start() error

+ func (dbc *DbClient) Stop(err error)

+ type NewPoints struct

+ ID string

+ Parent string

+ Points data.Points

+ func (np NewPoints) String() string

+ type Rule struct

+ Actions []Action

+ ActionsInactive []Action

+ Active bool

+ Conditions []Condition

+ Description string

+ Disable bool

+ ID string

+ Parent string

+ func (r Rule) String() string

+ type RuleClient struct

+ func (rc *RuleClient) EdgePoints(nodeID, parentID string, points []data.Point)

+ func (rc *RuleClient) Points(nodeID string, points []data.Point)

+ func (rc *RuleClient) Start() error

+ func (rc *RuleClient) Stop(err error)

+ type Variable struct

+ Description string

+ ID string

+ Parent string

+ Value float64

+ VariableType string

Aug 29, 2022

Changes in this version

type SerialDev

+ RxReset bool

+ TxReset bool

Aug 24, 2022

Changes in this version

type SerialDev

+ ErrorCountReset bool

Jul 29, 2022

Changes in this version

+ var ErrCobsDecodeError = errors.New("COBS decode error")

+ var ErrCobsLeftoverBufferFull = errors.New("COBS leftover buffer too full")

+ var ErrCobsTooMuchData = errors.New("COBS decode: too much data without null")

+ func GetNodeChildrenType(nc *nats.Conn, id string) ([]T, error)

+ func GetNodeType(nc *nats.Conn, id, parent string) ([]T, error)

+ func NodeWatcher(nc *nats.Conn, id, parent string) (get func() T, stop func(), err error)

+ func SendNodeType(nc *nats.Conn, node T) error

+ func SendPoints(nc *nats.Conn, subject string, points data.Points, ack bool) error

+ func SerialDecode(d []byte) (byte, string, data.Points, error)

+ func SerialEncode(seq byte, subject string, points data.Points) ([]byte, error)

+ func SubscribeEdgePoints(nc *nats.Conn, id, parent string, callback func(points []data.Point)) (stop func(), err error)

+ func SubscribePoints(nc *nats.Conn, id string, callback func(points []data.Point)) (stop func(), err error)

+ type BuiltInClients struct

+ func NewBuiltInClients(nc *nats.Conn) *BuiltInClients

+ func (bic *BuiltInClients) Start() error

+ func (bic *BuiltInClients) Stop(_ error)

type Client

+ func NewSerialDevClient(nc *nats.Conn, config SerialDev) Client

+ type CobsWrapper struct

+ func NewCobsWrapper(dev io.ReadWriteCloser) *CobsWrapper

+ func (cw *CobsWrapper) Close() error

+ func (cw *CobsWrapper) Read(b []byte) (int, error)

+ func (cw *CobsWrapper) Write(b []byte) (int, error)

+ type SerialDev struct

+ Baud string

+ Debug int

+ Description string

+ Disable bool

+ ErrorCount int

+ ID string

+ Log string

+ Parent string

+ Port string

+ Rx int

+ Tx int

+ Uptime int

+ type SerialDevClient struct

+ func (sd *SerialDevClient) EdgePoints(points []data.Point)

+ func (sd *SerialDevClient) Points(points []data.Point)

+ func (sd *SerialDevClient) Start() error

+ func (sd *SerialDevClient) Stop(err error)

Jul 7, 2022

Changes in this version

+ func DecodeEdgePointsMsg(msg *nats.Msg) (string, string, []data.Point, error)

+ func DecodeNodePointsMsg(msg *nats.Msg) (string, []data.Point, error)

+ func DeleteNode(nc *nats.Conn, id, parent string) error

+ func Dump(nc *nats.Conn, msg *nats.Msg) error

+ func DuplicateNode(nc *nats.Conn, id, newParent string) error

+ func EdgeConnect(eo EdgeOptions) (*nats.Conn, error)

+ func ExpBackoff(attempts int, max time.Duration) time.Duration

+ func GetNode(nc *nats.Conn, id, parent string) ([]data.NodeEdge, error)

+ func GetNodeChildren(nc *nats.Conn, id, typ string, includeDel bool, recursive bool) ([]data.NodeEdge, error)

+ func GetNodesForUser(nc *nats.Conn, userID string) ([]data.NodeEdge, error)

+ func ListenForFile(nc *nats.Conn, dir, deviceID string, callback func(path string)) error

+ func MirrorNode(nc *nats.Conn, id, newParent string) error

+ func MoveNode(nc *nats.Conn, id, oldParent, newParent string) error

+ func SendEdgePoint(nc *nats.Conn, nodeID, parentID string, point data.Point, ack bool) error

+ func SendEdgePoints(nc *nats.Conn, nodeID, parentID string, points data.Points, ack bool) error

+ func SendFile(nc *nats.Conn, deviceID string, reader io.Reader, name string, ...) error

+ func SendNode(nc *nats.Conn, node data.NodeEdge) error

+ func SendNodePoint(nc *nats.Conn, nodeID string, point data.Point, ack bool) error

+ func SendNodePointCreate(nc *nats.Conn, nodeID string, point data.Point, ack bool) error

+ func SendNodePoints(nc *nats.Conn, nodeID string, points data.Points, ack bool) error

+ func SendNodePointsCreate(nc *nats.Conn, nodeID string, points data.Points, ack bool) error

+ func String(nc *nats.Conn, msg *nats.Msg) (string, error)

+ func SubjectEdgeAllPoints() string

+ func SubjectEdgePoints(nodeID, parentID string) string

+ func SubjectNodeAllPoints() string

+ func SubjectNodePoints(nodeID string) string

+ func UserCheck(nc *nats.Conn, email, pass string) ([]data.NodeEdge, error)

+ type Client interface

+ EdgePoints func([]data.Point)

+ Points func([]data.Point)

+ Start func() error

+ Stop func(error)

+ type EdgeOptions struct

+ AuthToken string

+ Closed func()

+ Disconnected func()

+ NoEcho bool

+ Reconnected func()

+ URI string

+ type Manager struct

+ func NewManager(nc *nats.Conn, root string, construct func(nc *nats.Conn, config T) Client) *Manager[T]

+ func (m *Manager[T]) Start() error

+ func (m *Manager[T]) Stop(err error)

+ type Metric struct

+ func NewMetric(nc *nats.Conn, nodeID, pointType string, reportPeriod time.Duration) *Metric

+ func (m *Metric) AddSample(s float64) error

+ func (m *Metric) SetNodeID(id string)