fimpmqtt

Documentation

Index

• func NewConnectorInstance(name string, config interface{}) model.ConnInterface
• type Connector
  • func (conn *Connector) GetConnection() interface{}
  • func (conn *Connector) GetState() string
  • func (conn *Connector) Init() error
  • func (conn *Connector) LoadConfig(config interface{}) error
  • func (conn *Connector) Stop()
• type ConnectorConfig
• type Message
• type MsgPipeline

Functions

func NewConnectorInstance

func NewConnectorInstance(name string, config interface{}) model.ConnInterface

Types

type Connector

type Connector struct {
	// contains filtered or unexported fields
}

func (*Connector) GetConnection

func (conn *Connector) GetConnection() interface{}

Returns

func (*Connector) GetState

func (conn *Connector) GetState() string

func (*Connector) Init

func (conn *Connector) Init() error

func (*Connector) LoadConfig

func (conn *Connector) LoadConfig(config interface{}) error

func (*Connector) Stop

func (conn *Connector) Stop()

type ConnectorConfig

type ConnectorConfig struct {
	MqttServerURI         string
	MqttUsername          string
	MqttPassword          string
	MqttTopicGlobalPrefix string
	MqttClientIdPrefix    string
}

type Message

type Message struct {
	AddressStr string
	Address    fimpgo.Address
	Payload    fimpgo.FimpMessage
	RawPayload []byte
	Header     map[string]string
	CancelOp   bool // if true , listening end should close all operations
}

type MsgPipeline

type MsgPipeline chan Message