tasks

type HttpHandler struct {
	Port                 int
	Schema, Method, Path string
	Codes                []int
	Header               map[string]string
	ResponseHeader       map[string]string
	Jq                   string
	Timeout              time.Duration
	// contains filtered or unexported fields
}

type HttpResult struct {
	Jq interface{}
}

type KEBAHandler struct {
	Timeout time.Duration
	// contains filtered or unexported fields
}

type KebaResult struct {
	Addr, Serial string
}

type ModbusHandler struct {
	Port     int
	IDs      []uint8
	Models   []int
	Point    string
	Register modbus.Register `mapstructure:",squash"`
	Values   []int
	Invalid  []int

	Timeout time.Duration
	// contains filtered or unexported fields
}

type ModbusResult struct {
	SlaveID uint8
	Model   int         `json:",omitempty"`
	Point   string      `json:",omitempty"`
	Value   interface{} `json:",omitempty"`
}

type MqttHandler struct {
	Port    int
	Topic   string
	Timeout time.Duration
}

type PingHandler struct {
	Count   int
	Timeout time.Duration
}

type Result struct {
	Task
	ResultDetails
	Attributes map[string]interface{} // TODO remove, only used for post-processing
}

type ResultDetails struct {
	IP           string
	Port         int           `json:",omitempty"`
	Topic        string        `json:",omitempty"`
	ModbusResult *ModbusResult `json:",omitempty"`
	KebaResult   *KebaResult   `json:",omitempty"`
	SmaResult    *SmaResult    `json:",omitempty"`
}

type SMAHandler struct {
	Timeout  time.Duration
	Password string
	// contains filtered or unexported fields
}

type SmaResult struct {
	Serial string
	Http   bool
}

type Task struct {
	ID      string
	Type    TaskType
	Depends string
	Config  map[string]interface{}
	TaskHandler
}

type TaskHandler interface {
	Test(log *util.Logger, in ResultDetails) []ResultDetails
}

type TaskHandlerRegistry map[TaskType]func(map[string]interface{}) (TaskHandler, error)

type TaskType string

type TcpHandler struct {
	Ports   []int
	Timeout time.Duration
	// contains filtered or unexported fields
}