Documentation ¶
Index ¶
- type Client
- type ClientOption
- 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
- type CreateCertificateFromCsrResponse
- type CreateKeysAndCertificateResponse
- type Provisioner
- type ProvisionerOption
- type ProvisioningErrorResponse
- type ProvisioningResponse
- type RegisterThingRequest
- type RegisterThingResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface { IsConnected() bool IsConnectionOpen() bool Connect(clientId string) error Disconnect(quiesce uint) Publish(topic string, qos byte, retained bool, payload interface{}) error PublishWithReply(topic string, payload interface{}) (mqtt.Message, error) Subscribe(topic string, qos byte, callback mqtt.MessageHandler) error SubscribeMultiple(filters map[string]byte, callback mqtt.MessageHandler) error Unsubscribe(topics ...string) error }
Client is AWS IoT Core Client.
type ClientOption ¶
type ClientOption func(*client) error
ClientOption type
func WithCertificate ¶
func WithCertificate(certificate tls.Certificate) ClientOption
WithCertificate is Certificate setter
func WithCertificateAndPrivateKey ¶
func WithCertificateAndPrivateKey(certFile, keyFile string) ClientOption
WithCertificateAndPrivateKey is Certificate setter
func WithConnectTimeout ¶
func WithConnectTimeout(timeout time.Duration) ClientOption
WithConnectTimeout is connection timeout setter
func WithMQTTConfig ¶
func WithMQTTConfig(config *mqtt.ClientOptions) ClientOption
WithMQTTConfig is MQTT Client config setter
func WithPublishTimeout ¶
func WithPublishTimeout(timeout time.Duration) ClientOption
WithPublishTimeout is publish timeout setter
func WithRootCAFile ¶
func WithRootCAFile(caFile string) ClientOption
WithRootCAFile is Root CA PEM with file setter
func WithSubscribeTimeout ¶
func WithSubscribeTimeout(timeout time.Duration) ClientOption
WithSubscribeTimeout is subscription timeout setter
func WithTLSConfig ¶
func WithTLSConfig(tlsConfig *tls.Config) ClientOption
WithTLSConfig is TLS Config setter
type CreateCertificateFromCsrRequest ¶
type CreateCertificateFromCsrRequest struct {
CertificateSigningRequest string `json:"certificateSigningRequest"`
}
type Provisioner ¶
type Provisioner interface { Provisioning(templateName string, parameters map[string]interface{}) (*ProvisioningResponse, error) ProvisioningWithCsr(templateName string, parameters map[string]interface{}) (*ProvisioningResponse, error) }
func CreateProvisioner ¶
func CreateProvisioner(client Client, options ...ProvisionerOption) Provisioner
type ProvisionerOption ¶
type ProvisionerOption func(provisioner *provisioner)
ProvisionerOption type
func WithCurve ¶
func WithCurve(curve elliptic.Curve) ProvisionerOption
WithCurve is curve implements setter
func WithSignatureAlgorithm ¶
func WithSignatureAlgorithm(signatureAlgorithm x509.SignatureAlgorithm) ProvisionerOption
WithSignatureAlgorithm is signature algorithm setter
type ProvisioningResponse ¶
type RegisterThingRequest ¶
type RegisterThingResponse ¶
Click to show internal directories.
Click to hide internal directories.