lib

Documentation

Index

• func AuthWebhooks(ctx context.Context, config configuration.Config, ...)
• func CreateCommandHandler(config configuration.Config, mqtt Mqtt) platform_connector_lib.AsyncCommandHandler
• func CreateQueuedCommandHandler(ctx context.Context, config configuration.Config, mqtt Mqtt) platform_connector_lib.AsyncCommandHandler
• func Start(basectx context.Context, config configuration.Config) (err error)
• type Mqtt
  • func MqttStart(ctx context.Context, config configuration.Config) (mqtt Mqtt, err error)
• type Mqtt4
  • func Mqtt4Start(ctx context.Context, config configuration.Config) (mqtt *Mqtt4, err error)
  • func (this *Mqtt4) Publish(topic, msg string) (err error)
• type Mqtt5
  • func Mqtt5Start(ctx context.Context, config configuration.Config) (mqtt *Mqtt5, err error)
  • func (this *Mqtt5) Publish(topic, msg string) (err error)

Functions

func AuthWebhooks

func AuthWebhooks(ctx context.Context, config configuration.Config, connector *platform_connector_lib.Connector, connectionLog connectionlog.ConnectionLog)

func CreateCommandHandler

func CreateCommandHandler(config configuration.Config, mqtt Mqtt) platform_connector_lib.AsyncCommandHandler

func CreateQueuedCommandHandler

func CreateQueuedCommandHandler(ctx context.Context, config configuration.Config, mqtt Mqtt) platform_connector_lib.AsyncCommandHandler

func Start

func Start(basectx context.Context, config configuration.Config) (err error)

Types

type Mqtt

type Mqtt interface {
	Publish(topic, msg string) (err error)
}

func MqttStart

func MqttStart(ctx context.Context, config configuration.Config) (mqtt Mqtt, err error)

type Mqtt4

type Mqtt4 struct {
	Debug bool
	// contains filtered or unexported fields
}

func Mqtt4Start

func Mqtt4Start(ctx context.Context, config configuration.Config) (mqtt *Mqtt4, err error)

func (*Mqtt4) Publish

func (this *Mqtt4) Publish(topic, msg string) (err error)

type Mqtt5

type Mqtt5 struct {
	Debug bool
	// contains filtered or unexported fields
}

func Mqtt5Start

func Mqtt5Start(ctx context.Context, config configuration.Config) (mqtt *Mqtt5, err error)

func (*Mqtt5) Publish

func (this *Mqtt5) Publish(topic, msg string) (err error)