Documentation
¶
Index ¶
Constants ¶
View Source
const ( ScriptKeyDataIn = "dataIn" ScriptKeyDataOut = "dataOut" )
View Source
const (
PluginGeneric = "generic"
)
Variables ¶
This section is empty.
Functions ¶
func NewPluginGeneric ¶
NewPluginGeneric provider
Types ¶
type Config ¶
type Config struct {
Type string `json:"type" yaml:"type"`
RetryCount int `json:"retryCount" yaml:"retryCount"`
Script ScriptFormatter `json:"script" yaml:"script"`
Protocol cmap.CustomMap `json:"protocol" yaml:"protocol"` // mqtt type will be handled by default mqtt protocol
}
Config of generic provider
type GenericProtocol ¶
type GenericProtocol interface {
Post(rawMsg *msgTY.Message) error // post a message on a specified protocol
Close() error // close the protocol connection
}
Generic protocol
type Provider ¶
type Provider struct {
Config *Config
GatewayConfig *gwTY.Config
Protocol GenericProtocol
ProtocolType string
// contains filtered or unexported fields
}
Provider implementation
func (*Provider) ConvertToMessages ¶
Process received messages
type ScriptFormatter ¶
type ScriptFormatter struct {
OnReceive string `json:"onReceive" yaml:"onReceive"`
OnSend string `json:"onSend" yaml:"onSend"`
}
script used to format
Click to show internal directories.
Click to hide internal directories.