node

Documentation

Index

• Constants
• func New() plugins.Plugable
• func NewAttr() m.Attributes
• func NewSettings() m.Attributes
• func NewStates() (states map[string]entity_manager.ActorState)
• type Actor
  • func NewActor(entity *m.Entity, entityManager entity_manager.EntityManager, ...) (actor *Actor)
  • func (e *Actor) Spawn() entity_manager.PluginActor
• type DeviceType
• type MessageRequest
• type MessageResponse
• type MessageStatus
• type MqttMessage

Constants

const (
	Name            = "node"
	EntityNode      = common.EntityType("node")
	TopicPluginNode = "plugin.node"
)

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

Functions

func New

func New() plugins.Plugable

func NewAttr

func NewAttr() m.Attributes

func NewSettings

func NewSettings() m.Attributes

func NewStates

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

Types

type Actor

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

func NewActor

func NewActor(entity *m.Entity,
	entityManager entity_manager.EntityManager,
	adaptors *adaptors.Adaptors,
	scriptService scripts.ScriptService,
	eventBus event_bus.EventBus,
	mqttClient mqtt.MqttCli) (actor *Actor)

func (*Actor) Spawn

func (e *Actor) Spawn() entity_manager.PluginActor

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"`
	StartedAt time.Time `json:"started_at"`
}

type MqttMessage

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

MqttMessage ...