twomqtt

package module

Go to main page

Versions in this module

v0

v0.4.6

Dec 25, 2019

Changes in this version

+ type MoqClient struct

+ func (t MoqClient) AddRoute(topic string, callback mqtt.MessageHandler)

+ func (t MoqClient) Connect() mqtt.Token

+ func (t MoqClient) Disconnect(quiesce uint)

+ func (t MoqClient) IsConnected() bool

+ func (t MoqClient) IsConnectionOpen() bool

+ func (t MoqClient) OptionsReader() mqtt.ClientOptionsReader

+ func (t MoqClient) Publish(topic string, qos byte, retained bool, payload interface{}) mqtt.Token

+ func (t MoqClient) Subscribe(topic string, qos byte, callback mqtt.MessageHandler) mqtt.Token

+ func (t MoqClient) SubscribeMultiple(filters map[string]byte, callback mqtt.MessageHandler) mqtt.Token

+ func (t MoqClient) Unsubscribe(topics ...string) mqtt.Token

+ type MoqToken struct

+ func (t MoqToken) Error() error

+ func (t MoqToken) Wait() bool

+ func (t MoqToken) WaitTimeout(time.Duration) bool

v0.4.5

Dec 25, 2019

Changes in this version

+ type MQTT struct

+ func NewMQTT(opts MQTTOpts) *MQTT

+ func (c *MQTT) Initialize() *MQTT

+ func (c *MQTT) Publish(topic string, payload string) MQTTMessage

+ func (c *MQTT) PublishWithOpts(topic string, payload string, opts MQTTPublishOpts) MQTTMessage

+ func (c *MQTT) Run()

+ func (c *MQTT) SetConnectHandler(handler func()) *MQTT

+ func (c *MQTT) SetDisconnectHandler(handler func()) *MQTT

+ func (c *MQTT) SetDiscoveryHandler(handler func() []MQTTDiscovery) *MQTT

+ func (c *MQTT) SetReadIncomingChannelHandler(handler func()) *MQTT

+ func (c *MQTT) SetSubscribeHandler(handler func()) *MQTT

+ func (c *MQTT) Subscribe(topic string, qos byte, callback mqtt.MessageHandler) mqtt.Token

type MQTTDiscovery

+ func NewMQTTDiscovery(proxyConfig MQTTOpts, deviceName string, sensorName string, sensorType string) *MQTTDiscovery

+ type MQTTMessage struct

+ Payload string

+ Topic string

+ type MQTTOpts struct

+ Broker string

+ ClientID string

+ Discovery bool

+ DiscoveryName string

+ DiscoveryPrefix string

+ Password string

+ TopicPrefix string

+ Username string

+ func (c *MQTTOpts) AvailabilityTopic() string

+ func (c *MQTTOpts) CommandTopic(deviceName string, sensorName string) string

+ func (c *MQTTOpts) StateTopic(deviceName string, sensorName string) string

+ type MQTTPublishOpts struct

+ DuplicateCheck bool

+ Retained bool

v0.3.4

Oct 20, 2019

Changes in this version

type MQTTProxy

+ func (c *MQTTProxy) AdditionalClientTopic() string

v0.3.4-dev

Oct 20, 2019

v0.3.3

Oct 12, 2019

v0.3.2

Sep 26, 2019

v0.3.1

Sep 22, 2019

Changes in this version

type MQTTDiscovery

+ Device MQTTDiscoveryDevice

+ type MQTTDiscoveryDevice struct

+ Connections []string

+ Identifiers []string

+ Manufacturer string

+ Model string

+ Name string

+ SWVersion string

v0.3.0

Sep 20, 2019

v0.2.1

Sep 16, 2019

v0.2.0

Sep 16, 2019

Changes in this version

+ type CommandObserver interface

+ ReceiveCommand func(Command, Event)

+ type CommandPublisher struct

+ func (c *CommandPublisher) Register(l CommandObserver)

+ func (c *CommandPublisher) SendCommand(cmd Command, e Event)

+ type StateObserver interface

+ ReceiveState func(Event)

+ type StatePublisher struct

+ func (c *StatePublisher) Register(l StateObserver)

+ func (c *StatePublisher) SendState(e Event)

v0.1.1

Sep 2, 2019

Changes in this version

type MQTTProxy

+ func (c *MQTTProxy) PublishWithOpts(topic string, payload string, opts MQTTProxyPublishOptions)

+ type MQTTProxyPublishOptions struct

+ DuplicateCheck bool

+ Retained bool

v0.1.0

Aug 31, 2019

Changes in this version

+ func MQTTDiscoveryOverride(field reflect.StructField) (string, bool)

+ func MQTTOverride(field reflect.StructField) (string, bool)

+ func SimpleKVMapParser(kvSep string, itemSep string) func(v string) (interface{}, error)

+ type Command = int64

+ type Event struct

+ Payload interface{}

+ Type reflect.Type

+ type GeneralConfig struct

+ DebugLogLevel bool

+ type MQTTDiscovery struct

+ AuxCommandTopic string

+ AuxStateTemplate string

+ AuxStateTopic string

+ AvailabilityTopic string

+ AwayModeCommandTopic string

+ AwayModeStateTemplate string

+ AwayModeStateTopic string

+ BrightnessCommandTopic string

+ BrightnessScale string

+ BrightnessStateTopic string

+ BrightnessValueTemplate string

+ ColorTempCommandTopic string

+ ColorTempStateTopic string

+ ColorTempValueTemplate string

+ CommandTopic string

+ Component string

+ CurrentTemperatureTopic string

+ DeviceClass string

+ DiscoveryName string

+ DiscoveryPrefix string

+ EffectCommandTopic string

+ EffectList string

+ EffectStateTopic string

+ EffectValueTemplate string

+ ExpireAfter string

+ FanModeCommandTopic string

+ FanModeStateTemplate string

+ FanModeStateTopic string

+ ForceUpdate string

+ HoldCommandTopic string

+ HoldStateTemplate string

+ HoldStateTopic string

+ Icon string

+ Initial string

+ JSONAttributes string

+ JSONAttributesTopic string

+ MaxTemp string

+ MinTemp string

+ ModeCommandTopic string

+ ModeStateTemplate string

+ ModeStateTopic string

+ Name string

+ NodeID string

+ ObjectID string

+ OnCommandType string

+ Optimistic string

+ OscillationCommandTopic string

+ OscillationStateTopic string

+ OscillationValueTemplate string

+ PayloadArmAway string

+ PayloadArmHome string

+ PayloadAvailable string

+ PayloadClose string

+ PayloadDisarm string

+ PayloadHighSpeed string

+ PayloadLock string

+ PayloadLowSpeed string

+ PayloadMediumSpeed string

+ PayloadNotAvailable string

+ PayloadOff string

+ PayloadOn string

+ PayloadOpen string

+ PayloadOscillationOff string

+ PayloadOscillationOn string

+ PayloadStop string

+ PayloadUnlock string

+ PowerCommandTopic string

+ Retain string

+ RgbCommandTemplate string

+ RgbCommandTopic string

+ RgbStateTopic string

+ RgbValueTemplate string

+ SendIfOff string

+ SetPositionTemplate string

+ SetPositionTopic string

+ SpeedCommandTopic string

+ SpeedStateTopic string

+ SpeedValueTemplate string

+ Speeds string

+ StateClosed string

+ StateOff string

+ StateOn string

+ StateOpen string

+ StateTopic string

+ StateValueTemplate string

+ SwingModeCommandTopic string

+ SwingModeStateTemplate string

+ SwingModeStateTopic string

+ TemperatureCommandTopic string

+ TemperatureStateTemplate string

+ TemperatureStateTopic string

+ TiltClosedValue string

+ TiltCommandTopic string

+ TiltInvertState string

+ TiltMax string

+ TiltMin string

+ TiltOpenedValue string

+ TiltStatusOptimistic string

+ TiltStatusTopic string

+ Topic string

+ UniqueID string

+ UnitOfMeasurement string

+ ValueTemplate string

+ WhiteValueCommandTopic string

+ WhiteValueStateTopic string

+ WhiteValueTemplate string

+ XyCommandTopic string

+ XyStateTopic string

+ XyValueTemplate string

+ type MQTTProxy struct

+ Client mqtt.Client

+ func NewMQTTProxy(mqttCfg MQTTProxyConfig) *MQTTProxy

+ func (c *MQTTProxy) AvailabilityTopic() string

+ func (c *MQTTProxy) CommandTopic(name string, sensor string) string

+ func (c *MQTTProxy) Initialize(onConn mqtt.OnConnectHandler, onLost mqtt.ConnectionLostHandler)

+ func (c *MQTTProxy) LastPublishedOnTopic(topic string) string

+ func (c *MQTTProxy) LogSettings()

+ func (c *MQTTProxy) NewMQTTDiscovery(name string, sensor string, sensorType string) *MQTTDiscovery

+ func (c *MQTTProxy) Publish(topic string, payload string)

+ func (c *MQTTProxy) PublishDiscovery(mqd *MQTTDiscovery)

+ func (c *MQTTProxy) Run()

+ func (c *MQTTProxy) StateTopic(name string, sensor string) string

+ func (c *MQTTProxy) Subscribe(topic string, qos byte, callback mqtt.MessageHandler) mqtt.Token

+ type MQTTProxyConfig struct

+ Broker string

+ ClientID string

+ Discovery bool

+ DiscoveryName string

+ DiscoveryPrefix string

+ Password string

+ TopicPrefix string

+ Username string

+ type MoqMessage struct

+ PayloadSrc string

+ TopicSrc string

+ func (m *MoqMessage) Ack()

+ func (m *MoqMessage) Duplicate() bool

+ func (m *MoqMessage) MessageID() uint16

+ func (m *MoqMessage) Payload() []byte

+ func (m *MoqMessage) Qos() byte

+ func (m *MoqMessage) Retained() bool

+ func (m *MoqMessage) Topic() string

+ type Observer interface

+ ReceiveCommand func(Command, Event)

+ ReceiveState func(Event)

+ type Publisher interface

+ Register func(Observer)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL