lib

Documentation

Index

• func CreateTLSConfig(ClientCertificatePath string, PrivateKeyPath string, ...) (tlsConfig *tls.Config, err error)
• func GetCommandHandler(correlationservice *correlation.CorrelationService, mqtt Mqtt, ...) platform_connector_lib.AsyncCommandHandler
• func GetQueuedCommandHandler(ctx context.Context, correlationservice *correlation.CorrelationService, ...) platform_connector_lib.AsyncCommandHandler
• func InitWebhooks(config configuration.Config, connector *platform_connector_lib.Connector, ...) *http.Server
• func Start(ctx context.Context, config configuration.Config) (err error)
• func StringToList(str string) []string
• 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)
• type RequestEnvelope

Functions

func CreateTLSConfig

func CreateTLSConfig(ClientCertificatePath string, PrivateKeyPath string, RootCACertificatePath string) (tlsConfig *tls.Config, err error)

func GetCommandHandler

func GetCommandHandler(correlationservice *correlation.CorrelationService, mqtt Mqtt, config configuration.Config) platform_connector_lib.AsyncCommandHandler

func GetQueuedCommandHandler

func GetQueuedCommandHandler(ctx context.Context, correlationservice *correlation.CorrelationService, mqtt Mqtt, config configuration.Config) platform_connector_lib.AsyncCommandHandler

func InitWebhooks

func InitWebhooks(config configuration.Config, connector *platform_connector_lib.Connector, logger connectionlog.Logger, handlers []handler.Handler, connectionLimit *connectionlimit.ConnectionLimitHandler) *http.Server

func Start

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

func StringToList

func StringToList(str string) []string

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)

type RequestEnvelope

type RequestEnvelope struct {
	CorrelationId      string                                   `json:"correlation_id"`
	Payload            platform_connector_lib.CommandRequestMsg `json:"payload"`
	Time               int64                                    `json:"timestamp"`
	CompletionStrategy string                                   `json:"completion_strategy"`
}