Versions in this module Expand all Collapse all v0 v0.0.2 Apr 16, 2024 v0.0.1 Mar 7, 2024 Changes in this version + type Client interface + Connect func(clientId string) error + Disconnect func(quiesce uint) + IsConnected func() bool + IsConnectionOpen func() bool + Publish func(topic string, qos byte, retained bool, payload interface{}) error + PublishWithReply func(topic string, payload interface{}) (mqtt.Message, error) + Subscribe func(topic string, qos byte, callback mqtt.MessageHandler) error + SubscribeMultiple func(filters map[string]byte, callback mqtt.MessageHandler) error + Unsubscribe func(topics ...string) error + func New(endpoint string, options ...ClientOption) (Client, error) + type ClientOption func(*client) error + func WithCertificate(certificate tls.Certificate) ClientOption + func WithCertificateAndPrivateKey(certFile, keyFile string) ClientOption + func WithConnectTimeout(timeout time.Duration) ClientOption + func WithLogger(logger *slog.Logger) ClientOption + func WithMQTTConfig(config *mqtt.ClientOptions) ClientOption + func WithPublishTimeout(timeout time.Duration) ClientOption + func WithRootCA(pem []byte) ClientOption + func WithRootCAFile(caFile string) ClientOption + func WithSubscribeTimeout(timeout time.Duration) ClientOption + func WithTLSConfig(tlsConfig *tls.Config) ClientOption + type CreateCertificateFromCsrRequest struct + CertificateSigningRequest string + type CreateCertificateFromCsrResponse struct + CertificateId string + CertificateOwnershipToken string + CertificatePem string + type CreateKeysAndCertificateResponse struct + CertificateId string + CertificateOwnershipToken string + CertificatePem string + PrivateKey string + type Provisioner interface + Provisioning func(templateName string, parameters map[string]interface{}) (*ProvisioningResponse, error) + ProvisioningWithCsr func(templateName string, parameters map[string]interface{}) (*ProvisioningResponse, error) + func CreateProvisioner(client Client, options ...ProvisionerOption) Provisioner + type ProvisionerOption func(provisioner *provisioner) + func WithCurve(curve elliptic.Curve) ProvisionerOption + func WithSignatureAlgorithm(signatureAlgorithm x509.SignatureAlgorithm) ProvisionerOption + type ProvisioningErrorResponse struct + ErrorCode string + ErrorMessage string + StatusCode int + type ProvisioningResponse struct + Certificate string + CertificateId string + DeviceConfiguration map[string]interface{} + PrivateKey string + ThingName string + type RegisterThingRequest struct + CertificateOwnershipToken string + Parameters map[string]interface{} + type RegisterThingResponse struct + DeviceConfiguration map[string]interface{} + ThingName string