Documentation ¶
Overview ¶
broker is an package about define MQTT connecion.
Index ¶
- func GetBrokerNames(brokers []*Broker) []string
- func MQTTConnect(gwName string, b *Broker) (*MQTT.Client, error)
- func NewTLSConfig(b *Broker) (*tls.Config, error)
- type Broker
- func (b *Broker) AddSubscribed(deviceName string, qos byte) error
- func (b *Broker) Close() error
- func (b *Broker) DeleteSubscribed(deviceName string, qos byte) error
- func (b *Broker) FourceClose() error
- func (b *Broker) GenerateTopic(msg *message.Message) (message.TopicString, error)
- func (b *Broker) IsConnected() bool
- func (b *Broker) MQTTClientSetup(gwName string) error
- func (b *Broker) Publish(msg *message.Message) error
- func (broker *Broker) String() string
- func (b *Broker) SubscribeOnConnect(client *MQTT.Client)
- type Brokers
- type Subscribed
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetBrokerNames ¶
func MQTTConnect ¶
MQTTConnect returns MQTTClient with options.
Types ¶
type Broker ¶
type Broker struct { GatewayName string Name string `validate:"max=256,regexp=[^/]+,validtopic"` Priority int `validate:"min=1,max=3"` Host string `validate:"max=256"` Port int `validate:"min=1,max=65535"` Username string `validate:"max=256"` Password string `validate:"max=256"` RetryInterval int `validate:"min=0"` TopicPrefix string `validate:"max=256"` IsWill bool WillMessage []byte `validate:"max=256"` WillTopic string `validate:"max=256,validtopic"` Tls bool CaCert string `validate:"max=256"` ClientCert string `validate:"max=256"` ClientKey string `validate:"max=256"` TLSConfig *tls.Config Subscribed Subscribed // list of subscribed topics GwChan chan message.Message MQTTClient *MQTT.Client // contains filtered or unexported fields }
func (*Broker) DeleteSubscribed ¶
func (*Broker) FourceClose ¶
func (*Broker) GenerateTopic ¶
GenerateTopic generates topic from topicprefix, gwname and message.
func (*Broker) IsConnected ¶
func (*Broker) MQTTClientSetup ¶
MQTTClientSetup setup MQTTOptions and connect ot broker.
func (*Broker) SubscribeOnConnect ¶
type Brokers ¶
type Brokers []*Broker
func NewBrokers ¶
NewBrokers returns []*Broker from config.Config. If validation failes, retrun error.
type Subscribed ¶
func NewSubscribed ¶
func NewSubscribed() Subscribed
func (Subscribed) Delete ¶
func (s Subscribed) Delete(topic string) error
func (Subscribed) Length ¶
func (s Subscribed) Length() int
func (Subscribed) List ¶
func (s Subscribed) List() map[string]byte
Click to show internal directories.
Click to hide internal directories.