mqtt_client

package

v0.1.2 Latest Latest Go to latest Published: Sep 28, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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

func (c MqttConsumer) Start(subscribed chan bool)

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

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

func (p MqttPublisher) Start()

func (p MqttPublisher) StartFullSpeed()

func (p MqttPublisher) StartRateLimited()