iotanalytics

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

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

 Go to latest Published: May 26, 2018 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package iotanalytics provides the client and types for making API requests to AWS IoT Analytics.

AWS IoT Analytics provides advanced data analysis for AWS IoT. It allows you to collect large amounts of device data, process messages, store them, and then query the data and run sophisticated analytics to make accurate decisions in your IoT applications and machine learning use cases. 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 each of 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 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 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 IoTAnalytics for more information on creating client for this service. https://docs.aws.amazon.com/sdk-for-go/api/service/iotanalytics/#New

Index

Constants

View Source 
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"

	// ErrCodeServiceUnavailableException for service response error code
	// "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"
)
View Source 
const (
	ServiceName = "iotanalytics" // Service endpoint prefix API calls made to.
	EndpointsID = ServiceName    // Service ID for Regions and Endpoints metadata.
)

Service information constants

Variables

This section is empty.

Functions

This section is empty.

Types

type 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) GoString 

func (s AddAttributesActivity) GoString() string

GoString returns the string representation

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) GoString 

func (s BatchPutMessageErrorEntry) GoString() string

GoString returns the string representation

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"}'.
	//
	// 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) GoString 

func (s BatchPutMessageInput) GoString() string

GoString returns the string representation

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) GoString 

func (s BatchPutMessageOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s BatchPutMessageOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the BatchPutMessage API operation.

func (BatchPutMessageRequest) Send 

func (r BatchPutMessageRequest) Send() (*BatchPutMessageOutput, error)

Send marshals and sends the BatchPutMessage API 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) GoString 

func (s CancelPipelineReprocessingInput) GoString() string

GoString returns the string representation

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) GoString 

func (s CancelPipelineReprocessingOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s CancelPipelineReprocessingOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the CancelPipelineReprocessing API operation.

func (CancelPipelineReprocessingRequest) Send 

func (r CancelPipelineReprocessingRequest) Send() (*CancelPipelineReprocessingOutput, error)

Send marshals and sends the CancelPipelineReprocessing API 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) GoString 

func (s Channel) GoString() string

GoString returns the string representation

func (Channel) MarshalFields 

func (s Channel) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (Channel) String 

func (s Channel) String() string

String returns the string representation

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) GoString 

func (s ChannelActivity) GoString() string

GoString returns the string representation

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 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) GoString 

func (s ChannelSummary) GoString() string

GoString returns the string representation

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 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"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateChannelRequest

func (CreateChannelInput) GoString 

func (s CreateChannelInput) GoString() string

GoString returns the string representation

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) GoString 

func (s CreateChannelOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s CreateChannelOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the CreateChannel API operation.

func (CreateChannelRequest) Send 

func (r CreateChannelRequest) Send() (*CreateChannelOutput, error)

Send marshals and sends the CreateChannel API 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) GoString 

func (s CreateDatasetContentInput) GoString() string

GoString returns the string representation

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 {
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDatasetContentOutput

func (CreateDatasetContentOutput) GoString 

func (s CreateDatasetContentOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s CreateDatasetContentOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the CreateDatasetContent API operation.

func (CreateDatasetContentRequest) Send 

func (r CreateDatasetContentRequest) Send() (*CreateDatasetContentOutput, error)

Send marshals and sends the CreateDatasetContent API request.

type CreateDatasetInput 

type CreateDatasetInput struct {

	// A list of actions that create the data set. Only one action is supported
	// at this time.
	//
	// Actions is a required field
	Actions []DatasetAction `locationName:"actions" min:"1" type:"list" required:"true"`

	// The name of the data set.
	//
	// DatasetName is a required field
	DatasetName *string `locationName:"datasetName" min:"1" type:"string" required:"true"`

	// A list of triggers. A trigger causes data set content to be populated at
	// a specified time or time interval. 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
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDatasetRequest

func (CreateDatasetInput) GoString 

func (s CreateDatasetInput) GoString() string

GoString returns the string representation

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"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDatasetResponse

func (CreateDatasetOutput) GoString 

func (s CreateDatasetOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s CreateDatasetOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the CreateDataset API operation.

func (CreateDatasetRequest) Send 

func (r CreateDatasetRequest) Send() (*CreateDatasetOutput, error)

Send marshals and sends the CreateDataset API 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"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDatastoreRequest

func (CreateDatastoreInput) GoString 

func (s CreateDatastoreInput) GoString() string

GoString returns the string representation

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) GoString 

func (s CreateDatastoreOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s CreateDatastoreOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the CreateDatastore API operation.

func (CreateDatastoreRequest) Send 

func (r CreateDatastoreRequest) Send() (*CreateDatastoreOutput, error)

Send marshals and sends the CreateDatastore API request.

type CreatePipelineInput 

type CreatePipelineInput struct {

	// A list of pipeline activities.
	//
	// The list can be 1-25 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.
	//
	// 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"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreatePipelineRequest

func (CreatePipelineInput) GoString 

func (s CreatePipelineInput) GoString() string

GoString returns the string representation

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) GoString 

func (s CreatePipelineOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s CreatePipelineOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the CreatePipeline API operation.

func (CreatePipelineRequest) Send 

func (r CreatePipelineRequest) Send() (*CreatePipelineOutput, error)

Send marshals and sends the CreatePipeline API request.

type Dataset 

type Dataset struct {

	// The "DatasetAction" objects that create the data set.
	Actions []DatasetAction `locationName:"actions" min:"1" type:"list"`

	// The ARN of the data set.
	Arn *string `locationName:"arn" type:"string"`

	// 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"`

	// 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"`
	// 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) GoString 

func (s Dataset) GoString() string

GoString returns the string representation

func (Dataset) MarshalFields 

func (s Dataset) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (Dataset) String 

func (s Dataset) String() string

String returns the string representation

type DatasetAction 

type DatasetAction struct {

	// The name of the data set action.
	ActionName *string `locationName:"actionName" min:"1" type:"string"`

	// An "SqlQueryDatasetAction" object that contains the SQL query to modify the
	// message.
	QueryAction *SqlQueryDatasetAction `locationName:"queryAction" type:"structure"`
	// contains filtered or unexported fields
}

A "DatasetAction" object specifying the query that creates the data set content. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetAction

func (DatasetAction) GoString 

func (s DatasetAction) GoString() string

GoString returns the string representation

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 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 is in this state.
	Reason *string `locationName:"reason" type:"string"`

	// The state of the data set. Can be one of "CREATING", "SUCCEEDED" or "FAILED".
	State DatasetContentState `locationName:"state" type:"string" enum:"true"`
	// contains filtered or unexported fields
}

The state of the data set and the reason it is in this state. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetContentStatus

func (DatasetContentStatus) GoString 

func (s DatasetContentStatus) GoString() string

GoString returns the string representation

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 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) GoString 

func (s DatasetEntry) GoString() string

GoString returns the string representation

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 {

	// 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"`
	// 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) GoString 

func (s DatasetSummary) GoString() string

GoString returns the string representation

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 "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) GoString 

func (s DatasetTrigger) GoString() string

GoString returns the string representation

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

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:
	//
	// CREATINGThe data store is being created.
	//
	// ACTIVEThe data store has been created and can be used.
	//
	// DELETINGThe 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) GoString 

func (s Datastore) GoString() string

GoString returns the string representation

func (Datastore) MarshalFields 

func (s Datastore) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (Datastore) String 

func (s Datastore) String() string

String returns the string representation

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) GoString 

func (s DatastoreActivity) GoString() string

GoString returns the string representation

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 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) GoString 

func (s DatastoreSummary) GoString() string

GoString returns the string representation

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) GoString 

func (s DeleteChannelInput) GoString() string

GoString returns the string representation

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) GoString 

func (s DeleteChannelOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s DeleteChannelOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the DeleteChannel API operation.

func (DeleteChannelRequest) Send 

func (r DeleteChannelRequest) Send() (*DeleteChannelOutput, error)

Send marshals and sends the DeleteChannel API 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" type:"string"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteDatasetContentRequest

func (DeleteDatasetContentInput) GoString 

func (s DeleteDatasetContentInput) GoString() string

GoString returns the string representation

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) GoString 

func (s DeleteDatasetContentOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s DeleteDatasetContentOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the DeleteDatasetContent API operation.

func (DeleteDatasetContentRequest) Send 

func (r DeleteDatasetContentRequest) Send() (*DeleteDatasetContentOutput, error)

Send marshals and sends the DeleteDatasetContent API 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) GoString 

func (s DeleteDatasetInput) GoString() string

GoString returns the string representation

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) GoString 

func (s DeleteDatasetOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s DeleteDatasetOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the DeleteDataset API operation.

func (DeleteDatasetRequest) Send 

func (r DeleteDatasetRequest) Send() (*DeleteDatasetOutput, error)

Send marshals and sends the DeleteDataset API 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) GoString 

func (s DeleteDatastoreInput) GoString() string

GoString returns the string representation

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) GoString 

func (s DeleteDatastoreOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s DeleteDatastoreOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the DeleteDatastore API operation.

func (DeleteDatastoreRequest) Send 

func (r DeleteDatastoreRequest) Send() (*DeleteDatastoreOutput, error)

Send marshals and sends the DeleteDatastore API 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) GoString 

func (s DeletePipelineInput) GoString() string

GoString returns the string representation

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) GoString 

func (s DeletePipelineOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s DeletePipelineOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the DeletePipeline API operation.

func (DeletePipelineRequest) Send 

func (r DeletePipelineRequest) Send() (*DeletePipelineOutput, error)

Send marshals and sends the DeletePipeline API request.

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"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeChannelRequest

func (DescribeChannelInput) GoString 

func (s DescribeChannelInput) GoString() string

GoString returns the string representation

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"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeChannelResponse

func (DescribeChannelOutput) GoString 

func (s DescribeChannelOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s DescribeChannelOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the DescribeChannel API operation.

func (DescribeChannelRequest) Send 

func (r DescribeChannelRequest) Send() (*DescribeChannelOutput, error)

Send marshals and sends the DescribeChannel API 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) GoString 

func (s DescribeDatasetInput) GoString() string

GoString returns the string representation

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) GoString 

func (s DescribeDatasetOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s DescribeDatasetOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the DescribeDataset API operation.

func (DescribeDatasetRequest) Send 

func (r DescribeDatasetRequest) Send() (*DescribeDatasetOutput, error)

Send marshals and sends the DescribeDataset API 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"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeDatastoreRequest

func (DescribeDatastoreInput) GoString 

func (s DescribeDatastoreInput) GoString() string

GoString returns the string representation

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"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeDatastoreResponse

func (DescribeDatastoreOutput) GoString 

func (s DescribeDatastoreOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s DescribeDatastoreOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the DescribeDatastore API operation.

func (DescribeDatastoreRequest) Send 

func (r DescribeDatastoreRequest) Send() (*DescribeDatastoreOutput, error)

Send marshals and sends the DescribeDatastore API 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) GoString 

func (s DescribeLoggingOptionsInput) GoString() string

GoString returns the string representation

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) GoString 

func (s DescribeLoggingOptionsOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s DescribeLoggingOptionsOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the DescribeLoggingOptions API operation.

func (DescribeLoggingOptionsRequest) Send 

func (r DescribeLoggingOptionsRequest) Send() (*DescribeLoggingOptionsOutput, error)

Send marshals and sends the DescribeLoggingOptions API 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) GoString 

func (s DescribePipelineInput) GoString() string

GoString returns the string representation

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) GoString 

func (s DescribePipelineOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s DescribePipelineOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the DescribePipeline API operation.

func (DescribePipelineRequest) Send 

func (r DescribePipelineRequest) Send() (*DescribePipelineOutput, error)

Send marshals and sends the DescribePipeline API 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) GoString 

func (s DeviceRegistryEnrichActivity) GoString() string

GoString returns the string representation

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) GoString 

func (s DeviceShadowEnrichActivity) GoString() string

GoString returns the string representation

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 FilterActivity 

type FilterActivity struct {

	// An expression that looks like an 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) GoString 

func (s FilterActivity) GoString() string

GoString returns the string representation

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" type:"string"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/GetDatasetContentRequest

func (GetDatasetContentInput) GoString 

func (s GetDatasetContentInput) GoString() string

GoString returns the string representation

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) GoString 

func (s GetDatasetContentOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s GetDatasetContentOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the GetDatasetContent API operation.

func (GetDatasetContentRequest) Send 

func (r GetDatasetContentRequest) Send() (*GetDatasetContentOutput, error)

Send marshals and sends the GetDatasetContent API request.

type IoTAnalytics 

type IoTAnalytics struct {
	*aws.Client
}

IoTAnalytics provides the API operation methods for making requests to AWS IoT Analytics. See this package's package overview docs for details on the service.

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

func New 

func New(config aws.Config) *IoTAnalytics

New creates a new instance of the IoTAnalytics client with a config.

Example: 

// Create a IoTAnalytics client from just a config.
svc := iotanalytics.New(myConfig)

func (*IoTAnalytics) BatchPutMessageRequest 

func (c *IoTAnalytics) 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 the BatchPutMessageRequest method.
req := client.BatchPutMessageRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/BatchPutMessage

func (*IoTAnalytics) CancelPipelineReprocessingRequest 

func (c *IoTAnalytics) 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 the CancelPipelineReprocessingRequest method.
req := client.CancelPipelineReprocessingRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CancelPipelineReprocessing

func (*IoTAnalytics) CreateChannelRequest 

func (c *IoTAnalytics) 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 the CreateChannelRequest method.
req := client.CreateChannelRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateChannel

func (*IoTAnalytics) CreateDatasetContentRequest 

func (c *IoTAnalytics) 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 an SQL action. 

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDatasetContent

func (*IoTAnalytics) CreateDatasetRequest 

func (c *IoTAnalytics) 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 an SQL action.

This operation creates the skeleton of a data set. To populate the data set, call "CreateDatasetContent". 

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDataset

func (*IoTAnalytics) CreateDatastoreRequest 

func (c *IoTAnalytics) 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 the CreateDatastoreRequest method.
req := client.CreateDatastoreRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreateDatastore

func (*IoTAnalytics) CreatePipelineRequest 

func (c *IoTAnalytics) 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. 

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/CreatePipeline

func (*IoTAnalytics) DeleteChannelRequest 

func (c *IoTAnalytics) 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 the DeleteChannelRequest method.
req := client.DeleteChannelRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteChannel

func (*IoTAnalytics) DeleteDatasetContentRequest 

func (c *IoTAnalytics) 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 the DeleteDatasetContentRequest method.
req := client.DeleteDatasetContentRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteDatasetContent

func (*IoTAnalytics) DeleteDatasetRequest 

func (c *IoTAnalytics) 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 the DeleteDatasetRequest method.
req := client.DeleteDatasetRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteDataset

func (*IoTAnalytics) DeleteDatastoreRequest 

func (c *IoTAnalytics) 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 the DeleteDatastoreRequest method.
req := client.DeleteDatastoreRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeleteDatastore

func (*IoTAnalytics) DeletePipelineRequest 

func (c *IoTAnalytics) 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 the DeletePipelineRequest method.
req := client.DeletePipelineRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeletePipeline

func (*IoTAnalytics) DescribeChannelRequest 

func (c *IoTAnalytics) 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 the DescribeChannelRequest method.
req := client.DescribeChannelRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeChannel

func (*IoTAnalytics) DescribeDatasetRequest 

func (c *IoTAnalytics) 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 the DescribeDatasetRequest method.
req := client.DescribeDatasetRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeDataset

func (*IoTAnalytics) DescribeDatastoreRequest 

func (c *IoTAnalytics) 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 the DescribeDatastoreRequest method.
req := client.DescribeDatastoreRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeDatastore

func (*IoTAnalytics) DescribeLoggingOptionsRequest 

func (c *IoTAnalytics) 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 the DescribeLoggingOptionsRequest method.
req := client.DescribeLoggingOptionsRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribeLoggingOptions

func (*IoTAnalytics) DescribePipelineRequest 

func (c *IoTAnalytics) 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 the DescribePipelineRequest method.
req := client.DescribePipelineRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DescribePipeline

func (*IoTAnalytics) GetDatasetContentRequest 

func (c *IoTAnalytics) 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 the GetDatasetContentRequest method.
req := client.GetDatasetContentRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/GetDatasetContent

func (*IoTAnalytics) ListChannelsRequest 

func (c *IoTAnalytics) 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 the ListChannelsRequest method.
req := client.ListChannelsRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListChannels

func (*IoTAnalytics) ListDatasetsRequest 

func (c *IoTAnalytics) 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 the ListDatasetsRequest method.
req := client.ListDatasetsRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListDatasets

func (*IoTAnalytics) ListDatastoresRequest 

func (c *IoTAnalytics) 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 the ListDatastoresRequest method.
req := client.ListDatastoresRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListDatastores

func (*IoTAnalytics) ListPipelinesRequest 

func (c *IoTAnalytics) 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 the ListPipelinesRequest method.
req := client.ListPipelinesRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ListPipelines

func (*IoTAnalytics) PutLoggingOptionsRequest 

func (c *IoTAnalytics) 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. 

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/PutLoggingOptions

func (*IoTAnalytics) RunPipelineActivityRequest 

func (c *IoTAnalytics) 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 the RunPipelineActivityRequest method.
req := client.RunPipelineActivityRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/RunPipelineActivity

func (*IoTAnalytics) SampleChannelDataRequest 

func (c *IoTAnalytics) 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 the SampleChannelDataRequest method.
req := client.SampleChannelDataRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/SampleChannelData

func (*IoTAnalytics) StartPipelineReprocessingRequest 

func (c *IoTAnalytics) 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 the StartPipelineReprocessingRequest method.
req := client.StartPipelineReprocessingRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/StartPipelineReprocessing

func (*IoTAnalytics) UpdateChannelRequest 

func (c *IoTAnalytics) 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 the UpdateChannelRequest method.
req := client.UpdateChannelRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdateChannel

func (*IoTAnalytics) UpdateDatasetRequest 

func (c *IoTAnalytics) 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 the UpdateDatasetRequest method.
req := client.UpdateDatasetRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdateDataset

func (*IoTAnalytics) UpdateDatastoreRequest 

func (c *IoTAnalytics) 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 the UpdateDatastoreRequest method.
req := client.UpdateDatastoreRequest(params)
resp, err := req.Send()
if err == nil {
    fmt.Println(resp)
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdateDatastore

func (*IoTAnalytics) UpdatePipelineRequest 

func (c *IoTAnalytics) UpdatePipelineRequest(input *UpdatePipelineInput) UpdatePipelineRequest

UpdatePipelineRequest returns a request value for making API operation for AWS IoT Analytics.

Updates the settings of a pipeline. 

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

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdatePipeline

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) GoString 

func (s LambdaActivity) GoString() string

GoString returns the string representation

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) GoString 

func (s ListChannelsInput) GoString() string

GoString returns the string representation

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) GoString 

func (s ListChannelsOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s ListChannelsOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

func (ListChannelsOutput) String 

func (s ListChannelsOutput) String() string

String returns the string representation

type ListChannelsPager 

type ListChannelsPager struct {
	aws.Pager
}

ListChannelsPager is used to paginate the request. This can be done by calling Next and CurrentPage.

func (*ListChannelsPager) CurrentPage 

func (p *ListChannelsPager) CurrentPage() *ListChannelsOutput

type ListChannelsRequest 

type ListChannelsRequest struct {
	*aws.Request
	Input *ListChannelsInput
	Copy  func(*ListChannelsInput) ListChannelsRequest
}

ListChannelsRequest is a API request type for the ListChannels API operation.

func (*ListChannelsRequest) Paginate 

func (p *ListChannelsRequest) Paginate(opts ...aws.Option) ListChannelsPager

Paginate pages iterates over the pages of a ListChannelsRequest operation, calling the Next method for each page. Using the paginators Next method will depict whether or not there are more pages.

Note: This operation can generate multiple requests to a service. 

   // Example iterating over at most 3 pages of a ListChannels operation.
		req := client.ListChannelsRequest(input)
		p := req.Paginate()
		for p.Next() {
			page := p.CurrentPage()
		}

		if err := p.Err(); err != nil {
			return err
		}

func (ListChannelsRequest) Send 

func (r ListChannelsRequest) Send() (*ListChannelsOutput, error)

Send marshals and sends the ListChannels API 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) GoString 

func (s ListDatasetsInput) GoString() string

GoString returns the string representation

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) GoString 

func (s ListDatasetsOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s ListDatasetsOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

func (ListDatasetsOutput) String 

func (s ListDatasetsOutput) String() string

String returns the string representation

type ListDatasetsPager 

type ListDatasetsPager struct {
	aws.Pager
}

ListDatasetsPager is used to paginate the request. This can be done by calling Next and CurrentPage.

func (*ListDatasetsPager) CurrentPage 

func (p *ListDatasetsPager) CurrentPage() *ListDatasetsOutput

type ListDatasetsRequest 

type ListDatasetsRequest struct {
	*aws.Request
	Input *ListDatasetsInput
	Copy  func(*ListDatasetsInput) ListDatasetsRequest
}

ListDatasetsRequest is a API request type for the ListDatasets API operation.

func (*ListDatasetsRequest) Paginate 

func (p *ListDatasetsRequest) Paginate(opts ...aws.Option) ListDatasetsPager

Paginate pages iterates over the pages of a ListDatasetsRequest operation, calling the Next method for each page. Using the paginators Next method will depict whether or not there are more pages.

Note: This operation can generate multiple requests to a service. 

   // Example iterating over at most 3 pages of a ListDatasets operation.
		req := client.ListDatasetsRequest(input)
		p := req.Paginate()
		for p.Next() {
			page := p.CurrentPage()
		}

		if err := p.Err(); err != nil {
			return err
		}

func (ListDatasetsRequest) Send 

func (r ListDatasetsRequest) Send() (*ListDatasetsOutput, error)

Send marshals and sends the ListDatasets API 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) GoString 

func (s ListDatastoresInput) GoString() string

GoString returns the string representation

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) GoString 

func (s ListDatastoresOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s ListDatastoresOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

func (ListDatastoresOutput) String 

func (s ListDatastoresOutput) String() string

String returns the string representation

type ListDatastoresPager 

type ListDatastoresPager struct {
	aws.Pager
}

ListDatastoresPager is used to paginate the request. This can be done by calling Next and CurrentPage.

func (*ListDatastoresPager) CurrentPage 

func (p *ListDatastoresPager) CurrentPage() *ListDatastoresOutput

type ListDatastoresRequest 

type ListDatastoresRequest struct {
	*aws.Request
	Input *ListDatastoresInput
	Copy  func(*ListDatastoresInput) ListDatastoresRequest
}

ListDatastoresRequest is a API request type for the ListDatastores API operation.

func (*ListDatastoresRequest) Paginate 

func (p *ListDatastoresRequest) Paginate(opts ...aws.Option) ListDatastoresPager

Paginate pages iterates over the pages of a ListDatastoresRequest operation, calling the Next method for each page. Using the paginators Next method will depict whether or not there are more pages.

Note: This operation can generate multiple requests to a service. 

   // Example iterating over at most 3 pages of a ListDatastores operation.
		req := client.ListDatastoresRequest(input)
		p := req.Paginate()
		for p.Next() {
			page := p.CurrentPage()
		}

		if err := p.Err(); err != nil {
			return err
		}

func (ListDatastoresRequest) Send 

func (r ListDatastoresRequest) Send() (*ListDatastoresOutput, error)

Send marshals and sends the ListDatastores API 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) GoString 

func (s ListPipelinesInput) GoString() string

GoString returns the string representation

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) GoString 

func (s ListPipelinesOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s ListPipelinesOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

func (ListPipelinesOutput) String 

func (s ListPipelinesOutput) String() string

String returns the string representation

type ListPipelinesPager 

type ListPipelinesPager struct {
	aws.Pager
}

ListPipelinesPager is used to paginate the request. This can be done by calling Next and CurrentPage.

func (*ListPipelinesPager) CurrentPage 

func (p *ListPipelinesPager) CurrentPage() *ListPipelinesOutput

type ListPipelinesRequest 

type ListPipelinesRequest struct {
	*aws.Request
	Input *ListPipelinesInput
	Copy  func(*ListPipelinesInput) ListPipelinesRequest
}

ListPipelinesRequest is a API request type for the ListPipelines API operation.

func (*ListPipelinesRequest) Paginate 

func (p *ListPipelinesRequest) Paginate(opts ...aws.Option) ListPipelinesPager

Paginate pages iterates over the pages of a ListPipelinesRequest operation, calling the Next method for each page. Using the paginators Next method will depict whether or not there are more pages.

Note: This operation can generate multiple requests to a service. 

   // Example iterating over at most 3 pages of a ListPipelines operation.
		req := client.ListPipelinesRequest(input)
		p := req.Paginate()
		for p.Next() {
			page := p.CurrentPage()
		}

		if err := p.Err(); err != nil {
			return err
		}

func (ListPipelinesRequest) Send 

func (r ListPipelinesRequest) Send() (*ListPipelinesOutput, error)

Send marshals and sends the ListPipelines API 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) GoString 

func (s LoggingOptions) GoString() string

GoString returns the string representation

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 will contain 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) GoString 

func (s MathActivity) GoString() string

GoString returns the string representation

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.
	//
	// MessageId is a required field
	MessageId *string `locationName:"messageId" min:"1" type:"string" required:"true"`

	// The payload of the message.
	//
	// 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) GoString 

func (s Message) GoString() string

GoString returns the string representation

func (Message) MarshalFields 

func (s Message) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (Message) String 

func (s Message) String() string

String returns the string representation

func (*Message) Validate 

func (s *Message) 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) GoString 

func (s Pipeline) GoString() string

GoString returns the string representation

func (Pipeline) MarshalFields 

func (s Pipeline) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (Pipeline) String 

func (s Pipeline) String() string

String returns the string representation

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) GoString 

func (s PipelineActivity) GoString() string

GoString returns the string representation

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) GoString 

func (s PipelineSummary) GoString() string

GoString returns the string representation

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) GoString 

func (s PutLoggingOptionsInput) GoString() string

GoString returns the string representation

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) GoString 

func (s PutLoggingOptionsOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s PutLoggingOptionsOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the PutLoggingOptions API operation.

func (PutLoggingOptionsRequest) Send 

func (r PutLoggingOptionsRequest) Send() (*PutLoggingOptionsOutput, error)

Send marshals and sends the PutLoggingOptions API request.

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) GoString 

func (s RemoveAttributesActivity) GoString() string

GoString returns the string representation

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) GoString 

func (s ReprocessingSummary) GoString() string

GoString returns the string representation

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 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) GoString 

func (s RetentionPeriod) GoString() string

GoString returns the string representation

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) GoString 

func (s RunPipelineActivityInput) GoString() string

GoString returns the string representation

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) GoString 

func (s RunPipelineActivityOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s RunPipelineActivityOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the RunPipelineActivity API operation.

func (RunPipelineActivityRequest) Send 

func (r RunPipelineActivityRequest) Send() (*RunPipelineActivityOutput, error)

Send marshals and sends the RunPipelineActivity API request.

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) GoString 

func (s SampleChannelDataInput) GoString() string

GoString returns the string representation

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) GoString 

func (s SampleChannelDataOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s SampleChannelDataOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the SampleChannelData API operation.

func (SampleChannelDataRequest) Send 

func (r SampleChannelDataRequest) Send() (*SampleChannelDataOutput, error)

Send marshals and sends the SampleChannelData API 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 documentation.
	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) GoString 

func (s Schedule) GoString() string

GoString returns the string representation

func (Schedule) MarshalFields 

func (s Schedule) MarshalFields(e protocol.FieldEncoder) error

MarshalFields encodes the AWS API shape using the passed in protocol encoder.

func (Schedule) String 

func (s Schedule) String() string

String returns the string representation

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) GoString 

func (s SelectAttributesActivity) GoString() string

GoString returns the string representation

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 {

	// An 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) GoString 

func (s SqlQueryDatasetAction) GoString() string

GoString returns the string representation

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) GoString 

func (s StartPipelineReprocessingInput) GoString() string

GoString returns the string representation

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) GoString 

func (s StartPipelineReprocessingOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s StartPipelineReprocessingOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the StartPipelineReprocessing API operation.

func (StartPipelineReprocessingRequest) Send 

func (r StartPipelineReprocessingRequest) Send() (*StartPipelineReprocessingOutput, error)

Send marshals and sends the StartPipelineReprocessing API 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) GoString 

func (s UpdateChannelInput) GoString() string

GoString returns the string representation

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) GoString 

func (s UpdateChannelOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s UpdateChannelOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the UpdateChannel API operation.

func (UpdateChannelRequest) Send 

func (r UpdateChannelRequest) Send() (*UpdateChannelOutput, error)

Send marshals and sends the UpdateChannel API request.

type UpdateDatasetInput 

type UpdateDatasetInput struct {

	// A list of "DatasetAction" objects. Only one action is supported at this time.
	//
	// Actions is a required field
	Actions []DatasetAction `locationName:"actions" min:"1" type:"list" required:"true"`

	// 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"`

	// A list of "DatasetTrigger" objects. The list can be empty or can contain
	// up to five DataSetTrigger objects.
	Triggers []DatasetTrigger `locationName:"triggers" type:"list"`
	// contains filtered or unexported fields
}

Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/UpdateDatasetRequest

func (UpdateDatasetInput) GoString 

func (s UpdateDatasetInput) GoString() string

GoString returns the string representation

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) GoString 

func (s UpdateDatasetOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s UpdateDatasetOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the UpdateDataset API operation.

func (UpdateDatasetRequest) Send 

func (r UpdateDatasetRequest) Send() (*UpdateDatasetOutput, error)

Send marshals and sends the UpdateDataset API 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) GoString 

func (s UpdateDatastoreInput) GoString() string

GoString returns the string representation

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) GoString 

func (s UpdateDatastoreOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s UpdateDatastoreOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the UpdateDatastore API operation.

func (UpdateDatastoreRequest) Send 

func (r UpdateDatastoreRequest) Send() (*UpdateDatastoreOutput, error)

Send marshals and sends the UpdateDatastore API request.

type UpdatePipelineInput 

type UpdatePipelineInput struct {

	// A list of "PipelineActivity" objects.
	//
	// The list can be 1-25 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.
	//
	// 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) GoString 

func (s UpdatePipelineInput) GoString() string

GoString returns the string representation

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) GoString 

func (s UpdatePipelineOutput) GoString() string

GoString returns the string representation

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) SDKResponseMetadata 

func (s UpdatePipelineOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

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 a API request type for the UpdatePipeline API operation.

func (UpdatePipelineRequest) Send 

func (r UpdatePipelineRequest) Send() (*UpdatePipelineOutput, error)

Send marshals and sends the UpdatePipeline API request.

Source Files

View all Source files

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.

Jump to

Keyboard shortcuts

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