common

Documentation

Index

• Constants
• func Start(app *fx.App)
• func Stop(app *fx.App)
• func Work()
• type ClientStatus
• type ClientStatusModel
• type DeviceType
• type MessageRequest
• type MessageResponse
• type StatusType
• type Thread
• type ThreadCaller
• type ThreadState

Constants

const (
	Enabled  = StatusType("enabled")
	Disabled = StatusType("disabled")
)

const (
	DevTypeModBusRtu = DeviceType("modbus_rtu")
	DevTypeModBusTcp = DeviceType("modbus_tcp")
	DevTypeDefault   = DeviceType("default")
	DevTypeCommand   = DeviceType("command")
)

const (
	ThreadOk          = ThreadState("ok")
	ThreadBusy        = ThreadState("busy")
	ThreadDevNotFound = ThreadState("port by device not found")
	ThreadNotFound    = ThreadState("port not found")
	ThreadAllBusy     = ThreadState("all ports busy")
)

const (
	StatusEnabled  = ClientStatus("enabled")
	StatusDisabled = ClientStatus("disabled")
	StatusError    = ClientStatus("error")
	StatusBusy     = ClientStatus("busy")
)

Functions

func Start

func Start(app *fx.App)

Start ...

func Stop

func Stop(app *fx.App)

Stop ...

func Work

func Work()

Work ...

Types

type ClientStatus

type ClientStatus string

type ClientStatusModel

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

type DeviceType

type DeviceType string

type MessageRequest

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

type MessageResponse

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

type StatusType

type StatusType string

type Thread

type Thread interface {
	//DEPRECATED
	SetParams(baud, timeout, stopBits int) (err error)
	//DEPRECATED
	Open() (err error)
	//DEPRECATED
	Close()
	Restart()
	GetSerial() *serial.Serial
	Device() string
	SetErr()
	SetCon(conn interface{})
	GetCon() interface{}
}

type ThreadCaller

type ThreadCaller interface {
	Exec(t Thread) (resp *MessageResponse, err error)
	Send(entityId string, data interface{})
	EntityId() string
}

type ThreadState

type ThreadState string