Documentation ¶
Overview ¶
Package iotanalytics provides the client and types for making API requests to AWS IoT Analytics.
AWS IoT Analytics allows you to collect large amounts of device data, process messages, and store them. You can then query the data and run sophisticated analytics on it. AWS IoT Analytics enables advanced data exploration through integration with Jupyter Notebooks and data visualization through integration with Amazon QuickSight.
Traditional analytics and business intelligence tools are designed to process structured data. IoT data often comes from devices that record noisy processes (such as temperature, motion, or sound). As a result the data from these devices can have significant gaps, corrupted messages, and false readings that must be cleaned up before analysis can occur. Also, IoT data is often only meaningful in the context of other data from external sources.
AWS IoT Analytics automates the steps required to analyze data from IoT devices. AWS IoT Analytics filters, transforms, and enriches IoT data before storing it in a time-series data store for analysis. You can set up the service to collect only the data you need from your devices, apply mathematical transforms to process the data, and enrich the data with device-specific metadata such as device type and location before storing it. Then, you can analyze your data by running queries using the built-in SQL query engine, or perform more complex analytics and machine learning inference. AWS IoT Analytics includes pre-built models for common IoT use cases so you can answer questions like which devices are about to fail or which customers are at risk of abandoning their wearable devices.
See https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27 for more information on this service.
See iotanalytics package documentation for more information. https://docs.aws.amazon.com/sdk-for-go/api/service/iotanalytics/
Using the Client ¶
To use AWS IoT Analytics 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 Analytics client for more information on creating client for this service. https://docs.aws.amazon.com/sdk-for-go/api/service/iotanalytics/#New
Index ¶
- Constants
- type AddAttributesActivity
- type BatchPutMessageErrorEntry
- type BatchPutMessageInput
- type BatchPutMessageOutput
- type BatchPutMessageRequest
- type BatchPutMessageResponse
- type CancelPipelineReprocessingInput
- type CancelPipelineReprocessingOutput
- type CancelPipelineReprocessingRequest
- type CancelPipelineReprocessingResponse
- type Channel
- type ChannelActivity
- type ChannelStatistics
- type ChannelStatus
- type ChannelSummary
- type Client
- func (c *Client) BatchPutMessageRequest(input *BatchPutMessageInput) BatchPutMessageRequest
- func (c *Client) CancelPipelineReprocessingRequest(input *CancelPipelineReprocessingInput) CancelPipelineReprocessingRequest
- func (c *Client) CreateChannelRequest(input *CreateChannelInput) CreateChannelRequest
- func (c *Client) CreateDatasetContentRequest(input *CreateDatasetContentInput) CreateDatasetContentRequest
- func (c *Client) CreateDatasetRequest(input *CreateDatasetInput) CreateDatasetRequest
- func (c *Client) CreateDatastoreRequest(input *CreateDatastoreInput) CreateDatastoreRequest
- func (c *Client) CreatePipelineRequest(input *CreatePipelineInput) CreatePipelineRequest
- func (c *Client) DeleteChannelRequest(input *DeleteChannelInput) DeleteChannelRequest
- func (c *Client) DeleteDatasetContentRequest(input *DeleteDatasetContentInput) DeleteDatasetContentRequest
- func (c *Client) DeleteDatasetRequest(input *DeleteDatasetInput) DeleteDatasetRequest
- func (c *Client) DeleteDatastoreRequest(input *DeleteDatastoreInput) DeleteDatastoreRequest
- func (c *Client) DeletePipelineRequest(input *DeletePipelineInput) DeletePipelineRequest
- func (c *Client) DescribeChannelRequest(input *DescribeChannelInput) DescribeChannelRequest
- func (c *Client) DescribeDatasetRequest(input *DescribeDatasetInput) DescribeDatasetRequest
- func (c *Client) DescribeDatastoreRequest(input *DescribeDatastoreInput) DescribeDatastoreRequest
- func (c *Client) DescribeLoggingOptionsRequest(input *DescribeLoggingOptionsInput) DescribeLoggingOptionsRequest
- func (c *Client) DescribePipelineRequest(input *DescribePipelineInput) DescribePipelineRequest
- func (c *Client) GetDatasetContentRequest(input *GetDatasetContentInput) GetDatasetContentRequest
- func (c *Client) ListChannelsRequest(input *ListChannelsInput) ListChannelsRequest
- func (c *Client) ListDatasetContentsRequest(input *ListDatasetContentsInput) ListDatasetContentsRequest
- func (c *Client) ListDatasetsRequest(input *ListDatasetsInput) ListDatasetsRequest
- func (c *Client) ListDatastoresRequest(input *ListDatastoresInput) ListDatastoresRequest
- func (c *Client) ListPipelinesRequest(input *ListPipelinesInput) ListPipelinesRequest
- func (c *Client) ListTagsForResourceRequest(input *ListTagsForResourceInput) ListTagsForResourceRequest
- func (c *Client) PutLoggingOptionsRequest(input *PutLoggingOptionsInput) PutLoggingOptionsRequest
- func (c *Client) RunPipelineActivityRequest(input *RunPipelineActivityInput) RunPipelineActivityRequest
- func (c *Client) SampleChannelDataRequest(input *SampleChannelDataInput) SampleChannelDataRequest
- func (c *Client) StartPipelineReprocessingRequest(input *StartPipelineReprocessingInput) StartPipelineReprocessingRequest
- func (c *Client) TagResourceRequest(input *TagResourceInput) TagResourceRequest
- func (c *Client) UntagResourceRequest(input *UntagResourceInput) UntagResourceRequest
- func (c *Client) UpdateChannelRequest(input *UpdateChannelInput) UpdateChannelRequest
- func (c *Client) UpdateDatasetRequest(input *UpdateDatasetInput) UpdateDatasetRequest
- func (c *Client) UpdateDatastoreRequest(input *UpdateDatastoreInput) UpdateDatastoreRequest
- func (c *Client) UpdatePipelineRequest(input *UpdatePipelineInput) UpdatePipelineRequest
- type ComputeType
- type ContainerDatasetAction
- type CreateChannelInput
- type CreateChannelOutput
- type CreateChannelRequest
- type CreateChannelResponse
- type CreateDatasetContentInput
- type CreateDatasetContentOutput
- type CreateDatasetContentRequest
- type CreateDatasetContentResponse
- type CreateDatasetInput
- type CreateDatasetOutput
- type CreateDatasetRequest
- type CreateDatasetResponse
- type CreateDatastoreInput
- type CreateDatastoreOutput
- type CreateDatastoreRequest
- type CreateDatastoreResponse
- type CreatePipelineInput
- type CreatePipelineOutput
- type CreatePipelineRequest
- type CreatePipelineResponse
- type Dataset
- type DatasetAction
- type DatasetActionSummary
- type DatasetActionType
- type DatasetContentDeliveryDestination
- type DatasetContentDeliveryRule
- type DatasetContentState
- type DatasetContentStatus
- type DatasetContentSummary
- type DatasetContentVersionValue
- type DatasetEntry
- type DatasetStatus
- type DatasetSummary
- type DatasetTrigger
- type Datastore
- type DatastoreActivity
- type DatastoreStatistics
- type DatastoreStatus
- type DatastoreSummary
- type DeleteChannelInput
- type DeleteChannelOutput
- type DeleteChannelRequest
- type DeleteChannelResponse
- type DeleteDatasetContentInput
- type DeleteDatasetContentOutput
- type DeleteDatasetContentRequest
- type DeleteDatasetContentResponse
- type DeleteDatasetInput
- type DeleteDatasetOutput
- type DeleteDatasetRequest
- type DeleteDatasetResponse
- type DeleteDatastoreInput
- type DeleteDatastoreOutput
- type DeleteDatastoreRequest
- type DeleteDatastoreResponse
- type DeletePipelineInput
- type DeletePipelineOutput
- type DeletePipelineRequest
- type DeletePipelineResponse
- type DeltaTime
- type DescribeChannelInput
- type DescribeChannelOutput
- type DescribeChannelRequest
- type DescribeChannelResponse
- type DescribeDatasetInput
- type DescribeDatasetOutput
- type DescribeDatasetRequest
- type DescribeDatasetResponse
- type DescribeDatastoreInput
- type DescribeDatastoreOutput
- type DescribeDatastoreRequest
- type DescribeDatastoreResponse
- type DescribeLoggingOptionsInput
- type DescribeLoggingOptionsOutput
- type DescribeLoggingOptionsRequest
- type DescribeLoggingOptionsResponse
- type DescribePipelineInput
- type DescribePipelineOutput
- type DescribePipelineRequest
- type DescribePipelineResponse
- type DeviceRegistryEnrichActivity
- type DeviceShadowEnrichActivity
- type EstimatedResourceSize
- type FilterActivity
- type GetDatasetContentInput
- type GetDatasetContentOutput
- type GetDatasetContentRequest
- type GetDatasetContentResponse
- type GlueConfiguration
- type IotEventsDestinationConfiguration
- type LambdaActivity
- type ListChannelsInput
- type ListChannelsOutput
- type ListChannelsPaginator
- type ListChannelsRequest
- type ListChannelsResponse
- type ListDatasetContentsInput
- type ListDatasetContentsOutput
- type ListDatasetContentsPaginator
- type ListDatasetContentsRequest
- type ListDatasetContentsResponse
- type ListDatasetsInput
- type ListDatasetsOutput
- type ListDatasetsPaginator
- type ListDatasetsRequest
- type ListDatasetsResponse
- type ListDatastoresInput
- type ListDatastoresOutput
- type ListDatastoresPaginator
- type ListDatastoresRequest
- type ListDatastoresResponse
- type ListPipelinesInput
- type ListPipelinesOutput
- type ListPipelinesPaginator
- type ListPipelinesRequest
- type ListPipelinesResponse
- type ListTagsForResourceInput
- type ListTagsForResourceOutput
- type ListTagsForResourceRequest
- type ListTagsForResourceResponse
- type LoggingLevel
- type LoggingOptions
- type MathActivity
- type Message
- type OutputFileUriValue
- type Pipeline
- type PipelineActivity
- type PipelineSummary
- type PutLoggingOptionsInput
- type PutLoggingOptionsOutput
- type PutLoggingOptionsRequest
- type PutLoggingOptionsResponse
- type QueryFilter
- type RemoveAttributesActivity
- type ReprocessingStatus
- type ReprocessingSummary
- type ResourceConfiguration
- type RetentionPeriod
- type RunPipelineActivityInput
- type RunPipelineActivityOutput
- type RunPipelineActivityRequest
- type RunPipelineActivityResponse
- type S3DestinationConfiguration
- type SampleChannelDataInput
- type SampleChannelDataOutput
- type SampleChannelDataRequest
- type SampleChannelDataResponse
- type Schedule
- type SelectAttributesActivity
- type SqlQueryDatasetAction
- type StartPipelineReprocessingInput
- type StartPipelineReprocessingOutput
- type StartPipelineReprocessingRequest
- type StartPipelineReprocessingResponse
- type Tag
- type TagResourceInput
- type TagResourceOutput
- type TagResourceRequest
- type TagResourceResponse
- type TriggeringDataset
- type UntagResourceInput
- type UntagResourceOutput
- type UntagResourceRequest
- type UntagResourceResponse
- type UpdateChannelInput
- type UpdateChannelOutput
- type UpdateChannelRequest
- type UpdateChannelResponse
- type UpdateDatasetInput
- type UpdateDatasetOutput
- type UpdateDatasetRequest
- type UpdateDatasetResponse
- type UpdateDatastoreInput
- type UpdateDatastoreOutput
- type UpdateDatastoreRequest
- type UpdateDatastoreResponse
- type UpdatePipelineInput
- type UpdatePipelineOutput
- type UpdatePipelineRequest
- type UpdatePipelineResponse
- type Variable
- type VersioningConfiguration
Constants ¶
const ( ServiceName = "AWS IoT Analytics" // Service's name ServiceID = "IoTAnalytics" // Service's identifier EndpointsID = "iotanalytics" // Service's Endpoint identifier )
const ( // ErrCodeInternalFailureException for service response error code // "InternalFailureException". // // There was an internal failure. ErrCodeInternalFailureException = "InternalFailureException" // ErrCodeInvalidRequestException for service response error code // "InvalidRequestException". // // The request was not valid. ErrCodeInvalidRequestException = "InvalidRequestException" // ErrCodeLimitExceededException for service response error code // "LimitExceededException". // // The command caused an internal limit to be exceeded. ErrCodeLimitExceededException = "LimitExceededException" // ErrCodeResourceAlreadyExistsException for service response error code // "ResourceAlreadyExistsException". // // A resource with the same name already exists. ErrCodeResourceAlreadyExistsException = "ResourceAlreadyExistsException" // ErrCodeResourceNotFoundException for service response error code // "ResourceNotFoundException". // // A resource with the specified name could not be found. ErrCodeResourceNotFoundException = "ResourceNotFoundException" // "ServiceUnavailableException". // // The service is temporarily unavailable. ErrCodeServiceUnavailableException = "ServiceUnavailableException" // ErrCodeThrottlingException for service response error code // "ThrottlingException". // // The request was denied due to request throttling. ErrCodeThrottlingException = "ThrottlingException" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddAttributesActivity ¶
type AddAttributesActivity struct { // A list of 1-50 "AttributeNameMapping" objects that map an existing attribute // to a new attribute. // // The existing attributes remain in the message, so if you want to remove the // originals, use "RemoveAttributeActivity". // // Attributes is a required field Attributes map[string]string `locationName:"attributes" min:"1" type:"map" required:"true"` // The name of the 'addAttributes' activity. // // Name is a required field Name *string `locationName:"name" min:"1" type:"string" required:"true"` // The next activity in the pipeline. Next *string `locationName:"next" min:"1" type:"string"` // contains filtered or unexported fields }
An activity that adds other attributes based on existing attributes in the message. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/AddAttributesActivity
func (AddAttributesActivity) MarshalFields ¶
func (s AddAttributesActivity) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (AddAttributesActivity) String ¶
func (s AddAttributesActivity) String() string
String returns the string representation
func (*AddAttributesActivity) Validate ¶
func (s *AddAttributesActivity) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type BatchPutMessageErrorEntry ¶
type BatchPutMessageErrorEntry struct { // The code associated with the error. ErrorCode *string `locationName:"errorCode" type:"string"` // The message associated with the error. ErrorMessage *string `locationName:"errorMessage" type:"string"` // The ID of the message that caused the error. (See the value corresponding // to the "messageId" key in the message object.) MessageId *string `locationName:"messageId" min:"1" type:"string"` // contains filtered or unexported fields }
Contains informations about errors. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/BatchPutMessageErrorEntry
func (BatchPutMessageErrorEntry) MarshalFields ¶
func (s BatchPutMessageErrorEntry) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (BatchPutMessageErrorEntry) String ¶
func (s BatchPutMessageErrorEntry) String() string
String returns the string representation
type BatchPutMessageInput ¶
type BatchPutMessageInput struct { // The name of the channel where the messages are sent. // // ChannelName is a required field ChannelName *string `locationName:"channelName" min:"1" type:"string" required:"true"` // The list of messages to be sent. Each message has format: '{ "messageId": // "string", "payload": "string"}'. // // Note that the field names of message payloads (data) that you send to AWS // IoT Analytics: // // * Must contain only alphanumeric characters and undescores (_); no other // special characters are allowed. // // * Must begin with an alphabetic character or single underscore (_). // // * Cannot contain hyphens (-). // // * In regular expression terms: "^[A-Za-z_]([A-Za-z0-9]*|[A-Za-z0-9][A-Za-z0-9_]*)$". // // * Cannot be greater than 255 characters. // // * Are case-insensitive. (Fields named "foo" and "FOO" in the same payload // are considered duplicates.) // // For example, {"temp_01": 29} or {"_temp_01": 29} are valid, but {"temp-01": // 29}, {"01_temp": 29} or {"__temp_01": 29} are invalid in message payloads. // // Messages is a required field Messages []Message `locationName:"messages" type:"list" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/BatchPutMessageRequest
func (BatchPutMessageInput) MarshalFields ¶
func (s BatchPutMessageInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (BatchPutMessageInput) String ¶
func (s BatchPutMessageInput) String() string
String returns the string representation
func (*BatchPutMessageInput) Validate ¶
func (s *BatchPutMessageInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type BatchPutMessageOutput ¶
type BatchPutMessageOutput struct { // A list of any errors encountered when sending the messages to the channel. BatchPutMessageErrorEntries []BatchPutMessageErrorEntry `locationName:"batchPutMessageErrorEntries" type:"list"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/BatchPutMessageResponse
func (BatchPutMessageOutput) MarshalFields ¶
func (s BatchPutMessageOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (BatchPutMessageOutput) String ¶
func (s BatchPutMessageOutput) String() string
String returns the string representation
type BatchPutMessageRequest ¶
type BatchPutMessageRequest struct { *aws.Request Input *BatchPutMessageInput Copy func(*BatchPutMessageInput) BatchPutMessageRequest }
BatchPutMessageRequest is the request type for the BatchPutMessage API operation.
func (BatchPutMessageRequest) Send ¶
func (r BatchPutMessageRequest) Send(ctx context.Context) (*BatchPutMessageResponse, error)
Send marshals and sends the BatchPutMessage API request.
type BatchPutMessageResponse ¶ added in v0.9.0
type BatchPutMessageResponse struct { *BatchPutMessageOutput // contains filtered or unexported fields }
BatchPutMessageResponse is the response type for the BatchPutMessage API operation.
func (*BatchPutMessageResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *BatchPutMessageResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the BatchPutMessage request.
type CancelPipelineReprocessingInput ¶
type CancelPipelineReprocessingInput struct { // The name of pipeline for which data reprocessing is canceled. // // PipelineName is a required field PipelineName *string `location:"uri" locationName:"pipelineName" min:"1" type:"string" required:"true"` // The ID of the reprocessing task (returned by "StartPipelineReprocessing"). // // ReprocessingId is a required field ReprocessingId *string `location:"uri" locationName:"reprocessingId" type:"string" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CancelPipelineReprocessingRequest
func (CancelPipelineReprocessingInput) MarshalFields ¶
func (s CancelPipelineReprocessingInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (CancelPipelineReprocessingInput) String ¶
func (s CancelPipelineReprocessingInput) String() string
String returns the string representation
func (*CancelPipelineReprocessingInput) Validate ¶
func (s *CancelPipelineReprocessingInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CancelPipelineReprocessingOutput ¶
type CancelPipelineReprocessingOutput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CancelPipelineReprocessingResponse
func (CancelPipelineReprocessingOutput) MarshalFields ¶
func (s CancelPipelineReprocessingOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (CancelPipelineReprocessingOutput) String ¶
func (s CancelPipelineReprocessingOutput) String() string
String returns the string representation
type CancelPipelineReprocessingRequest ¶
type CancelPipelineReprocessingRequest struct { *aws.Request Input *CancelPipelineReprocessingInput Copy func(*CancelPipelineReprocessingInput) CancelPipelineReprocessingRequest }
CancelPipelineReprocessingRequest is the request type for the CancelPipelineReprocessing API operation.
func (CancelPipelineReprocessingRequest) Send ¶
func (r CancelPipelineReprocessingRequest) Send(ctx context.Context) (*CancelPipelineReprocessingResponse, error)
Send marshals and sends the CancelPipelineReprocessing API request.
type CancelPipelineReprocessingResponse ¶ added in v0.9.0
type CancelPipelineReprocessingResponse struct { *CancelPipelineReprocessingOutput // contains filtered or unexported fields }
CancelPipelineReprocessingResponse is the response type for the CancelPipelineReprocessing API operation.
func (*CancelPipelineReprocessingResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *CancelPipelineReprocessingResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the CancelPipelineReprocessing request.
type Channel ¶
type Channel struct { // The ARN of the channel. Arn *string `locationName:"arn" type:"string"` // When the channel was created. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"` // When the channel was last updated. LastUpdateTime *time.Time `locationName:"lastUpdateTime" type:"timestamp" timestampFormat:"unix"` // The name of the channel. Name *string `locationName:"name" min:"1" type:"string"` // How long, in days, message data is kept for the channel. RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"` // The status of the channel. Status ChannelStatus `locationName:"status" type:"string" enum:"true"` // contains filtered or unexported fields }
A collection of data from an MQTT topic. Channels archive the raw, unprocessed messages before publishing the data to a pipeline. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/Channel
func (Channel) MarshalFields ¶
func (s Channel) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
type ChannelActivity ¶
type ChannelActivity struct { // The name of the channel from which the messages are processed. // // ChannelName is a required field ChannelName *string `locationName:"channelName" min:"1" type:"string" required:"true"` // The name of the 'channel' activity. // // Name is a required field Name *string `locationName:"name" min:"1" type:"string" required:"true"` // The next activity in the pipeline. Next *string `locationName:"next" min:"1" type:"string"` // contains filtered or unexported fields }
The activity that determines the source of the messages to be processed. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ChannelActivity
func (ChannelActivity) MarshalFields ¶
func (s ChannelActivity) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ChannelActivity) String ¶
func (s ChannelActivity) String() string
String returns the string representation
func (*ChannelActivity) Validate ¶
func (s *ChannelActivity) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ChannelStatistics ¶ added in v0.5.0
type ChannelStatistics struct { // The estimated size of the channel. Size *EstimatedResourceSize `locationName:"size" type:"structure"` // contains filtered or unexported fields }
Statistics information about the channel. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ChannelStatistics
func (ChannelStatistics) MarshalFields ¶ added in v0.5.0
func (s ChannelStatistics) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ChannelStatistics) String ¶ added in v0.5.0
func (s ChannelStatistics) String() string
String returns the string representation
type ChannelStatus ¶
type ChannelStatus string
const ( ChannelStatusCreating ChannelStatus = "CREATING" ChannelStatusActive ChannelStatus = "ACTIVE" ChannelStatusDeleting ChannelStatus = "DELETING" )
Enum values for ChannelStatus
func (ChannelStatus) MarshalValue ¶
func (enum ChannelStatus) MarshalValue() (string, error)
func (ChannelStatus) MarshalValueBuf ¶
func (enum ChannelStatus) MarshalValueBuf(b []byte) ([]byte, error)
type ChannelSummary ¶
type ChannelSummary struct { // The name of the channel. ChannelName *string `locationName:"channelName" min:"1" type:"string"` // When the channel was created. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"` // The last time the channel was updated. LastUpdateTime *time.Time `locationName:"lastUpdateTime" type:"timestamp" timestampFormat:"unix"` // The status of the channel. Status ChannelStatus `locationName:"status" type:"string" enum:"true"` // contains filtered or unexported fields }
A summary of information about a channel. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ChannelSummary
func (ChannelSummary) MarshalFields ¶
func (s ChannelSummary) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ChannelSummary) String ¶
func (s ChannelSummary) String() string
String returns the string representation
type Client ¶ added in v0.9.0
Client provides the API operation methods for making requests to AWS IoT Analytics. See this package's package overview docs for details on the service.
The client's methods are safe to use concurrently. It is not safe to modify mutate any of the struct's properties though.
func New ¶
New creates a new instance of the client from the provided Config.
Example:
// Create a client from just a config. svc := iotanalytics.New(myConfig)
func (*Client) BatchPutMessageRequest ¶ added in v0.9.0
func (c *Client) BatchPutMessageRequest(input *BatchPutMessageInput) BatchPutMessageRequest
BatchPutMessageRequest returns a request value for making API operation for AWS IoT Analytics.
Sends messages to a channel.
// Example sending a request using BatchPutMessageRequest. req := client.BatchPutMessageRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/BatchPutMessage
func (*Client) CancelPipelineReprocessingRequest ¶ added in v0.9.0
func (c *Client) CancelPipelineReprocessingRequest(input *CancelPipelineReprocessingInput) CancelPipelineReprocessingRequest
CancelPipelineReprocessingRequest returns a request value for making API operation for AWS IoT Analytics.
Cancels the reprocessing of data through the pipeline.
// Example sending a request using CancelPipelineReprocessingRequest. req := client.CancelPipelineReprocessingRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CancelPipelineReprocessing
func (*Client) CreateChannelRequest ¶ added in v0.9.0
func (c *Client) CreateChannelRequest(input *CreateChannelInput) CreateChannelRequest
CreateChannelRequest returns a request value for making API operation for AWS IoT Analytics.
Creates a channel. A channel collects data from an MQTT topic and archives the raw, unprocessed messages before publishing the data to a pipeline.
// Example sending a request using CreateChannelRequest. req := client.CreateChannelRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateChannel
func (*Client) CreateDatasetContentRequest ¶ added in v0.9.0
func (c *Client) CreateDatasetContentRequest(input *CreateDatasetContentInput) CreateDatasetContentRequest
CreateDatasetContentRequest returns a request value for making API operation for AWS IoT Analytics.
Creates the content of a data set by applying a "queryAction" (a SQL query) or a "containerAction" (executing a containerized application).
// Example sending a request using CreateDatasetContentRequest. req := client.CreateDatasetContentRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDatasetContent
func (*Client) CreateDatasetRequest ¶ added in v0.9.0
func (c *Client) CreateDatasetRequest(input *CreateDatasetInput) CreateDatasetRequest
CreateDatasetRequest returns a request value for making API operation for AWS IoT Analytics.
Creates a data set. A data set stores data retrieved from a data store by applying a "queryAction" (a SQL query) or a "containerAction" (executing a containerized application). This operation creates the skeleton of a data set. The data set can be populated manually by calling "CreateDatasetContent" or automatically according to a "trigger" you specify.
// Example sending a request using CreateDatasetRequest. req := client.CreateDatasetRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDataset
func (*Client) CreateDatastoreRequest ¶ added in v0.9.0
func (c *Client) CreateDatastoreRequest(input *CreateDatastoreInput) CreateDatastoreRequest
CreateDatastoreRequest returns a request value for making API operation for AWS IoT Analytics.
Creates a data store, which is a repository for messages.
// Example sending a request using CreateDatastoreRequest. req := client.CreateDatastoreRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDatastore
func (*Client) CreatePipelineRequest ¶ added in v0.9.0
func (c *Client) CreatePipelineRequest(input *CreatePipelineInput) CreatePipelineRequest
CreatePipelineRequest returns a request value for making API operation for AWS IoT Analytics.
Creates a pipeline. A pipeline consumes messages from one or more channels and allows you to process the messages before storing them in a data store. You must specify both a channel and a datastore activity and, optionally, as many as 23 additional activities in the pipelineActivities array.
// Example sending a request using CreatePipelineRequest. req := client.CreatePipelineRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreatePipeline
func (*Client) DeleteChannelRequest ¶ added in v0.9.0
func (c *Client) DeleteChannelRequest(input *DeleteChannelInput) DeleteChannelRequest
DeleteChannelRequest returns a request value for making API operation for AWS IoT Analytics.
Deletes the specified channel.
// Example sending a request using DeleteChannelRequest. req := client.DeleteChannelRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteChannel
func (*Client) DeleteDatasetContentRequest ¶ added in v0.9.0
func (c *Client) DeleteDatasetContentRequest(input *DeleteDatasetContentInput) DeleteDatasetContentRequest
DeleteDatasetContentRequest returns a request value for making API operation for AWS IoT Analytics.
Deletes the content of the specified data set.
// Example sending a request using DeleteDatasetContentRequest. req := client.DeleteDatasetContentRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteDatasetContent
func (*Client) DeleteDatasetRequest ¶ added in v0.9.0
func (c *Client) DeleteDatasetRequest(input *DeleteDatasetInput) DeleteDatasetRequest
DeleteDatasetRequest returns a request value for making API operation for AWS IoT Analytics.
Deletes the specified data set.
You do not have to delete the content of the data set before you perform this operation.
// Example sending a request using DeleteDatasetRequest. req := client.DeleteDatasetRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteDataset
func (*Client) DeleteDatastoreRequest ¶ added in v0.9.0
func (c *Client) DeleteDatastoreRequest(input *DeleteDatastoreInput) DeleteDatastoreRequest
DeleteDatastoreRequest returns a request value for making API operation for AWS IoT Analytics.
Deletes the specified data store.
// Example sending a request using DeleteDatastoreRequest. req := client.DeleteDatastoreRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteDatastore
func (*Client) DeletePipelineRequest ¶ added in v0.9.0
func (c *Client) DeletePipelineRequest(input *DeletePipelineInput) DeletePipelineRequest
DeletePipelineRequest returns a request value for making API operation for AWS IoT Analytics.
Deletes the specified pipeline.
// Example sending a request using DeletePipelineRequest. req := client.DeletePipelineRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeletePipeline
func (*Client) DescribeChannelRequest ¶ added in v0.9.0
func (c *Client) DescribeChannelRequest(input *DescribeChannelInput) DescribeChannelRequest
DescribeChannelRequest returns a request value for making API operation for AWS IoT Analytics.
Retrieves information about a channel.
// Example sending a request using DescribeChannelRequest. req := client.DescribeChannelRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeChannel
func (*Client) DescribeDatasetRequest ¶ added in v0.9.0
func (c *Client) DescribeDatasetRequest(input *DescribeDatasetInput) DescribeDatasetRequest
DescribeDatasetRequest returns a request value for making API operation for AWS IoT Analytics.
Retrieves information about a data set.
// Example sending a request using DescribeDatasetRequest. req := client.DescribeDatasetRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeDataset
func (*Client) DescribeDatastoreRequest ¶ added in v0.9.0
func (c *Client) DescribeDatastoreRequest(input *DescribeDatastoreInput) DescribeDatastoreRequest
DescribeDatastoreRequest returns a request value for making API operation for AWS IoT Analytics.
Retrieves information about a data store.
// Example sending a request using DescribeDatastoreRequest. req := client.DescribeDatastoreRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeDatastore
func (*Client) DescribeLoggingOptionsRequest ¶ added in v0.9.0
func (c *Client) DescribeLoggingOptionsRequest(input *DescribeLoggingOptionsInput) DescribeLoggingOptionsRequest
DescribeLoggingOptionsRequest returns a request value for making API operation for AWS IoT Analytics.
Retrieves the current settings of the AWS IoT Analytics logging options.
// Example sending a request using DescribeLoggingOptionsRequest. req := client.DescribeLoggingOptionsRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeLoggingOptions
func (*Client) DescribePipelineRequest ¶ added in v0.9.0
func (c *Client) DescribePipelineRequest(input *DescribePipelineInput) DescribePipelineRequest
DescribePipelineRequest returns a request value for making API operation for AWS IoT Analytics.
Retrieves information about a pipeline.
// Example sending a request using DescribePipelineRequest. req := client.DescribePipelineRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribePipeline
func (*Client) GetDatasetContentRequest ¶ added in v0.9.0
func (c *Client) GetDatasetContentRequest(input *GetDatasetContentInput) GetDatasetContentRequest
GetDatasetContentRequest returns a request value for making API operation for AWS IoT Analytics.
Retrieves the contents of a data set as pre-signed URIs.
// Example sending a request using GetDatasetContentRequest. req := client.GetDatasetContentRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/GetDatasetContent
func (*Client) ListChannelsRequest ¶ added in v0.9.0
func (c *Client) ListChannelsRequest(input *ListChannelsInput) ListChannelsRequest
ListChannelsRequest returns a request value for making API operation for AWS IoT Analytics.
Retrieves a list of channels.
// Example sending a request using ListChannelsRequest. req := client.ListChannelsRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListChannels
func (*Client) ListDatasetContentsRequest ¶ added in v0.9.0
func (c *Client) ListDatasetContentsRequest(input *ListDatasetContentsInput) ListDatasetContentsRequest
ListDatasetContentsRequest returns a request value for making API operation for AWS IoT Analytics.
Lists information about data set contents that have been created.
// Example sending a request using ListDatasetContentsRequest. req := client.ListDatasetContentsRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListDatasetContents
func (*Client) ListDatasetsRequest ¶ added in v0.9.0
func (c *Client) ListDatasetsRequest(input *ListDatasetsInput) ListDatasetsRequest
ListDatasetsRequest returns a request value for making API operation for AWS IoT Analytics.
Retrieves information about data sets.
// Example sending a request using ListDatasetsRequest. req := client.ListDatasetsRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListDatasets
func (*Client) ListDatastoresRequest ¶ added in v0.9.0
func (c *Client) ListDatastoresRequest(input *ListDatastoresInput) ListDatastoresRequest
ListDatastoresRequest returns a request value for making API operation for AWS IoT Analytics.
Retrieves a list of data stores.
// Example sending a request using ListDatastoresRequest. req := client.ListDatastoresRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListDatastores
func (*Client) ListPipelinesRequest ¶ added in v0.9.0
func (c *Client) ListPipelinesRequest(input *ListPipelinesInput) ListPipelinesRequest
ListPipelinesRequest returns a request value for making API operation for AWS IoT Analytics.
Retrieves a list of pipelines.
// Example sending a request using ListPipelinesRequest. req := client.ListPipelinesRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListPipelines
func (*Client) ListTagsForResourceRequest ¶ added in v0.9.0
func (c *Client) ListTagsForResourceRequest(input *ListTagsForResourceInput) ListTagsForResourceRequest
ListTagsForResourceRequest returns a request value for making API operation for AWS IoT Analytics.
Lists the tags (metadata) which you have assigned to the resource.
// Example sending a request using ListTagsForResourceRequest. req := client.ListTagsForResourceRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListTagsForResource
func (*Client) PutLoggingOptionsRequest ¶ added in v0.9.0
func (c *Client) PutLoggingOptionsRequest(input *PutLoggingOptionsInput) PutLoggingOptionsRequest
PutLoggingOptionsRequest returns a request value for making API operation for AWS IoT Analytics.
Sets or updates the AWS IoT Analytics logging options.
Note that if you update the value of any loggingOptions field, it takes up to one minute for the change to take effect. Also, if you change the policy attached to the role you specified in the roleArn field (for example, to correct an invalid policy) it takes up to 5 minutes for that change to take effect.
// Example sending a request using PutLoggingOptionsRequest. req := client.PutLoggingOptionsRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/PutLoggingOptions
func (*Client) RunPipelineActivityRequest ¶ added in v0.9.0
func (c *Client) RunPipelineActivityRequest(input *RunPipelineActivityInput) RunPipelineActivityRequest
RunPipelineActivityRequest returns a request value for making API operation for AWS IoT Analytics.
Simulates the results of running a pipeline activity on a message payload.
// Example sending a request using RunPipelineActivityRequest. req := client.RunPipelineActivityRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/RunPipelineActivity
func (*Client) SampleChannelDataRequest ¶ added in v0.9.0
func (c *Client) SampleChannelDataRequest(input *SampleChannelDataInput) SampleChannelDataRequest
SampleChannelDataRequest returns a request value for making API operation for AWS IoT Analytics.
Retrieves a sample of messages from the specified channel ingested during the specified timeframe. Up to 10 messages can be retrieved.
// Example sending a request using SampleChannelDataRequest. req := client.SampleChannelDataRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/SampleChannelData
func (*Client) StartPipelineReprocessingRequest ¶ added in v0.9.0
func (c *Client) StartPipelineReprocessingRequest(input *StartPipelineReprocessingInput) StartPipelineReprocessingRequest
StartPipelineReprocessingRequest returns a request value for making API operation for AWS IoT Analytics.
Starts the reprocessing of raw message data through the pipeline.
// Example sending a request using StartPipelineReprocessingRequest. req := client.StartPipelineReprocessingRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/StartPipelineReprocessing
func (*Client) TagResourceRequest ¶ added in v0.9.0
func (c *Client) TagResourceRequest(input *TagResourceInput) TagResourceRequest
TagResourceRequest returns a request value for making API operation for AWS IoT Analytics.
Adds to or modifies the tags of the given resource. Tags are metadata which can be used to manage a resource.
// Example sending a request using TagResourceRequest. req := client.TagResourceRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/TagResource
func (*Client) UntagResourceRequest ¶ added in v0.9.0
func (c *Client) UntagResourceRequest(input *UntagResourceInput) UntagResourceRequest
UntagResourceRequest returns a request value for making API operation for AWS IoT Analytics.
Removes the given tags (metadata) from the resource.
// Example sending a request using UntagResourceRequest. req := client.UntagResourceRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UntagResource
func (*Client) UpdateChannelRequest ¶ added in v0.9.0
func (c *Client) UpdateChannelRequest(input *UpdateChannelInput) UpdateChannelRequest
UpdateChannelRequest returns a request value for making API operation for AWS IoT Analytics.
Updates the settings of a channel.
// Example sending a request using UpdateChannelRequest. req := client.UpdateChannelRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdateChannel
func (*Client) UpdateDatasetRequest ¶ added in v0.9.0
func (c *Client) UpdateDatasetRequest(input *UpdateDatasetInput) UpdateDatasetRequest
UpdateDatasetRequest returns a request value for making API operation for AWS IoT Analytics.
Updates the settings of a data set.
// Example sending a request using UpdateDatasetRequest. req := client.UpdateDatasetRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdateDataset
func (*Client) UpdateDatastoreRequest ¶ added in v0.9.0
func (c *Client) UpdateDatastoreRequest(input *UpdateDatastoreInput) UpdateDatastoreRequest
UpdateDatastoreRequest returns a request value for making API operation for AWS IoT Analytics.
Updates the settings of a data store.
// Example sending a request using UpdateDatastoreRequest. req := client.UpdateDatastoreRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdateDatastore
func (*Client) UpdatePipelineRequest ¶ added in v0.9.0
func (c *Client) UpdatePipelineRequest(input *UpdatePipelineInput) UpdatePipelineRequest
UpdatePipelineRequest returns a request value for making API operation for AWS IoT Analytics.
Updates the settings of a pipeline. You must specify both a channel and a datastore activity and, optionally, as many as 23 additional activities in the pipelineActivities array.
// Example sending a request using UpdatePipelineRequest. req := client.UpdatePipelineRequest(params) resp, err := req.Send(context.TODO()) if err == nil { fmt.Println(resp) }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdatePipeline
type ComputeType ¶ added in v0.5.0
type ComputeType string
const ( ComputeTypeAcu1 ComputeType = "ACU_1" ComputeTypeAcu2 ComputeType = "ACU_2" )
Enum values for ComputeType
func (ComputeType) MarshalValue ¶ added in v0.5.0
func (enum ComputeType) MarshalValue() (string, error)
func (ComputeType) MarshalValueBuf ¶ added in v0.5.0
func (enum ComputeType) MarshalValueBuf(b []byte) ([]byte, error)
type ContainerDatasetAction ¶ added in v0.5.0
type ContainerDatasetAction struct { // The ARN of the role which gives permission to the system to access needed // resources in order to run the "containerAction". This includes, at minimum, // permission to retrieve the data set contents which are the input to the containerized // application. // // ExecutionRoleArn is a required field ExecutionRoleArn *string `locationName:"executionRoleArn" min:"20" type:"string" required:"true"` // The ARN of the Docker container stored in your account. The Docker container // contains an application and needed support libraries and is used to generate // data set contents. // // Image is a required field Image *string `locationName:"image" type:"string" required:"true"` // Configuration of the resource which executes the "containerAction". // // ResourceConfiguration is a required field ResourceConfiguration *ResourceConfiguration `locationName:"resourceConfiguration" type:"structure" required:"true"` // The values of variables used within the context of the execution of the containerized // application (basically, parameters passed to the application). Each variable // must have a name and a value given by one of "stringValue", "datasetContentVersionValue", // or "outputFileUriValue". Variables []Variable `locationName:"variables" type:"list"` // contains filtered or unexported fields }
Information needed to run the "containerAction" to produce data set contents. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ContainerDatasetAction
func (ContainerDatasetAction) MarshalFields ¶ added in v0.5.0
func (s ContainerDatasetAction) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ContainerDatasetAction) String ¶ added in v0.5.0
func (s ContainerDatasetAction) String() string
String returns the string representation
func (*ContainerDatasetAction) Validate ¶ added in v0.5.0
func (s *ContainerDatasetAction) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateChannelInput ¶
type CreateChannelInput struct { // The name of the channel. // // ChannelName is a required field ChannelName *string `locationName:"channelName" min:"1" type:"string" required:"true"` // How long, in days, message data is kept for the channel. RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"` // Metadata which can be used to manage the channel. Tags []Tag `locationName:"tags" min:"1" type:"list"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateChannelRequest
func (CreateChannelInput) MarshalFields ¶
func (s CreateChannelInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (CreateChannelInput) String ¶
func (s CreateChannelInput) String() string
String returns the string representation
func (*CreateChannelInput) Validate ¶
func (s *CreateChannelInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateChannelOutput ¶
type CreateChannelOutput struct { // The ARN of the channel. ChannelArn *string `locationName:"channelArn" type:"string"` // The name of the channel. ChannelName *string `locationName:"channelName" min:"1" type:"string"` // How long, in days, message data is kept for the channel. RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateChannelResponse
func (CreateChannelOutput) MarshalFields ¶
func (s CreateChannelOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (CreateChannelOutput) String ¶
func (s CreateChannelOutput) String() string
String returns the string representation
type CreateChannelRequest ¶
type CreateChannelRequest struct { *aws.Request Input *CreateChannelInput Copy func(*CreateChannelInput) CreateChannelRequest }
CreateChannelRequest is the request type for the CreateChannel API operation.
func (CreateChannelRequest) Send ¶
func (r CreateChannelRequest) Send(ctx context.Context) (*CreateChannelResponse, error)
Send marshals and sends the CreateChannel API request.
type CreateChannelResponse ¶ added in v0.9.0
type CreateChannelResponse struct { *CreateChannelOutput // contains filtered or unexported fields }
CreateChannelResponse is the response type for the CreateChannel API operation.
func (*CreateChannelResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *CreateChannelResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the CreateChannel request.
type CreateDatasetContentInput ¶
type CreateDatasetContentInput struct { // The name of the data set. // // DatasetName is a required field DatasetName *string `location:"uri" locationName:"datasetName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDatasetContentRequest
func (CreateDatasetContentInput) MarshalFields ¶
func (s CreateDatasetContentInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (CreateDatasetContentInput) String ¶
func (s CreateDatasetContentInput) String() string
String returns the string representation
func (*CreateDatasetContentInput) Validate ¶
func (s *CreateDatasetContentInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateDatasetContentOutput ¶
type CreateDatasetContentOutput struct { // The version ID of the data set contents which are being created. VersionId *string `locationName:"versionId" min:"7" type:"string"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDatasetContentResponse
func (CreateDatasetContentOutput) MarshalFields ¶
func (s CreateDatasetContentOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (CreateDatasetContentOutput) String ¶
func (s CreateDatasetContentOutput) String() string
String returns the string representation
type CreateDatasetContentRequest ¶
type CreateDatasetContentRequest struct { *aws.Request Input *CreateDatasetContentInput Copy func(*CreateDatasetContentInput) CreateDatasetContentRequest }
CreateDatasetContentRequest is the request type for the CreateDatasetContent API operation.
func (CreateDatasetContentRequest) Send ¶
func (r CreateDatasetContentRequest) Send(ctx context.Context) (*CreateDatasetContentResponse, error)
Send marshals and sends the CreateDatasetContent API request.
type CreateDatasetContentResponse ¶ added in v0.9.0
type CreateDatasetContentResponse struct { *CreateDatasetContentOutput // contains filtered or unexported fields }
CreateDatasetContentResponse is the response type for the CreateDatasetContent API operation.
func (*CreateDatasetContentResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *CreateDatasetContentResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the CreateDatasetContent request.
type CreateDatasetInput ¶
type CreateDatasetInput struct { // A list of actions that create the data set contents. // // Actions is a required field Actions []DatasetAction `locationName:"actions" min:"1" type:"list" required:"true"` // When data set contents are created they are delivered to destinations specified // here. ContentDeliveryRules []DatasetContentDeliveryRule `locationName:"contentDeliveryRules" type:"list"` // The name of the data set. // // DatasetName is a required field DatasetName *string `locationName:"datasetName" min:"1" type:"string" required:"true"` // [Optional] How long, in days, versions of data set contents are kept for // the data set. If not specified or set to null, versions of data set contents // are retained for at most 90 days. The number of versions of data set contents // retained is determined by the versioningConfiguration parameter. (For more // information, see https://docs.aws.amazon.com/iotanalytics/latest/userguide/getting-started.html#aws-iot-analytics-dataset-versions) RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"` // Metadata which can be used to manage the data set. Tags []Tag `locationName:"tags" min:"1" type:"list"` // A list of triggers. A trigger causes data set contents to be populated at // a specified time interval or when another data set's contents are created. // The list of triggers can be empty or contain up to five DataSetTrigger objects. Triggers []DatasetTrigger `locationName:"triggers" type:"list"` // [Optional] How many versions of data set contents are kept. If not specified // or set to null, only the latest version plus the latest succeeded version // (if they are different) are kept for the time period specified by the "retentionPeriod" // parameter. (For more information, see https://docs.aws.amazon.com/iotanalytics/latest/userguide/getting-started.html#aws-iot-analytics-dataset-versions) VersioningConfiguration *VersioningConfiguration `locationName:"versioningConfiguration" type:"structure"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDatasetRequest
func (CreateDatasetInput) MarshalFields ¶
func (s CreateDatasetInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (CreateDatasetInput) String ¶
func (s CreateDatasetInput) String() string
String returns the string representation
func (*CreateDatasetInput) Validate ¶
func (s *CreateDatasetInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateDatasetOutput ¶
type CreateDatasetOutput struct { // The ARN of the data set. DatasetArn *string `locationName:"datasetArn" type:"string"` // The name of the data set. DatasetName *string `locationName:"datasetName" min:"1" type:"string"` // How long, in days, data set contents are kept for the data set. RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDatasetResponse
func (CreateDatasetOutput) MarshalFields ¶
func (s CreateDatasetOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (CreateDatasetOutput) String ¶
func (s CreateDatasetOutput) String() string
String returns the string representation
type CreateDatasetRequest ¶
type CreateDatasetRequest struct { *aws.Request Input *CreateDatasetInput Copy func(*CreateDatasetInput) CreateDatasetRequest }
CreateDatasetRequest is the request type for the CreateDataset API operation.
func (CreateDatasetRequest) Send ¶
func (r CreateDatasetRequest) Send(ctx context.Context) (*CreateDatasetResponse, error)
Send marshals and sends the CreateDataset API request.
type CreateDatasetResponse ¶ added in v0.9.0
type CreateDatasetResponse struct { *CreateDatasetOutput // contains filtered or unexported fields }
CreateDatasetResponse is the response type for the CreateDataset API operation.
func (*CreateDatasetResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *CreateDatasetResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the CreateDataset request.
type CreateDatastoreInput ¶
type CreateDatastoreInput struct { // The name of the data store. // // DatastoreName is a required field DatastoreName *string `locationName:"datastoreName" min:"1" type:"string" required:"true"` // How long, in days, message data is kept for the data store. RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"` // Metadata which can be used to manage the data store. Tags []Tag `locationName:"tags" min:"1" type:"list"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDatastoreRequest
func (CreateDatastoreInput) MarshalFields ¶
func (s CreateDatastoreInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (CreateDatastoreInput) String ¶
func (s CreateDatastoreInput) String() string
String returns the string representation
func (*CreateDatastoreInput) Validate ¶
func (s *CreateDatastoreInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreateDatastoreOutput ¶
type CreateDatastoreOutput struct { // The ARN of the data store. DatastoreArn *string `locationName:"datastoreArn" type:"string"` // The name of the data store. DatastoreName *string `locationName:"datastoreName" min:"1" type:"string"` // How long, in days, message data is kept for the data store. RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDatastoreResponse
func (CreateDatastoreOutput) MarshalFields ¶
func (s CreateDatastoreOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (CreateDatastoreOutput) String ¶
func (s CreateDatastoreOutput) String() string
String returns the string representation
type CreateDatastoreRequest ¶
type CreateDatastoreRequest struct { *aws.Request Input *CreateDatastoreInput Copy func(*CreateDatastoreInput) CreateDatastoreRequest }
CreateDatastoreRequest is the request type for the CreateDatastore API operation.
func (CreateDatastoreRequest) Send ¶
func (r CreateDatastoreRequest) Send(ctx context.Context) (*CreateDatastoreResponse, error)
Send marshals and sends the CreateDatastore API request.
type CreateDatastoreResponse ¶ added in v0.9.0
type CreateDatastoreResponse struct { *CreateDatastoreOutput // contains filtered or unexported fields }
CreateDatastoreResponse is the response type for the CreateDatastore API operation.
func (*CreateDatastoreResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *CreateDatastoreResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the CreateDatastore request.
type CreatePipelineInput ¶
type CreatePipelineInput struct { // A list of "PipelineActivity" objects. Activities perform transformations // on your messages, such as removing, renaming or adding message attributes; // filtering messages based on attribute values; invoking your Lambda functions // on messages for advanced processing; or performing mathematical transformations // to normalize device data. // // The list can be 2-25 PipelineActivity objects and must contain both a channel // and a datastore activity. Each entry in the list must contain only one activity, // for example: // // pipelineActivities = [ { "channel": { ... } }, { "lambda": { ... } }, ... // ] // // PipelineActivities is a required field PipelineActivities []PipelineActivity `locationName:"pipelineActivities" min:"1" type:"list" required:"true"` // The name of the pipeline. // // PipelineName is a required field PipelineName *string `locationName:"pipelineName" min:"1" type:"string" required:"true"` // Metadata which can be used to manage the pipeline. Tags []Tag `locationName:"tags" min:"1" type:"list"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreatePipelineRequest
func (CreatePipelineInput) MarshalFields ¶
func (s CreatePipelineInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (CreatePipelineInput) String ¶
func (s CreatePipelineInput) String() string
String returns the string representation
func (*CreatePipelineInput) Validate ¶
func (s *CreatePipelineInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type CreatePipelineOutput ¶
type CreatePipelineOutput struct { // The ARN of the pipeline. PipelineArn *string `locationName:"pipelineArn" type:"string"` // The name of the pipeline. PipelineName *string `locationName:"pipelineName" min:"1" type:"string"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreatePipelineResponse
func (CreatePipelineOutput) MarshalFields ¶
func (s CreatePipelineOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (CreatePipelineOutput) String ¶
func (s CreatePipelineOutput) String() string
String returns the string representation
type CreatePipelineRequest ¶
type CreatePipelineRequest struct { *aws.Request Input *CreatePipelineInput Copy func(*CreatePipelineInput) CreatePipelineRequest }
CreatePipelineRequest is the request type for the CreatePipeline API operation.
func (CreatePipelineRequest) Send ¶
func (r CreatePipelineRequest) Send(ctx context.Context) (*CreatePipelineResponse, error)
Send marshals and sends the CreatePipeline API request.
type CreatePipelineResponse ¶ added in v0.9.0
type CreatePipelineResponse struct { *CreatePipelineOutput // contains filtered or unexported fields }
CreatePipelineResponse is the response type for the CreatePipeline API operation.
func (*CreatePipelineResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *CreatePipelineResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the CreatePipeline request.
type Dataset ¶
type Dataset struct { // The "DatasetAction" objects that automatically create the data set contents. Actions []DatasetAction `locationName:"actions" min:"1" type:"list"` // The ARN of the data set. Arn *string `locationName:"arn" type:"string"` // When data set contents are created they are delivered to destinations specified // here. ContentDeliveryRules []DatasetContentDeliveryRule `locationName:"contentDeliveryRules" type:"list"` // When the data set was created. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"` // The last time the data set was updated. LastUpdateTime *time.Time `locationName:"lastUpdateTime" type:"timestamp" timestampFormat:"unix"` // The name of the data set. Name *string `locationName:"name" min:"1" type:"string"` // [Optional] How long, in days, message data is kept for the data set. RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"` // The status of the data set. Status DatasetStatus `locationName:"status" type:"string" enum:"true"` // The "DatasetTrigger" objects that specify when the data set is automatically // updated. Triggers []DatasetTrigger `locationName:"triggers" type:"list"` // [Optional] How many versions of data set contents are kept. If not specified // or set to null, only the latest version plus the latest succeeded version // (if they are different) are kept for the time period specified by the "retentionPeriod" // parameter. (For more information, see https://docs.aws.amazon.com/iotanalytics/latest/userguide/getting-started.html#aws-iot-analytics-dataset-versions) VersioningConfiguration *VersioningConfiguration `locationName:"versioningConfiguration" type:"structure"` // contains filtered or unexported fields }
Information about a data set. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/Dataset
func (Dataset) MarshalFields ¶
func (s Dataset) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
type DatasetAction ¶
type DatasetAction struct { // The name of the data set action by which data set contents are automatically // created. ActionName *string `locationName:"actionName" min:"1" type:"string"` // Information which allows the system to run a containerized application in // order to create the data set contents. The application must be in a Docker // container along with any needed support libraries. ContainerAction *ContainerDatasetAction `locationName:"containerAction" type:"structure"` // An "SqlQueryDatasetAction" object that uses an SQL query to automatically // create data set contents. QueryAction *SqlQueryDatasetAction `locationName:"queryAction" type:"structure"` // contains filtered or unexported fields }
A "DatasetAction" object that specifies how data set contents are automatically created. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetAction
func (DatasetAction) MarshalFields ¶
func (s DatasetAction) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DatasetAction) String ¶
func (s DatasetAction) String() string
String returns the string representation
func (*DatasetAction) Validate ¶
func (s *DatasetAction) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DatasetActionSummary ¶ added in v0.5.0
type DatasetActionSummary struct { // The name of the action which automatically creates the data set's contents. ActionName *string `locationName:"actionName" min:"1" type:"string"` // The type of action by which the data set's contents are automatically created. ActionType DatasetActionType `locationName:"actionType" type:"string" enum:"true"` // contains filtered or unexported fields }
Information about the action which automatically creates the data set's contents. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetActionSummary
func (DatasetActionSummary) MarshalFields ¶ added in v0.5.0
func (s DatasetActionSummary) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DatasetActionSummary) String ¶ added in v0.5.0
func (s DatasetActionSummary) String() string
String returns the string representation
type DatasetActionType ¶ added in v0.5.0
type DatasetActionType string
const ( DatasetActionTypeQuery DatasetActionType = "QUERY" DatasetActionTypeContainer DatasetActionType = "CONTAINER" )
Enum values for DatasetActionType
func (DatasetActionType) MarshalValue ¶ added in v0.5.0
func (enum DatasetActionType) MarshalValue() (string, error)
func (DatasetActionType) MarshalValueBuf ¶ added in v0.5.0
func (enum DatasetActionType) MarshalValueBuf(b []byte) ([]byte, error)
type DatasetContentDeliveryDestination ¶ added in v0.6.0
type DatasetContentDeliveryDestination struct { // Configuration information for delivery of data set contents to AWS IoT Events. IotEventsDestinationConfiguration *IotEventsDestinationConfiguration `locationName:"iotEventsDestinationConfiguration" type:"structure"` // Configuration information for delivery of data set contents to Amazon S3. S3DestinationConfiguration *S3DestinationConfiguration `locationName:"s3DestinationConfiguration" type:"structure"` // contains filtered or unexported fields }
The destination to which data set contents are delivered. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetContentDeliveryDestination
func (DatasetContentDeliveryDestination) MarshalFields ¶ added in v0.6.0
func (s DatasetContentDeliveryDestination) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DatasetContentDeliveryDestination) String ¶ added in v0.6.0
func (s DatasetContentDeliveryDestination) String() string
String returns the string representation
func (*DatasetContentDeliveryDestination) Validate ¶ added in v0.6.0
func (s *DatasetContentDeliveryDestination) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DatasetContentDeliveryRule ¶ added in v0.6.0
type DatasetContentDeliveryRule struct { // The destination to which data set contents are delivered. // // Destination is a required field Destination *DatasetContentDeliveryDestination `locationName:"destination" type:"structure" required:"true"` // The name of the data set content delivery rules entry. EntryName *string `locationName:"entryName" type:"string"` // contains filtered or unexported fields }
When data set contents are created they are delivered to destination specified here. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetContentDeliveryRule
func (DatasetContentDeliveryRule) MarshalFields ¶ added in v0.6.0
func (s DatasetContentDeliveryRule) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DatasetContentDeliveryRule) String ¶ added in v0.6.0
func (s DatasetContentDeliveryRule) String() string
String returns the string representation
func (*DatasetContentDeliveryRule) Validate ¶ added in v0.6.0
func (s *DatasetContentDeliveryRule) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DatasetContentState ¶
type DatasetContentState string
const ( DatasetContentStateCreating DatasetContentState = "CREATING" DatasetContentStateSucceeded DatasetContentState = "SUCCEEDED" DatasetContentStateFailed DatasetContentState = "FAILED" )
Enum values for DatasetContentState
func (DatasetContentState) MarshalValue ¶
func (enum DatasetContentState) MarshalValue() (string, error)
func (DatasetContentState) MarshalValueBuf ¶
func (enum DatasetContentState) MarshalValueBuf(b []byte) ([]byte, error)
type DatasetContentStatus ¶
type DatasetContentStatus struct { // The reason the data set contents are in this state. Reason *string `locationName:"reason" type:"string"` // The state of the data set contents. Can be one of "READY", "CREATING", "SUCCEEDED" // or "FAILED". State DatasetContentState `locationName:"state" type:"string" enum:"true"` // contains filtered or unexported fields }
The state of the data set contents and the reason they are in this state. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetContentStatus
func (DatasetContentStatus) MarshalFields ¶
func (s DatasetContentStatus) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DatasetContentStatus) String ¶
func (s DatasetContentStatus) String() string
String returns the string representation
type DatasetContentSummary ¶ added in v0.5.0
type DatasetContentSummary struct { // The actual time the creation of the data set contents was started. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"` // The time the creation of the data set contents was scheduled to start. ScheduleTime *time.Time `locationName:"scheduleTime" type:"timestamp" timestampFormat:"unix"` // The status of the data set contents. Status *DatasetContentStatus `locationName:"status" type:"structure"` // The version of the data set contents. Version *string `locationName:"version" min:"7" type:"string"` // contains filtered or unexported fields }
Summary information about data set contents. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetContentSummary
func (DatasetContentSummary) MarshalFields ¶ added in v0.5.0
func (s DatasetContentSummary) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DatasetContentSummary) String ¶ added in v0.5.0
func (s DatasetContentSummary) String() string
String returns the string representation
type DatasetContentVersionValue ¶ added in v0.5.0
type DatasetContentVersionValue struct { // The name of the data set whose latest contents are used as input to the notebook // or application. // // DatasetName is a required field DatasetName *string `locationName:"datasetName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
The data set whose latest contents are used as input to the notebook or application. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetContentVersionValue
func (DatasetContentVersionValue) MarshalFields ¶ added in v0.5.0
func (s DatasetContentVersionValue) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DatasetContentVersionValue) String ¶ added in v0.5.0
func (s DatasetContentVersionValue) String() string
String returns the string representation
func (*DatasetContentVersionValue) Validate ¶ added in v0.5.0
func (s *DatasetContentVersionValue) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DatasetEntry ¶
type DatasetEntry struct { // The pre-signed URI of the data set item. DataURI *string `locationName:"dataURI" type:"string"` // The name of the data set item. EntryName *string `locationName:"entryName" type:"string"` // contains filtered or unexported fields }
The reference to a data set entry. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetEntry
func (DatasetEntry) MarshalFields ¶
func (s DatasetEntry) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DatasetEntry) String ¶
func (s DatasetEntry) String() string
String returns the string representation
type DatasetStatus ¶
type DatasetStatus string
const ( DatasetStatusCreating DatasetStatus = "CREATING" DatasetStatusActive DatasetStatus = "ACTIVE" DatasetStatusDeleting DatasetStatus = "DELETING" )
Enum values for DatasetStatus
func (DatasetStatus) MarshalValue ¶
func (enum DatasetStatus) MarshalValue() (string, error)
func (DatasetStatus) MarshalValueBuf ¶
func (enum DatasetStatus) MarshalValueBuf(b []byte) ([]byte, error)
type DatasetSummary ¶
type DatasetSummary struct { // A list of "DataActionSummary" objects. Actions []DatasetActionSummary `locationName:"actions" min:"1" type:"list"` // The time the data set was created. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"` // The name of the data set. DatasetName *string `locationName:"datasetName" min:"1" type:"string"` // The last time the data set was updated. LastUpdateTime *time.Time `locationName:"lastUpdateTime" type:"timestamp" timestampFormat:"unix"` // The status of the data set. Status DatasetStatus `locationName:"status" type:"string" enum:"true"` // A list of triggers. A trigger causes data set content to be populated at // a specified time interval or when another data set is populated. The list // of triggers can be empty or contain up to five DataSetTrigger objects Triggers []DatasetTrigger `locationName:"triggers" type:"list"` // contains filtered or unexported fields }
A summary of information about a data set. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetSummary
func (DatasetSummary) MarshalFields ¶
func (s DatasetSummary) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DatasetSummary) String ¶
func (s DatasetSummary) String() string
String returns the string representation
type DatasetTrigger ¶
type DatasetTrigger struct { // The data set whose content creation triggers the creation of this data set's // contents. Dataset *TriggeringDataset `locationName:"dataset" type:"structure"` // The "Schedule" when the trigger is initiated. Schedule *Schedule `locationName:"schedule" type:"structure"` // contains filtered or unexported fields }
The "DatasetTrigger" that specifies when the data set is automatically updated. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetTrigger
func (DatasetTrigger) MarshalFields ¶
func (s DatasetTrigger) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DatasetTrigger) String ¶
func (s DatasetTrigger) String() string
String returns the string representation
func (*DatasetTrigger) Validate ¶ added in v0.5.0
func (s *DatasetTrigger) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type Datastore ¶
type Datastore struct { // The ARN of the data store. Arn *string `locationName:"arn" type:"string"` // When the data store was created. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"` // The last time the data store was updated. LastUpdateTime *time.Time `locationName:"lastUpdateTime" type:"timestamp" timestampFormat:"unix"` // The name of the data store. Name *string `locationName:"name" min:"1" type:"string"` // How long, in days, message data is kept for the data store. RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"` // The status of a data store: // // CREATING // // The data store is being created. // // ACTIVE // // The data store has been created and can be used. // // DELETING // // The data store is being deleted. Status DatastoreStatus `locationName:"status" type:"string" enum:"true"` // contains filtered or unexported fields }
Information about a data store. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/Datastore
func (Datastore) MarshalFields ¶
func (s Datastore) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
type DatastoreActivity ¶
type DatastoreActivity struct { // The name of the data store where processed messages are stored. // // DatastoreName is a required field DatastoreName *string `locationName:"datastoreName" min:"1" type:"string" required:"true"` // The name of the 'datastore' activity. // // Name is a required field Name *string `locationName:"name" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
The 'datastore' activity that specifies where to store the processed data. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatastoreActivity
func (DatastoreActivity) MarshalFields ¶
func (s DatastoreActivity) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DatastoreActivity) String ¶
func (s DatastoreActivity) String() string
String returns the string representation
func (*DatastoreActivity) Validate ¶
func (s *DatastoreActivity) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DatastoreStatistics ¶ added in v0.5.0
type DatastoreStatistics struct { // The estimated size of the data store. Size *EstimatedResourceSize `locationName:"size" type:"structure"` // contains filtered or unexported fields }
Statistical information about the data store. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatastoreStatistics
func (DatastoreStatistics) MarshalFields ¶ added in v0.5.0
func (s DatastoreStatistics) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DatastoreStatistics) String ¶ added in v0.5.0
func (s DatastoreStatistics) String() string
String returns the string representation
type DatastoreStatus ¶
type DatastoreStatus string
const ( DatastoreStatusCreating DatastoreStatus = "CREATING" DatastoreStatusActive DatastoreStatus = "ACTIVE" DatastoreStatusDeleting DatastoreStatus = "DELETING" )
Enum values for DatastoreStatus
func (DatastoreStatus) MarshalValue ¶
func (enum DatastoreStatus) MarshalValue() (string, error)
func (DatastoreStatus) MarshalValueBuf ¶
func (enum DatastoreStatus) MarshalValueBuf(b []byte) ([]byte, error)
type DatastoreSummary ¶
type DatastoreSummary struct { // When the data store was created. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"` // The name of the data store. DatastoreName *string `locationName:"datastoreName" min:"1" type:"string"` // The last time the data store was updated. LastUpdateTime *time.Time `locationName:"lastUpdateTime" type:"timestamp" timestampFormat:"unix"` // The status of the data store. Status DatastoreStatus `locationName:"status" type:"string" enum:"true"` // contains filtered or unexported fields }
A summary of information about a data store. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatastoreSummary
func (DatastoreSummary) MarshalFields ¶
func (s DatastoreSummary) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DatastoreSummary) String ¶
func (s DatastoreSummary) String() string
String returns the string representation
type DeleteChannelInput ¶
type DeleteChannelInput struct { // The name of the channel to delete. // // ChannelName is a required field ChannelName *string `location:"uri" locationName:"channelName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteChannelRequest
func (DeleteChannelInput) MarshalFields ¶
func (s DeleteChannelInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DeleteChannelInput) String ¶
func (s DeleteChannelInput) String() string
String returns the string representation
func (*DeleteChannelInput) Validate ¶
func (s *DeleteChannelInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeleteChannelOutput ¶
type DeleteChannelOutput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteChannelOutput
func (DeleteChannelOutput) MarshalFields ¶
func (s DeleteChannelOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DeleteChannelOutput) String ¶
func (s DeleteChannelOutput) String() string
String returns the string representation
type DeleteChannelRequest ¶
type DeleteChannelRequest struct { *aws.Request Input *DeleteChannelInput Copy func(*DeleteChannelInput) DeleteChannelRequest }
DeleteChannelRequest is the request type for the DeleteChannel API operation.
func (DeleteChannelRequest) Send ¶
func (r DeleteChannelRequest) Send(ctx context.Context) (*DeleteChannelResponse, error)
Send marshals and sends the DeleteChannel API request.
type DeleteChannelResponse ¶ added in v0.9.0
type DeleteChannelResponse struct { *DeleteChannelOutput // contains filtered or unexported fields }
DeleteChannelResponse is the response type for the DeleteChannel API operation.
func (*DeleteChannelResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *DeleteChannelResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the DeleteChannel request.
type DeleteDatasetContentInput ¶
type DeleteDatasetContentInput struct { // The name of the data set whose content is deleted. // // DatasetName is a required field DatasetName *string `location:"uri" locationName:"datasetName" min:"1" type:"string" required:"true"` // The version of the data set whose content is deleted. You can also use the // strings "$LATEST" or "$LATEST_SUCCEEDED" to delete the latest or latest successfully // completed data set. If not specified, "$LATEST_SUCCEEDED" is the default. VersionId *string `location:"querystring" locationName:"versionId" min:"7" type:"string"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteDatasetContentRequest
func (DeleteDatasetContentInput) MarshalFields ¶
func (s DeleteDatasetContentInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DeleteDatasetContentInput) String ¶
func (s DeleteDatasetContentInput) String() string
String returns the string representation
func (*DeleteDatasetContentInput) Validate ¶
func (s *DeleteDatasetContentInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeleteDatasetContentOutput ¶
type DeleteDatasetContentOutput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteDatasetContentOutput
func (DeleteDatasetContentOutput) MarshalFields ¶
func (s DeleteDatasetContentOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DeleteDatasetContentOutput) String ¶
func (s DeleteDatasetContentOutput) String() string
String returns the string representation
type DeleteDatasetContentRequest ¶
type DeleteDatasetContentRequest struct { *aws.Request Input *DeleteDatasetContentInput Copy func(*DeleteDatasetContentInput) DeleteDatasetContentRequest }
DeleteDatasetContentRequest is the request type for the DeleteDatasetContent API operation.
func (DeleteDatasetContentRequest) Send ¶
func (r DeleteDatasetContentRequest) Send(ctx context.Context) (*DeleteDatasetContentResponse, error)
Send marshals and sends the DeleteDatasetContent API request.
type DeleteDatasetContentResponse ¶ added in v0.9.0
type DeleteDatasetContentResponse struct { *DeleteDatasetContentOutput // contains filtered or unexported fields }
DeleteDatasetContentResponse is the response type for the DeleteDatasetContent API operation.
func (*DeleteDatasetContentResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *DeleteDatasetContentResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the DeleteDatasetContent request.
type DeleteDatasetInput ¶
type DeleteDatasetInput struct { // The name of the data set to delete. // // DatasetName is a required field DatasetName *string `location:"uri" locationName:"datasetName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteDatasetRequest
func (DeleteDatasetInput) MarshalFields ¶
func (s DeleteDatasetInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DeleteDatasetInput) String ¶
func (s DeleteDatasetInput) String() string
String returns the string representation
func (*DeleteDatasetInput) Validate ¶
func (s *DeleteDatasetInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeleteDatasetOutput ¶
type DeleteDatasetOutput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteDatasetOutput
func (DeleteDatasetOutput) MarshalFields ¶
func (s DeleteDatasetOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DeleteDatasetOutput) String ¶
func (s DeleteDatasetOutput) String() string
String returns the string representation
type DeleteDatasetRequest ¶
type DeleteDatasetRequest struct { *aws.Request Input *DeleteDatasetInput Copy func(*DeleteDatasetInput) DeleteDatasetRequest }
DeleteDatasetRequest is the request type for the DeleteDataset API operation.
func (DeleteDatasetRequest) Send ¶
func (r DeleteDatasetRequest) Send(ctx context.Context) (*DeleteDatasetResponse, error)
Send marshals and sends the DeleteDataset API request.
type DeleteDatasetResponse ¶ added in v0.9.0
type DeleteDatasetResponse struct { *DeleteDatasetOutput // contains filtered or unexported fields }
DeleteDatasetResponse is the response type for the DeleteDataset API operation.
func (*DeleteDatasetResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *DeleteDatasetResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the DeleteDataset request.
type DeleteDatastoreInput ¶
type DeleteDatastoreInput struct { // The name of the data store to delete. // // DatastoreName is a required field DatastoreName *string `location:"uri" locationName:"datastoreName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteDatastoreRequest
func (DeleteDatastoreInput) MarshalFields ¶
func (s DeleteDatastoreInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DeleteDatastoreInput) String ¶
func (s DeleteDatastoreInput) String() string
String returns the string representation
func (*DeleteDatastoreInput) Validate ¶
func (s *DeleteDatastoreInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeleteDatastoreOutput ¶
type DeleteDatastoreOutput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteDatastoreOutput
func (DeleteDatastoreOutput) MarshalFields ¶
func (s DeleteDatastoreOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DeleteDatastoreOutput) String ¶
func (s DeleteDatastoreOutput) String() string
String returns the string representation
type DeleteDatastoreRequest ¶
type DeleteDatastoreRequest struct { *aws.Request Input *DeleteDatastoreInput Copy func(*DeleteDatastoreInput) DeleteDatastoreRequest }
DeleteDatastoreRequest is the request type for the DeleteDatastore API operation.
func (DeleteDatastoreRequest) Send ¶
func (r DeleteDatastoreRequest) Send(ctx context.Context) (*DeleteDatastoreResponse, error)
Send marshals and sends the DeleteDatastore API request.
type DeleteDatastoreResponse ¶ added in v0.9.0
type DeleteDatastoreResponse struct { *DeleteDatastoreOutput // contains filtered or unexported fields }
DeleteDatastoreResponse is the response type for the DeleteDatastore API operation.
func (*DeleteDatastoreResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *DeleteDatastoreResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the DeleteDatastore request.
type DeletePipelineInput ¶
type DeletePipelineInput struct { // The name of the pipeline to delete. // // PipelineName is a required field PipelineName *string `location:"uri" locationName:"pipelineName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeletePipelineRequest
func (DeletePipelineInput) MarshalFields ¶
func (s DeletePipelineInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DeletePipelineInput) String ¶
func (s DeletePipelineInput) String() string
String returns the string representation
func (*DeletePipelineInput) Validate ¶
func (s *DeletePipelineInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeletePipelineOutput ¶
type DeletePipelineOutput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeletePipelineOutput
func (DeletePipelineOutput) MarshalFields ¶
func (s DeletePipelineOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DeletePipelineOutput) String ¶
func (s DeletePipelineOutput) String() string
String returns the string representation
type DeletePipelineRequest ¶
type DeletePipelineRequest struct { *aws.Request Input *DeletePipelineInput Copy func(*DeletePipelineInput) DeletePipelineRequest }
DeletePipelineRequest is the request type for the DeletePipeline API operation.
func (DeletePipelineRequest) Send ¶
func (r DeletePipelineRequest) Send(ctx context.Context) (*DeletePipelineResponse, error)
Send marshals and sends the DeletePipeline API request.
type DeletePipelineResponse ¶ added in v0.9.0
type DeletePipelineResponse struct { *DeletePipelineOutput // contains filtered or unexported fields }
DeletePipelineResponse is the response type for the DeletePipeline API operation.
func (*DeletePipelineResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *DeletePipelineResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the DeletePipeline request.
type DeltaTime ¶ added in v0.5.0
type DeltaTime struct { // The number of seconds of estimated "in flight" lag time of message data. // When you create data set contents using message data from a specified time // frame, some message data may still be "in flight" when processing begins, // and so will not arrive in time to be processed. Use this field to make allowances // for the "in flight" time of your message data, so that data not processed // from a previous time frame will be included with the next time frame. Without // this, missed message data would be excluded from processing during the next // time frame as well, because its timestamp places it within the previous time // frame. // // OffsetSeconds is a required field OffsetSeconds *int64 `locationName:"offsetSeconds" type:"integer" required:"true"` // An expression by which the time of the message data may be determined. This // may be the name of a timestamp field, or a SQL expression which is used to // derive the time the message data was generated. // // TimeExpression is a required field TimeExpression *string `locationName:"timeExpression" type:"string" required:"true"` // contains filtered or unexported fields }
Used to limit data to that which has arrived since the last execution of the action. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeltaTime
func (DeltaTime) MarshalFields ¶ added in v0.5.0
func (s DeltaTime) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
type DescribeChannelInput ¶
type DescribeChannelInput struct { // The name of the channel whose information is retrieved. // // ChannelName is a required field ChannelName *string `location:"uri" locationName:"channelName" min:"1" type:"string" required:"true"` // If true, additional statistical information about the channel is included // in the response. IncludeStatistics *bool `location:"querystring" locationName:"includeStatistics" type:"boolean"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeChannelRequest
func (DescribeChannelInput) MarshalFields ¶
func (s DescribeChannelInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DescribeChannelInput) String ¶
func (s DescribeChannelInput) String() string
String returns the string representation
func (*DescribeChannelInput) Validate ¶
func (s *DescribeChannelInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeChannelOutput ¶
type DescribeChannelOutput struct { // An object that contains information about the channel. Channel *Channel `locationName:"channel" type:"structure"` // Statistics about the channel. Included if the 'includeStatistics' parameter // is set to true in the request. Statistics *ChannelStatistics `locationName:"statistics" type:"structure"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeChannelResponse
func (DescribeChannelOutput) MarshalFields ¶
func (s DescribeChannelOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DescribeChannelOutput) String ¶
func (s DescribeChannelOutput) String() string
String returns the string representation
type DescribeChannelRequest ¶
type DescribeChannelRequest struct { *aws.Request Input *DescribeChannelInput Copy func(*DescribeChannelInput) DescribeChannelRequest }
DescribeChannelRequest is the request type for the DescribeChannel API operation.
func (DescribeChannelRequest) Send ¶
func (r DescribeChannelRequest) Send(ctx context.Context) (*DescribeChannelResponse, error)
Send marshals and sends the DescribeChannel API request.
type DescribeChannelResponse ¶ added in v0.9.0
type DescribeChannelResponse struct { *DescribeChannelOutput // contains filtered or unexported fields }
DescribeChannelResponse is the response type for the DescribeChannel API operation.
func (*DescribeChannelResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *DescribeChannelResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the DescribeChannel request.
type DescribeDatasetInput ¶
type DescribeDatasetInput struct { // The name of the data set whose information is retrieved. // // DatasetName is a required field DatasetName *string `location:"uri" locationName:"datasetName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeDatasetRequest
func (DescribeDatasetInput) MarshalFields ¶
func (s DescribeDatasetInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DescribeDatasetInput) String ¶
func (s DescribeDatasetInput) String() string
String returns the string representation
func (*DescribeDatasetInput) Validate ¶
func (s *DescribeDatasetInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeDatasetOutput ¶
type DescribeDatasetOutput struct { // An object that contains information about the data set. Dataset *Dataset `locationName:"dataset" type:"structure"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeDatasetResponse
func (DescribeDatasetOutput) MarshalFields ¶
func (s DescribeDatasetOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DescribeDatasetOutput) String ¶
func (s DescribeDatasetOutput) String() string
String returns the string representation
type DescribeDatasetRequest ¶
type DescribeDatasetRequest struct { *aws.Request Input *DescribeDatasetInput Copy func(*DescribeDatasetInput) DescribeDatasetRequest }
DescribeDatasetRequest is the request type for the DescribeDataset API operation.
func (DescribeDatasetRequest) Send ¶
func (r DescribeDatasetRequest) Send(ctx context.Context) (*DescribeDatasetResponse, error)
Send marshals and sends the DescribeDataset API request.
type DescribeDatasetResponse ¶ added in v0.9.0
type DescribeDatasetResponse struct { *DescribeDatasetOutput // contains filtered or unexported fields }
DescribeDatasetResponse is the response type for the DescribeDataset API operation.
func (*DescribeDatasetResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *DescribeDatasetResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the DescribeDataset request.
type DescribeDatastoreInput ¶
type DescribeDatastoreInput struct { // The name of the data store // // DatastoreName is a required field DatastoreName *string `location:"uri" locationName:"datastoreName" min:"1" type:"string" required:"true"` // If true, additional statistical information about the datastore is included // in the response. IncludeStatistics *bool `location:"querystring" locationName:"includeStatistics" type:"boolean"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeDatastoreRequest
func (DescribeDatastoreInput) MarshalFields ¶
func (s DescribeDatastoreInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DescribeDatastoreInput) String ¶
func (s DescribeDatastoreInput) String() string
String returns the string representation
func (*DescribeDatastoreInput) Validate ¶
func (s *DescribeDatastoreInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribeDatastoreOutput ¶
type DescribeDatastoreOutput struct { // Information about the data store. Datastore *Datastore `locationName:"datastore" type:"structure"` // Additional statistical information about the data store. Included if the // 'includeStatistics' parameter is set to true in the request. Statistics *DatastoreStatistics `locationName:"statistics" type:"structure"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeDatastoreResponse
func (DescribeDatastoreOutput) MarshalFields ¶
func (s DescribeDatastoreOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DescribeDatastoreOutput) String ¶
func (s DescribeDatastoreOutput) String() string
String returns the string representation
type DescribeDatastoreRequest ¶
type DescribeDatastoreRequest struct { *aws.Request Input *DescribeDatastoreInput Copy func(*DescribeDatastoreInput) DescribeDatastoreRequest }
DescribeDatastoreRequest is the request type for the DescribeDatastore API operation.
func (DescribeDatastoreRequest) Send ¶
func (r DescribeDatastoreRequest) Send(ctx context.Context) (*DescribeDatastoreResponse, error)
Send marshals and sends the DescribeDatastore API request.
type DescribeDatastoreResponse ¶ added in v0.9.0
type DescribeDatastoreResponse struct { *DescribeDatastoreOutput // contains filtered or unexported fields }
DescribeDatastoreResponse is the response type for the DescribeDatastore API operation.
func (*DescribeDatastoreResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *DescribeDatastoreResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the DescribeDatastore request.
type DescribeLoggingOptionsInput ¶
type DescribeLoggingOptionsInput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeLoggingOptionsRequest
func (DescribeLoggingOptionsInput) MarshalFields ¶
func (s DescribeLoggingOptionsInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DescribeLoggingOptionsInput) String ¶
func (s DescribeLoggingOptionsInput) String() string
String returns the string representation
type DescribeLoggingOptionsOutput ¶
type DescribeLoggingOptionsOutput struct { // The current settings of the AWS IoT Analytics logging options. LoggingOptions *LoggingOptions `locationName:"loggingOptions" type:"structure"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeLoggingOptionsResponse
func (DescribeLoggingOptionsOutput) MarshalFields ¶
func (s DescribeLoggingOptionsOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DescribeLoggingOptionsOutput) String ¶
func (s DescribeLoggingOptionsOutput) String() string
String returns the string representation
type DescribeLoggingOptionsRequest ¶
type DescribeLoggingOptionsRequest struct { *aws.Request Input *DescribeLoggingOptionsInput Copy func(*DescribeLoggingOptionsInput) DescribeLoggingOptionsRequest }
DescribeLoggingOptionsRequest is the request type for the DescribeLoggingOptions API operation.
func (DescribeLoggingOptionsRequest) Send ¶
func (r DescribeLoggingOptionsRequest) Send(ctx context.Context) (*DescribeLoggingOptionsResponse, error)
Send marshals and sends the DescribeLoggingOptions API request.
type DescribeLoggingOptionsResponse ¶ added in v0.9.0
type DescribeLoggingOptionsResponse struct { *DescribeLoggingOptionsOutput // contains filtered or unexported fields }
DescribeLoggingOptionsResponse is the response type for the DescribeLoggingOptions API operation.
func (*DescribeLoggingOptionsResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *DescribeLoggingOptionsResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the DescribeLoggingOptions request.
type DescribePipelineInput ¶
type DescribePipelineInput struct { // The name of the pipeline whose information is retrieved. // // PipelineName is a required field PipelineName *string `location:"uri" locationName:"pipelineName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribePipelineRequest
func (DescribePipelineInput) MarshalFields ¶
func (s DescribePipelineInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DescribePipelineInput) String ¶
func (s DescribePipelineInput) String() string
String returns the string representation
func (*DescribePipelineInput) Validate ¶
func (s *DescribePipelineInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DescribePipelineOutput ¶
type DescribePipelineOutput struct { // A "Pipeline" object that contains information about the pipeline. Pipeline *Pipeline `locationName:"pipeline" type:"structure"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribePipelineResponse
func (DescribePipelineOutput) MarshalFields ¶
func (s DescribePipelineOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DescribePipelineOutput) String ¶
func (s DescribePipelineOutput) String() string
String returns the string representation
type DescribePipelineRequest ¶
type DescribePipelineRequest struct { *aws.Request Input *DescribePipelineInput Copy func(*DescribePipelineInput) DescribePipelineRequest }
DescribePipelineRequest is the request type for the DescribePipeline API operation.
func (DescribePipelineRequest) Send ¶
func (r DescribePipelineRequest) Send(ctx context.Context) (*DescribePipelineResponse, error)
Send marshals and sends the DescribePipeline API request.
type DescribePipelineResponse ¶ added in v0.9.0
type DescribePipelineResponse struct { *DescribePipelineOutput // contains filtered or unexported fields }
DescribePipelineResponse is the response type for the DescribePipeline API operation.
func (*DescribePipelineResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *DescribePipelineResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the DescribePipeline request.
type DeviceRegistryEnrichActivity ¶
type DeviceRegistryEnrichActivity struct { // The name of the attribute that is added to the message. // // Attribute is a required field Attribute *string `locationName:"attribute" min:"1" type:"string" required:"true"` // The name of the 'deviceRegistryEnrich' activity. // // Name is a required field Name *string `locationName:"name" min:"1" type:"string" required:"true"` // The next activity in the pipeline. Next *string `locationName:"next" min:"1" type:"string"` // The ARN of the role that allows access to the device's registry information. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" min:"20" type:"string" required:"true"` // The name of the IoT device whose registry information is added to the message. // // ThingName is a required field ThingName *string `locationName:"thingName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
An activity that adds data from the AWS IoT device registry to your message. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeviceRegistryEnrichActivity
func (DeviceRegistryEnrichActivity) MarshalFields ¶
func (s DeviceRegistryEnrichActivity) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DeviceRegistryEnrichActivity) String ¶
func (s DeviceRegistryEnrichActivity) String() string
String returns the string representation
func (*DeviceRegistryEnrichActivity) Validate ¶
func (s *DeviceRegistryEnrichActivity) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type DeviceShadowEnrichActivity ¶
type DeviceShadowEnrichActivity struct { // The name of the attribute that is added to the message. // // Attribute is a required field Attribute *string `locationName:"attribute" min:"1" type:"string" required:"true"` // The name of the 'deviceShadowEnrich' activity. // // Name is a required field Name *string `locationName:"name" min:"1" type:"string" required:"true"` // The next activity in the pipeline. Next *string `locationName:"next" min:"1" type:"string"` // The ARN of the role that allows access to the device's shadow. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" min:"20" type:"string" required:"true"` // The name of the IoT device whose shadow information is added to the message. // // ThingName is a required field ThingName *string `locationName:"thingName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
An activity that adds information from the AWS IoT Device Shadows service to a message. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeviceShadowEnrichActivity
func (DeviceShadowEnrichActivity) MarshalFields ¶
func (s DeviceShadowEnrichActivity) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (DeviceShadowEnrichActivity) String ¶
func (s DeviceShadowEnrichActivity) String() string
String returns the string representation
func (*DeviceShadowEnrichActivity) Validate ¶
func (s *DeviceShadowEnrichActivity) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type EstimatedResourceSize ¶ added in v0.5.0
type EstimatedResourceSize struct { // The time when the estimate of the size of the resource was made. EstimatedOn *time.Time `locationName:"estimatedOn" type:"timestamp" timestampFormat:"unix"` // The estimated size of the resource in bytes. EstimatedSizeInBytes *float64 `locationName:"estimatedSizeInBytes" type:"double"` // contains filtered or unexported fields }
The estimated size of the resource. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/EstimatedResourceSize
func (EstimatedResourceSize) MarshalFields ¶ added in v0.5.0
func (s EstimatedResourceSize) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (EstimatedResourceSize) String ¶ added in v0.5.0
func (s EstimatedResourceSize) String() string
String returns the string representation
type FilterActivity ¶
type FilterActivity struct { // An expression that looks like a SQL WHERE clause that must return a Boolean // value. // // Filter is a required field Filter *string `locationName:"filter" min:"1" type:"string" required:"true"` // The name of the 'filter' activity. // // Name is a required field Name *string `locationName:"name" min:"1" type:"string" required:"true"` // The next activity in the pipeline. Next *string `locationName:"next" min:"1" type:"string"` // contains filtered or unexported fields }
An activity that filters a message based on its attributes. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/FilterActivity
func (FilterActivity) MarshalFields ¶
func (s FilterActivity) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (FilterActivity) String ¶
func (s FilterActivity) String() string
String returns the string representation
func (*FilterActivity) Validate ¶
func (s *FilterActivity) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type GetDatasetContentInput ¶
type GetDatasetContentInput struct { // The name of the data set whose contents are retrieved. // // DatasetName is a required field DatasetName *string `location:"uri" locationName:"datasetName" min:"1" type:"string" required:"true"` // The version of the data set whose contents are retrieved. You can also use // the strings "$LATEST" or "$LATEST_SUCCEEDED" to retrieve the contents of // the latest or latest successfully completed data set. If not specified, "$LATEST_SUCCEEDED" // is the default. VersionId *string `location:"querystring" locationName:"versionId" min:"7" type:"string"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/GetDatasetContentRequest
func (GetDatasetContentInput) MarshalFields ¶
func (s GetDatasetContentInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (GetDatasetContentInput) String ¶
func (s GetDatasetContentInput) String() string
String returns the string representation
func (*GetDatasetContentInput) Validate ¶
func (s *GetDatasetContentInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type GetDatasetContentOutput ¶
type GetDatasetContentOutput struct { // A list of "DatasetEntry" objects. Entries []DatasetEntry `locationName:"entries" type:"list"` // The status of the data set content. Status *DatasetContentStatus `locationName:"status" type:"structure"` // The time when the request was made. Timestamp *time.Time `locationName:"timestamp" type:"timestamp" timestampFormat:"unix"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/GetDatasetContentResponse
func (GetDatasetContentOutput) MarshalFields ¶
func (s GetDatasetContentOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (GetDatasetContentOutput) String ¶
func (s GetDatasetContentOutput) String() string
String returns the string representation
type GetDatasetContentRequest ¶
type GetDatasetContentRequest struct { *aws.Request Input *GetDatasetContentInput Copy func(*GetDatasetContentInput) GetDatasetContentRequest }
GetDatasetContentRequest is the request type for the GetDatasetContent API operation.
func (GetDatasetContentRequest) Send ¶
func (r GetDatasetContentRequest) Send(ctx context.Context) (*GetDatasetContentResponse, error)
Send marshals and sends the GetDatasetContent API request.
type GetDatasetContentResponse ¶ added in v0.9.0
type GetDatasetContentResponse struct { *GetDatasetContentOutput // contains filtered or unexported fields }
GetDatasetContentResponse is the response type for the GetDatasetContent API operation.
func (*GetDatasetContentResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *GetDatasetContentResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the GetDatasetContent request.
type GlueConfiguration ¶ added in v0.9.0
type GlueConfiguration struct { // The name of the database in your AWS Glue Data Catalog in which the table // is located. (An AWS Glue Data Catalog database contains Glue Data tables.) // // DatabaseName is a required field DatabaseName *string `locationName:"databaseName" min:"1" type:"string" required:"true"` // The name of the table in your AWS Glue Data Catalog which is used to perform // the ETL (extract, transform and load) operations. (An AWS Glue Data Catalog // table contains partitioned data and descriptions of data sources and targets.) // // TableName is a required field TableName *string `locationName:"tableName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
Configuration information for coordination with the AWS Glue ETL (extract, transform and load) service. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/GlueConfiguration
func (GlueConfiguration) MarshalFields ¶ added in v0.9.0
func (s GlueConfiguration) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (GlueConfiguration) String ¶ added in v0.9.0
func (s GlueConfiguration) String() string
String returns the string representation
func (*GlueConfiguration) Validate ¶ added in v0.9.0
func (s *GlueConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type IotEventsDestinationConfiguration ¶ added in v0.6.0
type IotEventsDestinationConfiguration struct { // The name of the AWS IoT Events input to which data set contents are delivered. // // InputName is a required field InputName *string `locationName:"inputName" min:"1" type:"string" required:"true"` // The ARN of the role which grants AWS IoT Analytics permission to deliver // data set contents to an AWS IoT Events input. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" min:"20" type:"string" required:"true"` // contains filtered or unexported fields }
Configuration information for delivery of data set contents to AWS IoT Events. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/IotEventsDestinationConfiguration
func (IotEventsDestinationConfiguration) MarshalFields ¶ added in v0.6.0
func (s IotEventsDestinationConfiguration) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (IotEventsDestinationConfiguration) String ¶ added in v0.6.0
func (s IotEventsDestinationConfiguration) String() string
String returns the string representation
func (*IotEventsDestinationConfiguration) Validate ¶ added in v0.6.0
func (s *IotEventsDestinationConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type LambdaActivity ¶
type LambdaActivity struct { // The number of messages passed to the Lambda function for processing. // // The AWS Lambda function must be able to process all of these messages within // five minutes, which is the maximum timeout duration for Lambda functions. // // BatchSize is a required field BatchSize *int64 `locationName:"batchSize" min:"1" type:"integer" required:"true"` // The name of the Lambda function that is run on the message. // // LambdaName is a required field LambdaName *string `locationName:"lambdaName" min:"1" type:"string" required:"true"` // The name of the 'lambda' activity. // // Name is a required field Name *string `locationName:"name" min:"1" type:"string" required:"true"` // The next activity in the pipeline. Next *string `locationName:"next" min:"1" type:"string"` // contains filtered or unexported fields }
An activity that runs a Lambda function to modify the message. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/LambdaActivity
func (LambdaActivity) MarshalFields ¶
func (s LambdaActivity) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (LambdaActivity) String ¶
func (s LambdaActivity) String() string
String returns the string representation
func (*LambdaActivity) Validate ¶
func (s *LambdaActivity) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListChannelsInput ¶
type ListChannelsInput struct { // The maximum number of results to return in this request. // // The default value is 100. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` // The token for the next set of results. NextToken *string `location:"querystring" locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListChannelsRequest
func (ListChannelsInput) MarshalFields ¶
func (s ListChannelsInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ListChannelsInput) String ¶
func (s ListChannelsInput) String() string
String returns the string representation
func (*ListChannelsInput) Validate ¶
func (s *ListChannelsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListChannelsOutput ¶
type ListChannelsOutput struct { // A list of "ChannelSummary" objects. ChannelSummaries []ChannelSummary `locationName:"channelSummaries" type:"list"` // The token to retrieve the next set of results, or null if there are no more // results. NextToken *string `locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListChannelsResponse
func (ListChannelsOutput) MarshalFields ¶
func (s ListChannelsOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ListChannelsOutput) String ¶
func (s ListChannelsOutput) String() string
String returns the string representation
type ListChannelsPaginator ¶ added in v0.9.0
ListChannelsPaginator is used to paginate the request. This can be done by calling Next and CurrentPage.
func NewListChannelsPaginator ¶ added in v0.9.0
func NewListChannelsPaginator(req ListChannelsRequest) ListChannelsPaginator
NewListChannelsRequestPaginator returns a paginator for ListChannels. Use Next method to get the next page, and CurrentPage to get the current response page from the paginator. Next will return false, if there are no more pages, or an error was encountered.
Note: This operation can generate multiple requests to a service.
// Example iterating over pages. req := client.ListChannelsRequest(input) p := iotanalytics.NewListChannelsRequestPaginator(req) for p.Next(context.TODO()) { page := p.CurrentPage() } if err := p.Err(); err != nil { return err }
func (*ListChannelsPaginator) CurrentPage ¶ added in v0.9.0
func (p *ListChannelsPaginator) CurrentPage() *ListChannelsOutput
type ListChannelsRequest ¶
type ListChannelsRequest struct { *aws.Request Input *ListChannelsInput Copy func(*ListChannelsInput) ListChannelsRequest }
ListChannelsRequest is the request type for the ListChannels API operation.
func (ListChannelsRequest) Send ¶
func (r ListChannelsRequest) Send(ctx context.Context) (*ListChannelsResponse, error)
Send marshals and sends the ListChannels API request.
type ListChannelsResponse ¶ added in v0.9.0
type ListChannelsResponse struct { *ListChannelsOutput // contains filtered or unexported fields }
ListChannelsResponse is the response type for the ListChannels API operation.
func (*ListChannelsResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *ListChannelsResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the ListChannels request.
type ListDatasetContentsInput ¶ added in v0.5.0
type ListDatasetContentsInput struct { // The name of the data set whose contents information you want to list. // // DatasetName is a required field DatasetName *string `location:"uri" locationName:"datasetName" min:"1" type:"string" required:"true"` // The maximum number of results to return in this request. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` // The token for the next set of results. NextToken *string `location:"querystring" locationName:"nextToken" type:"string"` // A filter to limit results to those data set contents whose creation is scheduled // before the given time. See the field triggers.schedule in the CreateDataset // request. (timestamp) ScheduledBefore *time.Time `location:"querystring" locationName:"scheduledBefore" type:"timestamp" timestampFormat:"unix"` // A filter to limit results to those data set contents whose creation is scheduled // on or after the given time. See the field triggers.schedule in the CreateDataset // request. (timestamp) ScheduledOnOrAfter *time.Time `location:"querystring" locationName:"scheduledOnOrAfter" type:"timestamp" timestampFormat:"unix"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListDatasetContentsRequest
func (ListDatasetContentsInput) MarshalFields ¶ added in v0.5.0
func (s ListDatasetContentsInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ListDatasetContentsInput) String ¶ added in v0.5.0
func (s ListDatasetContentsInput) String() string
String returns the string representation
func (*ListDatasetContentsInput) Validate ¶ added in v0.5.0
func (s *ListDatasetContentsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListDatasetContentsOutput ¶ added in v0.5.0
type ListDatasetContentsOutput struct { // Summary information about data set contents that have been created. DatasetContentSummaries []DatasetContentSummary `locationName:"datasetContentSummaries" type:"list"` // The token to retrieve the next set of results, or null if there are no more // results. NextToken *string `locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListDatasetContentsResponse
func (ListDatasetContentsOutput) MarshalFields ¶ added in v0.5.0
func (s ListDatasetContentsOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ListDatasetContentsOutput) String ¶ added in v0.5.0
func (s ListDatasetContentsOutput) String() string
String returns the string representation
type ListDatasetContentsPaginator ¶ added in v0.9.0
ListDatasetContentsPaginator is used to paginate the request. This can be done by calling Next and CurrentPage.
func NewListDatasetContentsPaginator ¶ added in v0.9.0
func NewListDatasetContentsPaginator(req ListDatasetContentsRequest) ListDatasetContentsPaginator
NewListDatasetContentsRequestPaginator returns a paginator for ListDatasetContents. Use Next method to get the next page, and CurrentPage to get the current response page from the paginator. Next will return false, if there are no more pages, or an error was encountered.
Note: This operation can generate multiple requests to a service.
// Example iterating over pages. req := client.ListDatasetContentsRequest(input) p := iotanalytics.NewListDatasetContentsRequestPaginator(req) for p.Next(context.TODO()) { page := p.CurrentPage() } if err := p.Err(); err != nil { return err }
func (*ListDatasetContentsPaginator) CurrentPage ¶ added in v0.9.0
func (p *ListDatasetContentsPaginator) CurrentPage() *ListDatasetContentsOutput
type ListDatasetContentsRequest ¶ added in v0.5.0
type ListDatasetContentsRequest struct { *aws.Request Input *ListDatasetContentsInput Copy func(*ListDatasetContentsInput) ListDatasetContentsRequest }
ListDatasetContentsRequest is the request type for the ListDatasetContents API operation.
func (ListDatasetContentsRequest) Send ¶ added in v0.5.0
func (r ListDatasetContentsRequest) Send(ctx context.Context) (*ListDatasetContentsResponse, error)
Send marshals and sends the ListDatasetContents API request.
type ListDatasetContentsResponse ¶ added in v0.9.0
type ListDatasetContentsResponse struct { *ListDatasetContentsOutput // contains filtered or unexported fields }
ListDatasetContentsResponse is the response type for the ListDatasetContents API operation.
func (*ListDatasetContentsResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *ListDatasetContentsResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the ListDatasetContents request.
type ListDatasetsInput ¶
type ListDatasetsInput struct { // The maximum number of results to return in this request. // // The default value is 100. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` // The token for the next set of results. NextToken *string `location:"querystring" locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListDatasetsRequest
func (ListDatasetsInput) MarshalFields ¶
func (s ListDatasetsInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ListDatasetsInput) String ¶
func (s ListDatasetsInput) String() string
String returns the string representation
func (*ListDatasetsInput) Validate ¶
func (s *ListDatasetsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListDatasetsOutput ¶
type ListDatasetsOutput struct { // A list of "DatasetSummary" objects. DatasetSummaries []DatasetSummary `locationName:"datasetSummaries" type:"list"` // The token to retrieve the next set of results, or null if there are no more // results. NextToken *string `locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListDatasetsResponse
func (ListDatasetsOutput) MarshalFields ¶
func (s ListDatasetsOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ListDatasetsOutput) String ¶
func (s ListDatasetsOutput) String() string
String returns the string representation
type ListDatasetsPaginator ¶ added in v0.9.0
ListDatasetsPaginator is used to paginate the request. This can be done by calling Next and CurrentPage.
func NewListDatasetsPaginator ¶ added in v0.9.0
func NewListDatasetsPaginator(req ListDatasetsRequest) ListDatasetsPaginator
NewListDatasetsRequestPaginator returns a paginator for ListDatasets. Use Next method to get the next page, and CurrentPage to get the current response page from the paginator. Next will return false, if there are no more pages, or an error was encountered.
Note: This operation can generate multiple requests to a service.
// Example iterating over pages. req := client.ListDatasetsRequest(input) p := iotanalytics.NewListDatasetsRequestPaginator(req) for p.Next(context.TODO()) { page := p.CurrentPage() } if err := p.Err(); err != nil { return err }
func (*ListDatasetsPaginator) CurrentPage ¶ added in v0.9.0
func (p *ListDatasetsPaginator) CurrentPage() *ListDatasetsOutput
type ListDatasetsRequest ¶
type ListDatasetsRequest struct { *aws.Request Input *ListDatasetsInput Copy func(*ListDatasetsInput) ListDatasetsRequest }
ListDatasetsRequest is the request type for the ListDatasets API operation.
func (ListDatasetsRequest) Send ¶
func (r ListDatasetsRequest) Send(ctx context.Context) (*ListDatasetsResponse, error)
Send marshals and sends the ListDatasets API request.
type ListDatasetsResponse ¶ added in v0.9.0
type ListDatasetsResponse struct { *ListDatasetsOutput // contains filtered or unexported fields }
ListDatasetsResponse is the response type for the ListDatasets API operation.
func (*ListDatasetsResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *ListDatasetsResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the ListDatasets request.
type ListDatastoresInput ¶
type ListDatastoresInput struct { // The maximum number of results to return in this request. // // The default value is 100. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` // The token for the next set of results. NextToken *string `location:"querystring" locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListDatastoresRequest
func (ListDatastoresInput) MarshalFields ¶
func (s ListDatastoresInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ListDatastoresInput) String ¶
func (s ListDatastoresInput) String() string
String returns the string representation
func (*ListDatastoresInput) Validate ¶
func (s *ListDatastoresInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListDatastoresOutput ¶
type ListDatastoresOutput struct { // A list of "DatastoreSummary" objects. DatastoreSummaries []DatastoreSummary `locationName:"datastoreSummaries" type:"list"` // The token to retrieve the next set of results, or null if there are no more // results. NextToken *string `locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListDatastoresResponse
func (ListDatastoresOutput) MarshalFields ¶
func (s ListDatastoresOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ListDatastoresOutput) String ¶
func (s ListDatastoresOutput) String() string
String returns the string representation
type ListDatastoresPaginator ¶ added in v0.9.0
ListDatastoresPaginator is used to paginate the request. This can be done by calling Next and CurrentPage.
func NewListDatastoresPaginator ¶ added in v0.9.0
func NewListDatastoresPaginator(req ListDatastoresRequest) ListDatastoresPaginator
NewListDatastoresRequestPaginator returns a paginator for ListDatastores. Use Next method to get the next page, and CurrentPage to get the current response page from the paginator. Next will return false, if there are no more pages, or an error was encountered.
Note: This operation can generate multiple requests to a service.
// Example iterating over pages. req := client.ListDatastoresRequest(input) p := iotanalytics.NewListDatastoresRequestPaginator(req) for p.Next(context.TODO()) { page := p.CurrentPage() } if err := p.Err(); err != nil { return err }
func (*ListDatastoresPaginator) CurrentPage ¶ added in v0.9.0
func (p *ListDatastoresPaginator) CurrentPage() *ListDatastoresOutput
type ListDatastoresRequest ¶
type ListDatastoresRequest struct { *aws.Request Input *ListDatastoresInput Copy func(*ListDatastoresInput) ListDatastoresRequest }
ListDatastoresRequest is the request type for the ListDatastores API operation.
func (ListDatastoresRequest) Send ¶
func (r ListDatastoresRequest) Send(ctx context.Context) (*ListDatastoresResponse, error)
Send marshals and sends the ListDatastores API request.
type ListDatastoresResponse ¶ added in v0.9.0
type ListDatastoresResponse struct { *ListDatastoresOutput // contains filtered or unexported fields }
ListDatastoresResponse is the response type for the ListDatastores API operation.
func (*ListDatastoresResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *ListDatastoresResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the ListDatastores request.
type ListPipelinesInput ¶
type ListPipelinesInput struct { // The maximum number of results to return in this request. // // The default value is 100. MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"` // The token for the next set of results. NextToken *string `location:"querystring" locationName:"nextToken" type:"string"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListPipelinesRequest
func (ListPipelinesInput) MarshalFields ¶
func (s ListPipelinesInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ListPipelinesInput) String ¶
func (s ListPipelinesInput) String() string
String returns the string representation
func (*ListPipelinesInput) Validate ¶
func (s *ListPipelinesInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListPipelinesOutput ¶
type ListPipelinesOutput struct { // The token to retrieve the next set of results, or null if there are no more // results. NextToken *string `locationName:"nextToken" type:"string"` // A list of "PipelineSummary" objects. PipelineSummaries []PipelineSummary `locationName:"pipelineSummaries" type:"list"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListPipelinesResponse
func (ListPipelinesOutput) MarshalFields ¶
func (s ListPipelinesOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ListPipelinesOutput) String ¶
func (s ListPipelinesOutput) String() string
String returns the string representation
type ListPipelinesPaginator ¶ added in v0.9.0
ListPipelinesPaginator is used to paginate the request. This can be done by calling Next and CurrentPage.
func NewListPipelinesPaginator ¶ added in v0.9.0
func NewListPipelinesPaginator(req ListPipelinesRequest) ListPipelinesPaginator
NewListPipelinesRequestPaginator returns a paginator for ListPipelines. Use Next method to get the next page, and CurrentPage to get the current response page from the paginator. Next will return false, if there are no more pages, or an error was encountered.
Note: This operation can generate multiple requests to a service.
// Example iterating over pages. req := client.ListPipelinesRequest(input) p := iotanalytics.NewListPipelinesRequestPaginator(req) for p.Next(context.TODO()) { page := p.CurrentPage() } if err := p.Err(); err != nil { return err }
func (*ListPipelinesPaginator) CurrentPage ¶ added in v0.9.0
func (p *ListPipelinesPaginator) CurrentPage() *ListPipelinesOutput
type ListPipelinesRequest ¶
type ListPipelinesRequest struct { *aws.Request Input *ListPipelinesInput Copy func(*ListPipelinesInput) ListPipelinesRequest }
ListPipelinesRequest is the request type for the ListPipelines API operation.
func (ListPipelinesRequest) Send ¶
func (r ListPipelinesRequest) Send(ctx context.Context) (*ListPipelinesResponse, error)
Send marshals and sends the ListPipelines API request.
type ListPipelinesResponse ¶ added in v0.9.0
type ListPipelinesResponse struct { *ListPipelinesOutput // contains filtered or unexported fields }
ListPipelinesResponse is the response type for the ListPipelines API operation.
func (*ListPipelinesResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *ListPipelinesResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the ListPipelines request.
type ListTagsForResourceInput ¶ added in v0.5.0
type ListTagsForResourceInput struct { // The ARN of the resource whose tags you want to list. // // ResourceArn is a required field ResourceArn *string `location:"querystring" locationName:"resourceArn" min:"20" type:"string" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListTagsForResourceRequest
func (ListTagsForResourceInput) MarshalFields ¶ added in v0.5.0
func (s ListTagsForResourceInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ListTagsForResourceInput) String ¶ added in v0.5.0
func (s ListTagsForResourceInput) String() string
String returns the string representation
func (*ListTagsForResourceInput) Validate ¶ added in v0.5.0
func (s *ListTagsForResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ListTagsForResourceOutput ¶ added in v0.5.0
type ListTagsForResourceOutput struct { // The tags (metadata) which you have assigned to the resource. Tags []Tag `locationName:"tags" min:"1" type:"list"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListTagsForResourceResponse
func (ListTagsForResourceOutput) MarshalFields ¶ added in v0.5.0
func (s ListTagsForResourceOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ListTagsForResourceOutput) String ¶ added in v0.5.0
func (s ListTagsForResourceOutput) String() string
String returns the string representation
type ListTagsForResourceRequest ¶ added in v0.5.0
type ListTagsForResourceRequest struct { *aws.Request Input *ListTagsForResourceInput Copy func(*ListTagsForResourceInput) ListTagsForResourceRequest }
ListTagsForResourceRequest is the request type for the ListTagsForResource API operation.
func (ListTagsForResourceRequest) Send ¶ added in v0.5.0
func (r ListTagsForResourceRequest) Send(ctx context.Context) (*ListTagsForResourceResponse, error)
Send marshals and sends the ListTagsForResource API request.
type ListTagsForResourceResponse ¶ added in v0.9.0
type ListTagsForResourceResponse struct { *ListTagsForResourceOutput // contains filtered or unexported fields }
ListTagsForResourceResponse is the response type for the ListTagsForResource API operation.
func (*ListTagsForResourceResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *ListTagsForResourceResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the ListTagsForResource request.
type LoggingLevel ¶
type LoggingLevel string
const (
LoggingLevelError LoggingLevel = "ERROR"
)
Enum values for LoggingLevel
func (LoggingLevel) MarshalValue ¶
func (enum LoggingLevel) MarshalValue() (string, error)
func (LoggingLevel) MarshalValueBuf ¶
func (enum LoggingLevel) MarshalValueBuf(b []byte) ([]byte, error)
type LoggingOptions ¶
type LoggingOptions struct { // If true, logging is enabled for AWS IoT Analytics. // // Enabled is a required field Enabled *bool `locationName:"enabled" type:"boolean" required:"true"` // The logging level. Currently, only "ERROR" is supported. // // Level is a required field Level LoggingLevel `locationName:"level" type:"string" required:"true" enum:"true"` // The ARN of the role that grants permission to AWS IoT Analytics to perform // logging. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" min:"20" type:"string" required:"true"` // contains filtered or unexported fields }
Information about logging options. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/LoggingOptions
func (LoggingOptions) MarshalFields ¶
func (s LoggingOptions) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (LoggingOptions) String ¶
func (s LoggingOptions) String() string
String returns the string representation
func (*LoggingOptions) Validate ¶
func (s *LoggingOptions) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type MathActivity ¶
type MathActivity struct { // The name of the attribute that contains the result of the math operation. // // Attribute is a required field Attribute *string `locationName:"attribute" min:"1" type:"string" required:"true"` // An expression that uses one or more existing attributes and must return an // integer value. // // Math is a required field Math *string `locationName:"math" min:"1" type:"string" required:"true"` // The name of the 'math' activity. // // Name is a required field Name *string `locationName:"name" min:"1" type:"string" required:"true"` // The next activity in the pipeline. Next *string `locationName:"next" min:"1" type:"string"` // contains filtered or unexported fields }
An activity that computes an arithmetic expression using the message's attributes. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/MathActivity
func (MathActivity) MarshalFields ¶
func (s MathActivity) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (MathActivity) String ¶
func (s MathActivity) String() string
String returns the string representation
func (*MathActivity) Validate ¶
func (s *MathActivity) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type Message ¶
type Message struct { // The ID you wish to assign to the message. Each "messageId" must be unique // within each batch sent. // // MessageId is a required field MessageId *string `locationName:"messageId" min:"1" type:"string" required:"true"` // The payload of the message. This may be a JSON string or a Base64-encoded // string representing binary data (in which case you must decode it by means // of a pipeline activity). // // Payload is automatically base64 encoded/decoded by the SDK. // // Payload is a required field Payload []byte `locationName:"payload" type:"blob" required:"true"` // contains filtered or unexported fields }
Information about a message. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/Message
func (Message) MarshalFields ¶
func (s Message) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
type OutputFileUriValue ¶ added in v0.5.0
type OutputFileUriValue struct { // The URI of the location where data set contents are stored, usually the URI // of a file in an S3 bucket. // // FileName is a required field FileName *string `locationName:"fileName" type:"string" required:"true"` // contains filtered or unexported fields }
The value of the variable as a structure that specifies an output file URI. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/OutputFileUriValue
func (OutputFileUriValue) MarshalFields ¶ added in v0.5.0
func (s OutputFileUriValue) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (OutputFileUriValue) String ¶ added in v0.5.0
func (s OutputFileUriValue) String() string
String returns the string representation
func (*OutputFileUriValue) Validate ¶ added in v0.5.0
func (s *OutputFileUriValue) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type Pipeline ¶
type Pipeline struct { // The activities that perform transformations on the messages. Activities []PipelineActivity `locationName:"activities" min:"1" type:"list"` // The ARN of the pipeline. Arn *string `locationName:"arn" type:"string"` // When the pipeline was created. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"` // The last time the pipeline was updated. LastUpdateTime *time.Time `locationName:"lastUpdateTime" type:"timestamp" timestampFormat:"unix"` // The name of the pipeline. Name *string `locationName:"name" min:"1" type:"string"` // A summary of information about the pipeline reprocessing. ReprocessingSummaries []ReprocessingSummary `locationName:"reprocessingSummaries" type:"list"` // contains filtered or unexported fields }
Contains information about a pipeline. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/Pipeline
func (Pipeline) MarshalFields ¶
func (s Pipeline) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
type PipelineActivity ¶
type PipelineActivity struct { // Adds other attributes based on existing attributes in the message. AddAttributes *AddAttributesActivity `locationName:"addAttributes" type:"structure"` // Determines the source of the messages to be processed. Channel *ChannelActivity `locationName:"channel" type:"structure"` // Specifies where to store the processed message data. Datastore *DatastoreActivity `locationName:"datastore" type:"structure"` // Adds data from the AWS IoT device registry to your message. DeviceRegistryEnrich *DeviceRegistryEnrichActivity `locationName:"deviceRegistryEnrich" type:"structure"` // Adds information from the AWS IoT Device Shadows service to a message. DeviceShadowEnrich *DeviceShadowEnrichActivity `locationName:"deviceShadowEnrich" type:"structure"` // Filters a message based on its attributes. Filter *FilterActivity `locationName:"filter" type:"structure"` // Runs a Lambda function to modify the message. Lambda *LambdaActivity `locationName:"lambda" type:"structure"` // Computes an arithmetic expression using the message's attributes and adds // it to the message. Math *MathActivity `locationName:"math" type:"structure"` // Removes attributes from a message. RemoveAttributes *RemoveAttributesActivity `locationName:"removeAttributes" type:"structure"` // Creates a new message using only the specified attributes from the original // message. SelectAttributes *SelectAttributesActivity `locationName:"selectAttributes" type:"structure"` // contains filtered or unexported fields }
An activity that performs a transformation on a message. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/PipelineActivity
func (PipelineActivity) MarshalFields ¶
func (s PipelineActivity) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (PipelineActivity) String ¶
func (s PipelineActivity) String() string
String returns the string representation
func (*PipelineActivity) Validate ¶
func (s *PipelineActivity) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type PipelineSummary ¶
type PipelineSummary struct { // When the pipeline was created. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"` // When the pipeline was last updated. LastUpdateTime *time.Time `locationName:"lastUpdateTime" type:"timestamp" timestampFormat:"unix"` // The name of the pipeline. PipelineName *string `locationName:"pipelineName" min:"1" type:"string"` // A summary of information about the pipeline reprocessing. ReprocessingSummaries []ReprocessingSummary `locationName:"reprocessingSummaries" type:"list"` // contains filtered or unexported fields }
A summary of information about a pipeline. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/PipelineSummary
func (PipelineSummary) MarshalFields ¶
func (s PipelineSummary) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (PipelineSummary) String ¶
func (s PipelineSummary) String() string
String returns the string representation
type PutLoggingOptionsInput ¶
type PutLoggingOptionsInput struct { // The new values of the AWS IoT Analytics logging options. // // LoggingOptions is a required field LoggingOptions *LoggingOptions `locationName:"loggingOptions" type:"structure" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/PutLoggingOptionsRequest
func (PutLoggingOptionsInput) MarshalFields ¶
func (s PutLoggingOptionsInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (PutLoggingOptionsInput) String ¶
func (s PutLoggingOptionsInput) String() string
String returns the string representation
func (*PutLoggingOptionsInput) Validate ¶
func (s *PutLoggingOptionsInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type PutLoggingOptionsOutput ¶
type PutLoggingOptionsOutput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/PutLoggingOptionsOutput
func (PutLoggingOptionsOutput) MarshalFields ¶
func (s PutLoggingOptionsOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (PutLoggingOptionsOutput) String ¶
func (s PutLoggingOptionsOutput) String() string
String returns the string representation
type PutLoggingOptionsRequest ¶
type PutLoggingOptionsRequest struct { *aws.Request Input *PutLoggingOptionsInput Copy func(*PutLoggingOptionsInput) PutLoggingOptionsRequest }
PutLoggingOptionsRequest is the request type for the PutLoggingOptions API operation.
func (PutLoggingOptionsRequest) Send ¶
func (r PutLoggingOptionsRequest) Send(ctx context.Context) (*PutLoggingOptionsResponse, error)
Send marshals and sends the PutLoggingOptions API request.
type PutLoggingOptionsResponse ¶ added in v0.9.0
type PutLoggingOptionsResponse struct { *PutLoggingOptionsOutput // contains filtered or unexported fields }
PutLoggingOptionsResponse is the response type for the PutLoggingOptions API operation.
func (*PutLoggingOptionsResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *PutLoggingOptionsResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the PutLoggingOptions request.
type QueryFilter ¶ added in v0.5.0
type QueryFilter struct { // Used to limit data to that which has arrived since the last execution of // the action. DeltaTime *DeltaTime `locationName:"deltaTime" type:"structure"` // contains filtered or unexported fields }
Information which is used to filter message data, to segregate it according to the time frame in which it arrives. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/QueryFilter
func (QueryFilter) MarshalFields ¶ added in v0.5.0
func (s QueryFilter) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (QueryFilter) String ¶ added in v0.5.0
func (s QueryFilter) String() string
String returns the string representation
func (*QueryFilter) Validate ¶ added in v0.5.0
func (s *QueryFilter) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type RemoveAttributesActivity ¶
type RemoveAttributesActivity struct { // A list of 1-50 attributes to remove from the message. // // Attributes is a required field Attributes []string `locationName:"attributes" min:"1" type:"list" required:"true"` // The name of the 'removeAttributes' activity. // // Name is a required field Name *string `locationName:"name" min:"1" type:"string" required:"true"` // The next activity in the pipeline. Next *string `locationName:"next" min:"1" type:"string"` // contains filtered or unexported fields }
An activity that removes attributes from a message. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/RemoveAttributesActivity
func (RemoveAttributesActivity) MarshalFields ¶
func (s RemoveAttributesActivity) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (RemoveAttributesActivity) String ¶
func (s RemoveAttributesActivity) String() string
String returns the string representation
func (*RemoveAttributesActivity) Validate ¶
func (s *RemoveAttributesActivity) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type ReprocessingStatus ¶
type ReprocessingStatus string
const ( ReprocessingStatusRunning ReprocessingStatus = "RUNNING" ReprocessingStatusSucceeded ReprocessingStatus = "SUCCEEDED" ReprocessingStatusCancelled ReprocessingStatus = "CANCELLED" ReprocessingStatusFailed ReprocessingStatus = "FAILED" )
Enum values for ReprocessingStatus
func (ReprocessingStatus) MarshalValue ¶
func (enum ReprocessingStatus) MarshalValue() (string, error)
func (ReprocessingStatus) MarshalValueBuf ¶
func (enum ReprocessingStatus) MarshalValueBuf(b []byte) ([]byte, error)
type ReprocessingSummary ¶
type ReprocessingSummary struct { // The time the pipeline reprocessing was created. CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"` // The 'reprocessingId' returned by "StartPipelineReprocessing". Id *string `locationName:"id" type:"string"` // The status of the pipeline reprocessing. Status ReprocessingStatus `locationName:"status" type:"string" enum:"true"` // contains filtered or unexported fields }
Information about pipeline reprocessing. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ReprocessingSummary
func (ReprocessingSummary) MarshalFields ¶
func (s ReprocessingSummary) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ReprocessingSummary) String ¶
func (s ReprocessingSummary) String() string
String returns the string representation
type ResourceConfiguration ¶ added in v0.5.0
type ResourceConfiguration struct { // The type of the compute resource used to execute the "containerAction". Possible // values are: ACU_1 (vCPU=4, memory=16GiB) or ACU_2 (vCPU=8, memory=32GiB). // // ComputeType is a required field ComputeType ComputeType `locationName:"computeType" type:"string" required:"true" enum:"true"` // The size (in GB) of the persistent storage available to the resource instance // used to execute the "containerAction" (min: 1, max: 50). // // VolumeSizeInGB is a required field VolumeSizeInGB *int64 `locationName:"volumeSizeInGB" min:"1" type:"integer" required:"true"` // contains filtered or unexported fields }
The configuration of the resource used to execute the "containerAction". Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ResourceConfiguration
func (ResourceConfiguration) MarshalFields ¶ added in v0.5.0
func (s ResourceConfiguration) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (ResourceConfiguration) String ¶ added in v0.5.0
func (s ResourceConfiguration) String() string
String returns the string representation
func (*ResourceConfiguration) Validate ¶ added in v0.5.0
func (s *ResourceConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type RetentionPeriod ¶
type RetentionPeriod struct { // The number of days that message data is kept. The "unlimited" parameter must // be false. NumberOfDays *int64 `locationName:"numberOfDays" min:"1" type:"integer"` // If true, message data is kept indefinitely. Unlimited *bool `locationName:"unlimited" type:"boolean"` // contains filtered or unexported fields }
How long, in days, message data is kept. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/RetentionPeriod
func (RetentionPeriod) MarshalFields ¶
func (s RetentionPeriod) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (RetentionPeriod) String ¶
func (s RetentionPeriod) String() string
String returns the string representation
func (*RetentionPeriod) Validate ¶
func (s *RetentionPeriod) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type RunPipelineActivityInput ¶
type RunPipelineActivityInput struct { // The sample message payloads on which the pipeline activity is run. // // Payloads is a required field Payloads [][]byte `locationName:"payloads" min:"1" type:"list" required:"true"` // The pipeline activity that is run. This must not be a 'channel' activity // or a 'datastore' activity because these activities are used in a pipeline // only to load the original message and to store the (possibly) transformed // message. If a 'lambda' activity is specified, only short-running Lambda functions // (those with a timeout of less than 30 seconds or less) can be used. // // PipelineActivity is a required field PipelineActivity *PipelineActivity `locationName:"pipelineActivity" type:"structure" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/RunPipelineActivityRequest
func (RunPipelineActivityInput) MarshalFields ¶
func (s RunPipelineActivityInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (RunPipelineActivityInput) String ¶
func (s RunPipelineActivityInput) String() string
String returns the string representation
func (*RunPipelineActivityInput) Validate ¶
func (s *RunPipelineActivityInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type RunPipelineActivityOutput ¶
type RunPipelineActivityOutput struct { // In case the pipeline activity fails, the log message that is generated. LogResult *string `locationName:"logResult" type:"string"` // The enriched or transformed sample message payloads as base64-encoded strings. // (The results of running the pipeline activity on each input sample message // payload, encoded in base64.) Payloads [][]byte `locationName:"payloads" min:"1" type:"list"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/RunPipelineActivityResponse
func (RunPipelineActivityOutput) MarshalFields ¶
func (s RunPipelineActivityOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (RunPipelineActivityOutput) String ¶
func (s RunPipelineActivityOutput) String() string
String returns the string representation
type RunPipelineActivityRequest ¶
type RunPipelineActivityRequest struct { *aws.Request Input *RunPipelineActivityInput Copy func(*RunPipelineActivityInput) RunPipelineActivityRequest }
RunPipelineActivityRequest is the request type for the RunPipelineActivity API operation.
func (RunPipelineActivityRequest) Send ¶
func (r RunPipelineActivityRequest) Send(ctx context.Context) (*RunPipelineActivityResponse, error)
Send marshals and sends the RunPipelineActivity API request.
type RunPipelineActivityResponse ¶ added in v0.9.0
type RunPipelineActivityResponse struct { *RunPipelineActivityOutput // contains filtered or unexported fields }
RunPipelineActivityResponse is the response type for the RunPipelineActivity API operation.
func (*RunPipelineActivityResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *RunPipelineActivityResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the RunPipelineActivity request.
type S3DestinationConfiguration ¶ added in v0.9.0
type S3DestinationConfiguration struct { // The name of the Amazon S3 bucket to which data set contents are delivered. // // Bucket is a required field Bucket *string `locationName:"bucket" min:"3" type:"string" required:"true"` // Configuration information for coordination with the AWS Glue ETL (extract, // transform and load) service. GlueConfiguration *GlueConfiguration `locationName:"glueConfiguration" type:"structure"` // The key of the data set contents object. Each object in an Amazon S3 bucket // has a key that is its unique identifier within the bucket (each object in // a bucket has exactly one key). // // Key is a required field Key *string `locationName:"key" min:"1" type:"string" required:"true"` // The ARN of the role which grants AWS IoT Analytics permission to interact // with your Amazon S3 and AWS Glue resources. // // RoleArn is a required field RoleArn *string `locationName:"roleArn" min:"20" type:"string" required:"true"` // contains filtered or unexported fields }
Configuration information for delivery of data set contents to Amazon S3. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/S3DestinationConfiguration
func (S3DestinationConfiguration) MarshalFields ¶ added in v0.9.0
func (s S3DestinationConfiguration) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (S3DestinationConfiguration) String ¶ added in v0.9.0
func (s S3DestinationConfiguration) String() string
String returns the string representation
func (*S3DestinationConfiguration) Validate ¶ added in v0.9.0
func (s *S3DestinationConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type SampleChannelDataInput ¶
type SampleChannelDataInput struct { // The name of the channel whose message samples are retrieved. // // ChannelName is a required field ChannelName *string `location:"uri" locationName:"channelName" min:"1" type:"string" required:"true"` // The end of the time window from which sample messages are retrieved. EndTime *time.Time `location:"querystring" locationName:"endTime" type:"timestamp" timestampFormat:"unix"` // The number of sample messages to be retrieved. The limit is 10, the default // is also 10. MaxMessages *int64 `location:"querystring" locationName:"maxMessages" min:"1" type:"integer"` // The start of the time window from which sample messages are retrieved. StartTime *time.Time `location:"querystring" locationName:"startTime" type:"timestamp" timestampFormat:"unix"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/SampleChannelDataRequest
func (SampleChannelDataInput) MarshalFields ¶
func (s SampleChannelDataInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (SampleChannelDataInput) String ¶
func (s SampleChannelDataInput) String() string
String returns the string representation
func (*SampleChannelDataInput) Validate ¶
func (s *SampleChannelDataInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type SampleChannelDataOutput ¶
type SampleChannelDataOutput struct { // The list of message samples. Each sample message is returned as a base64-encoded // string. Payloads [][]byte `locationName:"payloads" min:"1" type:"list"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/SampleChannelDataResponse
func (SampleChannelDataOutput) MarshalFields ¶
func (s SampleChannelDataOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (SampleChannelDataOutput) String ¶
func (s SampleChannelDataOutput) String() string
String returns the string representation
type SampleChannelDataRequest ¶
type SampleChannelDataRequest struct { *aws.Request Input *SampleChannelDataInput Copy func(*SampleChannelDataInput) SampleChannelDataRequest }
SampleChannelDataRequest is the request type for the SampleChannelData API operation.
func (SampleChannelDataRequest) Send ¶
func (r SampleChannelDataRequest) Send(ctx context.Context) (*SampleChannelDataResponse, error)
Send marshals and sends the SampleChannelData API request.
type SampleChannelDataResponse ¶ added in v0.9.0
type SampleChannelDataResponse struct { *SampleChannelDataOutput // contains filtered or unexported fields }
SampleChannelDataResponse is the response type for the SampleChannelData API operation.
func (*SampleChannelDataResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *SampleChannelDataResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the SampleChannelData request.
type Schedule ¶
type Schedule struct { // The expression that defines when to trigger an update. For more information, // see Schedule Expressions for Rules (https://docs.aws.amazon.com/AmazonCloudWatch/latest/events/ScheduledEvents.html) // in the Amazon CloudWatch Events User Guide. Expression *string `locationName:"expression" type:"string"` // contains filtered or unexported fields }
The schedule for when to trigger an update. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/Schedule
func (Schedule) MarshalFields ¶
func (s Schedule) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
type SelectAttributesActivity ¶
type SelectAttributesActivity struct { // A list of the attributes to select from the message. // // Attributes is a required field Attributes []string `locationName:"attributes" min:"1" type:"list" required:"true"` // The name of the 'selectAttributes' activity. // // Name is a required field Name *string `locationName:"name" min:"1" type:"string" required:"true"` // The next activity in the pipeline. Next *string `locationName:"next" min:"1" type:"string"` // contains filtered or unexported fields }
Creates a new message using only the specified attributes from the original message. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/SelectAttributesActivity
func (SelectAttributesActivity) MarshalFields ¶
func (s SelectAttributesActivity) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (SelectAttributesActivity) String ¶
func (s SelectAttributesActivity) String() string
String returns the string representation
func (*SelectAttributesActivity) Validate ¶
func (s *SelectAttributesActivity) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type SqlQueryDatasetAction ¶
type SqlQueryDatasetAction struct { // Pre-filters applied to message data. Filters []QueryFilter `locationName:"filters" type:"list"` // A SQL query string. // // SqlQuery is a required field SqlQuery *string `locationName:"sqlQuery" type:"string" required:"true"` // contains filtered or unexported fields }
The SQL query to modify the message. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/SqlQueryDatasetAction
func (SqlQueryDatasetAction) MarshalFields ¶
func (s SqlQueryDatasetAction) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (SqlQueryDatasetAction) String ¶
func (s SqlQueryDatasetAction) String() string
String returns the string representation
func (*SqlQueryDatasetAction) Validate ¶
func (s *SqlQueryDatasetAction) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type StartPipelineReprocessingInput ¶
type StartPipelineReprocessingInput struct { // The end time (exclusive) of raw message data that is reprocessed. EndTime *time.Time `locationName:"endTime" type:"timestamp" timestampFormat:"unix"` // The name of the pipeline on which to start reprocessing. // // PipelineName is a required field PipelineName *string `location:"uri" locationName:"pipelineName" min:"1" type:"string" required:"true"` // The start time (inclusive) of raw message data that is reprocessed. StartTime *time.Time `locationName:"startTime" type:"timestamp" timestampFormat:"unix"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/StartPipelineReprocessingRequest
func (StartPipelineReprocessingInput) MarshalFields ¶
func (s StartPipelineReprocessingInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (StartPipelineReprocessingInput) String ¶
func (s StartPipelineReprocessingInput) String() string
String returns the string representation
func (*StartPipelineReprocessingInput) Validate ¶
func (s *StartPipelineReprocessingInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type StartPipelineReprocessingOutput ¶
type StartPipelineReprocessingOutput struct { // The ID of the pipeline reprocessing activity that was started. ReprocessingId *string `locationName:"reprocessingId" type:"string"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/StartPipelineReprocessingResponse
func (StartPipelineReprocessingOutput) MarshalFields ¶
func (s StartPipelineReprocessingOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (StartPipelineReprocessingOutput) String ¶
func (s StartPipelineReprocessingOutput) String() string
String returns the string representation
type StartPipelineReprocessingRequest ¶
type StartPipelineReprocessingRequest struct { *aws.Request Input *StartPipelineReprocessingInput Copy func(*StartPipelineReprocessingInput) StartPipelineReprocessingRequest }
StartPipelineReprocessingRequest is the request type for the StartPipelineReprocessing API operation.
func (StartPipelineReprocessingRequest) Send ¶
func (r StartPipelineReprocessingRequest) Send(ctx context.Context) (*StartPipelineReprocessingResponse, error)
Send marshals and sends the StartPipelineReprocessing API request.
type StartPipelineReprocessingResponse ¶ added in v0.9.0
type StartPipelineReprocessingResponse struct { *StartPipelineReprocessingOutput // contains filtered or unexported fields }
StartPipelineReprocessingResponse is the response type for the StartPipelineReprocessing API operation.
func (*StartPipelineReprocessingResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *StartPipelineReprocessingResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the StartPipelineReprocessing request.
type Tag ¶ added in v0.5.0
type Tag struct { // The tag's key. // // Key is a required field Key *string `locationName:"key" min:"1" type:"string" required:"true"` // The tag's value. // // Value is a required field Value *string `locationName:"value" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
A set of key/value pairs which are used to manage the resource. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/Tag
func (Tag) MarshalFields ¶ added in v0.5.0
func (s Tag) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
type TagResourceInput ¶ added in v0.5.0
type TagResourceInput struct { // The ARN of the resource whose tags you want to modify. // // ResourceArn is a required field ResourceArn *string `location:"querystring" locationName:"resourceArn" min:"20" type:"string" required:"true"` // The new or modified tags for the resource. // // Tags is a required field Tags []Tag `locationName:"tags" min:"1" type:"list" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/TagResourceRequest
func (TagResourceInput) MarshalFields ¶ added in v0.5.0
func (s TagResourceInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (TagResourceInput) String ¶ added in v0.5.0
func (s TagResourceInput) String() string
String returns the string representation
func (*TagResourceInput) Validate ¶ added in v0.5.0
func (s *TagResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type TagResourceOutput ¶ added in v0.5.0
type TagResourceOutput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/TagResourceResponse
func (TagResourceOutput) MarshalFields ¶ added in v0.5.0
func (s TagResourceOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (TagResourceOutput) String ¶ added in v0.5.0
func (s TagResourceOutput) String() string
String returns the string representation
type TagResourceRequest ¶ added in v0.5.0
type TagResourceRequest struct { *aws.Request Input *TagResourceInput Copy func(*TagResourceInput) TagResourceRequest }
TagResourceRequest is the request type for the TagResource API operation.
func (TagResourceRequest) Send ¶ added in v0.5.0
func (r TagResourceRequest) Send(ctx context.Context) (*TagResourceResponse, error)
Send marshals and sends the TagResource API request.
type TagResourceResponse ¶ added in v0.9.0
type TagResourceResponse struct { *TagResourceOutput // contains filtered or unexported fields }
TagResourceResponse is the response type for the TagResource API operation.
func (*TagResourceResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *TagResourceResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the TagResource request.
type TriggeringDataset ¶ added in v0.5.0
type TriggeringDataset struct { // The name of the data set whose content generation triggers the new data set // content generation. // // Name is a required field Name *string `locationName:"name" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
Information about the data set whose content generation triggers the new data set content generation. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/TriggeringDataset
func (TriggeringDataset) MarshalFields ¶ added in v0.5.0
func (s TriggeringDataset) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (TriggeringDataset) String ¶ added in v0.5.0
func (s TriggeringDataset) String() string
String returns the string representation
func (*TriggeringDataset) Validate ¶ added in v0.5.0
func (s *TriggeringDataset) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UntagResourceInput ¶ added in v0.5.0
type UntagResourceInput struct { // The ARN of the resource whose tags you want to remove. // // ResourceArn is a required field ResourceArn *string `location:"querystring" locationName:"resourceArn" min:"20" type:"string" required:"true"` // The keys of those tags which you want to remove. // // TagKeys is a required field TagKeys []string `location:"querystring" locationName:"tagKeys" min:"1" type:"list" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UntagResourceRequest
func (UntagResourceInput) MarshalFields ¶ added in v0.5.0
func (s UntagResourceInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (UntagResourceInput) String ¶ added in v0.5.0
func (s UntagResourceInput) String() string
String returns the string representation
func (*UntagResourceInput) Validate ¶ added in v0.5.0
func (s *UntagResourceInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UntagResourceOutput ¶ added in v0.5.0
type UntagResourceOutput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UntagResourceResponse
func (UntagResourceOutput) MarshalFields ¶ added in v0.5.0
func (s UntagResourceOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (UntagResourceOutput) String ¶ added in v0.5.0
func (s UntagResourceOutput) String() string
String returns the string representation
type UntagResourceRequest ¶ added in v0.5.0
type UntagResourceRequest struct { *aws.Request Input *UntagResourceInput Copy func(*UntagResourceInput) UntagResourceRequest }
UntagResourceRequest is the request type for the UntagResource API operation.
func (UntagResourceRequest) Send ¶ added in v0.5.0
func (r UntagResourceRequest) Send(ctx context.Context) (*UntagResourceResponse, error)
Send marshals and sends the UntagResource API request.
type UntagResourceResponse ¶ added in v0.9.0
type UntagResourceResponse struct { *UntagResourceOutput // contains filtered or unexported fields }
UntagResourceResponse is the response type for the UntagResource API operation.
func (*UntagResourceResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *UntagResourceResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the UntagResource request.
type UpdateChannelInput ¶
type UpdateChannelInput struct { // The name of the channel to be updated. // // ChannelName is a required field ChannelName *string `location:"uri" locationName:"channelName" min:"1" type:"string" required:"true"` // How long, in days, message data is kept for the channel. RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdateChannelRequest
func (UpdateChannelInput) MarshalFields ¶
func (s UpdateChannelInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (UpdateChannelInput) String ¶
func (s UpdateChannelInput) String() string
String returns the string representation
func (*UpdateChannelInput) Validate ¶
func (s *UpdateChannelInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UpdateChannelOutput ¶
type UpdateChannelOutput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdateChannelOutput
func (UpdateChannelOutput) MarshalFields ¶
func (s UpdateChannelOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (UpdateChannelOutput) String ¶
func (s UpdateChannelOutput) String() string
String returns the string representation
type UpdateChannelRequest ¶
type UpdateChannelRequest struct { *aws.Request Input *UpdateChannelInput Copy func(*UpdateChannelInput) UpdateChannelRequest }
UpdateChannelRequest is the request type for the UpdateChannel API operation.
func (UpdateChannelRequest) Send ¶
func (r UpdateChannelRequest) Send(ctx context.Context) (*UpdateChannelResponse, error)
Send marshals and sends the UpdateChannel API request.
type UpdateChannelResponse ¶ added in v0.9.0
type UpdateChannelResponse struct { *UpdateChannelOutput // contains filtered or unexported fields }
UpdateChannelResponse is the response type for the UpdateChannel API operation.
func (*UpdateChannelResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *UpdateChannelResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the UpdateChannel request.
type UpdateDatasetInput ¶
type UpdateDatasetInput struct { // A list of "DatasetAction" objects. // // Actions is a required field Actions []DatasetAction `locationName:"actions" min:"1" type:"list" required:"true"` // When data set contents are created they are delivered to destinations specified // here. ContentDeliveryRules []DatasetContentDeliveryRule `locationName:"contentDeliveryRules" type:"list"` // The name of the data set to update. // // DatasetName is a required field DatasetName *string `location:"uri" locationName:"datasetName" min:"1" type:"string" required:"true"` // How long, in days, data set contents are kept for the data set. RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"` // A list of "DatasetTrigger" objects. The list can be empty or can contain // up to five DataSetTrigger objects. Triggers []DatasetTrigger `locationName:"triggers" type:"list"` // [Optional] How many versions of data set contents are kept. If not specified // or set to null, only the latest version plus the latest succeeded version // (if they are different) are kept for the time period specified by the "retentionPeriod" // parameter. (For more information, see https://docs.aws.amazon.com/iotanalytics/latest/userguide/getting-started.html#aws-iot-analytics-dataset-versions) VersioningConfiguration *VersioningConfiguration `locationName:"versioningConfiguration" type:"structure"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdateDatasetRequest
func (UpdateDatasetInput) MarshalFields ¶
func (s UpdateDatasetInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (UpdateDatasetInput) String ¶
func (s UpdateDatasetInput) String() string
String returns the string representation
func (*UpdateDatasetInput) Validate ¶
func (s *UpdateDatasetInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UpdateDatasetOutput ¶
type UpdateDatasetOutput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdateDatasetOutput
func (UpdateDatasetOutput) MarshalFields ¶
func (s UpdateDatasetOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (UpdateDatasetOutput) String ¶
func (s UpdateDatasetOutput) String() string
String returns the string representation
type UpdateDatasetRequest ¶
type UpdateDatasetRequest struct { *aws.Request Input *UpdateDatasetInput Copy func(*UpdateDatasetInput) UpdateDatasetRequest }
UpdateDatasetRequest is the request type for the UpdateDataset API operation.
func (UpdateDatasetRequest) Send ¶
func (r UpdateDatasetRequest) Send(ctx context.Context) (*UpdateDatasetResponse, error)
Send marshals and sends the UpdateDataset API request.
type UpdateDatasetResponse ¶ added in v0.9.0
type UpdateDatasetResponse struct { *UpdateDatasetOutput // contains filtered or unexported fields }
UpdateDatasetResponse is the response type for the UpdateDataset API operation.
func (*UpdateDatasetResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *UpdateDatasetResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the UpdateDataset request.
type UpdateDatastoreInput ¶
type UpdateDatastoreInput struct { // The name of the data store to be updated. // // DatastoreName is a required field DatastoreName *string `location:"uri" locationName:"datastoreName" min:"1" type:"string" required:"true"` // How long, in days, message data is kept for the data store. RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdateDatastoreRequest
func (UpdateDatastoreInput) MarshalFields ¶
func (s UpdateDatastoreInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (UpdateDatastoreInput) String ¶
func (s UpdateDatastoreInput) String() string
String returns the string representation
func (*UpdateDatastoreInput) Validate ¶
func (s *UpdateDatastoreInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UpdateDatastoreOutput ¶
type UpdateDatastoreOutput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdateDatastoreOutput
func (UpdateDatastoreOutput) MarshalFields ¶
func (s UpdateDatastoreOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (UpdateDatastoreOutput) String ¶
func (s UpdateDatastoreOutput) String() string
String returns the string representation
type UpdateDatastoreRequest ¶
type UpdateDatastoreRequest struct { *aws.Request Input *UpdateDatastoreInput Copy func(*UpdateDatastoreInput) UpdateDatastoreRequest }
UpdateDatastoreRequest is the request type for the UpdateDatastore API operation.
func (UpdateDatastoreRequest) Send ¶
func (r UpdateDatastoreRequest) Send(ctx context.Context) (*UpdateDatastoreResponse, error)
Send marshals and sends the UpdateDatastore API request.
type UpdateDatastoreResponse ¶ added in v0.9.0
type UpdateDatastoreResponse struct { *UpdateDatastoreOutput // contains filtered or unexported fields }
UpdateDatastoreResponse is the response type for the UpdateDatastore API operation.
func (*UpdateDatastoreResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *UpdateDatastoreResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the UpdateDatastore request.
type UpdatePipelineInput ¶
type UpdatePipelineInput struct { // A list of "PipelineActivity" objects. Activities perform transformations // on your messages, such as removing, renaming or adding message attributes; // filtering messages based on attribute values; invoking your Lambda functions // on messages for advanced processing; or performing mathematical transformations // to normalize device data. // // The list can be 2-25 PipelineActivity objects and must contain both a channel // and a datastore activity. Each entry in the list must contain only one activity, // for example: // // pipelineActivities = [ { "channel": { ... } }, { "lambda": { ... } }, ... // ] // // PipelineActivities is a required field PipelineActivities []PipelineActivity `locationName:"pipelineActivities" min:"1" type:"list" required:"true"` // The name of the pipeline to update. // // PipelineName is a required field PipelineName *string `location:"uri" locationName:"pipelineName" min:"1" type:"string" required:"true"` // contains filtered or unexported fields }
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdatePipelineRequest
func (UpdatePipelineInput) MarshalFields ¶
func (s UpdatePipelineInput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (UpdatePipelineInput) String ¶
func (s UpdatePipelineInput) String() string
String returns the string representation
func (*UpdatePipelineInput) Validate ¶
func (s *UpdatePipelineInput) Validate() error
Validate inspects the fields of the type to determine if they are valid.
type UpdatePipelineOutput ¶
type UpdatePipelineOutput struct {
// contains filtered or unexported fields
}
Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdatePipelineOutput
func (UpdatePipelineOutput) MarshalFields ¶
func (s UpdatePipelineOutput) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (UpdatePipelineOutput) String ¶
func (s UpdatePipelineOutput) String() string
String returns the string representation
type UpdatePipelineRequest ¶
type UpdatePipelineRequest struct { *aws.Request Input *UpdatePipelineInput Copy func(*UpdatePipelineInput) UpdatePipelineRequest }
UpdatePipelineRequest is the request type for the UpdatePipeline API operation.
func (UpdatePipelineRequest) Send ¶
func (r UpdatePipelineRequest) Send(ctx context.Context) (*UpdatePipelineResponse, error)
Send marshals and sends the UpdatePipeline API request.
type UpdatePipelineResponse ¶ added in v0.9.0
type UpdatePipelineResponse struct { *UpdatePipelineOutput // contains filtered or unexported fields }
UpdatePipelineResponse is the response type for the UpdatePipeline API operation.
func (*UpdatePipelineResponse) SDKResponseMetdata ¶ added in v0.9.0
func (r *UpdatePipelineResponse) SDKResponseMetdata() *aws.Response
SDKResponseMetdata returns the response metadata for the UpdatePipeline request.
type Variable ¶ added in v0.5.0
type Variable struct { // The value of the variable as a structure that specifies a data set content // version. DatasetContentVersionValue *DatasetContentVersionValue `locationName:"datasetContentVersionValue" type:"structure"` // The value of the variable as a double (numeric). DoubleValue *float64 `locationName:"doubleValue" type:"double"` // The name of the variable. // // Name is a required field Name *string `locationName:"name" min:"1" type:"string" required:"true"` // The value of the variable as a structure that specifies an output file URI. OutputFileUriValue *OutputFileUriValue `locationName:"outputFileUriValue" type:"structure"` // The value of the variable as a string. StringValue *string `locationName:"stringValue" type:"string"` // contains filtered or unexported fields }
An instance of a variable to be passed to the "containerAction" execution. Each variable must have a name and a value given by one of "stringValue", "datasetContentVersionValue", or "outputFileUriValue". Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/Variable
func (Variable) MarshalFields ¶ added in v0.5.0
func (s Variable) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
type VersioningConfiguration ¶ added in v0.8.0
type VersioningConfiguration struct { // How many versions of data set contents will be kept. The "unlimited" parameter // must be false. MaxVersions *int64 `locationName:"maxVersions" min:"1" type:"integer"` // If true, unlimited versions of data set contents will be kept. Unlimited *bool `locationName:"unlimited" type:"boolean"` // contains filtered or unexported fields }
Information about the versioning of data set contents. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/VersioningConfiguration
func (VersioningConfiguration) MarshalFields ¶ added in v0.8.0
func (s VersioningConfiguration) MarshalFields(e protocol.FieldEncoder) error
MarshalFields encodes the AWS API shape using the passed in protocol encoder.
func (VersioningConfiguration) String ¶ added in v0.8.0
func (s VersioningConfiguration) String() string
String returns the string representation
func (*VersioningConfiguration) Validate ¶ added in v0.8.0
func (s *VersioningConfiguration) Validate() error
Validate inspects the fields of the type to determine if they are valid.
Source Files ¶
- api_client.go
- api_doc.go
- api_enums.go
- api_errors.go
- api_op_BatchPutMessage.go
- api_op_CancelPipelineReprocessing.go
- api_op_CreateChannel.go
- api_op_CreateDataset.go
- api_op_CreateDatasetContent.go
- api_op_CreateDatastore.go
- api_op_CreatePipeline.go
- api_op_DeleteChannel.go
- api_op_DeleteDataset.go
- api_op_DeleteDatasetContent.go
- api_op_DeleteDatastore.go
- api_op_DeletePipeline.go
- api_op_DescribeChannel.go
- api_op_DescribeDataset.go
- api_op_DescribeDatastore.go
- api_op_DescribeLoggingOptions.go
- api_op_DescribePipeline.go
- api_op_GetDatasetContent.go
- api_op_ListChannels.go
- api_op_ListDatasetContents.go
- api_op_ListDatasets.go
- api_op_ListDatastores.go
- api_op_ListPipelines.go
- api_op_ListTagsForResource.go
- api_op_PutLoggingOptions.go
- api_op_RunPipelineActivity.go
- api_op_SampleChannelData.go
- api_op_StartPipelineReprocessing.go
- api_op_TagResource.go
- api_op_UntagResource.go
- api_op_UpdateChannel.go
- api_op_UpdateDataset.go
- api_op_UpdateDatastore.go
- api_op_UpdatePipeline.go
- api_types.go
Directories ¶
Path | Synopsis |
---|---|
Package iotanalyticsiface provides an interface to enable mocking the AWS IoT Analytics service client for testing your code.
|
Package iotanalyticsiface provides an interface to enable mocking the AWS IoT Analytics service client for testing your code. |