Documentation ¶
Overview ¶
Package iotdataplane provides the client and types for making API requests to AWS IoT Data Plane.
AWS IoT-Data enables secure, bi-directional communication between Internet-connected things (such as sensors, actuators, embedded devices, or smart appliances) and the AWS cloud. It implements a broker for applications and things to publish messages over HTTP (Publish) and retrieve, update, and delete thing shadows. A thing shadow is a persistent representation of your things and their state in the AWS cloud.
See https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28 for more information on this service.
See iotdataplane package documentation for more information. https://docs.aws.amazon.com/sdk-for-go/api/service/iotdataplane/
Using the Client ¶
To use the client for AWS IoT Data Plane you will first need to create a new instance of it.
When creating a client for an AWS service you'll first need to have a Session already created. The Session provides configuration that can be shared between multiple service clients. Additional configuration can be applied to the Session and service's client when they are constructed. The aws package's Config type contains several fields such as Region for the AWS Region the client should make API requests too. The optional Config value can be provided as the variadic argument for Sessions and client creation.
Once the service's client is created you can use it to make API requests the AWS service. These clients are safe to use concurrently.
// Create a session to share configuration, and load external configuration. sess := session.Must(session.NewSession()) // Create the service's client with the session. svc := iotdataplane.New(sess)
See the SDK's documentation for more information on how to use service clients. https://docs.aws.amazon.com/sdk-for-go/api/
See aws package's Config type for more information on configuration options. https://docs.aws.amazon.com/sdk-for-go/api/aws/#Config
See the AWS IoT Data Plane client IoTDataPlane for more information on creating the service's client. https://docs.aws.amazon.com/sdk-for-go/api/service/iotdataplane/#New
Once the client is created you can make an API request to the service. Each API method takes a input parameter, and returns the service response and an error.
The API method will document which error codes the service can be returned by the operation if the service models the API operation's errors. These errors will also be available as const strings prefixed with "ErrCode".
result, err := svc.DeleteThingShadow(params) if err != nil { // Cast err to awserr.Error to handle specific error codes. aerr, ok := err.(awserr.Error) if ok && aerr.Code() == <error code to check for> { // Specific error code handling } return err } fmt.Println("DeleteThingShadow result:") fmt.Println(result)
Using the Client with Context ¶
The service's client also provides methods to make API requests with a Context value. This allows you to control the timeout, and cancellation of pending requests. These methods also take request Option as variadic parameter to apply additional configuration to the API request.
ctx := context.Background() result, err := svc.DeleteThingShadowWithContext(ctx, params)
See the request package documentation for more information on using Context pattern with the SDK. https://docs.aws.amazon.com/sdk-for-go/api/aws/request/
Index ¶
- Constants
- type DeleteThingShadowInput
- type DeleteThingShadowOutput
- type GetThingShadowInput
- type GetThingShadowOutput
- type IoTDataPlane
- func (c *IoTDataPlane) DeleteThingShadow(input *DeleteThingShadowInput) (*DeleteThingShadowOutput, error)
- func (c *IoTDataPlane) DeleteThingShadowRequest(input *DeleteThingShadowInput) (req *request.Request, output *DeleteThingShadowOutput)
- func (c *IoTDataPlane) DeleteThingShadowWithContext(ctx aws.Context, input *DeleteThingShadowInput, opts ...request.Option) (*DeleteThingShadowOutput, error)
- func (c *IoTDataPlane) GetThingShadow(input *GetThingShadowInput) (*GetThingShadowOutput, error)
- func (c *IoTDataPlane) GetThingShadowRequest(input *GetThingShadowInput) (req *request.Request, output *GetThingShadowOutput)
- func (c *IoTDataPlane) GetThingShadowWithContext(ctx aws.Context, input *GetThingShadowInput, opts ...request.Option) (*GetThingShadowOutput, error)
- func (c *IoTDataPlane) Publish(input *PublishInput) (*PublishOutput, error)
- func (c *IoTDataPlane) PublishRequest(input *PublishInput) (req *request.Request, output *PublishOutput)
- func (c *IoTDataPlane) PublishWithContext(ctx aws.Context, input *PublishInput, opts ...request.Option) (*PublishOutput, error)
- func (c *IoTDataPlane) UpdateThingShadow(input *UpdateThingShadowInput) (*UpdateThingShadowOutput, error)
- func (c *IoTDataPlane) UpdateThingShadowRequest(input *UpdateThingShadowInput) (req *request.Request, output *UpdateThingShadowOutput)
- func (c *IoTDataPlane) UpdateThingShadowWithContext(ctx aws.Context, input *UpdateThingShadowInput, opts ...request.Option) (*UpdateThingShadowOutput, error)
- type PublishInput
- type PublishOutput
- type UpdateThingShadowInput
- func (s UpdateThingShadowInput) GoString() string
- func (s *UpdateThingShadowInput) SetPayload(v []byte) *UpdateThingShadowInput
- func (s *UpdateThingShadowInput) SetThingName(v string) *UpdateThingShadowInput
- func (s UpdateThingShadowInput) String() string
- func (s *UpdateThingShadowInput) Validate() error
- type UpdateThingShadowOutput
Examples ¶
Constants ¶
const ( // ErrCodeConflictException for service response error code // "ConflictException". // // The specified version does not match the version of the document. ErrCodeConflictException = "ConflictException" // ErrCodeInternalFailureException for service response error code // "InternalFailureException". // // An unexpected error has occurred. ErrCodeInternalFailureException = "InternalFailureException" // ErrCodeInvalidRequestException for service response error code // "InvalidRequestException". // // The request is not valid. ErrCodeInvalidRequestException = "InvalidRequestException" // ErrCodeMethodNotAllowedException for service response error code // "MethodNotAllowedException". // // The specified combination of HTTP verb and URI is not supported. ErrCodeMethodNotAllowedException = "MethodNotAllowedException" // ErrCodeRequestEntityTooLargeException for service response error code // "RequestEntityTooLargeException". // // The payload exceeds the maximum size allowed. ErrCodeRequestEntityTooLargeException = "RequestEntityTooLargeException" // ErrCodeResourceNotFoundException for service response error code // "ResourceNotFoundException". // // The specified resource does not exist. ErrCodeResourceNotFoundException = "ResourceNotFoundException" // "ServiceUnavailableException". // // The service is temporarily unavailable. ErrCodeServiceUnavailableException = "ServiceUnavailableException" // ErrCodeThrottlingException for service response error code // "ThrottlingException". // // The rate exceeds the limit. ErrCodeThrottlingException = "ThrottlingException" // "UnauthorizedException". // // You are not authorized to perform this operation. ErrCodeUnauthorizedException = "UnauthorizedException" // ErrCodeUnsupportedDocumentEncodingException for service response error code // "UnsupportedDocumentEncodingException". // // The document encoding is not supported. ErrCodeUnsupportedDocumentEncodingException = "UnsupportedDocumentEncodingException" )
const ( ServiceName = "data.iot" // Service endpoint prefix API calls made to. EndpointsID = ServiceName // Service ID for Regions and Endpoints metadata. )
Service information constants
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DeleteThingShadowInput ¶
type DeleteThingShadowInput struct { // The name of the thing. // // ThingName is a required field ThingName *string `location:"uri" locationName:"thingName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
The input for the DeleteThingShadow operation. Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/DeleteThingShadowRequest
func (DeleteThingShadowInput) GoString ¶
func (s DeleteThingShadowInput) GoString() string
GoString returns the string representation
func (*DeleteThingShadowInput) SetThingName ¶ added in v1.5.1
func (s *DeleteThingShadowInput) SetThingName(v string) *DeleteThingShadowInput
SetThingName sets the ThingName field's value.
func (DeleteThingShadowInput) String ¶
func (s DeleteThingShadowInput) String() string
String returns the string representation
func (*DeleteThingShadowInput) Validate ¶ added in v1.1.24
func (s *DeleteThingShadowInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeleteThingShadowOutput ¶
type DeleteThingShadowOutput struct { // The state information, in JSON format. // // Payload is a required field Payload []byte `locationName:"payload" type:"blob" required:"true"` // contains filtered or unexported fields }
The output from the DeleteThingShadow operation. Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/DeleteThingShadowResponse
func (DeleteThingShadowOutput) GoString ¶
func (s DeleteThingShadowOutput) GoString() string
GoString returns the string representation
func (*DeleteThingShadowOutput) SetPayload ¶ added in v1.5.1
func (s *DeleteThingShadowOutput) SetPayload(v []byte) *DeleteThingShadowOutput
SetPayload sets the Payload field's value.
func (DeleteThingShadowOutput) String ¶
func (s DeleteThingShadowOutput) String() string
String returns the string representation
type GetThingShadowInput ¶
type GetThingShadowInput struct { // The name of the thing. // // ThingName is a required field ThingName *string `location:"uri" locationName:"thingName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
The input for the GetThingShadow operation. Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/GetThingShadowRequest
func (GetThingShadowInput) GoString ¶
func (s GetThingShadowInput) GoString() string
GoString returns the string representation
func (*GetThingShadowInput) SetThingName ¶ added in v1.5.1
func (s *GetThingShadowInput) SetThingName(v string) *GetThingShadowInput
SetThingName sets the ThingName field's value.
func (GetThingShadowInput) String ¶
func (s GetThingShadowInput) String() string
String returns the string representation
func (*GetThingShadowInput) Validate ¶ added in v1.1.24
func (s *GetThingShadowInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type GetThingShadowOutput ¶
type GetThingShadowOutput struct { // The state information, in JSON format. Payload []byte `locationName:"payload" type:"blob"` // contains filtered or unexported fields }
The output from the GetThingShadow operation. Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/GetThingShadowResponse
func (GetThingShadowOutput) GoString ¶
func (s GetThingShadowOutput) GoString() string
GoString returns the string representation
func (*GetThingShadowOutput) SetPayload ¶ added in v1.5.1
func (s *GetThingShadowOutput) SetPayload(v []byte) *GetThingShadowOutput
SetPayload sets the Payload field's value.
func (GetThingShadowOutput) String ¶
func (s GetThingShadowOutput) String() string
String returns the string representation
type IoTDataPlane ¶
IoTDataPlane provides the API operation methods for making requests to AWS IoT Data Plane. See this package's package overview docs for details on the service.
IoTDataPlane methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.
func New ¶
func New(p client.ConfigProvider, cfgs ...*aws.Config) *IoTDataPlane
New creates a new instance of the IoTDataPlane client with a session. If additional configuration is needed for the client instance use the optional aws.Config parameter to add your extra config.
Example:
// Create a IoTDataPlane client from just a session. svc := iotdataplane.New(mySession) // Create a IoTDataPlane client with additional configuration svc := iotdataplane.New(mySession, aws.NewConfig().WithRegion("us-west-2"))
func (*IoTDataPlane) DeleteThingShadow ¶
func (c *IoTDataPlane) DeleteThingShadow(input *DeleteThingShadowInput) (*DeleteThingShadowOutput, error)
DeleteThingShadow API operation for AWS IoT Data Plane.
Deletes the thing shadow for the specified thing.
For more information, see DeleteThingShadow (http://docs.aws.amazon.com/iot/latest/developerguide/API_DeleteThingShadow.html) in the AWS IoT Developer Guide.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AWS IoT Data Plane's API operation DeleteThingShadow for usage and error information.
Returned Error Codes:
ErrCodeResourceNotFoundException "ResourceNotFoundException" The specified resource does not exist.
ErrCodeInvalidRequestException "InvalidRequestException" The request is not valid.
ErrCodeThrottlingException "ThrottlingException" The rate exceeds the limit.
ErrCodeUnauthorizedException "UnauthorizedException" You are not authorized to perform this operation.
ErrCodeServiceUnavailableException "ServiceUnavailableException" The service is temporarily unavailable.
ErrCodeInternalFailureException "InternalFailureException" An unexpected error has occurred.
ErrCodeMethodNotAllowedException "MethodNotAllowedException" The specified combination of HTTP verb and URI is not supported.
ErrCodeUnsupportedDocumentEncodingException "UnsupportedDocumentEncodingException" The document encoding is not supported.
Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/DeleteThingShadow
Example ¶
package main import ( "fmt" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/session" "github.com/aws/aws-sdk-go/service/iotdataplane" ) func main() { sess := session.Must(session.NewSession()) svc := iotdataplane.New(sess) params := &iotdataplane.DeleteThingShadowInput{ ThingName: aws.String("ThingName"), // Required } resp, err := svc.DeleteThingShadow(params) if err != nil { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) return } // Pretty-print the response data. fmt.Println(resp) }
Output:
func (*IoTDataPlane) DeleteThingShadowRequest ¶
func (c *IoTDataPlane) DeleteThingShadowRequest(input *DeleteThingShadowInput) (req *request.Request, output *DeleteThingShadowOutput)
DeleteThingShadowRequest generates a "aws/request.Request" representing the client's request for the DeleteThingShadow operation. The "output" return value can be used to capture response data after the request's "Send" method is called.
See DeleteThingShadow for usage and error information.
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 DeleteThingShadow 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 DeleteThingShadowRequest method. req, resp := client.DeleteThingShadowRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/DeleteThingShadow
func (*IoTDataPlane) DeleteThingShadowWithContext ¶ added in v1.8.0
func (c *IoTDataPlane) DeleteThingShadowWithContext(ctx aws.Context, input *DeleteThingShadowInput, opts ...request.Option) (*DeleteThingShadowOutput, error)
DeleteThingShadowWithContext is the same as DeleteThingShadow with the addition of the ability to pass a context and additional request options.
See DeleteThingShadow for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*IoTDataPlane) GetThingShadow ¶
func (c *IoTDataPlane) GetThingShadow(input *GetThingShadowInput) (*GetThingShadowOutput, error)
GetThingShadow API operation for AWS IoT Data Plane.
Gets the thing shadow for the specified thing.
For more information, see GetThingShadow (http://docs.aws.amazon.com/iot/latest/developerguide/API_GetThingShadow.html) in the AWS IoT Developer Guide.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AWS IoT Data Plane's API operation GetThingShadow for usage and error information.
Returned Error Codes:
ErrCodeInvalidRequestException "InvalidRequestException" The request is not valid.
ErrCodeResourceNotFoundException "ResourceNotFoundException" The specified resource does not exist.
ErrCodeThrottlingException "ThrottlingException" The rate exceeds the limit.
ErrCodeUnauthorizedException "UnauthorizedException" You are not authorized to perform this operation.
ErrCodeServiceUnavailableException "ServiceUnavailableException" The service is temporarily unavailable.
ErrCodeInternalFailureException "InternalFailureException" An unexpected error has occurred.
ErrCodeMethodNotAllowedException "MethodNotAllowedException" The specified combination of HTTP verb and URI is not supported.
ErrCodeUnsupportedDocumentEncodingException "UnsupportedDocumentEncodingException" The document encoding is not supported.
Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/GetThingShadow
Example ¶
package main import ( "fmt" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/session" "github.com/aws/aws-sdk-go/service/iotdataplane" ) func main() { sess := session.Must(session.NewSession()) svc := iotdataplane.New(sess) params := &iotdataplane.GetThingShadowInput{ ThingName: aws.String("ThingName"), // Required } resp, err := svc.GetThingShadow(params) if err != nil { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) return } // Pretty-print the response data. fmt.Println(resp) }
Output:
func (*IoTDataPlane) GetThingShadowRequest ¶
func (c *IoTDataPlane) GetThingShadowRequest(input *GetThingShadowInput) (req *request.Request, output *GetThingShadowOutput)
GetThingShadowRequest generates a "aws/request.Request" representing the client's request for the GetThingShadow operation. The "output" return value can be used to capture response data after the request's "Send" method is called.
See GetThingShadow for usage and error information.
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 GetThingShadow 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 GetThingShadowRequest method. req, resp := client.GetThingShadowRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/GetThingShadow
func (*IoTDataPlane) GetThingShadowWithContext ¶ added in v1.8.0
func (c *IoTDataPlane) GetThingShadowWithContext(ctx aws.Context, input *GetThingShadowInput, opts ...request.Option) (*GetThingShadowOutput, error)
GetThingShadowWithContext is the same as GetThingShadow with the addition of the ability to pass a context and additional request options.
See GetThingShadow for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*IoTDataPlane) Publish ¶
func (c *IoTDataPlane) Publish(input *PublishInput) (*PublishOutput, error)
Publish API operation for AWS IoT Data Plane.
Publishes state information.
For more information, see HTTP Protocol (http://docs.aws.amazon.com/iot/latest/developerguide/protocols.html#http) in the AWS IoT Developer Guide.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AWS IoT Data Plane's API operation Publish for usage and error information.
Returned Error Codes:
ErrCodeInternalFailureException "InternalFailureException" An unexpected error has occurred.
ErrCodeInvalidRequestException "InvalidRequestException" The request is not valid.
ErrCodeUnauthorizedException "UnauthorizedException" You are not authorized to perform this operation.
ErrCodeMethodNotAllowedException "MethodNotAllowedException" The specified combination of HTTP verb and URI is not supported.
Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/Publish
Example ¶
package main import ( "fmt" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/session" "github.com/aws/aws-sdk-go/service/iotdataplane" ) func main() { sess := session.Must(session.NewSession()) svc := iotdataplane.New(sess) params := &iotdataplane.PublishInput{ Topic: aws.String("Topic"), // Required Payload: []byte("PAYLOAD"), Qos: aws.Int64(1), } resp, err := svc.Publish(params) if err != nil { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) return } // Pretty-print the response data. fmt.Println(resp) }
Output:
func (*IoTDataPlane) PublishRequest ¶
func (c *IoTDataPlane) PublishRequest(input *PublishInput) (req *request.Request, output *PublishOutput)
PublishRequest generates a "aws/request.Request" representing the client's request for the Publish operation. The "output" return value can be used to capture response data after the request's "Send" method is called.
See Publish for usage and error information.
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 Publish 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 PublishRequest method. req, resp := client.PublishRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/Publish
func (*IoTDataPlane) PublishWithContext ¶ added in v1.8.0
func (c *IoTDataPlane) PublishWithContext(ctx aws.Context, input *PublishInput, opts ...request.Option) (*PublishOutput, error)
PublishWithContext is the same as Publish with the addition of the ability to pass a context and additional request options.
See Publish for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
func (*IoTDataPlane) UpdateThingShadow ¶
func (c *IoTDataPlane) UpdateThingShadow(input *UpdateThingShadowInput) (*UpdateThingShadowOutput, error)
UpdateThingShadow API operation for AWS IoT Data Plane.
Updates the thing shadow for the specified thing.
For more information, see UpdateThingShadow (http://docs.aws.amazon.com/iot/latest/developerguide/API_UpdateThingShadow.html) in the AWS IoT Developer Guide.
Returns awserr.Error for service API and SDK errors. Use runtime type assertions with awserr.Error's Code and Message methods to get detailed information about the error.
See the AWS API reference guide for AWS IoT Data Plane's API operation UpdateThingShadow for usage and error information.
Returned Error Codes:
ErrCodeConflictException "ConflictException" The specified version does not match the version of the document.
ErrCodeRequestEntityTooLargeException "RequestEntityTooLargeException" The payload exceeds the maximum size allowed.
ErrCodeInvalidRequestException "InvalidRequestException" The request is not valid.
ErrCodeThrottlingException "ThrottlingException" The rate exceeds the limit.
ErrCodeUnauthorizedException "UnauthorizedException" You are not authorized to perform this operation.
ErrCodeServiceUnavailableException "ServiceUnavailableException" The service is temporarily unavailable.
ErrCodeInternalFailureException "InternalFailureException" An unexpected error has occurred.
ErrCodeMethodNotAllowedException "MethodNotAllowedException" The specified combination of HTTP verb and URI is not supported.
ErrCodeUnsupportedDocumentEncodingException "UnsupportedDocumentEncodingException" The document encoding is not supported.
Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/UpdateThingShadow
Example ¶
package main import ( "fmt" "github.com/aws/aws-sdk-go/aws" "github.com/aws/aws-sdk-go/aws/session" "github.com/aws/aws-sdk-go/service/iotdataplane" ) func main() { sess := session.Must(session.NewSession()) svc := iotdataplane.New(sess) params := &iotdataplane.UpdateThingShadowInput{ Payload: []byte("PAYLOAD"), // Required ThingName: aws.String("ThingName"), // Required } resp, err := svc.UpdateThingShadow(params) if err != nil { // Print the error, cast err to awserr.Error to get the Code and // Message from an error. fmt.Println(err.Error()) return } // Pretty-print the response data. fmt.Println(resp) }
Output:
func (*IoTDataPlane) UpdateThingShadowRequest ¶
func (c *IoTDataPlane) UpdateThingShadowRequest(input *UpdateThingShadowInput) (req *request.Request, output *UpdateThingShadowOutput)
UpdateThingShadowRequest generates a "aws/request.Request" representing the client's request for the UpdateThingShadow operation. The "output" return value can be used to capture response data after the request's "Send" method is called.
See UpdateThingShadow for usage and error information.
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 UpdateThingShadow 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 UpdateThingShadowRequest method. req, resp := client.UpdateThingShadowRequest(params) err := req.Send() if err == nil { // resp is now filled fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/UpdateThingShadow
func (*IoTDataPlane) UpdateThingShadowWithContext ¶ added in v1.8.0
func (c *IoTDataPlane) UpdateThingShadowWithContext(ctx aws.Context, input *UpdateThingShadowInput, opts ...request.Option) (*UpdateThingShadowOutput, error)
UpdateThingShadowWithContext is the same as UpdateThingShadow with the addition of the ability to pass a context and additional request options.
See UpdateThingShadow for details on how to use this API operation.
The context must be non-nil and will be used for request cancellation. If the context is nil a panic will occur. In the future the SDK may create sub-contexts for http.Requests. See https://golang.org/pkg/context/ for more information on using Contexts.
type PublishInput ¶
type PublishInput struct { // The state information, in JSON format. Payload []byte `locationName:"payload" type:"blob"` // The Quality of Service (QoS) level. Qos *int64 `location:"querystring" locationName:"qos" type:"integer"` // The name of the MQTT topic. // // Topic is a required field Topic *string `location:"uri" locationName:"topic" type:"string" required:"true"` // contains filtered or unexported fields }
The input for the Publish operation. Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/PublishRequest
func (PublishInput) GoString ¶
func (s PublishInput) GoString() string
GoString returns the string representation
func (*PublishInput) SetPayload ¶ added in v1.5.1
func (s *PublishInput) SetPayload(v []byte) *PublishInput
SetPayload sets the Payload field's value.
func (*PublishInput) SetQos ¶ added in v1.5.1
func (s *PublishInput) SetQos(v int64) *PublishInput
SetQos sets the Qos field's value.
func (*PublishInput) SetTopic ¶ added in v1.5.1
func (s *PublishInput) SetTopic(v string) *PublishInput
SetTopic sets the Topic field's value.
func (PublishInput) String ¶
func (s PublishInput) String() string
String returns the string representation
func (*PublishInput) Validate ¶ added in v1.1.24
func (s *PublishInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type PublishOutput ¶
type PublishOutput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/PublishOutput
func (PublishOutput) GoString ¶
func (s PublishOutput) GoString() string
GoString returns the string representation
func (PublishOutput) String ¶
func (s PublishOutput) String() string
String returns the string representation
type UpdateThingShadowInput ¶
type UpdateThingShadowInput struct { // The state information, in JSON format. // // Payload is a required field Payload []byte `locationName:"payload" type:"blob" required:"true"` // The name of the thing. // // ThingName is a required field ThingName *string `location:"uri" locationName:"thingName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
The input for the UpdateThingShadow operation. Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/UpdateThingShadowRequest
func (UpdateThingShadowInput) GoString ¶
func (s UpdateThingShadowInput) GoString() string
GoString returns the string representation
func (*UpdateThingShadowInput) SetPayload ¶ added in v1.5.1
func (s *UpdateThingShadowInput) SetPayload(v []byte) *UpdateThingShadowInput
SetPayload sets the Payload field's value.
func (*UpdateThingShadowInput) SetThingName ¶ added in v1.5.1
func (s *UpdateThingShadowInput) SetThingName(v string) *UpdateThingShadowInput
SetThingName sets the ThingName field's value.
func (UpdateThingShadowInput) String ¶
func (s UpdateThingShadowInput) String() string
String returns the string representation
func (*UpdateThingShadowInput) Validate ¶ added in v1.1.24
func (s *UpdateThingShadowInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UpdateThingShadowOutput ¶
type UpdateThingShadowOutput struct { // The state information, in JSON format. Payload []byte `locationName:"payload" type:"blob"` // contains filtered or unexported fields }
The output from the UpdateThingShadow operation. Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-data-2015-05-28/UpdateThingShadowResponse
func (UpdateThingShadowOutput) GoString ¶
func (s UpdateThingShadowOutput) GoString() string
GoString returns the string representation
func (*UpdateThingShadowOutput) SetPayload ¶ added in v1.5.1
func (s *UpdateThingShadowOutput) SetPayload(v []byte) *UpdateThingShadowOutput
SetPayload sets the Payload field's value.
func (UpdateThingShadowOutput) String ¶
func (s UpdateThingShadowOutput) String() string
String returns the string representation
Directories ¶
Path | Synopsis |
---|---|
Package iotdataplaneiface provides an interface to enable mocking the AWS IoT Data Plane service client for testing your code.
|
Package iotdataplaneiface provides an interface to enable mocking the AWS IoT Data Plane service client for testing your code. |