Documentation ¶
Index ¶
- type MQTTConnection
- func (mqttcn *MQTTConnection) Connect() (err error)
- func (mqttcn *MQTTConnection) Disconnect(quiesce uint) (err error)
- func (mqttcn *MQTTConnection) Fprint(w io.Writer) (err error)
- func (mqttcn *MQTTConnection) IsConnected() (connected bool)
- func (mqttcn *MQTTConnection) IsSubscribed(topic string) (issbscrbed bool)
- func (mqttcn *MQTTConnection) Publish(topic string, qos byte, retained bool, message string) (err error)
- func (mqttcn *MQTTConnection) Resubscribe(unsubscribefirst bool, topic ...string) (err error)
- func (mqttcn *MQTTConnection) String() (s string)
- func (mqttcn *MQTTConnection) Subscribe(topic string, qos byte) (err error)
- func (mqttcn *MQTTConnection) SubscribedTopics(alreadylck ...bool) (subscrbdtpcs []string)
- func (mqttcn *MQTTConnection) Subscriptions(alreadylck ...bool) (subscrptns []*mqttsubscription)
- func (mqttcn *MQTTConnection) Unsubscribe(topic ...string) (err error)
- func (mqttcn *MQTTConnection) UnsubscribeAll() (err error)
- func (mqttcn *MQTTConnection) UpdateConnection(autoconnect bool, broker string, port int, user string, password string)
- type MQTTManager
- func (mqttmngr *MQTTManager) ActivateEvent(event string, eventpath string, args ...map[string]interface{})
- func (mqttmngr *MQTTManager) ActivateTopic(topic string, topicpath ...string)
- func (mqttmngr *MQTTManager) ActiveTopics() (atvtpcs map[string]string)
- func (mqttmngr *MQTTManager) Connect(alias string) (err error)
- func (mqttmngr *MQTTManager) Connected(alias string)
- func (mqttmngr *MQTTManager) Connection(alias string) (mqttcn *MQTTConnection)
- func (mqttmngr *MQTTManager) ConnectionExist(alias string) (exists bool)
- func (mqttmngr *MQTTManager) ConnectionInfo(alias string) (mqttcninfo string)
- func (mqttmngr *MQTTManager) Connections() (aliases []string)
- func (mqttmngr *MQTTManager) DeactivateEvent(event string)
- func (mqttmngr *MQTTManager) DeactivateTopic(topic string)
- func (mqttmngr *MQTTManager) Disconnect(alias string, quiesce uint) (err error)
- func (mqttmngr *MQTTManager) Disconnected(alias string, err error)
- func (mqttmngr *MQTTManager) Fprint(w io.Writer)
- func (mqttmngr *MQTTManager) IsConnect(alias string) (connected bool)
- func (mqttmngr *MQTTManager) IsSubscribed(alias string, topic string) (issbscrbed bool)
- func (mqttmngr *MQTTManager) Publish(alias string, topic string, qos byte, retained bool, message string) (err error)
- func (mqttmngr *MQTTManager) RegisterConnection(alias string, a ...interface{})
- func (mqttmngr *MQTTManager) String() (s string)
- func (mqttmngr *MQTTManager) Subscribe(alias string, topic string, qos byte) (err error)
- func (mqttmngr *MQTTManager) Subscriptions(alias string) (subscrptns []*mqttsubscription)
- func (mqttmngr *MQTTManager) UnregisterConnection(alias ...string)
- func (mqttmngr *MQTTManager) Unsubscribe(alias string, topic string) (err error)
- func (mqttmngr *MQTTManager) ValidEvents() (events []string)
- type MQTTManagerAPI
- type Message
- type MqttEvent
- type MqttEventing
- type MqttMessaging
- type Topic
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MQTTConnection ¶
type MQTTConnection struct { ClientId string // contains filtered or unexported fields }
func NewMQTTConnections ¶
func NewMQTTConnections(clientid string, a ...interface{}) (mqttcn *MQTTConnection)
func (*MQTTConnection) Connect ¶
func (mqttcn *MQTTConnection) Connect() (err error)
func (*MQTTConnection) Disconnect ¶
func (mqttcn *MQTTConnection) Disconnect(quiesce uint) (err error)
func (*MQTTConnection) IsConnected ¶
func (mqttcn *MQTTConnection) IsConnected() (connected bool)
func (*MQTTConnection) IsSubscribed ¶
func (mqttcn *MQTTConnection) IsSubscribed(topic string) (issbscrbed bool)
func (*MQTTConnection) Resubscribe ¶
func (mqttcn *MQTTConnection) Resubscribe(unsubscribefirst bool, topic ...string) (err error)
func (*MQTTConnection) String ¶
func (mqttcn *MQTTConnection) String() (s string)
func (*MQTTConnection) Subscribe ¶
func (mqttcn *MQTTConnection) Subscribe(topic string, qos byte) (err error)
func (*MQTTConnection) SubscribedTopics ¶
func (mqttcn *MQTTConnection) SubscribedTopics(alreadylck ...bool) (subscrbdtpcs []string)
func (*MQTTConnection) Subscriptions ¶
func (mqttcn *MQTTConnection) Subscriptions(alreadylck ...bool) (subscrptns []*mqttsubscription)
func (*MQTTConnection) Unsubscribe ¶
func (mqttcn *MQTTConnection) Unsubscribe(topic ...string) (err error)
func (*MQTTConnection) UnsubscribeAll ¶
func (mqttcn *MQTTConnection) UnsubscribeAll() (err error)
func (*MQTTConnection) UpdateConnection ¶
type MQTTManager ¶
type MQTTManager struct { MqttMessaging MqttMessaging MqttEventing MqttEventing // contains filtered or unexported fields }
func GLOBALMQTTMANAGER ¶
func GLOBALMQTTMANAGER() *MQTTManager
func NewMQTTManager ¶
func NewMQTTManager(a ...interface{}) (mqttmngr *MQTTManager)
func (*MQTTManager) ActivateEvent ¶
func (mqttmngr *MQTTManager) ActivateEvent(event string, eventpath string, args ...map[string]interface{})
func (*MQTTManager) ActivateTopic ¶
func (mqttmngr *MQTTManager) ActivateTopic(topic string, topicpath ...string)
func (*MQTTManager) ActiveTopics ¶
func (mqttmngr *MQTTManager) ActiveTopics() (atvtpcs map[string]string)
func (*MQTTManager) Connect ¶
func (mqttmngr *MQTTManager) Connect(alias string) (err error)
func (*MQTTManager) Connected ¶
func (mqttmngr *MQTTManager) Connected(alias string)
func (*MQTTManager) Connection ¶
func (mqttmngr *MQTTManager) Connection(alias string) (mqttcn *MQTTConnection)
func (*MQTTManager) ConnectionExist ¶
func (mqttmngr *MQTTManager) ConnectionExist(alias string) (exists bool)
func (*MQTTManager) ConnectionInfo ¶
func (mqttmngr *MQTTManager) ConnectionInfo(alias string) (mqttcninfo string)
func (*MQTTManager) Connections ¶
func (mqttmngr *MQTTManager) Connections() (aliases []string)
func (*MQTTManager) DeactivateEvent ¶
func (mqttmngr *MQTTManager) DeactivateEvent(event string)
func (*MQTTManager) DeactivateTopic ¶
func (mqttmngr *MQTTManager) DeactivateTopic(topic string)
func (*MQTTManager) Disconnect ¶
func (mqttmngr *MQTTManager) Disconnect(alias string, quiesce uint) (err error)
func (*MQTTManager) Disconnected ¶
func (mqttmngr *MQTTManager) Disconnected(alias string, err error)
func (*MQTTManager) Fprint ¶
func (mqttmngr *MQTTManager) Fprint(w io.Writer)
func (*MQTTManager) IsConnect ¶
func (mqttmngr *MQTTManager) IsConnect(alias string) (connected bool)
func (*MQTTManager) IsSubscribed ¶
func (mqttmngr *MQTTManager) IsSubscribed(alias string, topic string) (issbscrbed bool)
func (*MQTTManager) RegisterConnection ¶
func (mqttmngr *MQTTManager) RegisterConnection(alias string, a ...interface{})
func (*MQTTManager) String ¶
func (mqttmngr *MQTTManager) String() (s string)
func (*MQTTManager) Subscribe ¶
func (mqttmngr *MQTTManager) Subscribe(alias string, topic string, qos byte) (err error)
func (*MQTTManager) Subscriptions ¶
func (mqttmngr *MQTTManager) Subscriptions(alias string) (subscrptns []*mqttsubscription)
func (*MQTTManager) UnregisterConnection ¶
func (mqttmngr *MQTTManager) UnregisterConnection(alias ...string)
func (*MQTTManager) Unsubscribe ¶
func (mqttmngr *MQTTManager) Unsubscribe(alias string, topic string) (err error)
func (*MQTTManager) ValidEvents ¶
func (mqttmngr *MQTTManager) ValidEvents() (events []string)
type MQTTManagerAPI ¶
type MQTTManagerAPI interface { ActivateTopic(topic string, topicpath ...string) DeactivateTopic(topic string) ActiveTopics() (atvtpcs map[string]string) Connections() (aliases []string) Connection(alias string) (mqttcn *MQTTConnection) ConnectionInfo(alias string) (mqttcninfo string) RegisterConnection(alias string, a ...interface{}) Fprint(w io.Writer) String() (s string) UnregisterConnection(alias ...string) IsConnect(alias string) (connected bool) Connect(alias string) (err error) Disconnect(alias string, quiesce uint) (err error) IsSubscribed(alias string, topic string) (issbscrbed bool) Subscriptions(alias string) (subscrptns []*mqttsubscription) Subscribe(alias string, topic string, qos byte) (err error) Unsubscribe(alias string, topic string) (err error) Publish(alias string, topic string, qos byte, retained bool, message string) (err error) }
type Message ¶
type Message interface { Duplicate() bool Qos() byte Retained() bool Topic() string MessageID() uint16 Payload() []byte Connection() *MQTTConnection TopicPath() string Manager() MQTTManagerAPI Ack() }
type MqttEvent ¶
type MqttEvent interface { Event() string EventPath() string MqttConnection() *MQTTConnection MqttManager() MQTTManagerAPI Args() map[string]interface{} }
type MqttEventing ¶
type MqttEventing func(event MqttEvent)
type MqttMessaging ¶
type MqttMessaging func(message Message)
Click to show internal directories.
Click to hide internal directories.