client

Documentation

Index

• func MqttPayloadToBytes(payload interface{}) ([]byte, error)
• func NewErrorToken(err error) mqtt.Token
• func NewNamespaceClientOptions(clientId string) *mqtt.ClientOptions
• func SetFactory(fac Factory)
• type Factory
• type PublishingConfig
  • func NewTopicConfig(topic string) PublishingConfig
  • func (a *PublishingConfig) Publish(target mqtt.Client, payload interface{}) mqtt.Token
  • func (a *PublishingConfig) RetainFlag() bool
  • func (a *PublishingConfig) WithRetainFlag(retain bool)
• type QoS
• type Subscription
• type SubscriptionConfig
  • func (a *SubscriptionConfig) QualityOfService() QoS
  • func (a *SubscriptionConfig) Subscribe(target mqtt.Client, subscription Subscription) mqtt.Token
  • func (a *SubscriptionConfig) Topic() string
  • func (a *SubscriptionConfig) WithQualityOfService(qos QoS)

Functions

func MqttPayloadToBytes

func MqttPayloadToBytes(payload interface{}) ([]byte, error)

func NewErrorToken

func NewErrorToken(err error) mqtt.Token

func NewNamespaceClientOptions

func NewNamespaceClientOptions(clientId string) *mqtt.ClientOptions

func SetFactory

func SetFactory(fac Factory)

Types

type Factory

type Factory func(options config.MqttClientConfig, onConnect func(mqtt.Client)) (mqtt.Client, error)

var ClientFactory Factory

type PublishingConfig

type PublishingConfig struct {
	SubscriptionConfig
	// contains filtered or unexported fields
}

func NewTopicConfig

func NewTopicConfig(topic string) PublishingConfig

func (*PublishingConfig) Publish

func (a *PublishingConfig) Publish(target mqtt.Client, payload interface{}) mqtt.Token

func (*PublishingConfig) RetainFlag

func (a *PublishingConfig) RetainFlag() bool

func (*PublishingConfig) WithRetainFlag

func (a *PublishingConfig) WithRetainFlag(retain bool)

type QoS

type QoS byte

const (
	AtMostOnce  QoS = 0
	AtLeastOnce QoS = 1
	ExactlyOnce QoS = 2
)

type Subscription

type Subscription interface {
	PayloadFactory() interface{}
	SubscriptionHandler(payload interface{}, err error)
}

type SubscriptionConfig

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

func (*SubscriptionConfig) QualityOfService

func (a *SubscriptionConfig) QualityOfService() QoS

func (*SubscriptionConfig) Subscribe

func (a *SubscriptionConfig) Subscribe(target mqtt.Client, subscription Subscription) mqtt.Token

func (*SubscriptionConfig) Topic

func (a *SubscriptionConfig) Topic() string

func (*SubscriptionConfig) WithQualityOfService

func (a *SubscriptionConfig) WithQualityOfService(qos QoS)