external

type DbClientNode struct {
	//节点配置
	Config DbClientNodeConfiguration
	// contains filtered or unexported fields
}

type DbClientNodeConfiguration struct {
	// Sql SQL语句，可以使用${metaKeyName} 替换元数据中的变量
	Sql string
	// Params SQL语句参数列表，可以使用${metaKeyName} 替换元数据中的变量
	Params []interface{}
	// GetOne 是否只返回一条记录，true:返回结构不是数组结构，false：返回数据是数组结构
	GetOne bool
	// PoolSize 连接池大小
	PoolSize int
	// DriverName 数据库驱动名称，mysql或postgres
	DriverName string
	// Dsn 数据库连接配置，参考sql.Open参数
	Dsn string
}

type Email struct {
	//From 发件人邮箱
	From string
	//To 收件人邮箱，多个与`,`隔开
	To string
	//Cc 抄送人邮箱，多个与`,`隔开
	Cc string
	//Bcc 密送人邮箱，多个与`,`隔开
	Bcc string
	//Subject 邮件主题，可以使用 ${metaKeyName} 替换元数据中的变量
	Subject string
	//Body 邮件模板，可以使用 ${metaKeyName} 替换元数据中的变量
	Body string
}

type MqttClientNode struct {
	//节点配置
	Config MqttClientNodeConfiguration
	// contains filtered or unexported fields
}

type MqttClientNodeConfiguration struct {
	//publish topic
	Topic    string
	Server   string
	Username string
	Password string
	//MaxReconnectInterval 重连间隔 单位秒
	MaxReconnectInterval int
	QOS                  uint8
	CleanSession         bool
	ClientID             string
	CAFile               string
	CertFile             string
	CertKeyFile          string
}

type NetNode struct {
	// 节点配置
	Config NetNodeConfiguration
	// contains filtered or unexported fields
}

type NetNodeConfiguration struct {
	// 通信协议，可以是tcp、udp、ip4:1、ip6:ipv6-icmp、ip6:58、unix、unixgram，以及net包支持的协议类型。默认tcp协议
	Protocol string
	// 服务器的地址，格式为host:port
	Server string
	// 连接超时，单位为秒，如果<=0 则默认60
	ConnectTimeout int
	// 心跳间隔，用于定期发送心跳消息，单位为秒，如果<=0 则默认60
	HeartbeatInterval int
}

type RestApiCallNode struct {
	//节点配置
	Config RestApiCallNodeConfiguration
	// contains filtered or unexported fields
}

type RestApiCallNodeConfiguration struct {
	//RestEndpointUrlPattern HTTP URL地址,可以使用 ${metaKeyName} 替换元数据中的变量
	RestEndpointUrlPattern string
	//RequestMethod 请求方法，默认POST
	RequestMethod string
	// Without request body
	WithoutRequestBody bool
	//Headers 请求头,可以使用 ${metaKeyName} 替换元数据中的变量
	Headers map[string]string
	//ReadTimeoutMs 超时，单位毫秒，默认0:不限制
	ReadTimeoutMs int
	//MaxParallelRequestsCount 连接池大小，默认200。0代表不限制
	MaxParallelRequestsCount int
	//EnableProxy 是否开启代理
	EnableProxy bool
	//UseSystemProxyProperties 使用系统配置代理
	UseSystemProxyProperties bool
	//ProxyScheme 代理协议
	ProxyScheme string
	//ProxyHost 代理主机
	ProxyHost string
	//ProxyPort 代理端口
	ProxyPort int
	//ProxyUser 代理用户名
	ProxyUser string
	//ProxyPassword 代理密码
	ProxyPassword string
}

type SendEmailConfiguration struct {
	//SmtpHost Smtp主机地址
	SmtpHost string
	//SmtpPort Smtp端口
	SmtpPort int
	//Username 用户名
	Username string
	//Password 授权码
	Password string
	//EnableTls 是否是使用tls方式
	EnableTls bool
	//Email 邮件内容配置
	Email Email
	//ConnectTimeout 连接超时，单位秒
	ConnectTimeout int
}

type SendEmailNode struct {
	//节点配置
	Config                 SendEmailConfiguration
	ConnectTimeoutDuration time.Duration
	// contains filtered or unexported fields
}

type SshConfiguration struct {
	//Host ssh 主机地址
	Host string
	//Port ssh 主机端口
	Port int
	//Username ssh登录用户名
	Username string
	//Password ssh登录密码
	Password string
	//Cmd shell命令,可以使用 ${metaKeyName} 替换元数据中的变量
	Cmd string
}

type SshNode struct {
	//节点配置
	Config SshConfiguration
	// contains filtered or unexported fields
}