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 ...
	Name = "node"
	// EntityNode ...
	EntityNode = string("node")
	// TopicPluginNode ...
	TopicPluginNode = "plugin.node"
)

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

Functions

func New

func New() plugins.Plugable

New ...

func NewAttr

func NewAttr() m.Attributes

NewAttr ...

func NewSettings

func NewSettings() m.Attributes

NewSettings ...

func NewStates

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

NewStates ...

Types

type Actor

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

Actor ...

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)

NewActor ...

func (*Actor) Spawn

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

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"`
	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 ...