node

README

NODE Plugin

Documentation

Documentation

Index

• Constants
• Variables
• func New() supervisor.Pluggable
• func NewAttr() m.Attributes
• func NewSettings() m.Attributes
• func NewStates() (states map[string]supervisor.ActorState)
• type Actor
  • func NewActor(entity *m.Entity, service supervisor.Service, mqttClient mqtt.MqttCli) (actor *Actor)
  • func (e *Actor) Destroy()
  • func (e *Actor) Spawn()
• type DeviceType
• type MessageRequest
• type MessageResponse
• type MessageStatus
• type MqttMessage

Constants

const (
	// Name ...
	Name = "node"
	// TopicPluginNode ...
	TopicPluginNode = "system/plugins/node"

	Version = "0.0.1"
)

const (
	// AttrThread ...
	AttrThread = "thread"
	// AttrRps ...
	AttrRps = "rps"
	// AttrMin ...
	AttrMin = "min"
	// AttrMax ...
	AttrMax = "max"
	// AttrLatency ...
	AttrLatency = "latency"
	// AttrStartedAt ...
	AttrStartedAt = "started_at"
	// AttrNodeLogin ...
	AttrNodeLogin = "node_login"
	// AttrNodePass ...
	AttrNodePass = "node_pass"
)

Variables

var F embed.FS

Functions

func New

func New() supervisor.Pluggable

New ...

func NewAttr

func NewAttr() m.Attributes

NewAttr ...

func NewSettings

func NewSettings() m.Attributes

NewSettings ...

func NewStates

func NewStates() (states map[string]supervisor.ActorState)

NewStates ...

Types

type Actor

type Actor struct {
	*supervisor.BaseActor
	// contains filtered or unexported fields
}

Actor ...

func NewActor

func NewActor(entity *m.Entity,
	service supervisor.Service,
	mqttClient mqtt.MqttCli) (actor *Actor)

NewActor ...

func (*Actor) Destroy

func (e *Actor) Destroy()

func (*Actor) Spawn

func (e *Actor) Spawn()

Spawn ...

type DeviceType

type DeviceType string

DeviceType ...

type MessageRequest

type MessageRequest struct {
	EntityId   common.EntityId `json:"entity_id"`
	DeviceType DeviceType      `json:"device_type"`
	Properties json.RawMessage `json:"properties"`
	Command    json.RawMessage `json:"command"`
}

MessageRequest ...

type MessageResponse

type MessageResponse struct {
	EntityId   common.EntityId `json:"entity_id"`
	DeviceType DeviceType      `json:"device_type"`
	Properties json.RawMessage `json:"properties"`
	Response   json.RawMessage `json:"response"`
	Status     string          `json:"status"`
}

MessageResponse ...

type MessageStatus

type MessageStatus struct {
	Status    string    `json:"status"`
	Thread    int       `json:"thread"`
	Rps       int64     `json:"rps"`
	Min       int64     `json:"min"`
	Max       int64     `json:"max"`
	Laatency  int64     `json:"latency"`
	StartedAt time.Time `json:"started_at"`
}

MessageStatus ...

type MqttMessage

type MqttMessage struct {
	Dup      bool
	Qos      uint8
	Retained bool
	Topic    string
	PacketID uint16
	Payload  []byte
}

MqttMessage ...