mqtt_client

Documentation

Index

• type Consumer
  • func NewConsumer(cfg config.Config, id int) Consumer
• type Mqtt5Consumer
  • func (c Mqtt5Consumer) Start(ctx context.Context, subscribed chan bool)
  • func (c Mqtt5Consumer) Stop(reason string)
• type Mqtt5Publisher
  • func (p Mqtt5Publisher) Send()
  • func (p Mqtt5Publisher) Start(ctx context.Context)
  • func (p Mqtt5Publisher) StartFullSpeed(ctx context.Context)
  • func (p Mqtt5Publisher) StartIdle(ctx context.Context)
  • func (p Mqtt5Publisher) StartRateLimited(ctx context.Context)
  • func (p Mqtt5Publisher) Stop(reason string)
• type MqttConsumer
  • func (c MqttConsumer) Start(ctx context.Context, subscribed chan bool)
  • func (c MqttConsumer) Stop(reason string)
• type 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)
• type Publisher
  • func NewPublisher(cfg config.Config, id int) Publisher

Types

type Consumer

type Consumer interface {
	Start(context.Context, chan bool)
}

func NewConsumer

func NewConsumer(cfg config.Config, id int) Consumer

type Mqtt5Consumer

type Mqtt5Consumer struct {
	Id         int
	Connection *autopaho.ConnectionManager
	Topic      string
	Config     config.Config
}

func (Mqtt5Consumer) Start

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

func (Mqtt5Consumer) Stop

func (c Mqtt5Consumer) Stop(reason string)

type Mqtt5Publisher

type Mqtt5Publisher struct {
	Id         int
	Connection *autopaho.ConnectionManager
	Topic      string
	Config     config.Config
	// contains filtered or unexported fields
}

func (Mqtt5Publisher) Send

func (p Mqtt5Publisher) Send()

func (Mqtt5Publisher) Start

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

func (Mqtt5Publisher) StartFullSpeed

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

func (Mqtt5Publisher) StartIdle

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

func (Mqtt5Publisher) StartRateLimited

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

func (Mqtt5Publisher) Stop

func (p Mqtt5Publisher) Stop(reason string)

type MqttConsumer

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

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 (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)

type Publisher

type Publisher interface {
	Start(context.Context)
}

func NewPublisher

func NewPublisher(cfg config.Config, id int) Publisher