Documentation
¶
Index ¶
- type Connection
- func (c *Connection) GetClientId() string
- func (c *Connection) Publish(topic string, retained bool, input chan string) error
- func (c *Connection) PublishWithTransform(topic string, retained bool, input chan interface{}, transform fn) error
- func (c *Connection) SetDebugging(state bool) *Connection
- func (c *Connection) SetPassword(password string) *Connection
- func (c *Connection) SetPersistentClient(persistent bool) *Connection
- func (c *Connection) SetPublisherQos(qos byte) *Connection
- func (c *Connection) SetSubscriberQoS(qos byte) *Connection
- func (c *Connection) SetTLSConfig(tlsConfig *tls.Config) *Connection
- func (c *Connection) SetUsername(username string) *Connection
- func (c *Connection) Subscribe(topic string, output chan []byte) error
- type DebugLevel
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Connection ¶ added in v0.3.0
type Connection struct {
PerformanceDebugChannel chan string
DebugChannel chan string
// contains filtered or unexported fields
}
func NewMqttConnection ¶ added in v0.3.0
func NewMqttConnection(clientId string, hostname string, port int) *Connection
func (*Connection) GetClientId ¶ added in v0.3.0
func (c *Connection) GetClientId() string
func (*Connection) Publish ¶ added in v0.3.0
func (c *Connection) Publish(topic string, retained bool, input chan string) error
func (*Connection) PublishWithTransform ¶ added in v0.3.0
func (c *Connection) PublishWithTransform(topic string, retained bool, input chan interface{}, transform fn) error
func (*Connection) SetDebugging ¶ added in v0.3.0
func (c *Connection) SetDebugging(state bool) *Connection
func (*Connection) SetPassword ¶ added in v0.3.0
func (c *Connection) SetPassword(password string) *Connection
func (*Connection) SetPersistentClient ¶ added in v0.3.0
func (c *Connection) SetPersistentClient(persistent bool) *Connection
func (*Connection) SetPublisherQos ¶ added in v0.3.0
func (c *Connection) SetPublisherQos(qos byte) *Connection
func (*Connection) SetSubscriberQoS ¶ added in v0.3.0
func (c *Connection) SetSubscriberQoS(qos byte) *Connection
func (*Connection) SetTLSConfig ¶ added in v0.3.0
func (c *Connection) SetTLSConfig(tlsConfig *tls.Config) *Connection
func (*Connection) SetUsername ¶ added in v0.3.0
func (c *Connection) SetUsername(username string) *Connection
type DebugLevel ¶ added in v0.3.0
type DebugLevel int
Source Files
Click to show internal directories.
Click to hide internal directories.