mqtt_client

Documentation

Index

• type MqttConsumer
  • func NewConsumer(cfg config.Config, id int) *MqttConsumer
  • func (c MqttConsumer) Start(ctx context.Context, subscribed chan bool)
  • func (c MqttConsumer) Stop(reason string)
• type MqttPublisher
  • func NewPublisher(cfg config.Config, id int) *MqttPublisher
  • func (p MqttPublisher) Send()
  • func (p MqttPublisher) Start(ctx context.Context)
  • func (p MqttPublisher) StartFullSpeed(ctx context.Context)
  • func (p MqttPublisher) StartIdle(ctx context.Context)
  • func (p MqttPublisher) StartRateLimited(ctx context.Context)
  • func (p MqttPublisher) Stop(reason string)

Types

type MqttConsumer

type MqttConsumer struct {
	Id         int
	Connection mqtt.Client
	Topic      string
	Config     config.Config
}

func NewConsumer

func NewConsumer(cfg config.Config, id int) *MqttConsumer

func (MqttConsumer) Start

func (c MqttConsumer) Start(ctx context.Context, subscribed chan bool)

func (MqttConsumer) Stop

func (c MqttConsumer) Stop(reason string)

type MqttPublisher

type MqttPublisher struct {
	Id         int
	Connection mqtt.Client
	Topic      string
	Config     config.Config
	// contains filtered or unexported fields
}

func NewPublisher

func NewPublisher(cfg config.Config, id int) *MqttPublisher

func (MqttPublisher) Send

func (p MqttPublisher) Send()

func (MqttPublisher) Start

func (p MqttPublisher) Start(ctx context.Context)

func (MqttPublisher) StartFullSpeed

func (p MqttPublisher) StartFullSpeed(ctx context.Context)

func (MqttPublisher) StartIdle

func (p MqttPublisher) StartIdle(ctx context.Context)

func (MqttPublisher) StartRateLimited

func (p MqttPublisher) StartRateLimited(ctx context.Context)

func (MqttPublisher) Stop

func (p MqttPublisher) Stop(reason string)