node

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

type DeviceType string

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

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

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

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