iotjobsdataplane

package
v2.0.0-preview.2+incom... Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 15, 2018 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package iotjobsdataplane provides the client and types for making API requests to AWS IoT Jobs Data Plane.

AWS IoT Jobs is a service that allows you to define a set of jobs — remote operations that are sent to and executed on one or more devices connected to AWS IoT. For example, you can define a job that instructs a set of devices to download and install application or firmware updates, reboot, rotate certificates, or perform remote troubleshooting operations.

To create a job, you make a job document which is a description of the remote operations to be performed, and you specify a list of targets that should perform the operations. The targets can be individual things, thing groups or both.

AWS IoT Jobs sends a message to inform the targets that a job is available. The target starts the execution of the job by downloading the job document, performing the operations it specifies, and reporting its progress to AWS IoT. The Jobs service provides commands to track the progress of a job on a specific target and for all the targets of the job

See https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29 for more information on this service.

See iotjobsdataplane package documentation for more information. https://docs.aws.amazon.com/sdk-for-go/api/service/iotjobsdataplane/

Using the Client

To AWS IoT Jobs Data Plane with the SDK use the New function to create a new service client. With that client you can make API requests to the service. These clients are safe to use concurrently.

See the SDK's documentation for more information on how to use the SDK. https://docs.aws.amazon.com/sdk-for-go/api/

See aws.Config documentation for more information on configuring SDK clients. https://docs.aws.amazon.com/sdk-for-go/api/aws/#Config

See the AWS IoT Jobs Data Plane client IoTJobsDataPlane for more information on creating client for this service. https://docs.aws.amazon.com/sdk-for-go/api/service/iotjobsdataplane/#New

Index

Constants

View Source 
const (

	// ErrCodeCertificateValidationException for service response error code
	// "CertificateValidationException".
	//
	// The certificate is invalid.
	ErrCodeCertificateValidationException = "CertificateValidationException"

	// ErrCodeInvalidRequestException for service response error code
	// "InvalidRequestException".
	//
	// The contents of the request were invalid. For example, this code is returned
	// when an UpdateJobExecution request contains invalid status details. The message
	// contains details about the error.
	ErrCodeInvalidRequestException = "InvalidRequestException"

	// ErrCodeInvalidStateTransitionException for service response error code
	// "InvalidStateTransitionException".
	//
	// An update attempted to change the job execution to a state that is invalid
	// because of the job execution's current state (for example, an attempt to
	// change a request in state SUCCESS to state IN_PROGRESS). In this case, the
	// body of the error message also contains the executionState field.
	ErrCodeInvalidStateTransitionException = "InvalidStateTransitionException"

	// ErrCodeResourceNotFoundException for service response error code
	// "ResourceNotFoundException".
	//
	// The specified resource does not exist.
	ErrCodeResourceNotFoundException = "ResourceNotFoundException"

	// ErrCodeServiceUnavailableException for service response error code
	// "ServiceUnavailableException".
	//
	// The service is temporarily unavailable.
	ErrCodeServiceUnavailableException = "ServiceUnavailableException"

	// ErrCodeTerminalStateException for service response error code
	// "TerminalStateException".
	//
	// The job is in a terminal state.
	ErrCodeTerminalStateException = "TerminalStateException"

	// ErrCodeThrottlingException for service response error code
	// "ThrottlingException".
	//
	// The rate exceeds the limit.
	ErrCodeThrottlingException = "ThrottlingException"
)
View Source 
const (
	ServiceName = "data.jobs.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 DescribeJobExecutionInput 

type DescribeJobExecutionInput struct {

	// Optional. A number that identifies a particular job execution on a particular
	// device. If not specified, the latest job execution is returned.
	ExecutionNumber *int64 `location:"querystring" locationName:"executionNumber" type:"long"`

	// Optional. When set to true, the response contains the job document. The default
	// is false.
	IncludeJobDocument *bool `location:"querystring" locationName:"includeJobDocument" type:"boolean"`

	// The unique identifier assigned to this job when it was created.
	//
	// JobId is a required field
	JobId *string `location:"uri" locationName:"jobId" type:"string" required:"true"`

	// The thing name associated with the device the job execution is running on.
	//
	// ThingName is a required field
	ThingName *string `location:"uri" locationName:"thingName" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/DescribeJobExecutionRequest

func (DescribeJobExecutionInput) GoString 

func (s DescribeJobExecutionInput) GoString() string

GoString returns the string representation

func (*DescribeJobExecutionInput) SetExecutionNumber 

func (s *DescribeJobExecutionInput) SetExecutionNumber(v int64) *DescribeJobExecutionInput

SetExecutionNumber sets the ExecutionNumber field's value.

func (*DescribeJobExecutionInput) SetIncludeJobDocument 

func (s *DescribeJobExecutionInput) SetIncludeJobDocument(v bool) *DescribeJobExecutionInput

SetIncludeJobDocument sets the IncludeJobDocument field's value.

func (*DescribeJobExecutionInput) SetJobId 

func (s *DescribeJobExecutionInput) SetJobId(v string) *DescribeJobExecutionInput

SetJobId sets the JobId field's value.

func (*DescribeJobExecutionInput) SetThingName 

func (s *DescribeJobExecutionInput) SetThingName(v string) *DescribeJobExecutionInput

SetThingName sets the ThingName field's value.

func (DescribeJobExecutionInput) String 

func (s DescribeJobExecutionInput) String() string

String returns the string representation

func (*DescribeJobExecutionInput) Validate 

func (s *DescribeJobExecutionInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type DescribeJobExecutionOutput 

type DescribeJobExecutionOutput struct {

	// Contains data about a job execution.
	Execution *JobExecution `locationName:"execution" type:"structure"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/DescribeJobExecutionResponse

func (DescribeJobExecutionOutput) GoString 

func (s DescribeJobExecutionOutput) GoString() string

GoString returns the string representation

func (DescribeJobExecutionOutput) SDKResponseMetadata 

func (s DescribeJobExecutionOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

func (*DescribeJobExecutionOutput) SetExecution 

func (s *DescribeJobExecutionOutput) SetExecution(v *JobExecution) *DescribeJobExecutionOutput

SetExecution sets the Execution field's value.

func (DescribeJobExecutionOutput) String 

func (s DescribeJobExecutionOutput) String() string

String returns the string representation

type DescribeJobExecutionRequest 

type DescribeJobExecutionRequest struct {
	*aws.Request
	Input *DescribeJobExecutionInput
}

DescribeJobExecutionRequest is a API request type for the DescribeJobExecution API operation.

func (DescribeJobExecutionRequest) Send 

func (r DescribeJobExecutionRequest) Send() (*DescribeJobExecutionOutput, error)

Send marshals and sends the DescribeJobExecution API request.

type GetPendingJobExecutionsInput 

type GetPendingJobExecutionsInput struct {

	// The name of the thing that is executing the job.
	//
	// ThingName is a required field
	ThingName *string `location:"uri" locationName:"thingName" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/GetPendingJobExecutionsRequest

func (GetPendingJobExecutionsInput) GoString 

func (s GetPendingJobExecutionsInput) GoString() string

GoString returns the string representation

func (*GetPendingJobExecutionsInput) SetThingName 

func (s *GetPendingJobExecutionsInput) SetThingName(v string) *GetPendingJobExecutionsInput

SetThingName sets the ThingName field's value.

func (GetPendingJobExecutionsInput) String 

func (s GetPendingJobExecutionsInput) String() string

String returns the string representation

func (*GetPendingJobExecutionsInput) Validate 

func (s *GetPendingJobExecutionsInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type GetPendingJobExecutionsOutput 

type GetPendingJobExecutionsOutput struct {

	// A list of JobExecutionSummary objects with status IN_PROGRESS.
	InProgressJobs []JobExecutionSummary `locationName:"inProgressJobs" type:"list"`

	// A list of JobExecutionSummary objects with status QUEUED.
	QueuedJobs []JobExecutionSummary `locationName:"queuedJobs" type:"list"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/GetPendingJobExecutionsResponse

func (GetPendingJobExecutionsOutput) GoString 

func (s GetPendingJobExecutionsOutput) GoString() string

GoString returns the string representation

func (GetPendingJobExecutionsOutput) SDKResponseMetadata 

func (s GetPendingJobExecutionsOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

func (*GetPendingJobExecutionsOutput) SetInProgressJobs 

func (s *GetPendingJobExecutionsOutput) SetInProgressJobs(v []JobExecutionSummary) *GetPendingJobExecutionsOutput

SetInProgressJobs sets the InProgressJobs field's value.

func (*GetPendingJobExecutionsOutput) SetQueuedJobs 

func (s *GetPendingJobExecutionsOutput) SetQueuedJobs(v []JobExecutionSummary) *GetPendingJobExecutionsOutput

SetQueuedJobs sets the QueuedJobs field's value.

func (GetPendingJobExecutionsOutput) String 

func (s GetPendingJobExecutionsOutput) String() string

String returns the string representation

type GetPendingJobExecutionsRequest 

type GetPendingJobExecutionsRequest struct {
	*aws.Request
	Input *GetPendingJobExecutionsInput
}

GetPendingJobExecutionsRequest is a API request type for the GetPendingJobExecutions API operation.

func (GetPendingJobExecutionsRequest) Send 

func (r GetPendingJobExecutionsRequest) Send() (*GetPendingJobExecutionsOutput, error)

Send marshals and sends the GetPendingJobExecutions API request.

type IoTJobsDataPlane 

type IoTJobsDataPlane struct {
	*aws.Client
}

IoTJobsDataPlane provides the API operation methods for making requests to AWS IoT Jobs Data Plane. See this package's package overview docs for details on the service.

IoTJobsDataPlane methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.

func New 

func New(config aws.Config) *IoTJobsDataPlane

New creates a new instance of the IoTJobsDataPlane client with a config. If additional configuration is needed for the client instance use the optional aws.Config parameter to add your extra config.

Example: 

// Create a IoTJobsDataPlane client from just a config.
svc := iotjobsdataplane.New(myConfig)

// Create a IoTJobsDataPlane client with additional configuration
svc := iotjobsdataplane.New(myConfig, aws.NewConfig().WithRegion("us-west-2"))

func (*IoTJobsDataPlane) DescribeJobExecutionRequest 

func (c *IoTJobsDataPlane) DescribeJobExecutionRequest(input *DescribeJobExecutionInput) DescribeJobExecutionRequest

DescribeJobExecutionRequest returns a request value for making API operation for AWS IoT Jobs Data Plane.

Gets details of a job execution. 

// Example sending a request using the DescribeJobExecutionRequest method.
req := client.DescribeJobExecutionRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/DescribeJobExecution

func (*IoTJobsDataPlane) GetPendingJobExecutionsRequest 

func (c *IoTJobsDataPlane) GetPendingJobExecutionsRequest(input *GetPendingJobExecutionsInput) GetPendingJobExecutionsRequest

GetPendingJobExecutionsRequest returns a request value for making API operation for AWS IoT Jobs Data Plane.

Gets the list of all jobs for a thing that are not in a terminal status. 

// Example sending a request using the GetPendingJobExecutionsRequest method.
req := client.GetPendingJobExecutionsRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/GetPendingJobExecutions

func (*IoTJobsDataPlane) StartNextPendingJobExecutionRequest 

func (c *IoTJobsDataPlane) StartNextPendingJobExecutionRequest(input *StartNextPendingJobExecutionInput) StartNextPendingJobExecutionRequest

StartNextPendingJobExecutionRequest returns a request value for making API operation for AWS IoT Jobs Data Plane.

Gets and starts the next pending (status IN_PROGRESS or QUEUED) job execution for a thing. 

// Example sending a request using the StartNextPendingJobExecutionRequest method.
req := client.StartNextPendingJobExecutionRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/StartNextPendingJobExecution

func (*IoTJobsDataPlane) UpdateJobExecutionRequest 

func (c *IoTJobsDataPlane) UpdateJobExecutionRequest(input *UpdateJobExecutionInput) UpdateJobExecutionRequest

UpdateJobExecutionRequest returns a request value for making API operation for AWS IoT Jobs Data Plane.

Updates the status of a job execution. 

// Example sending a request using the UpdateJobExecutionRequest method.
req := client.UpdateJobExecutionRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/UpdateJobExecution

type JobExecution 

type JobExecution struct {

	// A number that identifies a particular job execution on a particular device.
	// It can be used later in commands that return or update job execution information.
	ExecutionNumber *int64 `locationName:"executionNumber" type:"long"`

	// The content of the job document.
	JobDocument *string `locationName:"jobDocument" type:"string"`

	// The unique identifier you assigned to this job when it was created.
	JobId *string `locationName:"jobId" min:"1" type:"string"`

	// The time, in milliseconds since the epoch, when the job execution was last
	// updated.
	LastUpdatedAt *int64 `locationName:"lastUpdatedAt" type:"long"`

	// The time, in milliseconds since the epoch, when the job execution was enqueued.
	QueuedAt *int64 `locationName:"queuedAt" type:"long"`

	// The time, in milliseconds since the epoch, when the job execution was started.
	StartedAt *int64 `locationName:"startedAt" type:"long"`

	// The status of the job execution. Can be one of: "QUEUED", "IN_PROGRESS",
	// "FAILED", "SUCCESS", "CANCELED", "REJECTED", or "REMOVED".
	Status JobExecutionStatus `locationName:"status" type:"string" enum:"true"`

	// A collection of name/value pairs that describe the status of the job execution.
	StatusDetails map[string]string `locationName:"statusDetails" type:"map"`

	// The name of the thing that is executing the job.
	ThingName *string `locationName:"thingName" min:"1" type:"string"`

	// The version of the job execution. Job execution versions are incremented
	// each time they are updated by a device.
	VersionNumber *int64 `locationName:"versionNumber" type:"long"`
	// contains filtered or unexported fields
}

Contains data about a job execution. Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/JobExecution

func (JobExecution) GoString 

func (s JobExecution) GoString() string

GoString returns the string representation

func (*JobExecution) SetExecutionNumber 

func (s *JobExecution) SetExecutionNumber(v int64) *JobExecution

SetExecutionNumber sets the ExecutionNumber field's value.

func (*JobExecution) SetJobDocument 

func (s *JobExecution) SetJobDocument(v string) *JobExecution

SetJobDocument sets the JobDocument field's value.

func (*JobExecution) SetJobId 

func (s *JobExecution) SetJobId(v string) *JobExecution

SetJobId sets the JobId field's value.

func (*JobExecution) SetLastUpdatedAt 

func (s *JobExecution) SetLastUpdatedAt(v int64) *JobExecution

SetLastUpdatedAt sets the LastUpdatedAt field's value.

func (*JobExecution) SetQueuedAt 

func (s *JobExecution) SetQueuedAt(v int64) *JobExecution

SetQueuedAt sets the QueuedAt field's value.

func (*JobExecution) SetStartedAt 

func (s *JobExecution) SetStartedAt(v int64) *JobExecution

SetStartedAt sets the StartedAt field's value.

func (*JobExecution) SetStatus 

func (s *JobExecution) SetStatus(v JobExecutionStatus) *JobExecution

SetStatus sets the Status field's value.

func (*JobExecution) SetStatusDetails 

func (s *JobExecution) SetStatusDetails(v map[string]string) *JobExecution

SetStatusDetails sets the StatusDetails field's value.

func (*JobExecution) SetThingName 

func (s *JobExecution) SetThingName(v string) *JobExecution

SetThingName sets the ThingName field's value.

func (*JobExecution) SetVersionNumber 

func (s *JobExecution) SetVersionNumber(v int64) *JobExecution

SetVersionNumber sets the VersionNumber field's value.

func (JobExecution) String 

func (s JobExecution) String() string

String returns the string representation

type JobExecutionState 

type JobExecutionState struct {

	// The status of the job execution. Can be one of: "QUEUED", "IN_PROGRESS",
	// "FAILED", "SUCCESS", "CANCELED", "REJECTED", or "REMOVED".
	Status JobExecutionStatus `locationName:"status" type:"string" enum:"true"`

	// A collection of name/value pairs that describe the status of the job execution.
	StatusDetails map[string]string `locationName:"statusDetails" type:"map"`

	// The version of the job execution. Job execution versions are incremented
	// each time they are updated by a device.
	VersionNumber *int64 `locationName:"versionNumber" type:"long"`
	// contains filtered or unexported fields
}

Contains data about the state of a job execution. Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/JobExecutionState

func (JobExecutionState) GoString 

func (s JobExecutionState) GoString() string

GoString returns the string representation

func (*JobExecutionState) SetStatus 

func (s *JobExecutionState) SetStatus(v JobExecutionStatus) *JobExecutionState

SetStatus sets the Status field's value.

func (*JobExecutionState) SetStatusDetails 

func (s *JobExecutionState) SetStatusDetails(v map[string]string) *JobExecutionState

SetStatusDetails sets the StatusDetails field's value.

func (*JobExecutionState) SetVersionNumber 

func (s *JobExecutionState) SetVersionNumber(v int64) *JobExecutionState

SetVersionNumber sets the VersionNumber field's value.

func (JobExecutionState) String 

func (s JobExecutionState) String() string

String returns the string representation

type JobExecutionStatus 

type JobExecutionStatus string
const (
	JobExecutionStatusQueued     JobExecutionStatus = "QUEUED"
	JobExecutionStatusInProgress JobExecutionStatus = "IN_PROGRESS"
	JobExecutionStatusSucceeded  JobExecutionStatus = "SUCCEEDED"
	JobExecutionStatusFailed     JobExecutionStatus = "FAILED"
	JobExecutionStatusRejected   JobExecutionStatus = "REJECTED"
	JobExecutionStatusRemoved    JobExecutionStatus = "REMOVED"
	JobExecutionStatusCanceled   JobExecutionStatus = "CANCELED"
)

Enum values for JobExecutionStatus

type JobExecutionSummary 

type JobExecutionSummary struct {

	// A number that identifies a particular job execution on a particular device.
	ExecutionNumber *int64 `locationName:"executionNumber" type:"long"`

	// The unique identifier you assigned to this job when it was created.
	JobId *string `locationName:"jobId" min:"1" type:"string"`

	// The time, in milliseconds since the epoch, when the job execution was last
	// updated.
	LastUpdatedAt *int64 `locationName:"lastUpdatedAt" type:"long"`

	// The time, in milliseconds since the epoch, when the job execution was enqueued.
	QueuedAt *int64 `locationName:"queuedAt" type:"long"`

	// The time, in milliseconds since the epoch, when the job execution started.
	StartedAt *int64 `locationName:"startedAt" type:"long"`

	// The version of the job execution. Job execution versions are incremented
	// each time AWS IoT Jobs receives an update from a device.
	VersionNumber *int64 `locationName:"versionNumber" type:"long"`
	// contains filtered or unexported fields
}

Contains a subset of information about a job execution. Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/JobExecutionSummary

func (JobExecutionSummary) GoString 

func (s JobExecutionSummary) GoString() string

GoString returns the string representation

func (*JobExecutionSummary) SetExecutionNumber 

func (s *JobExecutionSummary) SetExecutionNumber(v int64) *JobExecutionSummary

SetExecutionNumber sets the ExecutionNumber field's value.

func (*JobExecutionSummary) SetJobId 

func (s *JobExecutionSummary) SetJobId(v string) *JobExecutionSummary

SetJobId sets the JobId field's value.

func (*JobExecutionSummary) SetLastUpdatedAt 

func (s *JobExecutionSummary) SetLastUpdatedAt(v int64) *JobExecutionSummary

SetLastUpdatedAt sets the LastUpdatedAt field's value.

func (*JobExecutionSummary) SetQueuedAt 

func (s *JobExecutionSummary) SetQueuedAt(v int64) *JobExecutionSummary

SetQueuedAt sets the QueuedAt field's value.

func (*JobExecutionSummary) SetStartedAt 

func (s *JobExecutionSummary) SetStartedAt(v int64) *JobExecutionSummary

SetStartedAt sets the StartedAt field's value.

func (*JobExecutionSummary) SetVersionNumber 

func (s *JobExecutionSummary) SetVersionNumber(v int64) *JobExecutionSummary

SetVersionNumber sets the VersionNumber field's value.

func (JobExecutionSummary) String 

func (s JobExecutionSummary) String() string

String returns the string representation

type StartNextPendingJobExecutionInput 

type StartNextPendingJobExecutionInput struct {

	// A collection of name/value pairs that describe the status of the job execution.
	// If not specified, the statusDetails are unchanged.
	StatusDetails map[string]string `locationName:"statusDetails" type:"map"`

	// The name of the thing associated with the device.
	//
	// ThingName is a required field
	ThingName *string `location:"uri" locationName:"thingName" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/StartNextPendingJobExecutionRequest

func (StartNextPendingJobExecutionInput) GoString 

func (s StartNextPendingJobExecutionInput) GoString() string

GoString returns the string representation

func (*StartNextPendingJobExecutionInput) SetStatusDetails 

func (s *StartNextPendingJobExecutionInput) SetStatusDetails(v map[string]string) *StartNextPendingJobExecutionInput

SetStatusDetails sets the StatusDetails field's value.

func (*StartNextPendingJobExecutionInput) SetThingName 

func (s *StartNextPendingJobExecutionInput) SetThingName(v string) *StartNextPendingJobExecutionInput

SetThingName sets the ThingName field's value.

func (StartNextPendingJobExecutionInput) String 

func (s StartNextPendingJobExecutionInput) String() string

String returns the string representation

func (*StartNextPendingJobExecutionInput) Validate 

func (s *StartNextPendingJobExecutionInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type StartNextPendingJobExecutionOutput 

type StartNextPendingJobExecutionOutput struct {

	// A JobExecution object.
	Execution *JobExecution `locationName:"execution" type:"structure"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/StartNextPendingJobExecutionResponse

func (StartNextPendingJobExecutionOutput) GoString 

func (s StartNextPendingJobExecutionOutput) GoString() string

GoString returns the string representation

func (StartNextPendingJobExecutionOutput) SDKResponseMetadata 

func (s StartNextPendingJobExecutionOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

func (*StartNextPendingJobExecutionOutput) SetExecution 

func (s *StartNextPendingJobExecutionOutput) SetExecution(v *JobExecution) *StartNextPendingJobExecutionOutput

SetExecution sets the Execution field's value.

func (StartNextPendingJobExecutionOutput) String 

func (s StartNextPendingJobExecutionOutput) String() string

String returns the string representation

type StartNextPendingJobExecutionRequest 

type StartNextPendingJobExecutionRequest struct {
	*aws.Request
	Input *StartNextPendingJobExecutionInput
}

StartNextPendingJobExecutionRequest is a API request type for the StartNextPendingJobExecution API operation.

func (StartNextPendingJobExecutionRequest) Send 

func (r StartNextPendingJobExecutionRequest) Send() (*StartNextPendingJobExecutionOutput, error)

Send marshals and sends the StartNextPendingJobExecution API request.

type UpdateJobExecutionInput 

type UpdateJobExecutionInput struct {

	// Optional. A number that identifies a particular job execution on a particular
	// device.
	ExecutionNumber *int64 `locationName:"executionNumber" type:"long"`

	// Optional. The expected current version of the job execution. Each time you
	// update the job execution, its version is incremented. If the version of the
	// job execution stored in Jobs does not match, the update is rejected with
	// a VersionMismatch error, and an ErrorResponse that contains the current job
	// execution status data is returned. (This makes it unnecessary to perform
	// a separate DescribeJobExecution request in order to obtain the job execution
	// status data.)
	ExpectedVersion *int64 `locationName:"expectedVersion" type:"long"`

	// Optional. When set to true, the response contains the job document. The default
	// is false.
	IncludeJobDocument *bool `locationName:"includeJobDocument" type:"boolean"`

	// Optional. When included and set to true, the response contains the JobExecutionState
	// data. The default is false.
	IncludeJobExecutionState *bool `locationName:"includeJobExecutionState" type:"boolean"`

	// The unique identifier assigned to this job when it was created.
	//
	// JobId is a required field
	JobId *string `location:"uri" locationName:"jobId" min:"1" type:"string" required:"true"`

	// The new status for the job execution (IN_PROGRESS, FAILED, SUCCESS, or REJECTED).
	// This must be specified on every update.
	//
	// Status is a required field
	Status JobExecutionStatus `locationName:"status" type:"string" required:"true" enum:"true"`

	// Optional. A collection of name/value pairs that describe the status of the
	// job execution. If not specified, the statusDetails are unchanged.
	StatusDetails map[string]string `locationName:"statusDetails" type:"map"`

	// The name of the thing associated with the device.
	//
	// ThingName is a required field
	ThingName *string `location:"uri" locationName:"thingName" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/UpdateJobExecutionRequest

func (UpdateJobExecutionInput) GoString 

func (s UpdateJobExecutionInput) GoString() string

GoString returns the string representation

func (*UpdateJobExecutionInput) SetExecutionNumber 

func (s *UpdateJobExecutionInput) SetExecutionNumber(v int64) *UpdateJobExecutionInput

SetExecutionNumber sets the ExecutionNumber field's value.

func (*UpdateJobExecutionInput) SetExpectedVersion 

func (s *UpdateJobExecutionInput) SetExpectedVersion(v int64) *UpdateJobExecutionInput

SetExpectedVersion sets the ExpectedVersion field's value.

func (*UpdateJobExecutionInput) SetIncludeJobDocument 

func (s *UpdateJobExecutionInput) SetIncludeJobDocument(v bool) *UpdateJobExecutionInput

SetIncludeJobDocument sets the IncludeJobDocument field's value.

func (*UpdateJobExecutionInput) SetIncludeJobExecutionState 

func (s *UpdateJobExecutionInput) SetIncludeJobExecutionState(v bool) *UpdateJobExecutionInput

SetIncludeJobExecutionState sets the IncludeJobExecutionState field's value.

func (*UpdateJobExecutionInput) SetJobId 

func (s *UpdateJobExecutionInput) SetJobId(v string) *UpdateJobExecutionInput

SetJobId sets the JobId field's value.

func (*UpdateJobExecutionInput) SetStatus 

func (s *UpdateJobExecutionInput) SetStatus(v JobExecutionStatus) *UpdateJobExecutionInput

SetStatus sets the Status field's value.

func (*UpdateJobExecutionInput) SetStatusDetails 

func (s *UpdateJobExecutionInput) SetStatusDetails(v map[string]string) *UpdateJobExecutionInput

SetStatusDetails sets the StatusDetails field's value.

func (*UpdateJobExecutionInput) SetThingName 

func (s *UpdateJobExecutionInput) SetThingName(v string) *UpdateJobExecutionInput

SetThingName sets the ThingName field's value.

func (UpdateJobExecutionInput) String 

func (s UpdateJobExecutionInput) String() string

String returns the string representation

func (*UpdateJobExecutionInput) Validate 

func (s *UpdateJobExecutionInput) Validate() error

Validate inspects the fields of the type to determine if they are valid.

type UpdateJobExecutionOutput 

type UpdateJobExecutionOutput struct {

	// A JobExecutionState object.
	ExecutionState *JobExecutionState `locationName:"executionState" type:"structure"`

	// The contents of the Job Documents.
	JobDocument *string `locationName:"jobDocument" type:"string"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iot-jobs-data-2017-09-29/UpdateJobExecutionResponse

func (UpdateJobExecutionOutput) GoString 

func (s UpdateJobExecutionOutput) GoString() string

GoString returns the string representation

func (UpdateJobExecutionOutput) SDKResponseMetadata 

func (s UpdateJobExecutionOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

func (*UpdateJobExecutionOutput) SetExecutionState 

func (s *UpdateJobExecutionOutput) SetExecutionState(v *JobExecutionState) *UpdateJobExecutionOutput

SetExecutionState sets the ExecutionState field's value.

func (*UpdateJobExecutionOutput) SetJobDocument 

func (s *UpdateJobExecutionOutput) SetJobDocument(v string) *UpdateJobExecutionOutput

SetJobDocument sets the JobDocument field's value.

func (UpdateJobExecutionOutput) String 

func (s UpdateJobExecutionOutput) String() string

String returns the string representation

type UpdateJobExecutionRequest 

type UpdateJobExecutionRequest struct {
	*aws.Request
	Input *UpdateJobExecutionInput
}

UpdateJobExecutionRequest is a API request type for the UpdateJobExecution API operation.

func (UpdateJobExecutionRequest) Send 

func (r UpdateJobExecutionRequest) Send() (*UpdateJobExecutionOutput, error)

Send marshals and sends the UpdateJobExecution API request.

Source Files

View all Source files

Directories

Path Synopsis
Package iotjobsdataplaneiface provides an interface to enable mocking the AWS IoT Jobs Data Plane service client for testing your code.
 Package iotjobsdataplaneiface provides an interface to enable mocking the AWS IoT Jobs Data Plane service client for testing your code.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.