nats

Apr 30, 2022

Changes in this version

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

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

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

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

Apr 7, 2022

Changes in this version

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

Feb 4, 2022

Changes in this version

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

Jan 5, 2022

Changes in this version

type EdgeOptions

+ URI string

Sep 8, 2021

Changes in this version

+ type Metric struct

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

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

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

Jul 23, 2021

Changes in this version

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

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

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

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

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

+ func SendNode(src, dest *natsgo.Conn, node data.NodeEdge) error

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

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

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

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

+ func SubjectEdgeAllPoints() string

+ func SubjectEdgePoints(nodeID, parentID string) string

+ func SubjectNodeAllPoints() string

+ func SubjectNodePoints(nodeID string) string

type EdgeOptions

+ NoEcho bool

Apr 10, 2021

Changes in this version

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

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

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

Mar 31, 2021

Changes in this version

+ func DecodeNodeMsg(msg *natsgo.Msg) (string, []data.Point, error)

Feb 8, 2021

Changes in this version

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

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

Aug 20, 2020

Changes in this version

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

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

+ func ListenForCmd(nc *nats.Conn, deviceID string, callback func(cmd data.DeviceCmd)) error

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

+ func SendCmd(nc *nats.Conn, cmd data.DeviceCmd, timeout time.Duration) error

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

+ type EdgeOptions struct

+ AuthToken string

+ Closed func()

+ Disconnected func()

+ Reconnected func()

+ Server string