Documentation ¶
Index ¶
Constants ¶
View Source
const ( // Name ... Name = "node" // EntityNode ... EntityNode = string("node") // TopicPluginNode ... TopicPluginNode = "plugin.node" )
View Source
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 ¶
This section is empty.
Functions ¶
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 bus.Bus, mqttClient mqtt.MqttCli) (actor *Actor)
NewActor ...
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 ...
Click to show internal directories.
Click to hide internal directories.