 Documentation
      ¶
      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.