// THIS FILE IS AUTOMATICALLY GENERATED. DO NOT EDIT. // Package iot provides a client for AWS IoT. package iot import ( "fmt" "time" "github.com/aws/aws-sdk-go/aws/awsutil" "github.com/aws/aws-sdk-go/aws/request" "github.com/aws/aws-sdk-go/private/protocol" "github.com/aws/aws-sdk-go/private/protocol/restjson" ) const opAcceptCertificateTransfer = "AcceptCertificateTransfer" // AcceptCertificateTransferRequest generates a "aws/request.Request" representing the // client's request for the AcceptCertificateTransfer operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the AcceptCertificateTransfer method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the AcceptCertificateTransferRequest method. // req, resp := client.AcceptCertificateTransferRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) AcceptCertificateTransferRequest(input *AcceptCertificateTransferInput) (req *request.Request, output *AcceptCertificateTransferOutput) { op := &request.Operation{ Name: opAcceptCertificateTransfer, HTTPMethod: "PATCH", HTTPPath: "/accept-certificate-transfer/{certificateId}", } if input == nil { input = &AcceptCertificateTransferInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &AcceptCertificateTransferOutput{} req.Data = output return } // Accepts a pending certificate transfer. The default state of the certificate // is INACTIVE. // // To check for pending certificate transfers, call ListCertificates to enumerate // your certificates. func (c *IoT) AcceptCertificateTransfer(input *AcceptCertificateTransferInput) (*AcceptCertificateTransferOutput, error) { req, out := c.AcceptCertificateTransferRequest(input) err := req.Send() return out, err } const opAttachPrincipalPolicy = "AttachPrincipalPolicy" // AttachPrincipalPolicyRequest generates a "aws/request.Request" representing the // client's request for the AttachPrincipalPolicy operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the AttachPrincipalPolicy method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the AttachPrincipalPolicyRequest method. // req, resp := client.AttachPrincipalPolicyRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) AttachPrincipalPolicyRequest(input *AttachPrincipalPolicyInput) (req *request.Request, output *AttachPrincipalPolicyOutput) { op := &request.Operation{ Name: opAttachPrincipalPolicy, HTTPMethod: "PUT", HTTPPath: "/principal-policies/{policyName}", } if input == nil { input = &AttachPrincipalPolicyInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &AttachPrincipalPolicyOutput{} req.Data = output return } // Attaches the specified policy to the specified principal (certificate or // other credential). func (c *IoT) AttachPrincipalPolicy(input *AttachPrincipalPolicyInput) (*AttachPrincipalPolicyOutput, error) { req, out := c.AttachPrincipalPolicyRequest(input) err := req.Send() return out, err } const opAttachThingPrincipal = "AttachThingPrincipal" // AttachThingPrincipalRequest generates a "aws/request.Request" representing the // client's request for the AttachThingPrincipal operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the AttachThingPrincipal method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the AttachThingPrincipalRequest method. // req, resp := client.AttachThingPrincipalRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) AttachThingPrincipalRequest(input *AttachThingPrincipalInput) (req *request.Request, output *AttachThingPrincipalOutput) { op := &request.Operation{ Name: opAttachThingPrincipal, HTTPMethod: "PUT", HTTPPath: "/things/{thingName}/principals", } if input == nil { input = &AttachThingPrincipalInput{} } req = c.newRequest(op, input, output) output = &AttachThingPrincipalOutput{} req.Data = output return } // Attaches the specified principal to the specified thing. func (c *IoT) AttachThingPrincipal(input *AttachThingPrincipalInput) (*AttachThingPrincipalOutput, error) { req, out := c.AttachThingPrincipalRequest(input) err := req.Send() return out, err } const opCancelCertificateTransfer = "CancelCertificateTransfer" // CancelCertificateTransferRequest generates a "aws/request.Request" representing the // client's request for the CancelCertificateTransfer operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the CancelCertificateTransfer method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the CancelCertificateTransferRequest method. // req, resp := client.CancelCertificateTransferRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) CancelCertificateTransferRequest(input *CancelCertificateTransferInput) (req *request.Request, output *CancelCertificateTransferOutput) { op := &request.Operation{ Name: opCancelCertificateTransfer, HTTPMethod: "PATCH", HTTPPath: "/cancel-certificate-transfer/{certificateId}", } if input == nil { input = &CancelCertificateTransferInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &CancelCertificateTransferOutput{} req.Data = output return } // Cancels a pending transfer for the specified certificate. // // Note Only the transfer source account can use this operation to cancel a // transfer. (Transfer destinations can use RejectCertificateTransfer instead.) // After transfer, AWS IoT returns the certificate to the source account in // the INACTIVE state. After the destination account has accepted the transfer, // the transfer cannot be cancelled. // // After a certificate transfer is cancelled, the status of the certificate // changes from PENDING_TRANSFER to INACTIVE. func (c *IoT) CancelCertificateTransfer(input *CancelCertificateTransferInput) (*CancelCertificateTransferOutput, error) { req, out := c.CancelCertificateTransferRequest(input) err := req.Send() return out, err } const opCreateCertificateFromCsr = "CreateCertificateFromCsr" // CreateCertificateFromCsrRequest generates a "aws/request.Request" representing the // client's request for the CreateCertificateFromCsr operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the CreateCertificateFromCsr method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the CreateCertificateFromCsrRequest method. // req, resp := client.CreateCertificateFromCsrRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) CreateCertificateFromCsrRequest(input *CreateCertificateFromCsrInput) (req *request.Request, output *CreateCertificateFromCsrOutput) { op := &request.Operation{ Name: opCreateCertificateFromCsr, HTTPMethod: "POST", HTTPPath: "/certificates", } if input == nil { input = &CreateCertificateFromCsrInput{} } req = c.newRequest(op, input, output) output = &CreateCertificateFromCsrOutput{} req.Data = output return } // Creates an X.509 certificate using the specified certificate signing request. // // Note Reusing the same certificate signing request (CSR) results in a distinct // certificate. // // You can create multiple certificates in a batch by creating a directory, // copying multiple .csr files into that directory, and then specifying that // directory on the command line. The following commands show how to create // a batch of certificates given a batch of CSRs. // // Assuming a set of CSRs are located inside of the directory my-csr-directory: // // On Linux and OS X, the command is: // // $ ls my-csr-directory/ | xargs -I {} aws iot create-certificate-from-csr // --certificate-signing-request file://my-csr-directory/{} // // This command lists all of the CSRs in my-csr-directory and pipes each CSR // file name to the aws iot create-certificate-from-csr AWS CLI command to create // a certificate for the corresponding CSR. // // The aws iot create-certificate-from-csr part of the command can also be // run in parallel to speed up the certificate creation process: // // $ ls my-csr-directory/ | xargs -P 10 -I {} aws iot create-certificate-from-csr // --certificate-signing-request file://my-csr-directory/{} // // On Windows PowerShell, the command to create certificates for all CSRs // in my-csr-directory is: // // > ls -Name my-csr-directory | %{aws iot create-certificate-from-csr --certificate-signing-request // file://my-csr-directory/$_} // // On a Windows command prompt, the command to create certificates for all // CSRs in my-csr-directory is: // // > forfiles /p my-csr-directory /c "cmd /c aws iot create-certificate-from-csr // --certificate-signing-request file://@path" func (c *IoT) CreateCertificateFromCsr(input *CreateCertificateFromCsrInput) (*CreateCertificateFromCsrOutput, error) { req, out := c.CreateCertificateFromCsrRequest(input) err := req.Send() return out, err } const opCreateKeysAndCertificate = "CreateKeysAndCertificate" // CreateKeysAndCertificateRequest generates a "aws/request.Request" representing the // client's request for the CreateKeysAndCertificate operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the CreateKeysAndCertificate method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the CreateKeysAndCertificateRequest method. // req, resp := client.CreateKeysAndCertificateRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) CreateKeysAndCertificateRequest(input *CreateKeysAndCertificateInput) (req *request.Request, output *CreateKeysAndCertificateOutput) { op := &request.Operation{ Name: opCreateKeysAndCertificate, HTTPMethod: "POST", HTTPPath: "/keys-and-certificate", } if input == nil { input = &CreateKeysAndCertificateInput{} } req = c.newRequest(op, input, output) output = &CreateKeysAndCertificateOutput{} req.Data = output return } // Creates a 2048-bit RSA key pair and issues an X.509 certificate using the // issued public key. // // Note This is the only time AWS IoT issues the private key for this certificate, // so it is important to keep it in a secure location. func (c *IoT) CreateKeysAndCertificate(input *CreateKeysAndCertificateInput) (*CreateKeysAndCertificateOutput, error) { req, out := c.CreateKeysAndCertificateRequest(input) err := req.Send() return out, err } const opCreatePolicy = "CreatePolicy" // CreatePolicyRequest generates a "aws/request.Request" representing the // client's request for the CreatePolicy operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the CreatePolicy method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the CreatePolicyRequest method. // req, resp := client.CreatePolicyRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) CreatePolicyRequest(input *CreatePolicyInput) (req *request.Request, output *CreatePolicyOutput) { op := &request.Operation{ Name: opCreatePolicy, HTTPMethod: "POST", HTTPPath: "/policies/{policyName}", } if input == nil { input = &CreatePolicyInput{} } req = c.newRequest(op, input, output) output = &CreatePolicyOutput{} req.Data = output return } // Creates an AWS IoT policy. // // The created policy is the default version for the policy. This operation // creates a policy version with a version identifier of 1 and sets 1 as the // policy's default version. func (c *IoT) CreatePolicy(input *CreatePolicyInput) (*CreatePolicyOutput, error) { req, out := c.CreatePolicyRequest(input) err := req.Send() return out, err } const opCreatePolicyVersion = "CreatePolicyVersion" // CreatePolicyVersionRequest generates a "aws/request.Request" representing the // client's request for the CreatePolicyVersion operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the CreatePolicyVersion method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the CreatePolicyVersionRequest method. // req, resp := client.CreatePolicyVersionRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) CreatePolicyVersionRequest(input *CreatePolicyVersionInput) (req *request.Request, output *CreatePolicyVersionOutput) { op := &request.Operation{ Name: opCreatePolicyVersion, HTTPMethod: "POST", HTTPPath: "/policies/{policyName}/version", } if input == nil { input = &CreatePolicyVersionInput{} } req = c.newRequest(op, input, output) output = &CreatePolicyVersionOutput{} req.Data = output return } // Creates a new version of the specified AWS IoT policy. To update a policy, // create a new policy version. A managed policy can have up to five versions. // If the policy has five versions, you must use DeletePolicyVersion to delete // an existing version before you create a new one. // // Optionally, you can set the new version as the policy's default version. // The default version is the operative version (that is, the version that is // in effect for the certificates to which the policy is attached). func (c *IoT) CreatePolicyVersion(input *CreatePolicyVersionInput) (*CreatePolicyVersionOutput, error) { req, out := c.CreatePolicyVersionRequest(input) err := req.Send() return out, err } const opCreateThing = "CreateThing" // CreateThingRequest generates a "aws/request.Request" representing the // client's request for the CreateThing operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the CreateThing method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the CreateThingRequest method. // req, resp := client.CreateThingRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) CreateThingRequest(input *CreateThingInput) (req *request.Request, output *CreateThingOutput) { op := &request.Operation{ Name: opCreateThing, HTTPMethod: "POST", HTTPPath: "/things/{thingName}", } if input == nil { input = &CreateThingInput{} } req = c.newRequest(op, input, output) output = &CreateThingOutput{} req.Data = output return } // Creates a thing record in the thing registry. func (c *IoT) CreateThing(input *CreateThingInput) (*CreateThingOutput, error) { req, out := c.CreateThingRequest(input) err := req.Send() return out, err } const opCreateThingType = "CreateThingType" // CreateThingTypeRequest generates a "aws/request.Request" representing the // client's request for the CreateThingType operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the CreateThingType method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the CreateThingTypeRequest method. // req, resp := client.CreateThingTypeRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) CreateThingTypeRequest(input *CreateThingTypeInput) (req *request.Request, output *CreateThingTypeOutput) { op := &request.Operation{ Name: opCreateThingType, HTTPMethod: "POST", HTTPPath: "/thing-types/{thingTypeName}", } if input == nil { input = &CreateThingTypeInput{} } req = c.newRequest(op, input, output) output = &CreateThingTypeOutput{} req.Data = output return } // Creates a new thing type. func (c *IoT) CreateThingType(input *CreateThingTypeInput) (*CreateThingTypeOutput, error) { req, out := c.CreateThingTypeRequest(input) err := req.Send() return out, err } const opCreateTopicRule = "CreateTopicRule" // CreateTopicRuleRequest generates a "aws/request.Request" representing the // client's request for the CreateTopicRule operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the CreateTopicRule method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the CreateTopicRuleRequest method. // req, resp := client.CreateTopicRuleRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) CreateTopicRuleRequest(input *CreateTopicRuleInput) (req *request.Request, output *CreateTopicRuleOutput) { op := &request.Operation{ Name: opCreateTopicRule, HTTPMethod: "POST", HTTPPath: "/rules/{ruleName}", } if input == nil { input = &CreateTopicRuleInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &CreateTopicRuleOutput{} req.Data = output return } // Creates a rule. Creating rules is an administrator-level action. Any user // who has permission to create rules will be able to access data processed // by the rule. func (c *IoT) CreateTopicRule(input *CreateTopicRuleInput) (*CreateTopicRuleOutput, error) { req, out := c.CreateTopicRuleRequest(input) err := req.Send() return out, err } const opDeleteCACertificate = "DeleteCACertificate" // DeleteCACertificateRequest generates a "aws/request.Request" representing the // client's request for the DeleteCACertificate operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DeleteCACertificate method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DeleteCACertificateRequest method. // req, resp := client.DeleteCACertificateRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DeleteCACertificateRequest(input *DeleteCACertificateInput) (req *request.Request, output *DeleteCACertificateOutput) { op := &request.Operation{ Name: opDeleteCACertificate, HTTPMethod: "DELETE", HTTPPath: "/cacertificate/{caCertificateId}", } if input == nil { input = &DeleteCACertificateInput{} } req = c.newRequest(op, input, output) output = &DeleteCACertificateOutput{} req.Data = output return } // Deletes a registered CA certificate. func (c *IoT) DeleteCACertificate(input *DeleteCACertificateInput) (*DeleteCACertificateOutput, error) { req, out := c.DeleteCACertificateRequest(input) err := req.Send() return out, err } const opDeleteCertificate = "DeleteCertificate" // DeleteCertificateRequest generates a "aws/request.Request" representing the // client's request for the DeleteCertificate operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DeleteCertificate method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DeleteCertificateRequest method. // req, resp := client.DeleteCertificateRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DeleteCertificateRequest(input *DeleteCertificateInput) (req *request.Request, output *DeleteCertificateOutput) { op := &request.Operation{ Name: opDeleteCertificate, HTTPMethod: "DELETE", HTTPPath: "/certificates/{certificateId}", } if input == nil { input = &DeleteCertificateInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &DeleteCertificateOutput{} req.Data = output return } // Deletes the specified certificate. // // A certificate cannot be deleted if it has a policy attached to it or if // its status is set to ACTIVE. To delete a certificate, first use the DetachPrincipalPolicy // API to detach all policies. Next, use the UpdateCertificate API to set the // certificate to the INACTIVE status. func (c *IoT) DeleteCertificate(input *DeleteCertificateInput) (*DeleteCertificateOutput, error) { req, out := c.DeleteCertificateRequest(input) err := req.Send() return out, err } const opDeletePolicy = "DeletePolicy" // DeletePolicyRequest generates a "aws/request.Request" representing the // client's request for the DeletePolicy operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DeletePolicy method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DeletePolicyRequest method. // req, resp := client.DeletePolicyRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DeletePolicyRequest(input *DeletePolicyInput) (req *request.Request, output *DeletePolicyOutput) { op := &request.Operation{ Name: opDeletePolicy, HTTPMethod: "DELETE", HTTPPath: "/policies/{policyName}", } if input == nil { input = &DeletePolicyInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &DeletePolicyOutput{} req.Data = output return } // Deletes the specified policy. // // A policy cannot be deleted if it has non-default versions or it is attached // to any certificate. // // To delete a policy, use the DeletePolicyVersion API to delete all non-default // versions of the policy; use the DetachPrincipalPolicy API to detach the policy // from any certificate; and then use the DeletePolicy API to delete the policy. // // When a policy is deleted using DeletePolicy, its default version is deleted // with it. func (c *IoT) DeletePolicy(input *DeletePolicyInput) (*DeletePolicyOutput, error) { req, out := c.DeletePolicyRequest(input) err := req.Send() return out, err } const opDeletePolicyVersion = "DeletePolicyVersion" // DeletePolicyVersionRequest generates a "aws/request.Request" representing the // client's request for the DeletePolicyVersion operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DeletePolicyVersion method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DeletePolicyVersionRequest method. // req, resp := client.DeletePolicyVersionRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DeletePolicyVersionRequest(input *DeletePolicyVersionInput) (req *request.Request, output *DeletePolicyVersionOutput) { op := &request.Operation{ Name: opDeletePolicyVersion, HTTPMethod: "DELETE", HTTPPath: "/policies/{policyName}/version/{policyVersionId}", } if input == nil { input = &DeletePolicyVersionInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &DeletePolicyVersionOutput{} req.Data = output return } // Deletes the specified version of the specified policy. You cannot delete // the default version of a policy using this API. To delete the default version // of a policy, use DeletePolicy. To find out which version of a policy is marked // as the default version, use ListPolicyVersions. func (c *IoT) DeletePolicyVersion(input *DeletePolicyVersionInput) (*DeletePolicyVersionOutput, error) { req, out := c.DeletePolicyVersionRequest(input) err := req.Send() return out, err } const opDeleteRegistrationCode = "DeleteRegistrationCode" // DeleteRegistrationCodeRequest generates a "aws/request.Request" representing the // client's request for the DeleteRegistrationCode operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DeleteRegistrationCode method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DeleteRegistrationCodeRequest method. // req, resp := client.DeleteRegistrationCodeRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DeleteRegistrationCodeRequest(input *DeleteRegistrationCodeInput) (req *request.Request, output *DeleteRegistrationCodeOutput) { op := &request.Operation{ Name: opDeleteRegistrationCode, HTTPMethod: "DELETE", HTTPPath: "/registrationcode", } if input == nil { input = &DeleteRegistrationCodeInput{} } req = c.newRequest(op, input, output) output = &DeleteRegistrationCodeOutput{} req.Data = output return } // Deletes a CA certificate registration code. func (c *IoT) DeleteRegistrationCode(input *DeleteRegistrationCodeInput) (*DeleteRegistrationCodeOutput, error) { req, out := c.DeleteRegistrationCodeRequest(input) err := req.Send() return out, err } const opDeleteThing = "DeleteThing" // DeleteThingRequest generates a "aws/request.Request" representing the // client's request for the DeleteThing operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DeleteThing method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DeleteThingRequest method. // req, resp := client.DeleteThingRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DeleteThingRequest(input *DeleteThingInput) (req *request.Request, output *DeleteThingOutput) { op := &request.Operation{ Name: opDeleteThing, HTTPMethod: "DELETE", HTTPPath: "/things/{thingName}", } if input == nil { input = &DeleteThingInput{} } req = c.newRequest(op, input, output) output = &DeleteThingOutput{} req.Data = output return } // Deletes the specified thing. func (c *IoT) DeleteThing(input *DeleteThingInput) (*DeleteThingOutput, error) { req, out := c.DeleteThingRequest(input) err := req.Send() return out, err } const opDeleteThingType = "DeleteThingType" // DeleteThingTypeRequest generates a "aws/request.Request" representing the // client's request for the DeleteThingType operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DeleteThingType method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DeleteThingTypeRequest method. // req, resp := client.DeleteThingTypeRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DeleteThingTypeRequest(input *DeleteThingTypeInput) (req *request.Request, output *DeleteThingTypeOutput) { op := &request.Operation{ Name: opDeleteThingType, HTTPMethod: "DELETE", HTTPPath: "/thing-types/{thingTypeName}", } if input == nil { input = &DeleteThingTypeInput{} } req = c.newRequest(op, input, output) output = &DeleteThingTypeOutput{} req.Data = output return } // Deletes the specified thing type . You cannot delete a thing type if it has // things associated with it. To delete a thing type, first mark it as deprecated // by calling DeprecateThingType, then remove any associated things by calling // UpdateThing to change the thing type on any associated thing, and finally // use DeleteThingType to delete the thing type. func (c *IoT) DeleteThingType(input *DeleteThingTypeInput) (*DeleteThingTypeOutput, error) { req, out := c.DeleteThingTypeRequest(input) err := req.Send() return out, err } const opDeleteTopicRule = "DeleteTopicRule" // DeleteTopicRuleRequest generates a "aws/request.Request" representing the // client's request for the DeleteTopicRule operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DeleteTopicRule method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DeleteTopicRuleRequest method. // req, resp := client.DeleteTopicRuleRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DeleteTopicRuleRequest(input *DeleteTopicRuleInput) (req *request.Request, output *DeleteTopicRuleOutput) { op := &request.Operation{ Name: opDeleteTopicRule, HTTPMethod: "DELETE", HTTPPath: "/rules/{ruleName}", } if input == nil { input = &DeleteTopicRuleInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &DeleteTopicRuleOutput{} req.Data = output return } // Deletes the specified rule. func (c *IoT) DeleteTopicRule(input *DeleteTopicRuleInput) (*DeleteTopicRuleOutput, error) { req, out := c.DeleteTopicRuleRequest(input) err := req.Send() return out, err } const opDeprecateThingType = "DeprecateThingType" // DeprecateThingTypeRequest generates a "aws/request.Request" representing the // client's request for the DeprecateThingType operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DeprecateThingType method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DeprecateThingTypeRequest method. // req, resp := client.DeprecateThingTypeRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DeprecateThingTypeRequest(input *DeprecateThingTypeInput) (req *request.Request, output *DeprecateThingTypeOutput) { op := &request.Operation{ Name: opDeprecateThingType, HTTPMethod: "POST", HTTPPath: "/thing-types/{thingTypeName}/deprecate", } if input == nil { input = &DeprecateThingTypeInput{} } req = c.newRequest(op, input, output) output = &DeprecateThingTypeOutput{} req.Data = output return } // Deprecates a thing type. You can not associate new things with deprecated // thing type. func (c *IoT) DeprecateThingType(input *DeprecateThingTypeInput) (*DeprecateThingTypeOutput, error) { req, out := c.DeprecateThingTypeRequest(input) err := req.Send() return out, err } const opDescribeCACertificate = "DescribeCACertificate" // DescribeCACertificateRequest generates a "aws/request.Request" representing the // client's request for the DescribeCACertificate operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DescribeCACertificate method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DescribeCACertificateRequest method. // req, resp := client.DescribeCACertificateRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DescribeCACertificateRequest(input *DescribeCACertificateInput) (req *request.Request, output *DescribeCACertificateOutput) { op := &request.Operation{ Name: opDescribeCACertificate, HTTPMethod: "GET", HTTPPath: "/cacertificate/{caCertificateId}", } if input == nil { input = &DescribeCACertificateInput{} } req = c.newRequest(op, input, output) output = &DescribeCACertificateOutput{} req.Data = output return } // Describes a registered CA certificate. func (c *IoT) DescribeCACertificate(input *DescribeCACertificateInput) (*DescribeCACertificateOutput, error) { req, out := c.DescribeCACertificateRequest(input) err := req.Send() return out, err } const opDescribeCertificate = "DescribeCertificate" // DescribeCertificateRequest generates a "aws/request.Request" representing the // client's request for the DescribeCertificate operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DescribeCertificate method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DescribeCertificateRequest method. // req, resp := client.DescribeCertificateRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DescribeCertificateRequest(input *DescribeCertificateInput) (req *request.Request, output *DescribeCertificateOutput) { op := &request.Operation{ Name: opDescribeCertificate, HTTPMethod: "GET", HTTPPath: "/certificates/{certificateId}", } if input == nil { input = &DescribeCertificateInput{} } req = c.newRequest(op, input, output) output = &DescribeCertificateOutput{} req.Data = output return } // Gets information about the specified certificate. func (c *IoT) DescribeCertificate(input *DescribeCertificateInput) (*DescribeCertificateOutput, error) { req, out := c.DescribeCertificateRequest(input) err := req.Send() return out, err } const opDescribeEndpoint = "DescribeEndpoint" // DescribeEndpointRequest generates a "aws/request.Request" representing the // client's request for the DescribeEndpoint operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DescribeEndpoint method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DescribeEndpointRequest method. // req, resp := client.DescribeEndpointRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DescribeEndpointRequest(input *DescribeEndpointInput) (req *request.Request, output *DescribeEndpointOutput) { op := &request.Operation{ Name: opDescribeEndpoint, HTTPMethod: "GET", HTTPPath: "/endpoint", } if input == nil { input = &DescribeEndpointInput{} } req = c.newRequest(op, input, output) output = &DescribeEndpointOutput{} req.Data = output return } // Returns a unique endpoint specific to the AWS account making the call. func (c *IoT) DescribeEndpoint(input *DescribeEndpointInput) (*DescribeEndpointOutput, error) { req, out := c.DescribeEndpointRequest(input) err := req.Send() return out, err } const opDescribeThing = "DescribeThing" // DescribeThingRequest generates a "aws/request.Request" representing the // client's request for the DescribeThing operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DescribeThing method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DescribeThingRequest method. // req, resp := client.DescribeThingRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DescribeThingRequest(input *DescribeThingInput) (req *request.Request, output *DescribeThingOutput) { op := &request.Operation{ Name: opDescribeThing, HTTPMethod: "GET", HTTPPath: "/things/{thingName}", } if input == nil { input = &DescribeThingInput{} } req = c.newRequest(op, input, output) output = &DescribeThingOutput{} req.Data = output return } // Gets information about the specified thing. func (c *IoT) DescribeThing(input *DescribeThingInput) (*DescribeThingOutput, error) { req, out := c.DescribeThingRequest(input) err := req.Send() return out, err } const opDescribeThingType = "DescribeThingType" // DescribeThingTypeRequest generates a "aws/request.Request" representing the // client's request for the DescribeThingType operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DescribeThingType method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DescribeThingTypeRequest method. // req, resp := client.DescribeThingTypeRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DescribeThingTypeRequest(input *DescribeThingTypeInput) (req *request.Request, output *DescribeThingTypeOutput) { op := &request.Operation{ Name: opDescribeThingType, HTTPMethod: "GET", HTTPPath: "/thing-types/{thingTypeName}", } if input == nil { input = &DescribeThingTypeInput{} } req = c.newRequest(op, input, output) output = &DescribeThingTypeOutput{} req.Data = output return } // Gets information about the specified thing type. func (c *IoT) DescribeThingType(input *DescribeThingTypeInput) (*DescribeThingTypeOutput, error) { req, out := c.DescribeThingTypeRequest(input) err := req.Send() return out, err } const opDetachPrincipalPolicy = "DetachPrincipalPolicy" // DetachPrincipalPolicyRequest generates a "aws/request.Request" representing the // client's request for the DetachPrincipalPolicy operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DetachPrincipalPolicy method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DetachPrincipalPolicyRequest method. // req, resp := client.DetachPrincipalPolicyRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DetachPrincipalPolicyRequest(input *DetachPrincipalPolicyInput) (req *request.Request, output *DetachPrincipalPolicyOutput) { op := &request.Operation{ Name: opDetachPrincipalPolicy, HTTPMethod: "DELETE", HTTPPath: "/principal-policies/{policyName}", } if input == nil { input = &DetachPrincipalPolicyInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &DetachPrincipalPolicyOutput{} req.Data = output return } // Removes the specified policy from the specified certificate. func (c *IoT) DetachPrincipalPolicy(input *DetachPrincipalPolicyInput) (*DetachPrincipalPolicyOutput, error) { req, out := c.DetachPrincipalPolicyRequest(input) err := req.Send() return out, err } const opDetachThingPrincipal = "DetachThingPrincipal" // DetachThingPrincipalRequest generates a "aws/request.Request" representing the // client's request for the DetachThingPrincipal operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DetachThingPrincipal method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DetachThingPrincipalRequest method. // req, resp := client.DetachThingPrincipalRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DetachThingPrincipalRequest(input *DetachThingPrincipalInput) (req *request.Request, output *DetachThingPrincipalOutput) { op := &request.Operation{ Name: opDetachThingPrincipal, HTTPMethod: "DELETE", HTTPPath: "/things/{thingName}/principals", } if input == nil { input = &DetachThingPrincipalInput{} } req = c.newRequest(op, input, output) output = &DetachThingPrincipalOutput{} req.Data = output return } // Detaches the specified principal from the specified thing. func (c *IoT) DetachThingPrincipal(input *DetachThingPrincipalInput) (*DetachThingPrincipalOutput, error) { req, out := c.DetachThingPrincipalRequest(input) err := req.Send() return out, err } const opDisableTopicRule = "DisableTopicRule" // DisableTopicRuleRequest generates a "aws/request.Request" representing the // client's request for the DisableTopicRule operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the DisableTopicRule method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the DisableTopicRuleRequest method. // req, resp := client.DisableTopicRuleRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) DisableTopicRuleRequest(input *DisableTopicRuleInput) (req *request.Request, output *DisableTopicRuleOutput) { op := &request.Operation{ Name: opDisableTopicRule, HTTPMethod: "POST", HTTPPath: "/rules/{ruleName}/disable", } if input == nil { input = &DisableTopicRuleInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &DisableTopicRuleOutput{} req.Data = output return } // Disables the specified rule. func (c *IoT) DisableTopicRule(input *DisableTopicRuleInput) (*DisableTopicRuleOutput, error) { req, out := c.DisableTopicRuleRequest(input) err := req.Send() return out, err } const opEnableTopicRule = "EnableTopicRule" // EnableTopicRuleRequest generates a "aws/request.Request" representing the // client's request for the EnableTopicRule operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the EnableTopicRule method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the EnableTopicRuleRequest method. // req, resp := client.EnableTopicRuleRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) EnableTopicRuleRequest(input *EnableTopicRuleInput) (req *request.Request, output *EnableTopicRuleOutput) { op := &request.Operation{ Name: opEnableTopicRule, HTTPMethod: "POST", HTTPPath: "/rules/{ruleName}/enable", } if input == nil { input = &EnableTopicRuleInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &EnableTopicRuleOutput{} req.Data = output return } // Enables the specified rule. func (c *IoT) EnableTopicRule(input *EnableTopicRuleInput) (*EnableTopicRuleOutput, error) { req, out := c.EnableTopicRuleRequest(input) err := req.Send() return out, err } const opGetLoggingOptions = "GetLoggingOptions" // GetLoggingOptionsRequest generates a "aws/request.Request" representing the // client's request for the GetLoggingOptions operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the GetLoggingOptions method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the GetLoggingOptionsRequest method. // req, resp := client.GetLoggingOptionsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) GetLoggingOptionsRequest(input *GetLoggingOptionsInput) (req *request.Request, output *GetLoggingOptionsOutput) { op := &request.Operation{ Name: opGetLoggingOptions, HTTPMethod: "GET", HTTPPath: "/loggingOptions", } if input == nil { input = &GetLoggingOptionsInput{} } req = c.newRequest(op, input, output) output = &GetLoggingOptionsOutput{} req.Data = output return } // Gets the logging options. func (c *IoT) GetLoggingOptions(input *GetLoggingOptionsInput) (*GetLoggingOptionsOutput, error) { req, out := c.GetLoggingOptionsRequest(input) err := req.Send() return out, err } const opGetPolicy = "GetPolicy" // GetPolicyRequest generates a "aws/request.Request" representing the // client's request for the GetPolicy operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the GetPolicy method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the GetPolicyRequest method. // req, resp := client.GetPolicyRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) GetPolicyRequest(input *GetPolicyInput) (req *request.Request, output *GetPolicyOutput) { op := &request.Operation{ Name: opGetPolicy, HTTPMethod: "GET", HTTPPath: "/policies/{policyName}", } if input == nil { input = &GetPolicyInput{} } req = c.newRequest(op, input, output) output = &GetPolicyOutput{} req.Data = output return } // Gets information about the specified policy with the policy document of the // default version. func (c *IoT) GetPolicy(input *GetPolicyInput) (*GetPolicyOutput, error) { req, out := c.GetPolicyRequest(input) err := req.Send() return out, err } const opGetPolicyVersion = "GetPolicyVersion" // GetPolicyVersionRequest generates a "aws/request.Request" representing the // client's request for the GetPolicyVersion operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the GetPolicyVersion method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the GetPolicyVersionRequest method. // req, resp := client.GetPolicyVersionRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) GetPolicyVersionRequest(input *GetPolicyVersionInput) (req *request.Request, output *GetPolicyVersionOutput) { op := &request.Operation{ Name: opGetPolicyVersion, HTTPMethod: "GET", HTTPPath: "/policies/{policyName}/version/{policyVersionId}", } if input == nil { input = &GetPolicyVersionInput{} } req = c.newRequest(op, input, output) output = &GetPolicyVersionOutput{} req.Data = output return } // Gets information about the specified policy version. func (c *IoT) GetPolicyVersion(input *GetPolicyVersionInput) (*GetPolicyVersionOutput, error) { req, out := c.GetPolicyVersionRequest(input) err := req.Send() return out, err } const opGetRegistrationCode = "GetRegistrationCode" // GetRegistrationCodeRequest generates a "aws/request.Request" representing the // client's request for the GetRegistrationCode operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the GetRegistrationCode method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the GetRegistrationCodeRequest method. // req, resp := client.GetRegistrationCodeRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) GetRegistrationCodeRequest(input *GetRegistrationCodeInput) (req *request.Request, output *GetRegistrationCodeOutput) { op := &request.Operation{ Name: opGetRegistrationCode, HTTPMethod: "GET", HTTPPath: "/registrationcode", } if input == nil { input = &GetRegistrationCodeInput{} } req = c.newRequest(op, input, output) output = &GetRegistrationCodeOutput{} req.Data = output return } // Gets a registration code used to register a CA certificate with AWS IoT. func (c *IoT) GetRegistrationCode(input *GetRegistrationCodeInput) (*GetRegistrationCodeOutput, error) { req, out := c.GetRegistrationCodeRequest(input) err := req.Send() return out, err } const opGetTopicRule = "GetTopicRule" // GetTopicRuleRequest generates a "aws/request.Request" representing the // client's request for the GetTopicRule operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the GetTopicRule method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the GetTopicRuleRequest method. // req, resp := client.GetTopicRuleRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) GetTopicRuleRequest(input *GetTopicRuleInput) (req *request.Request, output *GetTopicRuleOutput) { op := &request.Operation{ Name: opGetTopicRule, HTTPMethod: "GET", HTTPPath: "/rules/{ruleName}", } if input == nil { input = &GetTopicRuleInput{} } req = c.newRequest(op, input, output) output = &GetTopicRuleOutput{} req.Data = output return } // Gets information about the specified rule. func (c *IoT) GetTopicRule(input *GetTopicRuleInput) (*GetTopicRuleOutput, error) { req, out := c.GetTopicRuleRequest(input) err := req.Send() return out, err } const opListCACertificates = "ListCACertificates" // ListCACertificatesRequest generates a "aws/request.Request" representing the // client's request for the ListCACertificates operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the ListCACertificates method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the ListCACertificatesRequest method. // req, resp := client.ListCACertificatesRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) ListCACertificatesRequest(input *ListCACertificatesInput) (req *request.Request, output *ListCACertificatesOutput) { op := &request.Operation{ Name: opListCACertificates, HTTPMethod: "GET", HTTPPath: "/cacertificates", } if input == nil { input = &ListCACertificatesInput{} } req = c.newRequest(op, input, output) output = &ListCACertificatesOutput{} req.Data = output return } // Lists the CA certificates registered for your AWS account. // // The results are paginated with a default page size of 25. You can use the // returned marker to retrieve additional results. func (c *IoT) ListCACertificates(input *ListCACertificatesInput) (*ListCACertificatesOutput, error) { req, out := c.ListCACertificatesRequest(input) err := req.Send() return out, err } const opListCertificates = "ListCertificates" // ListCertificatesRequest generates a "aws/request.Request" representing the // client's request for the ListCertificates operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the ListCertificates method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the ListCertificatesRequest method. // req, resp := client.ListCertificatesRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) ListCertificatesRequest(input *ListCertificatesInput) (req *request.Request, output *ListCertificatesOutput) { op := &request.Operation{ Name: opListCertificates, HTTPMethod: "GET", HTTPPath: "/certificates", } if input == nil { input = &ListCertificatesInput{} } req = c.newRequest(op, input, output) output = &ListCertificatesOutput{} req.Data = output return } // Lists the certificates registered in your AWS account. // // The results are paginated with a default page size of 25. You can use the // returned marker to retrieve additional results. func (c *IoT) ListCertificates(input *ListCertificatesInput) (*ListCertificatesOutput, error) { req, out := c.ListCertificatesRequest(input) err := req.Send() return out, err } const opListCertificatesByCA = "ListCertificatesByCA" // ListCertificatesByCARequest generates a "aws/request.Request" representing the // client's request for the ListCertificatesByCA operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the ListCertificatesByCA method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the ListCertificatesByCARequest method. // req, resp := client.ListCertificatesByCARequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) ListCertificatesByCARequest(input *ListCertificatesByCAInput) (req *request.Request, output *ListCertificatesByCAOutput) { op := &request.Operation{ Name: opListCertificatesByCA, HTTPMethod: "GET", HTTPPath: "/certificates-by-ca/{caCertificateId}", } if input == nil { input = &ListCertificatesByCAInput{} } req = c.newRequest(op, input, output) output = &ListCertificatesByCAOutput{} req.Data = output return } // List the device certificates signed by the specified CA certificate. func (c *IoT) ListCertificatesByCA(input *ListCertificatesByCAInput) (*ListCertificatesByCAOutput, error) { req, out := c.ListCertificatesByCARequest(input) err := req.Send() return out, err } const opListOutgoingCertificates = "ListOutgoingCertificates" // ListOutgoingCertificatesRequest generates a "aws/request.Request" representing the // client's request for the ListOutgoingCertificates operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the ListOutgoingCertificates method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the ListOutgoingCertificatesRequest method. // req, resp := client.ListOutgoingCertificatesRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) ListOutgoingCertificatesRequest(input *ListOutgoingCertificatesInput) (req *request.Request, output *ListOutgoingCertificatesOutput) { op := &request.Operation{ Name: opListOutgoingCertificates, HTTPMethod: "GET", HTTPPath: "/certificates-out-going", } if input == nil { input = &ListOutgoingCertificatesInput{} } req = c.newRequest(op, input, output) output = &ListOutgoingCertificatesOutput{} req.Data = output return } // Lists certificates that are being transfered but not yet accepted. func (c *IoT) ListOutgoingCertificates(input *ListOutgoingCertificatesInput) (*ListOutgoingCertificatesOutput, error) { req, out := c.ListOutgoingCertificatesRequest(input) err := req.Send() return out, err } const opListPolicies = "ListPolicies" // ListPoliciesRequest generates a "aws/request.Request" representing the // client's request for the ListPolicies operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the ListPolicies method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the ListPoliciesRequest method. // req, resp := client.ListPoliciesRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) ListPoliciesRequest(input *ListPoliciesInput) (req *request.Request, output *ListPoliciesOutput) { op := &request.Operation{ Name: opListPolicies, HTTPMethod: "GET", HTTPPath: "/policies", } if input == nil { input = &ListPoliciesInput{} } req = c.newRequest(op, input, output) output = &ListPoliciesOutput{} req.Data = output return } // Lists your policies. func (c *IoT) ListPolicies(input *ListPoliciesInput) (*ListPoliciesOutput, error) { req, out := c.ListPoliciesRequest(input) err := req.Send() return out, err } const opListPolicyPrincipals = "ListPolicyPrincipals" // ListPolicyPrincipalsRequest generates a "aws/request.Request" representing the // client's request for the ListPolicyPrincipals operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the ListPolicyPrincipals method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the ListPolicyPrincipalsRequest method. // req, resp := client.ListPolicyPrincipalsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) ListPolicyPrincipalsRequest(input *ListPolicyPrincipalsInput) (req *request.Request, output *ListPolicyPrincipalsOutput) { op := &request.Operation{ Name: opListPolicyPrincipals, HTTPMethod: "GET", HTTPPath: "/policy-principals", } if input == nil { input = &ListPolicyPrincipalsInput{} } req = c.newRequest(op, input, output) output = &ListPolicyPrincipalsOutput{} req.Data = output return } // Lists the principals associated with the specified policy. func (c *IoT) ListPolicyPrincipals(input *ListPolicyPrincipalsInput) (*ListPolicyPrincipalsOutput, error) { req, out := c.ListPolicyPrincipalsRequest(input) err := req.Send() return out, err } const opListPolicyVersions = "ListPolicyVersions" // ListPolicyVersionsRequest generates a "aws/request.Request" representing the // client's request for the ListPolicyVersions operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the ListPolicyVersions method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the ListPolicyVersionsRequest method. // req, resp := client.ListPolicyVersionsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) ListPolicyVersionsRequest(input *ListPolicyVersionsInput) (req *request.Request, output *ListPolicyVersionsOutput) { op := &request.Operation{ Name: opListPolicyVersions, HTTPMethod: "GET", HTTPPath: "/policies/{policyName}/version", } if input == nil { input = &ListPolicyVersionsInput{} } req = c.newRequest(op, input, output) output = &ListPolicyVersionsOutput{} req.Data = output return } // Lists the versions of the specified policy and identifies the default version. func (c *IoT) ListPolicyVersions(input *ListPolicyVersionsInput) (*ListPolicyVersionsOutput, error) { req, out := c.ListPolicyVersionsRequest(input) err := req.Send() return out, err } const opListPrincipalPolicies = "ListPrincipalPolicies" // ListPrincipalPoliciesRequest generates a "aws/request.Request" representing the // client's request for the ListPrincipalPolicies operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the ListPrincipalPolicies method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the ListPrincipalPoliciesRequest method. // req, resp := client.ListPrincipalPoliciesRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) ListPrincipalPoliciesRequest(input *ListPrincipalPoliciesInput) (req *request.Request, output *ListPrincipalPoliciesOutput) { op := &request.Operation{ Name: opListPrincipalPolicies, HTTPMethod: "GET", HTTPPath: "/principal-policies", } if input == nil { input = &ListPrincipalPoliciesInput{} } req = c.newRequest(op, input, output) output = &ListPrincipalPoliciesOutput{} req.Data = output return } // Lists the policies attached to the specified principal. If you use an Cognito // identity, the ID must be in AmazonCognito Identity format (http://docs.aws.amazon.com/cognitoidentity/latest/APIReference/API_GetCredentialsForIdentity.html#API_GetCredentialsForIdentity_RequestSyntax). func (c *IoT) ListPrincipalPolicies(input *ListPrincipalPoliciesInput) (*ListPrincipalPoliciesOutput, error) { req, out := c.ListPrincipalPoliciesRequest(input) err := req.Send() return out, err } const opListPrincipalThings = "ListPrincipalThings" // ListPrincipalThingsRequest generates a "aws/request.Request" representing the // client's request for the ListPrincipalThings operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the ListPrincipalThings method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the ListPrincipalThingsRequest method. // req, resp := client.ListPrincipalThingsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) ListPrincipalThingsRequest(input *ListPrincipalThingsInput) (req *request.Request, output *ListPrincipalThingsOutput) { op := &request.Operation{ Name: opListPrincipalThings, HTTPMethod: "GET", HTTPPath: "/principals/things", } if input == nil { input = &ListPrincipalThingsInput{} } req = c.newRequest(op, input, output) output = &ListPrincipalThingsOutput{} req.Data = output return } // Lists the things associated with the specified principal. func (c *IoT) ListPrincipalThings(input *ListPrincipalThingsInput) (*ListPrincipalThingsOutput, error) { req, out := c.ListPrincipalThingsRequest(input) err := req.Send() return out, err } const opListThingPrincipals = "ListThingPrincipals" // ListThingPrincipalsRequest generates a "aws/request.Request" representing the // client's request for the ListThingPrincipals operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the ListThingPrincipals method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the ListThingPrincipalsRequest method. // req, resp := client.ListThingPrincipalsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) ListThingPrincipalsRequest(input *ListThingPrincipalsInput) (req *request.Request, output *ListThingPrincipalsOutput) { op := &request.Operation{ Name: opListThingPrincipals, HTTPMethod: "GET", HTTPPath: "/things/{thingName}/principals", } if input == nil { input = &ListThingPrincipalsInput{} } req = c.newRequest(op, input, output) output = &ListThingPrincipalsOutput{} req.Data = output return } // Lists the principals associated with the specified thing. func (c *IoT) ListThingPrincipals(input *ListThingPrincipalsInput) (*ListThingPrincipalsOutput, error) { req, out := c.ListThingPrincipalsRequest(input) err := req.Send() return out, err } const opListThingTypes = "ListThingTypes" // ListThingTypesRequest generates a "aws/request.Request" representing the // client's request for the ListThingTypes operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the ListThingTypes method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the ListThingTypesRequest method. // req, resp := client.ListThingTypesRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) ListThingTypesRequest(input *ListThingTypesInput) (req *request.Request, output *ListThingTypesOutput) { op := &request.Operation{ Name: opListThingTypes, HTTPMethod: "GET", HTTPPath: "/thing-types", } if input == nil { input = &ListThingTypesInput{} } req = c.newRequest(op, input, output) output = &ListThingTypesOutput{} req.Data = output return } // Lists the existing thing types. func (c *IoT) ListThingTypes(input *ListThingTypesInput) (*ListThingTypesOutput, error) { req, out := c.ListThingTypesRequest(input) err := req.Send() return out, err } const opListThings = "ListThings" // ListThingsRequest generates a "aws/request.Request" representing the // client's request for the ListThings operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the ListThings method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the ListThingsRequest method. // req, resp := client.ListThingsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) ListThingsRequest(input *ListThingsInput) (req *request.Request, output *ListThingsOutput) { op := &request.Operation{ Name: opListThings, HTTPMethod: "GET", HTTPPath: "/things", } if input == nil { input = &ListThingsInput{} } req = c.newRequest(op, input, output) output = &ListThingsOutput{} req.Data = output return } // Lists your things. Use the attributeName and attributeValue parameters to // filter your things. For example, calling ListThings with attributeName=Color // and attributeValue=Red retrieves all things in the registry that contain // an attribute Color with the value Red. func (c *IoT) ListThings(input *ListThingsInput) (*ListThingsOutput, error) { req, out := c.ListThingsRequest(input) err := req.Send() return out, err } const opListTopicRules = "ListTopicRules" // ListTopicRulesRequest generates a "aws/request.Request" representing the // client's request for the ListTopicRules operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the ListTopicRules method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the ListTopicRulesRequest method. // req, resp := client.ListTopicRulesRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) ListTopicRulesRequest(input *ListTopicRulesInput) (req *request.Request, output *ListTopicRulesOutput) { op := &request.Operation{ Name: opListTopicRules, HTTPMethod: "GET", HTTPPath: "/rules", } if input == nil { input = &ListTopicRulesInput{} } req = c.newRequest(op, input, output) output = &ListTopicRulesOutput{} req.Data = output return } // Lists the rules for the specific topic. func (c *IoT) ListTopicRules(input *ListTopicRulesInput) (*ListTopicRulesOutput, error) { req, out := c.ListTopicRulesRequest(input) err := req.Send() return out, err } const opRegisterCACertificate = "RegisterCACertificate" // RegisterCACertificateRequest generates a "aws/request.Request" representing the // client's request for the RegisterCACertificate operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the RegisterCACertificate method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the RegisterCACertificateRequest method. // req, resp := client.RegisterCACertificateRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) RegisterCACertificateRequest(input *RegisterCACertificateInput) (req *request.Request, output *RegisterCACertificateOutput) { op := &request.Operation{ Name: opRegisterCACertificate, HTTPMethod: "POST", HTTPPath: "/cacertificate", } if input == nil { input = &RegisterCACertificateInput{} } req = c.newRequest(op, input, output) output = &RegisterCACertificateOutput{} req.Data = output return } // Registers a CA certificate with AWS IoT. This CA certificate can then be // used to sign device certificates, which can be then registered with AWS IoT. // You can register up to 10 CA certificates per AWS account that have the same // subject field and public key. This enables you to have up to 10 certificate // authorities sign your device certificates. If you have more than one CA certificate // registered, make sure you pass the CA certificate when you register your // device certificates with the RegisterCertificate API. func (c *IoT) RegisterCACertificate(input *RegisterCACertificateInput) (*RegisterCACertificateOutput, error) { req, out := c.RegisterCACertificateRequest(input) err := req.Send() return out, err } const opRegisterCertificate = "RegisterCertificate" // RegisterCertificateRequest generates a "aws/request.Request" representing the // client's request for the RegisterCertificate operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the RegisterCertificate method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the RegisterCertificateRequest method. // req, resp := client.RegisterCertificateRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) RegisterCertificateRequest(input *RegisterCertificateInput) (req *request.Request, output *RegisterCertificateOutput) { op := &request.Operation{ Name: opRegisterCertificate, HTTPMethod: "POST", HTTPPath: "/certificate/register", } if input == nil { input = &RegisterCertificateInput{} } req = c.newRequest(op, input, output) output = &RegisterCertificateOutput{} req.Data = output return } // Registers a device certificate with AWS IoT. If you have more than one CA // certificate that has the same subject field, you must specify the CA certificate // that was used to sign the device certificate being registered. func (c *IoT) RegisterCertificate(input *RegisterCertificateInput) (*RegisterCertificateOutput, error) { req, out := c.RegisterCertificateRequest(input) err := req.Send() return out, err } const opRejectCertificateTransfer = "RejectCertificateTransfer" // RejectCertificateTransferRequest generates a "aws/request.Request" representing the // client's request for the RejectCertificateTransfer operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the RejectCertificateTransfer method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the RejectCertificateTransferRequest method. // req, resp := client.RejectCertificateTransferRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) RejectCertificateTransferRequest(input *RejectCertificateTransferInput) (req *request.Request, output *RejectCertificateTransferOutput) { op := &request.Operation{ Name: opRejectCertificateTransfer, HTTPMethod: "PATCH", HTTPPath: "/reject-certificate-transfer/{certificateId}", } if input == nil { input = &RejectCertificateTransferInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &RejectCertificateTransferOutput{} req.Data = output return } // Rejects a pending certificate transfer. After AWS IoT rejects a certificate // transfer, the certificate status changes from PENDING_TRANSFER to INACTIVE. // // To check for pending certificate transfers, call ListCertificates to enumerate // your certificates. // // This operation can only be called by the transfer destination. After it // is called, the certificate will be returned to the source's account in the // INACTIVE state. func (c *IoT) RejectCertificateTransfer(input *RejectCertificateTransferInput) (*RejectCertificateTransferOutput, error) { req, out := c.RejectCertificateTransferRequest(input) err := req.Send() return out, err } const opReplaceTopicRule = "ReplaceTopicRule" // ReplaceTopicRuleRequest generates a "aws/request.Request" representing the // client's request for the ReplaceTopicRule operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the ReplaceTopicRule method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the ReplaceTopicRuleRequest method. // req, resp := client.ReplaceTopicRuleRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) ReplaceTopicRuleRequest(input *ReplaceTopicRuleInput) (req *request.Request, output *ReplaceTopicRuleOutput) { op := &request.Operation{ Name: opReplaceTopicRule, HTTPMethod: "PATCH", HTTPPath: "/rules/{ruleName}", } if input == nil { input = &ReplaceTopicRuleInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &ReplaceTopicRuleOutput{} req.Data = output return } // Replaces the specified rule. You must specify all parameters for the new // rule. Creating rules is an administrator-level action. Any user who has permission // to create rules will be able to access data processed by the rule. func (c *IoT) ReplaceTopicRule(input *ReplaceTopicRuleInput) (*ReplaceTopicRuleOutput, error) { req, out := c.ReplaceTopicRuleRequest(input) err := req.Send() return out, err } const opSetDefaultPolicyVersion = "SetDefaultPolicyVersion" // SetDefaultPolicyVersionRequest generates a "aws/request.Request" representing the // client's request for the SetDefaultPolicyVersion operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the SetDefaultPolicyVersion method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the SetDefaultPolicyVersionRequest method. // req, resp := client.SetDefaultPolicyVersionRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) SetDefaultPolicyVersionRequest(input *SetDefaultPolicyVersionInput) (req *request.Request, output *SetDefaultPolicyVersionOutput) { op := &request.Operation{ Name: opSetDefaultPolicyVersion, HTTPMethod: "PATCH", HTTPPath: "/policies/{policyName}/version/{policyVersionId}", } if input == nil { input = &SetDefaultPolicyVersionInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &SetDefaultPolicyVersionOutput{} req.Data = output return } // Sets the specified version of the specified policy as the policy's default // (operative) version. This action affects all certificates to which the policy // is attached. To list the principals the policy is attached to, use the ListPrincipalPolicy // API. func (c *IoT) SetDefaultPolicyVersion(input *SetDefaultPolicyVersionInput) (*SetDefaultPolicyVersionOutput, error) { req, out := c.SetDefaultPolicyVersionRequest(input) err := req.Send() return out, err } const opSetLoggingOptions = "SetLoggingOptions" // SetLoggingOptionsRequest generates a "aws/request.Request" representing the // client's request for the SetLoggingOptions operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the SetLoggingOptions method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the SetLoggingOptionsRequest method. // req, resp := client.SetLoggingOptionsRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) SetLoggingOptionsRequest(input *SetLoggingOptionsInput) (req *request.Request, output *SetLoggingOptionsOutput) { op := &request.Operation{ Name: opSetLoggingOptions, HTTPMethod: "POST", HTTPPath: "/loggingOptions", } if input == nil { input = &SetLoggingOptionsInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &SetLoggingOptionsOutput{} req.Data = output return } // Sets the logging options. func (c *IoT) SetLoggingOptions(input *SetLoggingOptionsInput) (*SetLoggingOptionsOutput, error) { req, out := c.SetLoggingOptionsRequest(input) err := req.Send() return out, err } const opTransferCertificate = "TransferCertificate" // TransferCertificateRequest generates a "aws/request.Request" representing the // client's request for the TransferCertificate operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the TransferCertificate method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the TransferCertificateRequest method. // req, resp := client.TransferCertificateRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) TransferCertificateRequest(input *TransferCertificateInput) (req *request.Request, output *TransferCertificateOutput) { op := &request.Operation{ Name: opTransferCertificate, HTTPMethod: "PATCH", HTTPPath: "/transfer-certificate/{certificateId}", } if input == nil { input = &TransferCertificateInput{} } req = c.newRequest(op, input, output) output = &TransferCertificateOutput{} req.Data = output return } // Transfers the specified certificate to the specified AWS account. // // You can cancel the transfer until it is acknowledged by the recipient. // // No notification is sent to the transfer destination's account. It is up // to the caller to notify the transfer target. // // The certificate being transferred must not be in the ACTIVE state. You can // use the UpdateCertificate API to deactivate it. // // The certificate must not have any policies attached to it. You can use the // DetachPrincipalPolicy API to detach them. func (c *IoT) TransferCertificate(input *TransferCertificateInput) (*TransferCertificateOutput, error) { req, out := c.TransferCertificateRequest(input) err := req.Send() return out, err } const opUpdateCACertificate = "UpdateCACertificate" // UpdateCACertificateRequest generates a "aws/request.Request" representing the // client's request for the UpdateCACertificate operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the UpdateCACertificate method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the UpdateCACertificateRequest method. // req, resp := client.UpdateCACertificateRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) UpdateCACertificateRequest(input *UpdateCACertificateInput) (req *request.Request, output *UpdateCACertificateOutput) { op := &request.Operation{ Name: opUpdateCACertificate, HTTPMethod: "PUT", HTTPPath: "/cacertificate/{caCertificateId}", } if input == nil { input = &UpdateCACertificateInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &UpdateCACertificateOutput{} req.Data = output return } // Updates a registered CA certificate. func (c *IoT) UpdateCACertificate(input *UpdateCACertificateInput) (*UpdateCACertificateOutput, error) { req, out := c.UpdateCACertificateRequest(input) err := req.Send() return out, err } const opUpdateCertificate = "UpdateCertificate" // UpdateCertificateRequest generates a "aws/request.Request" representing the // client's request for the UpdateCertificate operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the UpdateCertificate method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the UpdateCertificateRequest method. // req, resp := client.UpdateCertificateRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) UpdateCertificateRequest(input *UpdateCertificateInput) (req *request.Request, output *UpdateCertificateOutput) { op := &request.Operation{ Name: opUpdateCertificate, HTTPMethod: "PUT", HTTPPath: "/certificates/{certificateId}", } if input == nil { input = &UpdateCertificateInput{} } req = c.newRequest(op, input, output) req.Handlers.Unmarshal.Remove(restjson.UnmarshalHandler) req.Handlers.Unmarshal.PushBackNamed(protocol.UnmarshalDiscardBodyHandler) output = &UpdateCertificateOutput{} req.Data = output return } // Updates the status of the specified certificate. This operation is idempotent. // // Moving a certificate from the ACTIVE state (including REVOKED) will not // disconnect currently connected devices, but these devices will be unable // to reconnect. // // The ACTIVE state is required to authenticate devices connecting to AWS IoT // using a certificate. func (c *IoT) UpdateCertificate(input *UpdateCertificateInput) (*UpdateCertificateOutput, error) { req, out := c.UpdateCertificateRequest(input) err := req.Send() return out, err } const opUpdateThing = "UpdateThing" // UpdateThingRequest generates a "aws/request.Request" representing the // client's request for the UpdateThing operation. The "output" return // value can be used to capture response data after the request's "Send" method // is called. // // Creating a request object using this method should be used when you want to inject // custom logic into the request's lifecycle using a custom handler, or if you want to // access properties on the request object before or after sending the request. If // you just want the service response, call the UpdateThing method directly // instead. // // Note: You must call the "Send" method on the returned request object in order // to execute the request. // // // Example sending a request using the UpdateThingRequest method. // req, resp := client.UpdateThingRequest(params) // // err := req.Send() // if err == nil { // resp is now filled // fmt.Println(resp) // } // func (c *IoT) UpdateThingRequest(input *UpdateThingInput) (req *request.Request, output *UpdateThingOutput) { op := &request.Operation{ Name: opUpdateThing, HTTPMethod: "PATCH", HTTPPath: "/things/{thingName}", } if input == nil { input = &UpdateThingInput{} } req = c.newRequest(op, input, output) output = &UpdateThingOutput{} req.Data = output return } // Updates the data for a thing. func (c *IoT) UpdateThing(input *UpdateThingInput) (*UpdateThingOutput, error) { req, out := c.UpdateThingRequest(input) err := req.Send() return out, err } // The input for the AcceptCertificateTransfer operation. type AcceptCertificateTransferInput struct { _ struct{} `type:"structure"` // The ID of the certificate. CertificateId *string `location:"uri" locationName:"certificateId" min:"64" type:"string" required:"true"` // Specifies whether the certificate is active. SetAsActive *bool `location:"querystring" locationName:"setAsActive" type:"boolean"` } // String returns the string representation func (s AcceptCertificateTransferInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s AcceptCertificateTransferInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *AcceptCertificateTransferInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "AcceptCertificateTransferInput"} if s.CertificateId == nil { invalidParams.Add(request.NewErrParamRequired("CertificateId")) } if s.CertificateId != nil && len(*s.CertificateId) < 64 { invalidParams.Add(request.NewErrParamMinLen("CertificateId", 64)) } if invalidParams.Len() > 0 { return invalidParams } return nil } type AcceptCertificateTransferOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s AcceptCertificateTransferOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s AcceptCertificateTransferOutput) GoString() string { return s.String() } // Describes the actions associated with a rule. type Action struct { _ struct{} `type:"structure"` // Change the state of a CloudWatch alarm. CloudwatchAlarm *CloudwatchAlarmAction `locationName:"cloudwatchAlarm" type:"structure"` // Capture a CloudWatch metric. CloudwatchMetric *CloudwatchMetricAction `locationName:"cloudwatchMetric" type:"structure"` // Write to a DynamoDB table. DynamoDB *DynamoDBAction `locationName:"dynamoDB" type:"structure"` // Write data to an Amazon Elasticsearch Service; domain. Elasticsearch *ElasticsearchAction `locationName:"elasticsearch" type:"structure"` // Write to an Amazon Kinesis Firehose stream. Firehose *FirehoseAction `locationName:"firehose" type:"structure"` // Write data to an Amazon Kinesis stream. Kinesis *KinesisAction `locationName:"kinesis" type:"structure"` // Invoke a Lambda function. Lambda *LambdaAction `locationName:"lambda" type:"structure"` // Publish to another MQTT topic. Republish *RepublishAction `locationName:"republish" type:"structure"` // Write to an Amazon S3 bucket. S3 *S3Action `locationName:"s3" type:"structure"` // Publish to an Amazon SNS topic. Sns *SnsAction `locationName:"sns" type:"structure"` // Publish to an Amazon SQS queue. Sqs *SqsAction `locationName:"sqs" type:"structure"` } // String returns the string representation func (s Action) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s Action) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *Action) Validate() error { invalidParams := request.ErrInvalidParams{Context: "Action"} if s.CloudwatchAlarm != nil { if err := s.CloudwatchAlarm.Validate(); err != nil { invalidParams.AddNested("CloudwatchAlarm", err.(request.ErrInvalidParams)) } } if s.CloudwatchMetric != nil { if err := s.CloudwatchMetric.Validate(); err != nil { invalidParams.AddNested("CloudwatchMetric", err.(request.ErrInvalidParams)) } } if s.DynamoDB != nil { if err := s.DynamoDB.Validate(); err != nil { invalidParams.AddNested("DynamoDB", err.(request.ErrInvalidParams)) } } if s.Elasticsearch != nil { if err := s.Elasticsearch.Validate(); err != nil { invalidParams.AddNested("Elasticsearch", err.(request.ErrInvalidParams)) } } if s.Firehose != nil { if err := s.Firehose.Validate(); err != nil { invalidParams.AddNested("Firehose", err.(request.ErrInvalidParams)) } } if s.Kinesis != nil { if err := s.Kinesis.Validate(); err != nil { invalidParams.AddNested("Kinesis", err.(request.ErrInvalidParams)) } } if s.Lambda != nil { if err := s.Lambda.Validate(); err != nil { invalidParams.AddNested("Lambda", err.(request.ErrInvalidParams)) } } if s.Republish != nil { if err := s.Republish.Validate(); err != nil { invalidParams.AddNested("Republish", err.(request.ErrInvalidParams)) } } if s.S3 != nil { if err := s.S3.Validate(); err != nil { invalidParams.AddNested("S3", err.(request.ErrInvalidParams)) } } if s.Sns != nil { if err := s.Sns.Validate(); err != nil { invalidParams.AddNested("Sns", err.(request.ErrInvalidParams)) } } if s.Sqs != nil { if err := s.Sqs.Validate(); err != nil { invalidParams.AddNested("Sqs", err.(request.ErrInvalidParams)) } } if invalidParams.Len() > 0 { return invalidParams } return nil } // The input for the AttachPrincipalPolicy operation. type AttachPrincipalPolicyInput struct { _ struct{} `type:"structure"` // The policy name. PolicyName *string `location:"uri" locationName:"policyName" min:"1" type:"string" required:"true"` // The principal, which can be a certificate ARN (as returned from the CreateCertificate // operation) or an Amazon Cognito ID. Principal *string `location:"header" locationName:"x-amzn-iot-principal" type:"string" required:"true"` } // String returns the string representation func (s AttachPrincipalPolicyInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s AttachPrincipalPolicyInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *AttachPrincipalPolicyInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "AttachPrincipalPolicyInput"} if s.PolicyName == nil { invalidParams.Add(request.NewErrParamRequired("PolicyName")) } if s.PolicyName != nil && len(*s.PolicyName) < 1 { invalidParams.Add(request.NewErrParamMinLen("PolicyName", 1)) } if s.Principal == nil { invalidParams.Add(request.NewErrParamRequired("Principal")) } if invalidParams.Len() > 0 { return invalidParams } return nil } type AttachPrincipalPolicyOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s AttachPrincipalPolicyOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s AttachPrincipalPolicyOutput) GoString() string { return s.String() } // The input for the AttachThingPrincipal operation. type AttachThingPrincipalInput struct { _ struct{} `type:"structure"` // The principal, such as a certificate or other credential. Principal *string `location:"header" locationName:"x-amzn-principal" type:"string" required:"true"` // The name of the thing. ThingName *string `location:"uri" locationName:"thingName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s AttachThingPrincipalInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s AttachThingPrincipalInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *AttachThingPrincipalInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "AttachThingPrincipalInput"} if s.Principal == nil { invalidParams.Add(request.NewErrParamRequired("Principal")) } if s.ThingName == nil { invalidParams.Add(request.NewErrParamRequired("ThingName")) } if s.ThingName != nil && len(*s.ThingName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the AttachThingPrincipal operation. type AttachThingPrincipalOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s AttachThingPrincipalOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s AttachThingPrincipalOutput) GoString() string { return s.String() } // The attribute payload. type AttributePayload struct { _ struct{} `type:"structure"` // A JSON string containing up to three key-value pair in JSON format. For example: // // {\"attributes\":{\"string1\":\"string2\"}}) Attributes map[string]*string `locationName:"attributes" type:"map"` // Specifies whether the list of attributes provided in the AttributePayload // is merged with the attributes stored in the registry, instead of overwriting // them. // // To remove an attribute, call UpdateThing with an empty attribute value. // // The merge attribute is only valid when calling UpdateThing. Merge *bool `locationName:"merge" type:"boolean"` } // String returns the string representation func (s AttributePayload) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s AttributePayload) GoString() string { return s.String() } // A CA certificate. type CACertificate struct { _ struct{} `type:"structure"` // The ARN of the CA certificate. CertificateArn *string `locationName:"certificateArn" type:"string"` // The ID of the CA certificate. CertificateId *string `locationName:"certificateId" min:"64" type:"string"` // The date the CA certificate was created. CreationDate *time.Time `locationName:"creationDate" type:"timestamp" timestampFormat:"unix"` // The status of the CA certificate. // // The status value REGISTER_INACTIVE is deprecated and should not be used. Status *string `locationName:"status" type:"string" enum:"CACertificateStatus"` } // String returns the string representation func (s CACertificate) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CACertificate) GoString() string { return s.String() } // Describes a CA certificate. type CACertificateDescription struct { _ struct{} `type:"structure"` // Whether the CA certificate configured for auto registration of device certificates. // Valid values are "ENABLE" and "DISABLE" AutoRegistrationStatus *string `locationName:"autoRegistrationStatus" type:"string" enum:"AutoRegistrationStatus"` // The CA certificate ARN. CertificateArn *string `locationName:"certificateArn" type:"string"` // The CA certificate ID. CertificateId *string `locationName:"certificateId" min:"64" type:"string"` // The CA certificate data, in PEM format. CertificatePem *string `locationName:"certificatePem" min:"1" type:"string"` // The date the CA certificate was created. CreationDate *time.Time `locationName:"creationDate" type:"timestamp" timestampFormat:"unix"` // The owner of the CA certificate. OwnedBy *string `locationName:"ownedBy" type:"string"` // The status of a CA certificate. Status *string `locationName:"status" type:"string" enum:"CACertificateStatus"` } // String returns the string representation func (s CACertificateDescription) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CACertificateDescription) GoString() string { return s.String() } // The input for the CancelCertificateTransfer operation. type CancelCertificateTransferInput struct { _ struct{} `type:"structure"` // The ID of the certificate. CertificateId *string `location:"uri" locationName:"certificateId" min:"64" type:"string" required:"true"` } // String returns the string representation func (s CancelCertificateTransferInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CancelCertificateTransferInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *CancelCertificateTransferInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CancelCertificateTransferInput"} if s.CertificateId == nil { invalidParams.Add(request.NewErrParamRequired("CertificateId")) } if s.CertificateId != nil && len(*s.CertificateId) < 64 { invalidParams.Add(request.NewErrParamMinLen("CertificateId", 64)) } if invalidParams.Len() > 0 { return invalidParams } return nil } type CancelCertificateTransferOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s CancelCertificateTransferOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CancelCertificateTransferOutput) GoString() string { return s.String() } // Information about a certificate. type Certificate struct { _ struct{} `type:"structure"` // The ARN of the certificate. CertificateArn *string `locationName:"certificateArn" type:"string"` // The ID of the certificate. CertificateId *string `locationName:"certificateId" min:"64" type:"string"` // The date and time the certificate was created. CreationDate *time.Time `locationName:"creationDate" type:"timestamp" timestampFormat:"unix"` // The status of the certificate. // // The status value REGISTER_INACTIVE is deprecated and should not be used. Status *string `locationName:"status" type:"string" enum:"CertificateStatus"` } // String returns the string representation func (s Certificate) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s Certificate) GoString() string { return s.String() } // Describes a certificate. type CertificateDescription struct { _ struct{} `type:"structure"` // The certificate ID of the CA certificate used to sign this certificate. CaCertificateId *string `locationName:"caCertificateId" min:"64" type:"string"` // The ARN of the certificate. CertificateArn *string `locationName:"certificateArn" type:"string"` // The ID of the certificate. CertificateId *string `locationName:"certificateId" min:"64" type:"string"` // The certificate data, in PEM format. CertificatePem *string `locationName:"certificatePem" min:"1" type:"string"` // The date and time the certificate was created. CreationDate *time.Time `locationName:"creationDate" type:"timestamp" timestampFormat:"unix"` // The date and time the certificate was last modified. LastModifiedDate *time.Time `locationName:"lastModifiedDate" type:"timestamp" timestampFormat:"unix"` // The ID of the AWS account that owns the certificate. OwnedBy *string `locationName:"ownedBy" type:"string"` // The ID of the AWS account of the previous owner of the certificate. PreviousOwnedBy *string `locationName:"previousOwnedBy" type:"string"` // The status of the certificate. Status *string `locationName:"status" type:"string" enum:"CertificateStatus"` // The transfer data. TransferData *TransferData `locationName:"transferData" type:"structure"` } // String returns the string representation func (s CertificateDescription) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CertificateDescription) GoString() string { return s.String() } // Describes an action that updates a CloudWatch alarm. type CloudwatchAlarmAction struct { _ struct{} `type:"structure"` // The CloudWatch alarm name. AlarmName *string `locationName:"alarmName" type:"string" required:"true"` // The IAM role that allows access to the CloudWatch alarm. RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The reason for the alarm change. StateReason *string `locationName:"stateReason" type:"string" required:"true"` // The value of the alarm state. Acceptable values are: OK, ALARM, INSUFFICIENT_DATA. StateValue *string `locationName:"stateValue" type:"string" required:"true"` } // String returns the string representation func (s CloudwatchAlarmAction) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CloudwatchAlarmAction) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *CloudwatchAlarmAction) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CloudwatchAlarmAction"} if s.AlarmName == nil { invalidParams.Add(request.NewErrParamRequired("AlarmName")) } if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if s.StateReason == nil { invalidParams.Add(request.NewErrParamRequired("StateReason")) } if s.StateValue == nil { invalidParams.Add(request.NewErrParamRequired("StateValue")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // Describes an action that captures a CloudWatch metric. type CloudwatchMetricAction struct { _ struct{} `type:"structure"` // The CloudWatch metric name. MetricName *string `locationName:"metricName" type:"string" required:"true"` // The CloudWatch metric namespace name. MetricNamespace *string `locationName:"metricNamespace" type:"string" required:"true"` // An optional Unix timestamp (http://docs.aws.amazon.com/AmazonCloudWatch/latest/DeveloperGuide/cloudwatch_concepts.html#about_timestamp). MetricTimestamp *string `locationName:"metricTimestamp" type:"string"` // The metric unit (http://docs.aws.amazon.com/AmazonCloudWatch/latest/DeveloperGuide/cloudwatch_concepts.html#Unit) // supported by CloudWatch. MetricUnit *string `locationName:"metricUnit" type:"string" required:"true"` // The CloudWatch metric value. MetricValue *string `locationName:"metricValue" type:"string" required:"true"` // The IAM role that allows access to the CloudWatch metric. RoleArn *string `locationName:"roleArn" type:"string" required:"true"` } // String returns the string representation func (s CloudwatchMetricAction) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CloudwatchMetricAction) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *CloudwatchMetricAction) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CloudwatchMetricAction"} if s.MetricName == nil { invalidParams.Add(request.NewErrParamRequired("MetricName")) } if s.MetricNamespace == nil { invalidParams.Add(request.NewErrParamRequired("MetricNamespace")) } if s.MetricUnit == nil { invalidParams.Add(request.NewErrParamRequired("MetricUnit")) } if s.MetricValue == nil { invalidParams.Add(request.NewErrParamRequired("MetricValue")) } if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The input for the CreateCertificateFromCsr operation. type CreateCertificateFromCsrInput struct { _ struct{} `type:"structure"` // The certificate signing request (CSR). CertificateSigningRequest *string `locationName:"certificateSigningRequest" min:"1" type:"string" required:"true"` // Specifies whether the certificate is active. SetAsActive *bool `location:"querystring" locationName:"setAsActive" type:"boolean"` } // String returns the string representation func (s CreateCertificateFromCsrInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CreateCertificateFromCsrInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *CreateCertificateFromCsrInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CreateCertificateFromCsrInput"} if s.CertificateSigningRequest == nil { invalidParams.Add(request.NewErrParamRequired("CertificateSigningRequest")) } if s.CertificateSigningRequest != nil && len(*s.CertificateSigningRequest) < 1 { invalidParams.Add(request.NewErrParamMinLen("CertificateSigningRequest", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the CreateCertificateFromCsr operation. type CreateCertificateFromCsrOutput struct { _ struct{} `type:"structure"` // The Amazon Resource Name (ARN) of the certificate. You can use the ARN as // a principal for policy operations. CertificateArn *string `locationName:"certificateArn" type:"string"` // The ID of the certificate. Certificate management operations only take a // certificateId. CertificateId *string `locationName:"certificateId" min:"64" type:"string"` // The certificate data, in PEM format. CertificatePem *string `locationName:"certificatePem" min:"1" type:"string"` } // String returns the string representation func (s CreateCertificateFromCsrOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CreateCertificateFromCsrOutput) GoString() string { return s.String() } // The input for the CreateKeysAndCertificate operation. type CreateKeysAndCertificateInput struct { _ struct{} `type:"structure"` // Specifies whether the certificate is active. SetAsActive *bool `location:"querystring" locationName:"setAsActive" type:"boolean"` } // String returns the string representation func (s CreateKeysAndCertificateInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CreateKeysAndCertificateInput) GoString() string { return s.String() } // The output of the CreateKeysAndCertificate operation. type CreateKeysAndCertificateOutput struct { _ struct{} `type:"structure"` // The ARN of the certificate. CertificateArn *string `locationName:"certificateArn" type:"string"` // The ID of the certificate. AWS IoT issues a default subject name for the // certificate (for example, AWS IoT Certificate). CertificateId *string `locationName:"certificateId" min:"64" type:"string"` // The certificate data, in PEM format. CertificatePem *string `locationName:"certificatePem" min:"1" type:"string"` // The generated key pair. KeyPair *KeyPair `locationName:"keyPair" type:"structure"` } // String returns the string representation func (s CreateKeysAndCertificateOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CreateKeysAndCertificateOutput) GoString() string { return s.String() } // The input for the CreatePolicy operation. type CreatePolicyInput struct { _ struct{} `type:"structure"` // The JSON document that describes the policy. policyDocument must have a minimum // length of 1, with a maximum length of 2048, excluding whitespace. PolicyDocument *string `locationName:"policyDocument" type:"string" required:"true"` // The policy name. PolicyName *string `location:"uri" locationName:"policyName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s CreatePolicyInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CreatePolicyInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *CreatePolicyInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CreatePolicyInput"} if s.PolicyDocument == nil { invalidParams.Add(request.NewErrParamRequired("PolicyDocument")) } if s.PolicyName == nil { invalidParams.Add(request.NewErrParamRequired("PolicyName")) } if s.PolicyName != nil && len(*s.PolicyName) < 1 { invalidParams.Add(request.NewErrParamMinLen("PolicyName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the CreatePolicy operation. type CreatePolicyOutput struct { _ struct{} `type:"structure"` // The policy ARN. PolicyArn *string `locationName:"policyArn" type:"string"` // The JSON document that describes the policy. PolicyDocument *string `locationName:"policyDocument" type:"string"` // The policy name. PolicyName *string `locationName:"policyName" min:"1" type:"string"` // The policy version ID. PolicyVersionId *string `locationName:"policyVersionId" type:"string"` } // String returns the string representation func (s CreatePolicyOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CreatePolicyOutput) GoString() string { return s.String() } // The input for the CreatePolicyVersion operation. type CreatePolicyVersionInput struct { _ struct{} `type:"structure"` // The JSON document that describes the policy. Minimum length of 1. Maximum // length of 2048, excluding whitespaces PolicyDocument *string `locationName:"policyDocument" type:"string" required:"true"` // The policy name. PolicyName *string `location:"uri" locationName:"policyName" min:"1" type:"string" required:"true"` // Specifies whether the policy version is set as the default. When this parameter // is true, the new policy version becomes the operative version (that is, the // version that is in effect for the certificates to which the policy is attached). SetAsDefault *bool `location:"querystring" locationName:"setAsDefault" type:"boolean"` } // String returns the string representation func (s CreatePolicyVersionInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CreatePolicyVersionInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *CreatePolicyVersionInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CreatePolicyVersionInput"} if s.PolicyDocument == nil { invalidParams.Add(request.NewErrParamRequired("PolicyDocument")) } if s.PolicyName == nil { invalidParams.Add(request.NewErrParamRequired("PolicyName")) } if s.PolicyName != nil && len(*s.PolicyName) < 1 { invalidParams.Add(request.NewErrParamMinLen("PolicyName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output of the CreatePolicyVersion operation. type CreatePolicyVersionOutput struct { _ struct{} `type:"structure"` // Specifies whether the policy version is the default. IsDefaultVersion *bool `locationName:"isDefaultVersion" type:"boolean"` // The policy ARN. PolicyArn *string `locationName:"policyArn" type:"string"` // The JSON document that describes the policy. PolicyDocument *string `locationName:"policyDocument" type:"string"` // The policy version ID. PolicyVersionId *string `locationName:"policyVersionId" type:"string"` } // String returns the string representation func (s CreatePolicyVersionOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CreatePolicyVersionOutput) GoString() string { return s.String() } // The input for the CreateThing operation. type CreateThingInput struct { _ struct{} `type:"structure"` // The attribute payload, which consists of up to three name/value pairs in // a JSON document. For example: // // {\"attributes\":{\"string1\":\"string2\"}}) AttributePayload *AttributePayload `locationName:"attributePayload" type:"structure"` // The name of the thing to create. ThingName *string `location:"uri" locationName:"thingName" min:"1" type:"string" required:"true"` // The name of the thing type associated with the new thing. ThingTypeName *string `locationName:"thingTypeName" min:"1" type:"string"` } // String returns the string representation func (s CreateThingInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CreateThingInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *CreateThingInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CreateThingInput"} if s.ThingName == nil { invalidParams.Add(request.NewErrParamRequired("ThingName")) } if s.ThingName != nil && len(*s.ThingName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingName", 1)) } if s.ThingTypeName != nil && len(*s.ThingTypeName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingTypeName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output of the CreateThing operation. type CreateThingOutput struct { _ struct{} `type:"structure"` // The ARN of the new thing. ThingArn *string `locationName:"thingArn" type:"string"` // The name of the new thing. ThingName *string `locationName:"thingName" min:"1" type:"string"` } // String returns the string representation func (s CreateThingOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CreateThingOutput) GoString() string { return s.String() } // The input for the CreateThingType operation. type CreateThingTypeInput struct { _ struct{} `type:"structure"` // The name of the thing type. ThingTypeName *string `location:"uri" locationName:"thingTypeName" min:"1" type:"string" required:"true"` // The ThingTypeProperties for the thing type to create. It contains information // about the new thing type including a description, and a list of searchable // thing attribute names. ThingTypeProperties *ThingTypeProperties `locationName:"thingTypeProperties" type:"structure"` } // String returns the string representation func (s CreateThingTypeInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CreateThingTypeInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *CreateThingTypeInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CreateThingTypeInput"} if s.ThingTypeName == nil { invalidParams.Add(request.NewErrParamRequired("ThingTypeName")) } if s.ThingTypeName != nil && len(*s.ThingTypeName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingTypeName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output of the CreateThingType operation. type CreateThingTypeOutput struct { _ struct{} `type:"structure"` // The Amazon Resource Name (ARN) of the thing type. ThingTypeArn *string `locationName:"thingTypeArn" type:"string"` // The name of the thing type. ThingTypeName *string `locationName:"thingTypeName" min:"1" type:"string"` } // String returns the string representation func (s CreateThingTypeOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CreateThingTypeOutput) GoString() string { return s.String() } // The input for the CreateTopicRule operation. type CreateTopicRuleInput struct { _ struct{} `type:"structure" payload:"TopicRulePayload"` // The name of the rule. RuleName *string `location:"uri" locationName:"ruleName" min:"1" type:"string" required:"true"` // The rule payload. TopicRulePayload *TopicRulePayload `locationName:"topicRulePayload" type:"structure" required:"true"` } // String returns the string representation func (s CreateTopicRuleInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CreateTopicRuleInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *CreateTopicRuleInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "CreateTopicRuleInput"} if s.RuleName == nil { invalidParams.Add(request.NewErrParamRequired("RuleName")) } if s.RuleName != nil && len(*s.RuleName) < 1 { invalidParams.Add(request.NewErrParamMinLen("RuleName", 1)) } if s.TopicRulePayload == nil { invalidParams.Add(request.NewErrParamRequired("TopicRulePayload")) } if s.TopicRulePayload != nil { if err := s.TopicRulePayload.Validate(); err != nil { invalidParams.AddNested("TopicRulePayload", err.(request.ErrInvalidParams)) } } if invalidParams.Len() > 0 { return invalidParams } return nil } type CreateTopicRuleOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s CreateTopicRuleOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s CreateTopicRuleOutput) GoString() string { return s.String() } // Input for the DeleteCACertificate operation. type DeleteCACertificateInput struct { _ struct{} `type:"structure"` // The ID of the certificate to delete. CertificateId *string `location:"uri" locationName:"caCertificateId" min:"64" type:"string" required:"true"` } // String returns the string representation func (s DeleteCACertificateInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeleteCACertificateInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DeleteCACertificateInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeleteCACertificateInput"} if s.CertificateId == nil { invalidParams.Add(request.NewErrParamRequired("CertificateId")) } if s.CertificateId != nil && len(*s.CertificateId) < 64 { invalidParams.Add(request.NewErrParamMinLen("CertificateId", 64)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output for the DeleteCACertificate operation. type DeleteCACertificateOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s DeleteCACertificateOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeleteCACertificateOutput) GoString() string { return s.String() } // The input for the DeleteCertificate operation. type DeleteCertificateInput struct { _ struct{} `type:"structure"` // The ID of the certificate. CertificateId *string `location:"uri" locationName:"certificateId" min:"64" type:"string" required:"true"` } // String returns the string representation func (s DeleteCertificateInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeleteCertificateInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DeleteCertificateInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeleteCertificateInput"} if s.CertificateId == nil { invalidParams.Add(request.NewErrParamRequired("CertificateId")) } if s.CertificateId != nil && len(*s.CertificateId) < 64 { invalidParams.Add(request.NewErrParamMinLen("CertificateId", 64)) } if invalidParams.Len() > 0 { return invalidParams } return nil } type DeleteCertificateOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s DeleteCertificateOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeleteCertificateOutput) GoString() string { return s.String() } // The input for the DeletePolicy operation. type DeletePolicyInput struct { _ struct{} `type:"structure"` // The name of the policy to delete. PolicyName *string `location:"uri" locationName:"policyName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s DeletePolicyInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeletePolicyInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DeletePolicyInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeletePolicyInput"} if s.PolicyName == nil { invalidParams.Add(request.NewErrParamRequired("PolicyName")) } if s.PolicyName != nil && len(*s.PolicyName) < 1 { invalidParams.Add(request.NewErrParamMinLen("PolicyName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } type DeletePolicyOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s DeletePolicyOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeletePolicyOutput) GoString() string { return s.String() } // The input for the DeletePolicyVersion operation. type DeletePolicyVersionInput struct { _ struct{} `type:"structure"` // The name of the policy. PolicyName *string `location:"uri" locationName:"policyName" min:"1" type:"string" required:"true"` // The policy version ID. PolicyVersionId *string `location:"uri" locationName:"policyVersionId" type:"string" required:"true"` } // String returns the string representation func (s DeletePolicyVersionInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeletePolicyVersionInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DeletePolicyVersionInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeletePolicyVersionInput"} if s.PolicyName == nil { invalidParams.Add(request.NewErrParamRequired("PolicyName")) } if s.PolicyName != nil && len(*s.PolicyName) < 1 { invalidParams.Add(request.NewErrParamMinLen("PolicyName", 1)) } if s.PolicyVersionId == nil { invalidParams.Add(request.NewErrParamRequired("PolicyVersionId")) } if invalidParams.Len() > 0 { return invalidParams } return nil } type DeletePolicyVersionOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s DeletePolicyVersionOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeletePolicyVersionOutput) GoString() string { return s.String() } // The input for the DeleteRegistrationCode operation. type DeleteRegistrationCodeInput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s DeleteRegistrationCodeInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeleteRegistrationCodeInput) GoString() string { return s.String() } // The output for the DeleteRegistrationCode operation. type DeleteRegistrationCodeOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s DeleteRegistrationCodeOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeleteRegistrationCodeOutput) GoString() string { return s.String() } // The input for the DeleteThing operation. type DeleteThingInput struct { _ struct{} `type:"structure"` // The expected version of the thing record in the registry. If the version // of the record in the registry does not match the expected version specified // in the request, the DeleteThing request is rejected with a VersionConflictException. ExpectedVersion *int64 `location:"querystring" locationName:"expectedVersion" type:"long"` // The name of the thing to delete. ThingName *string `location:"uri" locationName:"thingName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s DeleteThingInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeleteThingInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DeleteThingInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeleteThingInput"} if s.ThingName == nil { invalidParams.Add(request.NewErrParamRequired("ThingName")) } if s.ThingName != nil && len(*s.ThingName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output of the DeleteThing operation. type DeleteThingOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s DeleteThingOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeleteThingOutput) GoString() string { return s.String() } // The input for the DeleteThingType operation. type DeleteThingTypeInput struct { _ struct{} `type:"structure"` // The name of the thing type. ThingTypeName *string `location:"uri" locationName:"thingTypeName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s DeleteThingTypeInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeleteThingTypeInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DeleteThingTypeInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeleteThingTypeInput"} if s.ThingTypeName == nil { invalidParams.Add(request.NewErrParamRequired("ThingTypeName")) } if s.ThingTypeName != nil && len(*s.ThingTypeName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingTypeName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output for the DeleteThingType operation. type DeleteThingTypeOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s DeleteThingTypeOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeleteThingTypeOutput) GoString() string { return s.String() } // The input for the DeleteTopicRule operation. type DeleteTopicRuleInput struct { _ struct{} `type:"structure"` // The name of the rule. RuleName *string `location:"uri" locationName:"ruleName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s DeleteTopicRuleInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeleteTopicRuleInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DeleteTopicRuleInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeleteTopicRuleInput"} if s.RuleName == nil { invalidParams.Add(request.NewErrParamRequired("RuleName")) } if s.RuleName != nil && len(*s.RuleName) < 1 { invalidParams.Add(request.NewErrParamMinLen("RuleName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } type DeleteTopicRuleOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s DeleteTopicRuleOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeleteTopicRuleOutput) GoString() string { return s.String() } // The input for the DeprecateThingType operation. type DeprecateThingTypeInput struct { _ struct{} `type:"structure"` // The name of the thing type to deprecate. ThingTypeName *string `location:"uri" locationName:"thingTypeName" min:"1" type:"string" required:"true"` // Whether to undeprecate a deprecated thing type. If true, the thing type will // not be deprecated anymore and you can associate it with things. UndoDeprecate *bool `locationName:"undoDeprecate" type:"boolean"` } // String returns the string representation func (s DeprecateThingTypeInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeprecateThingTypeInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DeprecateThingTypeInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DeprecateThingTypeInput"} if s.ThingTypeName == nil { invalidParams.Add(request.NewErrParamRequired("ThingTypeName")) } if s.ThingTypeName != nil && len(*s.ThingTypeName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingTypeName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output for the DeprecateThingType operation. type DeprecateThingTypeOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s DeprecateThingTypeOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DeprecateThingTypeOutput) GoString() string { return s.String() } // The input for the DescribeCACertificate operation. type DescribeCACertificateInput struct { _ struct{} `type:"structure"` // The CA certificate identifier. CertificateId *string `location:"uri" locationName:"caCertificateId" min:"64" type:"string" required:"true"` } // String returns the string representation func (s DescribeCACertificateInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DescribeCACertificateInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DescribeCACertificateInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DescribeCACertificateInput"} if s.CertificateId == nil { invalidParams.Add(request.NewErrParamRequired("CertificateId")) } if s.CertificateId != nil && len(*s.CertificateId) < 64 { invalidParams.Add(request.NewErrParamMinLen("CertificateId", 64)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the DescribeCACertificate operation. type DescribeCACertificateOutput struct { _ struct{} `type:"structure"` // The CA certificate description. CertificateDescription *CACertificateDescription `locationName:"certificateDescription" type:"structure"` } // String returns the string representation func (s DescribeCACertificateOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DescribeCACertificateOutput) GoString() string { return s.String() } // The input for the DescribeCertificate operation. type DescribeCertificateInput struct { _ struct{} `type:"structure"` // The ID of the certificate. CertificateId *string `location:"uri" locationName:"certificateId" min:"64" type:"string" required:"true"` } // String returns the string representation func (s DescribeCertificateInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DescribeCertificateInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DescribeCertificateInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DescribeCertificateInput"} if s.CertificateId == nil { invalidParams.Add(request.NewErrParamRequired("CertificateId")) } if s.CertificateId != nil && len(*s.CertificateId) < 64 { invalidParams.Add(request.NewErrParamMinLen("CertificateId", 64)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output of the DescribeCertificate operation. type DescribeCertificateOutput struct { _ struct{} `type:"structure"` // The description of the certificate. CertificateDescription *CertificateDescription `locationName:"certificateDescription" type:"structure"` } // String returns the string representation func (s DescribeCertificateOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DescribeCertificateOutput) GoString() string { return s.String() } // The input for the DescribeEndpoint operation. type DescribeEndpointInput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s DescribeEndpointInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DescribeEndpointInput) GoString() string { return s.String() } // The output from the DescribeEndpoint operation. type DescribeEndpointOutput struct { _ struct{} `type:"structure"` // The endpoint. The format of the endpoint is as follows: identifier.iot.region.amazonaws.com. EndpointAddress *string `locationName:"endpointAddress" type:"string"` } // String returns the string representation func (s DescribeEndpointOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DescribeEndpointOutput) GoString() string { return s.String() } // The input for the DescribeThing operation. type DescribeThingInput struct { _ struct{} `type:"structure"` // The name of the thing. ThingName *string `location:"uri" locationName:"thingName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s DescribeThingInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DescribeThingInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DescribeThingInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DescribeThingInput"} if s.ThingName == nil { invalidParams.Add(request.NewErrParamRequired("ThingName")) } if s.ThingName != nil && len(*s.ThingName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the DescribeThing operation. type DescribeThingOutput struct { _ struct{} `type:"structure"` // The thing attributes. Attributes map[string]*string `locationName:"attributes" type:"map"` // The default client ID. DefaultClientId *string `locationName:"defaultClientId" type:"string"` // The name of the thing. ThingName *string `locationName:"thingName" min:"1" type:"string"` // The thing type name. ThingTypeName *string `locationName:"thingTypeName" min:"1" type:"string"` // The current version of the thing record in the registry. // // To avoid unintentional changes to the information in the registry, you // can pass the version information in the expectedVersion parameter of the // UpdateThing and DeleteThing calls. Version *int64 `locationName:"version" type:"long"` } // String returns the string representation func (s DescribeThingOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DescribeThingOutput) GoString() string { return s.String() } // The input for the DescribeThingType operation. type DescribeThingTypeInput struct { _ struct{} `type:"structure"` // The name of the thing type. ThingTypeName *string `location:"uri" locationName:"thingTypeName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s DescribeThingTypeInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DescribeThingTypeInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DescribeThingTypeInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DescribeThingTypeInput"} if s.ThingTypeName == nil { invalidParams.Add(request.NewErrParamRequired("ThingTypeName")) } if s.ThingTypeName != nil && len(*s.ThingTypeName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingTypeName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output for the DescribeThingType operation. type DescribeThingTypeOutput struct { _ struct{} `type:"structure"` // The ThingTypeMetadata contains additional information about the thing type // including: creation date and time, a value indicating whether the thing type // is deprecated, and a date and time when time was deprecated. ThingTypeMetadata *ThingTypeMetadata `locationName:"thingTypeMetadata" type:"structure"` // The name of the thing type. ThingTypeName *string `locationName:"thingTypeName" min:"1" type:"string"` // The ThingTypeProperties contains information about the thing type including // description, and a list of searchable thing attribute names. ThingTypeProperties *ThingTypeProperties `locationName:"thingTypeProperties" type:"structure"` } // String returns the string representation func (s DescribeThingTypeOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DescribeThingTypeOutput) GoString() string { return s.String() } // The input for the DetachPrincipalPolicy operation. type DetachPrincipalPolicyInput struct { _ struct{} `type:"structure"` // The name of the policy to detach. PolicyName *string `location:"uri" locationName:"policyName" min:"1" type:"string" required:"true"` // The principal. // // If the principal is a certificate, specify the certificate ARN. If the principal // is an Amazon Cognito identity, specify the identity ID. Principal *string `location:"header" locationName:"x-amzn-iot-principal" type:"string" required:"true"` } // String returns the string representation func (s DetachPrincipalPolicyInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DetachPrincipalPolicyInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DetachPrincipalPolicyInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DetachPrincipalPolicyInput"} if s.PolicyName == nil { invalidParams.Add(request.NewErrParamRequired("PolicyName")) } if s.PolicyName != nil && len(*s.PolicyName) < 1 { invalidParams.Add(request.NewErrParamMinLen("PolicyName", 1)) } if s.Principal == nil { invalidParams.Add(request.NewErrParamRequired("Principal")) } if invalidParams.Len() > 0 { return invalidParams } return nil } type DetachPrincipalPolicyOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s DetachPrincipalPolicyOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DetachPrincipalPolicyOutput) GoString() string { return s.String() } // The input for the DetachThingPrincipal operation. type DetachThingPrincipalInput struct { _ struct{} `type:"structure"` // If the principal is a certificate, this value must be ARN of the certificate. // If the principal is an Amazon Cognito identity, this value must be the ID // of the Amazon Cognito identity. Principal *string `location:"header" locationName:"x-amzn-principal" type:"string" required:"true"` // The name of the thing. ThingName *string `location:"uri" locationName:"thingName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s DetachThingPrincipalInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DetachThingPrincipalInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DetachThingPrincipalInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DetachThingPrincipalInput"} if s.Principal == nil { invalidParams.Add(request.NewErrParamRequired("Principal")) } if s.ThingName == nil { invalidParams.Add(request.NewErrParamRequired("ThingName")) } if s.ThingName != nil && len(*s.ThingName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the DetachThingPrincipal operation. type DetachThingPrincipalOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s DetachThingPrincipalOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DetachThingPrincipalOutput) GoString() string { return s.String() } // The input for the DisableTopicRuleRequest operation. type DisableTopicRuleInput struct { _ struct{} `type:"structure"` // The name of the rule to disable. RuleName *string `location:"uri" locationName:"ruleName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s DisableTopicRuleInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DisableTopicRuleInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DisableTopicRuleInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DisableTopicRuleInput"} if s.RuleName == nil { invalidParams.Add(request.NewErrParamRequired("RuleName")) } if s.RuleName != nil && len(*s.RuleName) < 1 { invalidParams.Add(request.NewErrParamMinLen("RuleName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } type DisableTopicRuleOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s DisableTopicRuleOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DisableTopicRuleOutput) GoString() string { return s.String() } // Describes an action to write to a DynamoDB table. // // The tableName, hashKeyField, and rangeKeyField values must match the values // used when you created the table. // // The hashKeyValue and rangeKeyvalue fields use a substitution template syntax. // These templates provide data at runtime. The syntax is as follows: ${sql-expression}. // // You can specify any valid expression in a WHERE or SELECT clause, including // JSON properties, comparisons, calculations, and functions. For example, the // following field uses the third level of the topic: // // "hashKeyValue": "${topic(3)}" // // The following field uses the timestamp: // // "rangeKeyValue": "${timestamp()}" type DynamoDBAction struct { _ struct{} `type:"structure"` // The hash key name. HashKeyField *string `locationName:"hashKeyField" type:"string" required:"true"` // The hash key type. Valid values are "STRING" or "NUMBER" HashKeyType *string `locationName:"hashKeyType" type:"string" enum:"DynamoKeyType"` // The hash key value. HashKeyValue *string `locationName:"hashKeyValue" type:"string" required:"true"` // The type of operation to be performed. This follows the substitution template, // so it can be ${operation}, but the substitution must result in one of the // following: INSERT, UPDATE, or DELETE. Operation *string `locationName:"operation" type:"string"` // The action payload. This name can be customized. PayloadField *string `locationName:"payloadField" type:"string"` // The range key name. RangeKeyField *string `locationName:"rangeKeyField" type:"string"` // The range key type. Valid values are "STRING" or "NUMBER" RangeKeyType *string `locationName:"rangeKeyType" type:"string" enum:"DynamoKeyType"` // The range key value. RangeKeyValue *string `locationName:"rangeKeyValue" type:"string"` // The ARN of the IAM role that grants access to the DynamoDB table. RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The name of the DynamoDB table. TableName *string `locationName:"tableName" type:"string" required:"true"` } // String returns the string representation func (s DynamoDBAction) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s DynamoDBAction) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *DynamoDBAction) Validate() error { invalidParams := request.ErrInvalidParams{Context: "DynamoDBAction"} if s.HashKeyField == nil { invalidParams.Add(request.NewErrParamRequired("HashKeyField")) } if s.HashKeyValue == nil { invalidParams.Add(request.NewErrParamRequired("HashKeyValue")) } if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if s.TableName == nil { invalidParams.Add(request.NewErrParamRequired("TableName")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // Describes an action that writes data to an Amazon Elasticsearch Service; // domain. type ElasticsearchAction struct { _ struct{} `type:"structure"` // The endpoint of your Elasticsearch domain. Endpoint *string `locationName:"endpoint" type:"string" required:"true"` // The unique identifier for the document you are storing. Id *string `locationName:"id" type:"string" required:"true"` // The Elasticsearch index where you want to store your data. Index *string `locationName:"index" type:"string" required:"true"` // The IAM role ARN that has access to Elasticsearch. RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The type of document you are storing. Type *string `locationName:"type" type:"string" required:"true"` } // String returns the string representation func (s ElasticsearchAction) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ElasticsearchAction) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ElasticsearchAction) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ElasticsearchAction"} if s.Endpoint == nil { invalidParams.Add(request.NewErrParamRequired("Endpoint")) } if s.Id == nil { invalidParams.Add(request.NewErrParamRequired("Id")) } if s.Index == nil { invalidParams.Add(request.NewErrParamRequired("Index")) } if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if s.Type == nil { invalidParams.Add(request.NewErrParamRequired("Type")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The input for the EnableTopicRuleRequest operation. type EnableTopicRuleInput struct { _ struct{} `type:"structure"` // The name of the topic rule to enable. RuleName *string `location:"uri" locationName:"ruleName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s EnableTopicRuleInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s EnableTopicRuleInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *EnableTopicRuleInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "EnableTopicRuleInput"} if s.RuleName == nil { invalidParams.Add(request.NewErrParamRequired("RuleName")) } if s.RuleName != nil && len(*s.RuleName) < 1 { invalidParams.Add(request.NewErrParamMinLen("RuleName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } type EnableTopicRuleOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s EnableTopicRuleOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s EnableTopicRuleOutput) GoString() string { return s.String() } // Describes an action that writes data to an Amazon Kinesis Firehose stream. type FirehoseAction struct { _ struct{} `type:"structure"` // The delivery stream name. DeliveryStreamName *string `locationName:"deliveryStreamName" type:"string" required:"true"` // The IAM role that grants access to the Amazon Kinesis Firehost stream. RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // A character separator that will be used to separate records written to the // firehose stream. Valid values are: '\n' (newline), '\t' (tab), '\r\n' (Windows // newline), ',' (comma). Separator *string `locationName:"separator" type:"string"` } // String returns the string representation func (s FirehoseAction) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s FirehoseAction) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *FirehoseAction) Validate() error { invalidParams := request.ErrInvalidParams{Context: "FirehoseAction"} if s.DeliveryStreamName == nil { invalidParams.Add(request.NewErrParamRequired("DeliveryStreamName")) } if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The input for the GetLoggingOptions operation. type GetLoggingOptionsInput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s GetLoggingOptionsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s GetLoggingOptionsInput) GoString() string { return s.String() } // The output from the GetLoggingOptions operation. type GetLoggingOptionsOutput struct { _ struct{} `type:"structure"` // The logging level. LogLevel *string `locationName:"logLevel" type:"string" enum:"LogLevel"` // The ARN of the IAM role that grants access. RoleArn *string `locationName:"roleArn" type:"string"` } // String returns the string representation func (s GetLoggingOptionsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s GetLoggingOptionsOutput) GoString() string { return s.String() } // The input for the GetPolicy operation. type GetPolicyInput struct { _ struct{} `type:"structure"` // The name of the policy. PolicyName *string `location:"uri" locationName:"policyName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s GetPolicyInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s GetPolicyInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *GetPolicyInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetPolicyInput"} if s.PolicyName == nil { invalidParams.Add(request.NewErrParamRequired("PolicyName")) } if s.PolicyName != nil && len(*s.PolicyName) < 1 { invalidParams.Add(request.NewErrParamMinLen("PolicyName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the GetPolicy operation. type GetPolicyOutput struct { _ struct{} `type:"structure"` // The default policy version ID. DefaultVersionId *string `locationName:"defaultVersionId" type:"string"` // The policy ARN. PolicyArn *string `locationName:"policyArn" type:"string"` // The JSON document that describes the policy. PolicyDocument *string `locationName:"policyDocument" type:"string"` // The policy name. PolicyName *string `locationName:"policyName" min:"1" type:"string"` } // String returns the string representation func (s GetPolicyOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s GetPolicyOutput) GoString() string { return s.String() } // The input for the GetPolicyVersion operation. type GetPolicyVersionInput struct { _ struct{} `type:"structure"` // The name of the policy. PolicyName *string `location:"uri" locationName:"policyName" min:"1" type:"string" required:"true"` // The policy version ID. PolicyVersionId *string `location:"uri" locationName:"policyVersionId" type:"string" required:"true"` } // String returns the string representation func (s GetPolicyVersionInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s GetPolicyVersionInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *GetPolicyVersionInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetPolicyVersionInput"} if s.PolicyName == nil { invalidParams.Add(request.NewErrParamRequired("PolicyName")) } if s.PolicyName != nil && len(*s.PolicyName) < 1 { invalidParams.Add(request.NewErrParamMinLen("PolicyName", 1)) } if s.PolicyVersionId == nil { invalidParams.Add(request.NewErrParamRequired("PolicyVersionId")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the GetPolicyVersion operation. type GetPolicyVersionOutput struct { _ struct{} `type:"structure"` // Specifies whether the policy version is the default. IsDefaultVersion *bool `locationName:"isDefaultVersion" type:"boolean"` // The policy ARN. PolicyArn *string `locationName:"policyArn" type:"string"` // The JSON document that describes the policy. PolicyDocument *string `locationName:"policyDocument" type:"string"` // The policy name. PolicyName *string `locationName:"policyName" min:"1" type:"string"` // The policy version ID. PolicyVersionId *string `locationName:"policyVersionId" type:"string"` } // String returns the string representation func (s GetPolicyVersionOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s GetPolicyVersionOutput) GoString() string { return s.String() } // The input to the GetRegistrationCode operation. type GetRegistrationCodeInput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s GetRegistrationCodeInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s GetRegistrationCodeInput) GoString() string { return s.String() } // The output from the GetRegistrationCode operation. type GetRegistrationCodeOutput struct { _ struct{} `type:"structure"` // The CA certificate registration code. RegistrationCode *string `locationName:"registrationCode" min:"64" type:"string"` } // String returns the string representation func (s GetRegistrationCodeOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s GetRegistrationCodeOutput) GoString() string { return s.String() } // The input for the GetTopicRule operation. type GetTopicRuleInput struct { _ struct{} `type:"structure"` // The name of the rule. RuleName *string `location:"uri" locationName:"ruleName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s GetTopicRuleInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s GetTopicRuleInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *GetTopicRuleInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "GetTopicRuleInput"} if s.RuleName == nil { invalidParams.Add(request.NewErrParamRequired("RuleName")) } if s.RuleName != nil && len(*s.RuleName) < 1 { invalidParams.Add(request.NewErrParamMinLen("RuleName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the GetTopicRule operation. type GetTopicRuleOutput struct { _ struct{} `type:"structure"` // The rule. Rule *TopicRule `locationName:"rule" type:"structure"` // The rule ARN. RuleArn *string `locationName:"ruleArn" type:"string"` } // String returns the string representation func (s GetTopicRuleOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s GetTopicRuleOutput) GoString() string { return s.String() } // Describes a key pair. type KeyPair struct { _ struct{} `type:"structure"` // The private key. PrivateKey *string `min:"1" type:"string"` // The public key. PublicKey *string `min:"1" type:"string"` } // String returns the string representation func (s KeyPair) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s KeyPair) GoString() string { return s.String() } // Describes an action to write data to an Amazon Kinesis stream. type KinesisAction struct { _ struct{} `type:"structure"` // The partition key. PartitionKey *string `locationName:"partitionKey" type:"string"` // The ARN of the IAM role that grants access to the Amazon Kinesis stream. RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The name of the Amazon Kinesis stream. StreamName *string `locationName:"streamName" type:"string" required:"true"` } // String returns the string representation func (s KinesisAction) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s KinesisAction) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *KinesisAction) Validate() error { invalidParams := request.ErrInvalidParams{Context: "KinesisAction"} if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if s.StreamName == nil { invalidParams.Add(request.NewErrParamRequired("StreamName")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // Describes an action to invoke a Lambda function. type LambdaAction struct { _ struct{} `type:"structure"` // The ARN of the Lambda function. FunctionArn *string `locationName:"functionArn" type:"string" required:"true"` } // String returns the string representation func (s LambdaAction) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s LambdaAction) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *LambdaAction) Validate() error { invalidParams := request.ErrInvalidParams{Context: "LambdaAction"} if s.FunctionArn == nil { invalidParams.Add(request.NewErrParamRequired("FunctionArn")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // Input for the ListCACertificates operation. type ListCACertificatesInput struct { _ struct{} `type:"structure"` // Determines the order of the results. AscendingOrder *bool `location:"querystring" locationName:"isAscendingOrder" type:"boolean"` // The marker for the next set of results. Marker *string `location:"querystring" locationName:"marker" type:"string"` // The result page size. PageSize *int64 `location:"querystring" locationName:"pageSize" min:"1" type:"integer"` } // String returns the string representation func (s ListCACertificatesInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListCACertificatesInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListCACertificatesInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListCACertificatesInput"} if s.PageSize != nil && *s.PageSize < 1 { invalidParams.Add(request.NewErrParamMinValue("PageSize", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the ListCACertificates operation. type ListCACertificatesOutput struct { _ struct{} `type:"structure"` // The CA certificates registered in your AWS account. Certificates []*CACertificate `locationName:"certificates" type:"list"` // The current position within the list of CA certificates. NextMarker *string `locationName:"nextMarker" type:"string"` } // String returns the string representation func (s ListCACertificatesOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListCACertificatesOutput) GoString() string { return s.String() } // The input to the ListCertificatesByCA operation. type ListCertificatesByCAInput struct { _ struct{} `type:"structure"` // Specifies the order for results. If True, the results are returned in ascending // order, based on the creation date. AscendingOrder *bool `location:"querystring" locationName:"isAscendingOrder" type:"boolean"` // The ID of the CA certificate. This operation will list all registered device // certificate that were signed by this CA certificate. CaCertificateId *string `location:"uri" locationName:"caCertificateId" min:"64" type:"string" required:"true"` // The marker for the next set of results. Marker *string `location:"querystring" locationName:"marker" type:"string"` // The result page size. PageSize *int64 `location:"querystring" locationName:"pageSize" min:"1" type:"integer"` } // String returns the string representation func (s ListCertificatesByCAInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListCertificatesByCAInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListCertificatesByCAInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListCertificatesByCAInput"} if s.CaCertificateId == nil { invalidParams.Add(request.NewErrParamRequired("CaCertificateId")) } if s.CaCertificateId != nil && len(*s.CaCertificateId) < 64 { invalidParams.Add(request.NewErrParamMinLen("CaCertificateId", 64)) } if s.PageSize != nil && *s.PageSize < 1 { invalidParams.Add(request.NewErrParamMinValue("PageSize", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output of the ListCertificatesByCA operation. type ListCertificatesByCAOutput struct { _ struct{} `type:"structure"` // The device certificates signed by the specified CA certificate. Certificates []*Certificate `locationName:"certificates" type:"list"` // The marker for the next set of results, or null if there are no additional // results. NextMarker *string `locationName:"nextMarker" type:"string"` } // String returns the string representation func (s ListCertificatesByCAOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListCertificatesByCAOutput) GoString() string { return s.String() } // The input for the ListCertificates operation. type ListCertificatesInput struct { _ struct{} `type:"structure"` // Specifies the order for results. If True, the results are returned in ascending // order, based on the creation date. AscendingOrder *bool `location:"querystring" locationName:"isAscendingOrder" type:"boolean"` // The marker for the next set of results. Marker *string `location:"querystring" locationName:"marker" type:"string"` // The result page size. PageSize *int64 `location:"querystring" locationName:"pageSize" min:"1" type:"integer"` } // String returns the string representation func (s ListCertificatesInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListCertificatesInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListCertificatesInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListCertificatesInput"} if s.PageSize != nil && *s.PageSize < 1 { invalidParams.Add(request.NewErrParamMinValue("PageSize", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output of the ListCertificates operation. type ListCertificatesOutput struct { _ struct{} `type:"structure"` // The descriptions of the certificates. Certificates []*Certificate `locationName:"certificates" type:"list"` // The marker for the next set of results, or null if there are no additional // results. NextMarker *string `locationName:"nextMarker" type:"string"` } // String returns the string representation func (s ListCertificatesOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListCertificatesOutput) GoString() string { return s.String() } // The input to the ListOutgoingCertificates operation. type ListOutgoingCertificatesInput struct { _ struct{} `type:"structure"` // Specifies the order for results. If True, the results are returned in ascending // order, based on the creation date. AscendingOrder *bool `location:"querystring" locationName:"isAscendingOrder" type:"boolean"` // The marker for the next set of results. Marker *string `location:"querystring" locationName:"marker" type:"string"` // The result page size. PageSize *int64 `location:"querystring" locationName:"pageSize" min:"1" type:"integer"` } // String returns the string representation func (s ListOutgoingCertificatesInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListOutgoingCertificatesInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListOutgoingCertificatesInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListOutgoingCertificatesInput"} if s.PageSize != nil && *s.PageSize < 1 { invalidParams.Add(request.NewErrParamMinValue("PageSize", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the ListOutgoingCertificates operation. type ListOutgoingCertificatesOutput struct { _ struct{} `type:"structure"` // The marker for the next set of results. NextMarker *string `locationName:"nextMarker" type:"string"` // The certificates that are being transfered but not yet accepted. OutgoingCertificates []*OutgoingCertificate `locationName:"outgoingCertificates" type:"list"` } // String returns the string representation func (s ListOutgoingCertificatesOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListOutgoingCertificatesOutput) GoString() string { return s.String() } // The input for the ListPolicies operation. type ListPoliciesInput struct { _ struct{} `type:"structure"` // Specifies the order for results. If true, the results are returned in ascending // creation order. AscendingOrder *bool `location:"querystring" locationName:"isAscendingOrder" type:"boolean"` // The marker for the next set of results. Marker *string `location:"querystring" locationName:"marker" type:"string"` // The result page size. PageSize *int64 `location:"querystring" locationName:"pageSize" min:"1" type:"integer"` } // String returns the string representation func (s ListPoliciesInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListPoliciesInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListPoliciesInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListPoliciesInput"} if s.PageSize != nil && *s.PageSize < 1 { invalidParams.Add(request.NewErrParamMinValue("PageSize", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the ListPolicies operation. type ListPoliciesOutput struct { _ struct{} `type:"structure"` // The marker for the next set of results, or null if there are no additional // results. NextMarker *string `locationName:"nextMarker" type:"string"` // The descriptions of the policies. Policies []*Policy `locationName:"policies" type:"list"` } // String returns the string representation func (s ListPoliciesOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListPoliciesOutput) GoString() string { return s.String() } // The input for the ListPolicyPrincipals operation. type ListPolicyPrincipalsInput struct { _ struct{} `type:"structure"` // Specifies the order for results. If true, the results are returned in ascending // creation order. AscendingOrder *bool `location:"querystring" locationName:"isAscendingOrder" type:"boolean"` // The marker for the next set of results. Marker *string `location:"querystring" locationName:"marker" type:"string"` // The result page size. PageSize *int64 `location:"querystring" locationName:"pageSize" min:"1" type:"integer"` // The policy name. PolicyName *string `location:"header" locationName:"x-amzn-iot-policy" min:"1" type:"string" required:"true"` } // String returns the string representation func (s ListPolicyPrincipalsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListPolicyPrincipalsInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListPolicyPrincipalsInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListPolicyPrincipalsInput"} if s.PageSize != nil && *s.PageSize < 1 { invalidParams.Add(request.NewErrParamMinValue("PageSize", 1)) } if s.PolicyName == nil { invalidParams.Add(request.NewErrParamRequired("PolicyName")) } if s.PolicyName != nil && len(*s.PolicyName) < 1 { invalidParams.Add(request.NewErrParamMinLen("PolicyName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the ListPolicyPrincipals operation. type ListPolicyPrincipalsOutput struct { _ struct{} `type:"structure"` // The marker for the next set of results, or null if there are no additional // results. NextMarker *string `locationName:"nextMarker" type:"string"` // The descriptions of the principals. Principals []*string `locationName:"principals" type:"list"` } // String returns the string representation func (s ListPolicyPrincipalsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListPolicyPrincipalsOutput) GoString() string { return s.String() } // The input for the ListPolicyVersions operation. type ListPolicyVersionsInput struct { _ struct{} `type:"structure"` // The policy name. PolicyName *string `location:"uri" locationName:"policyName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s ListPolicyVersionsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListPolicyVersionsInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListPolicyVersionsInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListPolicyVersionsInput"} if s.PolicyName == nil { invalidParams.Add(request.NewErrParamRequired("PolicyName")) } if s.PolicyName != nil && len(*s.PolicyName) < 1 { invalidParams.Add(request.NewErrParamMinLen("PolicyName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the ListPolicyVersions operation. type ListPolicyVersionsOutput struct { _ struct{} `type:"structure"` // The policy versions. PolicyVersions []*PolicyVersion `locationName:"policyVersions" type:"list"` } // String returns the string representation func (s ListPolicyVersionsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListPolicyVersionsOutput) GoString() string { return s.String() } // The input for the ListPrincipalPolicies operation. type ListPrincipalPoliciesInput struct { _ struct{} `type:"structure"` // Specifies the order for results. If true, results are returned in ascending // creation order. AscendingOrder *bool `location:"querystring" locationName:"isAscendingOrder" type:"boolean"` // The marker for the next set of results. Marker *string `location:"querystring" locationName:"marker" type:"string"` // The result page size. PageSize *int64 `location:"querystring" locationName:"pageSize" min:"1" type:"integer"` // The principal. Principal *string `location:"header" locationName:"x-amzn-iot-principal" type:"string" required:"true"` } // String returns the string representation func (s ListPrincipalPoliciesInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListPrincipalPoliciesInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListPrincipalPoliciesInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListPrincipalPoliciesInput"} if s.PageSize != nil && *s.PageSize < 1 { invalidParams.Add(request.NewErrParamMinValue("PageSize", 1)) } if s.Principal == nil { invalidParams.Add(request.NewErrParamRequired("Principal")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the ListPrincipalPolicies operation. type ListPrincipalPoliciesOutput struct { _ struct{} `type:"structure"` // The marker for the next set of results, or null if there are no additional // results. NextMarker *string `locationName:"nextMarker" type:"string"` // The policies. Policies []*Policy `locationName:"policies" type:"list"` } // String returns the string representation func (s ListPrincipalPoliciesOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListPrincipalPoliciesOutput) GoString() string { return s.String() } // The input for the ListPrincipalThings operation. type ListPrincipalThingsInput struct { _ struct{} `type:"structure"` // The maximum number of results to return in this operation. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` // The token for the next set of results, or null if there are no additional // results. NextToken *string `location:"querystring" locationName:"nextToken" type:"string"` // The principal. Principal *string `location:"header" locationName:"x-amzn-principal" type:"string" required:"true"` } // String returns the string representation func (s ListPrincipalThingsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListPrincipalThingsInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListPrincipalThingsInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListPrincipalThingsInput"} if s.MaxResults != nil && *s.MaxResults < 1 { invalidParams.Add(request.NewErrParamMinValue("MaxResults", 1)) } if s.Principal == nil { invalidParams.Add(request.NewErrParamRequired("Principal")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the ListPrincipalThings operation. type ListPrincipalThingsOutput struct { _ struct{} `type:"structure"` // The token for the next set of results, or null if there are no additional // results. NextToken *string `locationName:"nextToken" type:"string"` // The things. Things []*string `locationName:"things" type:"list"` } // String returns the string representation func (s ListPrincipalThingsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListPrincipalThingsOutput) GoString() string { return s.String() } // The input for the ListThingPrincipal operation. type ListThingPrincipalsInput struct { _ struct{} `type:"structure"` // The name of the thing. ThingName *string `location:"uri" locationName:"thingName" min:"1" type:"string" required:"true"` } // String returns the string representation func (s ListThingPrincipalsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListThingPrincipalsInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListThingPrincipalsInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListThingPrincipalsInput"} if s.ThingName == nil { invalidParams.Add(request.NewErrParamRequired("ThingName")) } if s.ThingName != nil && len(*s.ThingName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the ListThingPrincipals operation. type ListThingPrincipalsOutput struct { _ struct{} `type:"structure"` // The principals associated with the thing. Principals []*string `locationName:"principals" type:"list"` } // String returns the string representation func (s ListThingPrincipalsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListThingPrincipalsOutput) GoString() string { return s.String() } // The input for the ListThingTypes operation. type ListThingTypesInput struct { _ struct{} `type:"structure"` // The maximum number of results to return in this operation. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` // The token for the next set of results, or null if there are no additional // results. NextToken *string `location:"querystring" locationName:"nextToken" type:"string"` // The name of the thing type. ThingTypeName *string `location:"querystring" locationName:"thingTypeName" min:"1" type:"string"` } // String returns the string representation func (s ListThingTypesInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListThingTypesInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListThingTypesInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListThingTypesInput"} if s.MaxResults != nil && *s.MaxResults < 1 { invalidParams.Add(request.NewErrParamMinValue("MaxResults", 1)) } if s.ThingTypeName != nil && len(*s.ThingTypeName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingTypeName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output for the ListThingTypes operation. type ListThingTypesOutput struct { _ struct{} `type:"structure"` // The token for the next set of results, or null if there are no additional // results. NextToken *string `locationName:"nextToken" type:"string"` // The thing types. ThingTypes []*ThingTypeDefinition `locationName:"thingTypes" type:"list"` } // String returns the string representation func (s ListThingTypesOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListThingTypesOutput) GoString() string { return s.String() } // The input for the ListThings operation. type ListThingsInput struct { _ struct{} `type:"structure"` // The attribute name used to search for things. AttributeName *string `location:"querystring" locationName:"attributeName" type:"string"` // The attribute value used to search for things. AttributeValue *string `location:"querystring" locationName:"attributeValue" type:"string"` // The maximum number of results to return in this operation. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` // The token for the next set of results, or null if there are no additional // results. NextToken *string `location:"querystring" locationName:"nextToken" type:"string"` // The name of the thing type used to search for things. ThingTypeName *string `location:"querystring" locationName:"thingTypeName" min:"1" type:"string"` } // String returns the string representation func (s ListThingsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListThingsInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListThingsInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListThingsInput"} if s.MaxResults != nil && *s.MaxResults < 1 { invalidParams.Add(request.NewErrParamMinValue("MaxResults", 1)) } if s.ThingTypeName != nil && len(*s.ThingTypeName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingTypeName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the ListThings operation. type ListThingsOutput struct { _ struct{} `type:"structure"` // The token for the next set of results, or null if there are no additional // results. NextToken *string `locationName:"nextToken" type:"string"` // The things. Things []*ThingAttribute `locationName:"things" type:"list"` } // String returns the string representation func (s ListThingsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListThingsOutput) GoString() string { return s.String() } // The input for the ListTopicRules operation. type ListTopicRulesInput struct { _ struct{} `type:"structure"` // The maximum number of results to return. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` // A token used to retrieve the next value. NextToken *string `location:"querystring" locationName:"nextToken" type:"string"` // Specifies whether the rule is disabled. RuleDisabled *bool `location:"querystring" locationName:"ruleDisabled" type:"boolean"` // The topic. Topic *string `location:"querystring" locationName:"topic" type:"string"` } // String returns the string representation func (s ListTopicRulesInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListTopicRulesInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ListTopicRulesInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ListTopicRulesInput"} if s.MaxResults != nil && *s.MaxResults < 1 { invalidParams.Add(request.NewErrParamMinValue("MaxResults", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the ListTopicRules operation. type ListTopicRulesOutput struct { _ struct{} `type:"structure"` // A token used to retrieve the next value. NextToken *string `locationName:"nextToken" type:"string"` // The rules. Rules []*TopicRuleListItem `locationName:"rules" type:"list"` } // String returns the string representation func (s ListTopicRulesOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ListTopicRulesOutput) GoString() string { return s.String() } // Describes the logging options payload. type LoggingOptionsPayload struct { _ struct{} `type:"structure"` // The logging level. LogLevel *string `locationName:"logLevel" type:"string" enum:"LogLevel"` // The ARN of the IAM role that grants access. RoleArn *string `locationName:"roleArn" type:"string" required:"true"` } // String returns the string representation func (s LoggingOptionsPayload) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s LoggingOptionsPayload) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *LoggingOptionsPayload) Validate() error { invalidParams := request.ErrInvalidParams{Context: "LoggingOptionsPayload"} if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // A certificate that has been transfered but not yet accepted. type OutgoingCertificate struct { _ struct{} `type:"structure"` // The certificate ARN. CertificateArn *string `locationName:"certificateArn" type:"string"` // The certificate ID. CertificateId *string `locationName:"certificateId" min:"64" type:"string"` // The certificate creation date. CreationDate *time.Time `locationName:"creationDate" type:"timestamp" timestampFormat:"unix"` // The date the transfer was initiated. TransferDate *time.Time `locationName:"transferDate" type:"timestamp" timestampFormat:"unix"` // The transfer message. TransferMessage *string `locationName:"transferMessage" type:"string"` // The AWS account to which the transfer was made. TransferredTo *string `locationName:"transferredTo" type:"string"` } // String returns the string representation func (s OutgoingCertificate) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s OutgoingCertificate) GoString() string { return s.String() } // Describes an AWS IoT policy. type Policy struct { _ struct{} `type:"structure"` // The policy ARN. PolicyArn *string `locationName:"policyArn" type:"string"` // The policy name. PolicyName *string `locationName:"policyName" min:"1" type:"string"` } // String returns the string representation func (s Policy) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s Policy) GoString() string { return s.String() } // Describes a policy version. type PolicyVersion struct { _ struct{} `type:"structure"` // The date and time the policy was created. CreateDate *time.Time `locationName:"createDate" type:"timestamp" timestampFormat:"unix"` // Specifies whether the policy version is the default. IsDefaultVersion *bool `locationName:"isDefaultVersion" type:"boolean"` // The policy version ID. VersionId *string `locationName:"versionId" type:"string"` } // String returns the string representation func (s PolicyVersion) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s PolicyVersion) GoString() string { return s.String() } // The input to the RegisterCACertificate operation. type RegisterCACertificateInput struct { _ struct{} `type:"structure"` // Allows this CA certificate to be used for auto registration of device certificates. AllowAutoRegistration *bool `location:"querystring" locationName:"allowAutoRegistration" type:"boolean"` // The CA certificate. CaCertificate *string `locationName:"caCertificate" min:"1" type:"string" required:"true"` // A boolean value that specifies if the CA certificate is set to active. SetAsActive *bool `location:"querystring" locationName:"setAsActive" type:"boolean"` // The private key verification certificate. VerificationCertificate *string `locationName:"verificationCertificate" min:"1" type:"string" required:"true"` } // String returns the string representation func (s RegisterCACertificateInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s RegisterCACertificateInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *RegisterCACertificateInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "RegisterCACertificateInput"} if s.CaCertificate == nil { invalidParams.Add(request.NewErrParamRequired("CaCertificate")) } if s.CaCertificate != nil && len(*s.CaCertificate) < 1 { invalidParams.Add(request.NewErrParamMinLen("CaCertificate", 1)) } if s.VerificationCertificate == nil { invalidParams.Add(request.NewErrParamRequired("VerificationCertificate")) } if s.VerificationCertificate != nil && len(*s.VerificationCertificate) < 1 { invalidParams.Add(request.NewErrParamMinLen("VerificationCertificate", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the RegisterCACertificateResponse operation. type RegisterCACertificateOutput struct { _ struct{} `type:"structure"` // The CA certificate ARN. CertificateArn *string `locationName:"certificateArn" type:"string"` // The CA certificate identifier. CertificateId *string `locationName:"certificateId" min:"64" type:"string"` } // String returns the string representation func (s RegisterCACertificateOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s RegisterCACertificateOutput) GoString() string { return s.String() } // The input to the RegisterCertificate operation. type RegisterCertificateInput struct { _ struct{} `type:"structure"` // The CA certificate used to sign the device certificate being registered. CaCertificatePem *string `locationName:"caCertificatePem" min:"1" type:"string"` // The certificate data, in PEM format. CertificatePem *string `locationName:"certificatePem" min:"1" type:"string" required:"true"` // A boolean value that specifies if the CA certificate is set to active. SetAsActive *bool `location:"querystring" locationName:"setAsActive" type:"boolean"` } // String returns the string representation func (s RegisterCertificateInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s RegisterCertificateInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *RegisterCertificateInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "RegisterCertificateInput"} if s.CaCertificatePem != nil && len(*s.CaCertificatePem) < 1 { invalidParams.Add(request.NewErrParamMinLen("CaCertificatePem", 1)) } if s.CertificatePem == nil { invalidParams.Add(request.NewErrParamRequired("CertificatePem")) } if s.CertificatePem != nil && len(*s.CertificatePem) < 1 { invalidParams.Add(request.NewErrParamMinLen("CertificatePem", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the RegisterCertificate operation. type RegisterCertificateOutput struct { _ struct{} `type:"structure"` // The certificate ARN. CertificateArn *string `locationName:"certificateArn" type:"string"` // The certificate identifier. CertificateId *string `locationName:"certificateId" min:"64" type:"string"` } // String returns the string representation func (s RegisterCertificateOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s RegisterCertificateOutput) GoString() string { return s.String() } // The input for the RejectCertificateTransfer operation. type RejectCertificateTransferInput struct { _ struct{} `type:"structure"` // The ID of the certificate. CertificateId *string `location:"uri" locationName:"certificateId" min:"64" type:"string" required:"true"` // The reason the certificate transfer was rejected. RejectReason *string `locationName:"rejectReason" type:"string"` } // String returns the string representation func (s RejectCertificateTransferInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s RejectCertificateTransferInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *RejectCertificateTransferInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "RejectCertificateTransferInput"} if s.CertificateId == nil { invalidParams.Add(request.NewErrParamRequired("CertificateId")) } if s.CertificateId != nil && len(*s.CertificateId) < 64 { invalidParams.Add(request.NewErrParamMinLen("CertificateId", 64)) } if invalidParams.Len() > 0 { return invalidParams } return nil } type RejectCertificateTransferOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s RejectCertificateTransferOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s RejectCertificateTransferOutput) GoString() string { return s.String() } // The input for the ReplaceTopicRule operation. type ReplaceTopicRuleInput struct { _ struct{} `type:"structure" payload:"TopicRulePayload"` // The name of the rule. RuleName *string `location:"uri" locationName:"ruleName" min:"1" type:"string" required:"true"` // The rule payload. TopicRulePayload *TopicRulePayload `locationName:"topicRulePayload" type:"structure" required:"true"` } // String returns the string representation func (s ReplaceTopicRuleInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ReplaceTopicRuleInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *ReplaceTopicRuleInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "ReplaceTopicRuleInput"} if s.RuleName == nil { invalidParams.Add(request.NewErrParamRequired("RuleName")) } if s.RuleName != nil && len(*s.RuleName) < 1 { invalidParams.Add(request.NewErrParamMinLen("RuleName", 1)) } if s.TopicRulePayload == nil { invalidParams.Add(request.NewErrParamRequired("TopicRulePayload")) } if s.TopicRulePayload != nil { if err := s.TopicRulePayload.Validate(); err != nil { invalidParams.AddNested("TopicRulePayload", err.(request.ErrInvalidParams)) } } if invalidParams.Len() > 0 { return invalidParams } return nil } type ReplaceTopicRuleOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s ReplaceTopicRuleOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ReplaceTopicRuleOutput) GoString() string { return s.String() } // Describes an action to republish to another topic. type RepublishAction struct { _ struct{} `type:"structure"` // The ARN of the IAM role that grants access. RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The name of the MQTT topic. Topic *string `locationName:"topic" type:"string" required:"true"` } // String returns the string representation func (s RepublishAction) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s RepublishAction) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *RepublishAction) Validate() error { invalidParams := request.ErrInvalidParams{Context: "RepublishAction"} if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if s.Topic == nil { invalidParams.Add(request.NewErrParamRequired("Topic")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // Describes an action to write data to an Amazon S3 bucket. type S3Action struct { _ struct{} `type:"structure"` // The Amazon S3 bucket. BucketName *string `locationName:"bucketName" type:"string" required:"true"` // The object key. Key *string `locationName:"key" type:"string" required:"true"` // The ARN of the IAM role that grants access. RoleArn *string `locationName:"roleArn" type:"string" required:"true"` } // String returns the string representation func (s S3Action) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s S3Action) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *S3Action) Validate() error { invalidParams := request.ErrInvalidParams{Context: "S3Action"} if s.BucketName == nil { invalidParams.Add(request.NewErrParamRequired("BucketName")) } if s.Key == nil { invalidParams.Add(request.NewErrParamRequired("Key")) } if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The input for the SetDefaultPolicyVersion operation. type SetDefaultPolicyVersionInput struct { _ struct{} `type:"structure"` // The policy name. PolicyName *string `location:"uri" locationName:"policyName" min:"1" type:"string" required:"true"` // The policy version ID. PolicyVersionId *string `location:"uri" locationName:"policyVersionId" type:"string" required:"true"` } // String returns the string representation func (s SetDefaultPolicyVersionInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s SetDefaultPolicyVersionInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *SetDefaultPolicyVersionInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "SetDefaultPolicyVersionInput"} if s.PolicyName == nil { invalidParams.Add(request.NewErrParamRequired("PolicyName")) } if s.PolicyName != nil && len(*s.PolicyName) < 1 { invalidParams.Add(request.NewErrParamMinLen("PolicyName", 1)) } if s.PolicyVersionId == nil { invalidParams.Add(request.NewErrParamRequired("PolicyVersionId")) } if invalidParams.Len() > 0 { return invalidParams } return nil } type SetDefaultPolicyVersionOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s SetDefaultPolicyVersionOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s SetDefaultPolicyVersionOutput) GoString() string { return s.String() } // The input for the SetLoggingOptions operation. type SetLoggingOptionsInput struct { _ struct{} `type:"structure" payload:"LoggingOptionsPayload"` // The logging options payload. LoggingOptionsPayload *LoggingOptionsPayload `locationName:"loggingOptionsPayload" type:"structure" required:"true"` } // String returns the string representation func (s SetLoggingOptionsInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s SetLoggingOptionsInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *SetLoggingOptionsInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "SetLoggingOptionsInput"} if s.LoggingOptionsPayload == nil { invalidParams.Add(request.NewErrParamRequired("LoggingOptionsPayload")) } if s.LoggingOptionsPayload != nil { if err := s.LoggingOptionsPayload.Validate(); err != nil { invalidParams.AddNested("LoggingOptionsPayload", err.(request.ErrInvalidParams)) } } if invalidParams.Len() > 0 { return invalidParams } return nil } type SetLoggingOptionsOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s SetLoggingOptionsOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s SetLoggingOptionsOutput) GoString() string { return s.String() } // Describes an action to publish to an Amazon SNS topic. type SnsAction struct { _ struct{} `type:"structure"` // The message format of the message to publish. Optional. Accepted values are // "JSON" and "RAW". The default value of the attribute is "RAW". SNS uses this // setting to determine if the payload should be parsed and relevant platform-specific // bits of the payload should be extracted. To read more about SNS message formats, // see refer to their official documentation. MessageFormat *string `locationName:"messageFormat" type:"string" enum:"MessageFormat"` // The ARN of the IAM role that grants access. RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // The ARN of the SNS topic. TargetArn *string `locationName:"targetArn" type:"string" required:"true"` } // String returns the string representation func (s SnsAction) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s SnsAction) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *SnsAction) Validate() error { invalidParams := request.ErrInvalidParams{Context: "SnsAction"} if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if s.TargetArn == nil { invalidParams.Add(request.NewErrParamRequired("TargetArn")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // Describes an action to publish data to an Amazon SQS queue. type SqsAction struct { _ struct{} `type:"structure"` // The URL of the Amazon SQS queue. QueueUrl *string `locationName:"queueUrl" type:"string" required:"true"` // The ARN of the IAM role that grants access. RoleArn *string `locationName:"roleArn" type:"string" required:"true"` // Specifies whether to use Base64 encoding. UseBase64 *bool `locationName:"useBase64" type:"boolean"` } // String returns the string representation func (s SqsAction) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s SqsAction) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *SqsAction) Validate() error { invalidParams := request.ErrInvalidParams{Context: "SqsAction"} if s.QueueUrl == nil { invalidParams.Add(request.NewErrParamRequired("QueueUrl")) } if s.RoleArn == nil { invalidParams.Add(request.NewErrParamRequired("RoleArn")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The properties of the thing, including thing name, thing type name, and a // list of thing attributes. type ThingAttribute struct { _ struct{} `type:"structure"` // A list of thing attributes which are name-value pairs. Attributes map[string]*string `locationName:"attributes" type:"map"` // The name of the thing. ThingName *string `locationName:"thingName" min:"1" type:"string"` // The name of the thing type, if the thing has been associated with a type. ThingTypeName *string `locationName:"thingTypeName" min:"1" type:"string"` // The version of the thing record in the registry. Version *int64 `locationName:"version" type:"long"` } // String returns the string representation func (s ThingAttribute) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ThingAttribute) GoString() string { return s.String() } // The definition of the thing type, including thing type name and description. type ThingTypeDefinition struct { _ struct{} `type:"structure"` // The ThingTypeMetadata contains additional information about the thing type // including: creation date and time, a value indicating whether the thing type // is deprecated, and a date and time when time was deprecated. ThingTypeMetadata *ThingTypeMetadata `locationName:"thingTypeMetadata" type:"structure"` // The name of the thing type. ThingTypeName *string `locationName:"thingTypeName" min:"1" type:"string"` // The ThingTypeProperties for the thing type. ThingTypeProperties *ThingTypeProperties `locationName:"thingTypeProperties" type:"structure"` } // String returns the string representation func (s ThingTypeDefinition) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ThingTypeDefinition) GoString() string { return s.String() } // The ThingTypeMetadata contains additional information about the thing type // including: creation date and time, a value indicating whether the thing type // is deprecated, and a date and time when time was deprecated. type ThingTypeMetadata struct { _ struct{} `type:"structure"` // The date and time when the thing type was created. CreationDate *time.Time `locationName:"creationDate" type:"timestamp" timestampFormat:"unix"` // Whether the thing type is deprecated. If true, no new things could be associated // with this type. Deprecated *bool `locationName:"deprecated" type:"boolean"` // The date and time when the thing type was deprecated. DeprecationDate *time.Time `locationName:"deprecationDate" type:"timestamp" timestampFormat:"unix"` } // String returns the string representation func (s ThingTypeMetadata) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ThingTypeMetadata) GoString() string { return s.String() } // The ThingTypeProperties contains information about the thing type including: // a thing type description, and a list of searchable thing attribute names. type ThingTypeProperties struct { _ struct{} `type:"structure"` // A list of searchable thing attribute names. SearchableAttributes []*string `locationName:"searchableAttributes" type:"list"` // The description of the thing type. ThingTypeDescription *string `locationName:"thingTypeDescription" type:"string"` } // String returns the string representation func (s ThingTypeProperties) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s ThingTypeProperties) GoString() string { return s.String() } // Describes a rule. type TopicRule struct { _ struct{} `type:"structure"` // The actions associated with the rule. Actions []*Action `locationName:"actions" type:"list"` // The version of the SQL rules engine to use when evaluating the rule. AwsIotSqlVersion *string `locationName:"awsIotSqlVersion" type:"string"` // The date and time the rule was created. CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" timestampFormat:"unix"` // The description of the rule. Description *string `locationName:"description" type:"string"` // Specifies whether the rule is disabled. RuleDisabled *bool `locationName:"ruleDisabled" type:"boolean"` // The name of the rule. RuleName *string `locationName:"ruleName" min:"1" type:"string"` // The SQL statement used to query the topic. When using a SQL query with multiple // lines, be sure to escape the newline characters. Sql *string `locationName:"sql" type:"string"` } // String returns the string representation func (s TopicRule) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s TopicRule) GoString() string { return s.String() } // Describes a rule. type TopicRuleListItem struct { _ struct{} `type:"structure"` // The date and time the rule was created. CreatedAt *time.Time `locationName:"createdAt" type:"timestamp" timestampFormat:"unix"` // The rule ARN. RuleArn *string `locationName:"ruleArn" type:"string"` // Specifies whether the rule is disabled. RuleDisabled *bool `locationName:"ruleDisabled" type:"boolean"` // The name of the rule. RuleName *string `locationName:"ruleName" min:"1" type:"string"` // The pattern for the topic names that apply. TopicPattern *string `locationName:"topicPattern" type:"string"` } // String returns the string representation func (s TopicRuleListItem) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s TopicRuleListItem) GoString() string { return s.String() } // Describes a rule. type TopicRulePayload struct { _ struct{} `type:"structure"` // The actions associated with the rule. Actions []*Action `locationName:"actions" type:"list" required:"true"` // The version of the SQL rules engine to use when evaluating the rule. AwsIotSqlVersion *string `locationName:"awsIotSqlVersion" type:"string"` // The description of the rule. Description *string `locationName:"description" type:"string"` // Specifies whether the rule is disabled. RuleDisabled *bool `locationName:"ruleDisabled" type:"boolean"` // The SQL statement used to query the topic. For more information, see AWS // IoT SQL Reference (http://docs.aws.amazon.com/iot/latest/developerguide/iot-rules.html#aws-iot-sql-reference) // in the AWS IoT Developer Guide. Sql *string `locationName:"sql" type:"string" required:"true"` } // String returns the string representation func (s TopicRulePayload) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s TopicRulePayload) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *TopicRulePayload) Validate() error { invalidParams := request.ErrInvalidParams{Context: "TopicRulePayload"} if s.Actions == nil { invalidParams.Add(request.NewErrParamRequired("Actions")) } if s.Sql == nil { invalidParams.Add(request.NewErrParamRequired("Sql")) } if s.Actions != nil { for i, v := range s.Actions { if v == nil { continue } if err := v.Validate(); err != nil { invalidParams.AddNested(fmt.Sprintf("%s[%v]", "Actions", i), err.(request.ErrInvalidParams)) } } } if invalidParams.Len() > 0 { return invalidParams } return nil } // The input for the TransferCertificate operation. type TransferCertificateInput struct { _ struct{} `type:"structure"` // The ID of the certificate. CertificateId *string `location:"uri" locationName:"certificateId" min:"64" type:"string" required:"true"` // The AWS account. TargetAwsAccount *string `location:"querystring" locationName:"targetAwsAccount" type:"string" required:"true"` // The transfer message. TransferMessage *string `locationName:"transferMessage" type:"string"` } // String returns the string representation func (s TransferCertificateInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s TransferCertificateInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *TransferCertificateInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "TransferCertificateInput"} if s.CertificateId == nil { invalidParams.Add(request.NewErrParamRequired("CertificateId")) } if s.CertificateId != nil && len(*s.CertificateId) < 64 { invalidParams.Add(request.NewErrParamMinLen("CertificateId", 64)) } if s.TargetAwsAccount == nil { invalidParams.Add(request.NewErrParamRequired("TargetAwsAccount")) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the TransferCertificate operation. type TransferCertificateOutput struct { _ struct{} `type:"structure"` // The ARN of the certificate. TransferredCertificateArn *string `locationName:"transferredCertificateArn" type:"string"` } // String returns the string representation func (s TransferCertificateOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s TransferCertificateOutput) GoString() string { return s.String() } // Data used to transfer a certificate to an AWS account. type TransferData struct { _ struct{} `type:"structure"` // The date the transfer was accepted. AcceptDate *time.Time `locationName:"acceptDate" type:"timestamp" timestampFormat:"unix"` // The date the transfer was rejected. RejectDate *time.Time `locationName:"rejectDate" type:"timestamp" timestampFormat:"unix"` // The reason why the transfer was rejected. RejectReason *string `locationName:"rejectReason" type:"string"` // The date the transfer took place. TransferDate *time.Time `locationName:"transferDate" type:"timestamp" timestampFormat:"unix"` // The transfer message. TransferMessage *string `locationName:"transferMessage" type:"string"` } // String returns the string representation func (s TransferData) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s TransferData) GoString() string { return s.String() } // The input to the UpdateCACertificate operation. type UpdateCACertificateInput struct { _ struct{} `type:"structure"` // The CA certificate identifier. CertificateId *string `location:"uri" locationName:"caCertificateId" min:"64" type:"string" required:"true"` // The new value for the auto registration status. Valid values are: "ENABLE" // or "DISABLE". NewAutoRegistrationStatus *string `location:"querystring" locationName:"newAutoRegistrationStatus" type:"string" enum:"AutoRegistrationStatus"` // The updated status of the CA certificate. // // Note: The status value REGISTER_INACTIVE is deprecated and should not be // used. NewStatus *string `location:"querystring" locationName:"newStatus" type:"string" enum:"CACertificateStatus"` } // String returns the string representation func (s UpdateCACertificateInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s UpdateCACertificateInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *UpdateCACertificateInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "UpdateCACertificateInput"} if s.CertificateId == nil { invalidParams.Add(request.NewErrParamRequired("CertificateId")) } if s.CertificateId != nil && len(*s.CertificateId) < 64 { invalidParams.Add(request.NewErrParamMinLen("CertificateId", 64)) } if invalidParams.Len() > 0 { return invalidParams } return nil } type UpdateCACertificateOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s UpdateCACertificateOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s UpdateCACertificateOutput) GoString() string { return s.String() } // The input for the UpdateCertificate operation. type UpdateCertificateInput struct { _ struct{} `type:"structure"` // The ID of the certificate. CertificateId *string `location:"uri" locationName:"certificateId" min:"64" type:"string" required:"true"` // The new status. // // Note: Setting the status to PENDING_TRANSFER will result in an exception // being thrown. PENDING_TRANSFER is a status used internally by AWS IoT. It // is not intended for developer use. // // Note: The status value REGISTER_INACTIVE is deprecated and should not be // used. NewStatus *string `location:"querystring" locationName:"newStatus" type:"string" required:"true" enum:"CertificateStatus"` } // String returns the string representation func (s UpdateCertificateInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s UpdateCertificateInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *UpdateCertificateInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "UpdateCertificateInput"} if s.CertificateId == nil { invalidParams.Add(request.NewErrParamRequired("CertificateId")) } if s.CertificateId != nil && len(*s.CertificateId) < 64 { invalidParams.Add(request.NewErrParamMinLen("CertificateId", 64)) } if s.NewStatus == nil { invalidParams.Add(request.NewErrParamRequired("NewStatus")) } if invalidParams.Len() > 0 { return invalidParams } return nil } type UpdateCertificateOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s UpdateCertificateOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s UpdateCertificateOutput) GoString() string { return s.String() } // The input for the UpdateThing operation. type UpdateThingInput struct { _ struct{} `type:"structure"` // A list of thing attributes, a JSON string containing name-value pairs. For // example: // // {\"attributes\":{\"name1\":\"value2\"}}) // // This data is used to add new attributes or update existing attributes. AttributePayload *AttributePayload `locationName:"attributePayload" type:"structure"` // The expected version of the thing record in the registry. If the version // of the record in the registry does not match the expected version specified // in the request, the UpdateThing request is rejected with a VersionConflictException. ExpectedVersion *int64 `locationName:"expectedVersion" type:"long"` // Remove a thing type association. If true, the assocation is removed. RemoveThingType *bool `locationName:"removeThingType" type:"boolean"` // The name of the thing to update. ThingName *string `location:"uri" locationName:"thingName" min:"1" type:"string" required:"true"` // The name of the thing type. ThingTypeName *string `locationName:"thingTypeName" min:"1" type:"string"` } // String returns the string representation func (s UpdateThingInput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s UpdateThingInput) GoString() string { return s.String() } // Validate inspects the fields of the type to determine if they are valid. func (s *UpdateThingInput) Validate() error { invalidParams := request.ErrInvalidParams{Context: "UpdateThingInput"} if s.ThingName == nil { invalidParams.Add(request.NewErrParamRequired("ThingName")) } if s.ThingName != nil && len(*s.ThingName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingName", 1)) } if s.ThingTypeName != nil && len(*s.ThingTypeName) < 1 { invalidParams.Add(request.NewErrParamMinLen("ThingTypeName", 1)) } if invalidParams.Len() > 0 { return invalidParams } return nil } // The output from the UpdateThing operation. type UpdateThingOutput struct { _ struct{} `type:"structure"` } // String returns the string representation func (s UpdateThingOutput) String() string { return awsutil.Prettify(s) } // GoString returns the string representation func (s UpdateThingOutput) GoString() string { return s.String() } const ( // @enum AutoRegistrationStatus AutoRegistrationStatusEnable = "ENABLE" // @enum AutoRegistrationStatus AutoRegistrationStatusDisable = "DISABLE" ) const ( // @enum CACertificateStatus CACertificateStatusActive = "ACTIVE" // @enum CACertificateStatus CACertificateStatusInactive = "INACTIVE" ) const ( // @enum CertificateStatus CertificateStatusActive = "ACTIVE" // @enum CertificateStatus CertificateStatusInactive = "INACTIVE" // @enum CertificateStatus CertificateStatusRevoked = "REVOKED" // @enum CertificateStatus CertificateStatusPendingTransfer = "PENDING_TRANSFER" // @enum CertificateStatus CertificateStatusRegisterInactive = "REGISTER_INACTIVE" // @enum CertificateStatus CertificateStatusPendingActivation = "PENDING_ACTIVATION" ) const ( // @enum DynamoKeyType DynamoKeyTypeString = "STRING" // @enum DynamoKeyType DynamoKeyTypeNumber = "NUMBER" ) const ( // @enum LogLevel LogLevelDebug = "DEBUG" // @enum LogLevel LogLevelInfo = "INFO" // @enum LogLevel LogLevelError = "ERROR" // @enum LogLevel LogLevelWarn = "WARN" // @enum LogLevel LogLevelDisabled = "DISABLED" ) const ( // @enum MessageFormat MessageFormatRaw = "RAW" // @enum MessageFormat MessageFormatJson = "JSON" )