iotanalytics

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2018 License: Apache-2.0 Imports: 7 Imported by: 13

Documentation

Overview

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

AWS IoT Analytics allows you to collect large amounts of device data, process messages, and store them. You can then query the data and run sophisticated analytics on it. AWS IoT Analytics enables advanced data exploration through integration with Jupyter Notebooks and data visualization through integration with Amazon QuickSight.

Traditional analytics and business intelligence tools are designed to process structured data. IoT data often comes from devices that record noisy processes (such as temperature, motion, or sound). As a result the data from these devices can have significant gaps, corrupted messages, and false readings that must be cleaned up before analysis can occur. Also, IoT data is often only meaningful in the context of other data from external sources.

AWS IoT Analytics automates the steps required to analyze data from IoT devices. AWS IoT Analytics filters, transforms, and enriches IoT data before storing it in a time-series data store for analysis. You can set up the service to collect only the data you need from your devices, apply mathematical transforms to process the data, and enrich the data with device-specific metadata such as device type and location before storing it. Then, you can analyze your data by running queries using the built-in SQL query engine, or perform more complex analytics and machine learning inference. AWS IoT Analytics includes pre-built models for common IoT use cases so you can answer questions like which devices are about to fail or which customers are at risk of abandoning their wearable devices.

See https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27 for more information on this service.

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

Using the Client

To 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 ChannelStatistics added in v0.5.0 

type ChannelStatistics struct {

	// The estimated size of the channel.
	Size *EstimatedResourceSize `locationName:"size" type:"structure"`
	// contains filtered or unexported fields
}

Statistics information about the channel. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ChannelStatistics

func (ChannelStatistics) GoString added in v0.5.0 

func (s ChannelStatistics) GoString() string

GoString returns the string representation

func (ChannelStatistics) MarshalFields added in v0.5.0 

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

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

func (ChannelStatistics) String added in v0.5.0 

func (s ChannelStatistics) String() string

String returns the string representation

type ChannelStatus 

type ChannelStatus string
const (
	ChannelStatusCreating ChannelStatus = "CREATING"
	ChannelStatusActive   ChannelStatus = "ACTIVE"
	ChannelStatusDeleting ChannelStatus = "DELETING"
)

Enum values for ChannelStatus

func (ChannelStatus) MarshalValue 

func (enum ChannelStatus) MarshalValue() (string, error)

func (ChannelStatus) MarshalValueBuf 

func (enum ChannelStatus) MarshalValueBuf(b []byte) ([]byte, error)

type ChannelSummary 

type ChannelSummary struct {

	// The name of the channel.
	ChannelName *string `locationName:"channelName" min:"1" type:"string"`

	// When the channel was created.
	CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"`

	// The last time the channel was updated.
	LastUpdateTime *time.Time `locationName:"lastUpdateTime" type:"timestamp" timestampFormat:"unix"`

	// The status of the channel.
	Status ChannelStatus `locationName:"status" type:"string" enum:"true"`
	// contains filtered or unexported fields
}

A summary of information about a channel. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ChannelSummary

func (ChannelSummary) 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 ComputeType added in v0.5.0 

type ComputeType string
const (
	ComputeTypeAcu1 ComputeType = "ACU_1"
	ComputeTypeAcu2 ComputeType = "ACU_2"
)

Enum values for ComputeType

func (ComputeType) MarshalValue added in v0.5.0 

func (enum ComputeType) MarshalValue() (string, error)

func (ComputeType) MarshalValueBuf added in v0.5.0 

func (enum ComputeType) MarshalValueBuf(b []byte) ([]byte, error)

type ContainerDatasetAction added in v0.5.0 

type ContainerDatasetAction struct {

	// The ARN of the role which gives permission to the system to access needed
	// resources in order to run the "containerAction". This includes, at minimum,
	// permission to retrieve the data set contents which are the input to the containerized
	// application.
	//
	// ExecutionRoleArn is a required field
	ExecutionRoleArn *string `locationName:"executionRoleArn" min:"20" type:"string" required:"true"`

	// The ARN of the Docker container stored in your account. The Docker container
	// contains an application and needed support libraries and is used to generate
	// data set contents.
	//
	// Image is a required field
	Image *string `locationName:"image" type:"string" required:"true"`

	// Configuration of the resource which executes the "containerAction".
	//
	// ResourceConfiguration is a required field
	ResourceConfiguration *ResourceConfiguration `locationName:"resourceConfiguration" type:"structure" required:"true"`

	// The values of variables used within the context of the execution of the containerized
	// application (basically, parameters passed to the application). Each variable
	// must have a name and a value given by one of "stringValue", "datasetContentVersionValue",
	// or "outputFileUriValue".
	Variables []Variable `locationName:"variables" type:"list"`
	// contains filtered or unexported fields
}

Information needed to run the "containerAction" to produce data set contents. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ContainerDatasetAction

func (ContainerDatasetAction) GoString added in v0.5.0 

func (s ContainerDatasetAction) GoString() string

GoString returns the string representation

func (ContainerDatasetAction) MarshalFields added in v0.5.0 

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

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

func (ContainerDatasetAction) String added in v0.5.0 

func (s ContainerDatasetAction) String() string

String returns the string representation

func (*ContainerDatasetAction) Validate added in v0.5.0 

func (s *ContainerDatasetAction) Validate() error

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

type CreateChannelInput 

type CreateChannelInput struct {

	// The name of the channel.
	//
	// ChannelName is a required field
	ChannelName *string `locationName:"channelName" min:"1" type:"string" required:"true"`

	// How long, in days, message data is kept for the channel.
	RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"`

	// Metadata which can be used to manage the channel.
	Tags []Tag `locationName:"tags" min:"1" type:"list"`
	// contains filtered or unexported fields
}

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

func (CreateChannelInput) 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 {

	// The version ID of the data set contents which are being created.
	VersionId *string `locationName:"versionId" min:"7" type:"string"`
	// contains filtered or unexported fields
}

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

func (CreateDatasetContentOutput) 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 contents.
	//
	// Actions is a required field
	Actions []DatasetAction `locationName:"actions" min:"1" type:"list" required:"true"`

	ContentDeliveryRules []DatasetContentDeliveryRule `locationName:"contentDeliveryRules" type:"list"`

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

	// [Optional] How long, in days, message data is kept for the data set. If not
	// given or set to null, the latest version of the dataset content plus the
	// latest succeeded version (if they are different) are retained for at most
	// 90 days.
	RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"`

	// Metadata which can be used to manage the data set.
	Tags []Tag `locationName:"tags" min:"1" type:"list"`

	// A list of triggers. A trigger causes data set contents to be populated at
	// a specified time interval or when another data set's contents are created.
	// The list of triggers can be empty or contain up to five DataSetTrigger objects.
	Triggers []DatasetTrigger `locationName:"triggers" type:"list"`
	// 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"`

	// How long, in days, message data is kept for the data set.
	RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"`
	// contains filtered or unexported fields
}

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

func (CreateDatasetOutput) 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"`

	// Metadata which can be used to manage the data store.
	Tags []Tag `locationName:"tags" min:"1" type:"list"`
	// contains filtered or unexported fields
}

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

func (CreateDatastoreInput) 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"`

	// Metadata which can be used to manage the pipeline.
	Tags []Tag `locationName:"tags" min:"1" type:"list"`
	// contains filtered or unexported fields
}

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

func (CreatePipelineInput) 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 automatically create the data set contents.
	Actions []DatasetAction `locationName:"actions" min:"1" type:"list"`

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

	ContentDeliveryRules []DatasetContentDeliveryRule `locationName:"contentDeliveryRules" type:"list"`

	// When the data set was created.
	CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"`

	// The last time the data set was updated.
	LastUpdateTime *time.Time `locationName:"lastUpdateTime" type:"timestamp" timestampFormat:"unix"`

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

	// [Optional] How long, in days, message data is kept for the data set.
	RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"`

	// The status of the data set.
	Status DatasetStatus `locationName:"status" type:"string" enum:"true"`

	// The "DatasetTrigger" objects that specify when the data set is automatically
	// updated.
	Triggers []DatasetTrigger `locationName:"triggers" type:"list"`
	// 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 by which data set contents are automatically
	// created.
	ActionName *string `locationName:"actionName" min:"1" type:"string"`

	// Information which allows the system to run a containerized application in
	// order to create the data set contents. The application must be in a Docker
	// container along with any needed support libraries.
	ContainerAction *ContainerDatasetAction `locationName:"containerAction" type:"structure"`

	// An "SqlQueryDatasetAction" object that 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 DatasetActionSummary added in v0.5.0 

type DatasetActionSummary struct {

	// The name of the action which automatically creates the data set's contents.
	ActionName *string `locationName:"actionName" min:"1" type:"string"`

	// The type of action by which the data set's contents are automatically created.
	ActionType DatasetActionType `locationName:"actionType" type:"string" enum:"true"`
	// contains filtered or unexported fields
}

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

func (DatasetActionSummary) GoString added in v0.5.0 

func (s DatasetActionSummary) GoString() string

GoString returns the string representation

func (DatasetActionSummary) MarshalFields added in v0.5.0 

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

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

func (DatasetActionSummary) String added in v0.5.0 

func (s DatasetActionSummary) String() string

String returns the string representation

type DatasetActionType added in v0.5.0 

type DatasetActionType string
const (
	DatasetActionTypeQuery     DatasetActionType = "QUERY"
	DatasetActionTypeContainer DatasetActionType = "CONTAINER"
)

Enum values for DatasetActionType

func (DatasetActionType) MarshalValue added in v0.5.0 

func (enum DatasetActionType) MarshalValue() (string, error)

func (DatasetActionType) MarshalValueBuf added in v0.5.0 

func (enum DatasetActionType) MarshalValueBuf(b []byte) ([]byte, error)

type DatasetContentDeliveryDestination added in v0.6.0 

type DatasetContentDeliveryDestination struct {
	IotEventsDestinationConfiguration *IotEventsDestinationConfiguration `locationName:"iotEventsDestinationConfiguration" type:"structure"`
	// contains filtered or unexported fields
}

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

func (DatasetContentDeliveryDestination) GoString added in v0.6.0 

func (s DatasetContentDeliveryDestination) GoString() string

GoString returns the string representation

func (DatasetContentDeliveryDestination) MarshalFields added in v0.6.0 

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

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

func (DatasetContentDeliveryDestination) String added in v0.6.0 

func (s DatasetContentDeliveryDestination) String() string

String returns the string representation

func (*DatasetContentDeliveryDestination) Validate added in v0.6.0 

func (s *DatasetContentDeliveryDestination) Validate() error

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

type DatasetContentDeliveryRule added in v0.6.0 

type DatasetContentDeliveryRule struct {

	// Destination is a required field
	Destination *DatasetContentDeliveryDestination `locationName:"destination" type:"structure" required:"true"`

	EntryName *string `locationName:"entryName" type:"string"`
	// contains filtered or unexported fields
}

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

func (DatasetContentDeliveryRule) GoString added in v0.6.0 

func (s DatasetContentDeliveryRule) GoString() string

GoString returns the string representation

func (DatasetContentDeliveryRule) MarshalFields added in v0.6.0 

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

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

func (DatasetContentDeliveryRule) String added in v0.6.0 

func (s DatasetContentDeliveryRule) String() string

String returns the string representation

func (*DatasetContentDeliveryRule) Validate added in v0.6.0 

func (s *DatasetContentDeliveryRule) Validate() error

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

type DatasetContentState 

type DatasetContentState string
const (
	DatasetContentStateCreating  DatasetContentState = "CREATING"
	DatasetContentStateSucceeded DatasetContentState = "SUCCEEDED"
	DatasetContentStateFailed    DatasetContentState = "FAILED"
)

Enum values for DatasetContentState

func (DatasetContentState) MarshalValue 

func (enum DatasetContentState) MarshalValue() (string, error)

func (DatasetContentState) MarshalValueBuf 

func (enum DatasetContentState) MarshalValueBuf(b []byte) ([]byte, error)

type DatasetContentStatus 

type DatasetContentStatus struct {

	// The reason the data set contents are in this state.
	Reason *string `locationName:"reason" type:"string"`

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

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

func (DatasetContentStatus) 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 DatasetContentSummary added in v0.5.0 

type DatasetContentSummary struct {

	// The actual time the creation of the data set contents was started.
	CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"`

	// The time the creation of the data set contents was scheduled to start.
	ScheduleTime *time.Time `locationName:"scheduleTime" type:"timestamp" timestampFormat:"unix"`

	// The status of the data set contents.
	Status *DatasetContentStatus `locationName:"status" type:"structure"`

	// The version of the data set contents.
	Version *string `locationName:"version" min:"7" type:"string"`
	// contains filtered or unexported fields
}

Summary information about data set contents. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetContentSummary

func (DatasetContentSummary) GoString added in v0.5.0 

func (s DatasetContentSummary) GoString() string

GoString returns the string representation

func (DatasetContentSummary) MarshalFields added in v0.5.0 

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

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

func (DatasetContentSummary) String added in v0.5.0 

func (s DatasetContentSummary) String() string

String returns the string representation

type DatasetContentVersionValue added in v0.5.0 

type DatasetContentVersionValue struct {

	// The name of the data set whose latest contents will be used as input to the
	// notebook or application.
	//
	// DatasetName is a required field
	DatasetName *string `locationName:"datasetName" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The data set whose latest contents will be used as input to the notebook or application. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetContentVersionValue

func (DatasetContentVersionValue) GoString added in v0.5.0 

func (s DatasetContentVersionValue) GoString() string

GoString returns the string representation

func (DatasetContentVersionValue) MarshalFields added in v0.5.0 

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

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

func (DatasetContentVersionValue) String added in v0.5.0 

func (s DatasetContentVersionValue) String() string

String returns the string representation

func (*DatasetContentVersionValue) Validate added in v0.5.0 

func (s *DatasetContentVersionValue) Validate() error

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

type DatasetEntry 

type DatasetEntry struct {

	// The pre-signed URI of the data set item.
	DataURI *string `locationName:"dataURI" type:"string"`

	// The name of the data set item.
	EntryName *string `locationName:"entryName" type:"string"`
	// contains filtered or unexported fields
}

The reference to a data set entry. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetEntry

func (DatasetEntry) 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 {

	// A list of "DataActionSummary" objects.
	Actions []DatasetActionSummary `locationName:"actions" min:"1" type:"list"`

	// The time the data set was created.
	CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"`

	// The name of the data set.
	DatasetName *string `locationName:"datasetName" min:"1" type:"string"`

	// The last time the data set was updated.
	LastUpdateTime *time.Time `locationName:"lastUpdateTime" type:"timestamp" timestampFormat:"unix"`

	// The status of the data set.
	Status DatasetStatus `locationName:"status" type:"string" enum:"true"`

	// A list of triggers. A trigger causes data set content to be populated at
	// a specified time interval or when another data set is populated. The list
	// of triggers can be empty or contain up to five DataSetTrigger objects
	Triggers []DatasetTrigger `locationName:"triggers" type:"list"`
	// contains filtered or unexported fields
}

A summary of information about a data set. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetSummary

func (DatasetSummary) 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 data set whose content creation will trigger the creation of this data
	// set's contents.
	Dataset *TriggeringDataset `locationName:"dataset" type:"structure"`

	// The "Schedule" when the trigger is initiated.
	Schedule *Schedule `locationName:"schedule" type:"structure"`
	// contains filtered or unexported fields
}

The "DatasetTrigger" that specifies when the data set is automatically updated. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatasetTrigger

func (DatasetTrigger) 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

func (*DatasetTrigger) Validate added in v0.5.0 

func (s *DatasetTrigger) Validate() error

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

type Datastore 

type Datastore struct {

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

	// When the data store was created.
	CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"`

	// The last time the data store was updated.
	LastUpdateTime *time.Time `locationName:"lastUpdateTime" type:"timestamp" timestampFormat:"unix"`

	// The name of the data store.
	Name *string `locationName:"name" min:"1" type:"string"`

	// How long, in days, message data is kept for the data store.
	RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"`

	// The status of a data store:
	//
	// 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 DatastoreStatistics added in v0.5.0 

type DatastoreStatistics struct {

	// The estimated size of the data store.
	Size *EstimatedResourceSize `locationName:"size" type:"structure"`
	// contains filtered or unexported fields
}

Statistical information about the data store. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatastoreStatistics

func (DatastoreStatistics) GoString added in v0.5.0 

func (s DatastoreStatistics) GoString() string

GoString returns the string representation

func (DatastoreStatistics) MarshalFields added in v0.5.0 

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

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

func (DatastoreStatistics) String added in v0.5.0 

func (s DatastoreStatistics) String() string

String returns the string representation

type DatastoreStatus 

type DatastoreStatus string
const (
	DatastoreStatusCreating DatastoreStatus = "CREATING"
	DatastoreStatusActive   DatastoreStatus = "ACTIVE"
	DatastoreStatusDeleting DatastoreStatus = "DELETING"
)

Enum values for DatastoreStatus

func (DatastoreStatus) MarshalValue 

func (enum DatastoreStatus) MarshalValue() (string, error)

func (DatastoreStatus) MarshalValueBuf 

func (enum DatastoreStatus) MarshalValueBuf(b []byte) ([]byte, error)

type DatastoreSummary 

type DatastoreSummary struct {

	// When the data store was created.
	CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"`

	// The name of the data store.
	DatastoreName *string `locationName:"datastoreName" min:"1" type:"string"`

	// The last time the data store was updated.
	LastUpdateTime *time.Time `locationName:"lastUpdateTime" type:"timestamp" timestampFormat:"unix"`

	// The status of the data store.
	Status DatastoreStatus `locationName:"status" type:"string" enum:"true"`
	// contains filtered or unexported fields
}

A summary of information about a data store. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DatastoreSummary

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

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

func (DeleteDatasetContentInput) 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 DeltaTime added in v0.5.0 

type DeltaTime struct {

	// The number of seconds of estimated "in flight" lag time of message data.
	//
	// OffsetSeconds is a required field
	OffsetSeconds *int64 `locationName:"offsetSeconds" type:"integer" required:"true"`

	// An expression by which the time of the message data may be determined. This
	// may be the name of a timestamp field, or a SQL expression which is used to
	// derive the time the message data was generated.
	//
	// TimeExpression is a required field
	TimeExpression *string `locationName:"timeExpression" type:"string" required:"true"`
	// contains filtered or unexported fields
}

When you create data set contents using message data from a specified time frame, some message data may still be "in flight" when processing begins, and so will not arrive in time to be processed. Use this field to make allowances for the "in flight" time of your message data, so that data not processed from the previous time frame will be included with the next time frame. Without this, missed message data would be excluded from processing during the next time frame as well, because its timestamp places it within the previous time frame. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/DeltaTime

func (DeltaTime) GoString added in v0.5.0 

func (s DeltaTime) GoString() string

GoString returns the string representation

func (DeltaTime) MarshalFields added in v0.5.0 

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

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

func (DeltaTime) String added in v0.5.0 

func (s DeltaTime) String() string

String returns the string representation

func (*DeltaTime) Validate added in v0.5.0 

func (s *DeltaTime) Validate() error

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

type DescribeChannelInput 

type DescribeChannelInput struct {

	// The name of the channel whose information is retrieved.
	//
	// ChannelName is a required field
	ChannelName *string `location:"uri" locationName:"channelName" min:"1" type:"string" required:"true"`

	// If true, additional statistical information about the channel is included
	// in the response.
	IncludeStatistics *bool `location:"querystring" locationName:"includeStatistics" type:"boolean"`
	// contains filtered or unexported fields
}

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

func (DescribeChannelInput) 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"`

	// Statistics about the channel. Included if the 'includeStatistics' parameter
	// is set to true in the request.
	Statistics *ChannelStatistics `locationName:"statistics" type:"structure"`
	// contains filtered or unexported fields
}

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

func (DescribeChannelOutput) 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"`

	// If true, additional statistical information about the datastore is included
	// in the response.
	IncludeStatistics *bool `location:"querystring" locationName:"includeStatistics" type:"boolean"`
	// contains filtered or unexported fields
}

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

func (DescribeDatastoreInput) 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"`

	// Additional statistical information about the data store. Included if the
	// 'includeStatistics' parameter is set to true in the request.
	Statistics *DatastoreStatistics `locationName:"statistics" type:"structure"`
	// contains filtered or unexported fields
}

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

func (DescribeDatastoreOutput) 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 EstimatedResourceSize added in v0.5.0 

type EstimatedResourceSize struct {

	// The time when the estimate of the size of the resource was made.
	EstimatedOn *time.Time `locationName:"estimatedOn" type:"timestamp" timestampFormat:"unix"`

	// The estimated size of the resource in bytes.
	EstimatedSizeInBytes *float64 `locationName:"estimatedSizeInBytes" type:"double"`
	// contains filtered or unexported fields
}

The estimated size of the resource. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/EstimatedResourceSize

func (EstimatedResourceSize) GoString added in v0.5.0 

func (s EstimatedResourceSize) GoString() string

GoString returns the string representation

func (EstimatedResourceSize) MarshalFields added in v0.5.0 

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

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

func (EstimatedResourceSize) String added in v0.5.0 

func (s EstimatedResourceSize) String() string

String returns the string representation

type FilterActivity 

type FilterActivity struct {

	// An expression that looks like a SQL WHERE clause that must return a Boolean
	// value.
	//
	// Filter is a required field
	Filter *string `locationName:"filter" min:"1" type:"string" required:"true"`

	// The name of the 'filter' activity.
	//
	// Name is a required field
	Name *string `locationName:"name" min:"1" type:"string" required:"true"`

	// The next activity in the pipeline.
	Next *string `locationName:"next" min:"1" type:"string"`
	// contains filtered or unexported fields
}

An activity that filters a message based on its attributes. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/FilterActivity

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

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

func (GetDatasetContentInput) 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 a 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 a "queryAction" (a SQL query) or a "containerAction" (executing a containerized application). This operation creates the skeleton of a data set. The data set can be populated manually by calling "CreateDatasetContent" or automatically according to a "trigger" you specify. 

// Example sending a request using 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) ListDatasetContentsRequest added in v0.5.0 

func (c *IoTAnalytics) ListDatasetContentsRequest(input *ListDatasetContentsInput) ListDatasetContentsRequest

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

Lists information about data set contents that have been created. 

// Example sending a request using the ListDatasetContentsRequest method.
req := client.ListDatasetContentsRequest(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/ListDatasetContents

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) ListTagsForResourceRequest added in v0.5.0 

func (c *IoTAnalytics) ListTagsForResourceRequest(input *ListTagsForResourceInput) ListTagsForResourceRequest

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

Lists the tags (metadata) which you have assigned to the resource. 

// Example sending a request using the ListTagsForResourceRequest method.
req := client.ListTagsForResourceRequest(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/ListTagsForResource

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.

Note that if you update the value of any loggingOptions field, it takes up to one minute for the change to take effect. Also, if you change the policy attached to the role you specified in the roleArn field (for example, to correct an invalid policy) it takes up to 5 minutes for that change to take effect. 

// Example sending a request using 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) TagResourceRequest added in v0.5.0 

func (c *IoTAnalytics) TagResourceRequest(input *TagResourceInput) TagResourceRequest

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

Adds to or modifies the tags of the given resource. Tags are metadata which can be used to manage a resource. 

// Example sending a request using the TagResourceRequest method.
req := client.TagResourceRequest(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/TagResource

func (*IoTAnalytics) UntagResourceRequest added in v0.5.0 

func (c *IoTAnalytics) UntagResourceRequest(input *UntagResourceInput) UntagResourceRequest

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

Removes the given tags (metadata) from the resource. 

// Example sending a request using the UntagResourceRequest method.
req := client.UntagResourceRequest(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/UntagResource

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 IotEventsDestinationConfiguration added in v0.6.0 

type IotEventsDestinationConfiguration struct {

	// InputName is a required field
	InputName *string `locationName:"inputName" min:"1" type:"string" required:"true"`

	// RoleArn is a required field
	RoleArn *string `locationName:"roleArn" min:"20" type:"string" required:"true"`
	// contains filtered or unexported fields
}

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

func (IotEventsDestinationConfiguration) GoString added in v0.6.0 

func (s IotEventsDestinationConfiguration) GoString() string

GoString returns the string representation

func (IotEventsDestinationConfiguration) MarshalFields added in v0.6.0 

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

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

func (IotEventsDestinationConfiguration) String added in v0.6.0 

func (s IotEventsDestinationConfiguration) String() string

String returns the string representation

func (*IotEventsDestinationConfiguration) Validate added in v0.6.0 

func (s *IotEventsDestinationConfiguration) Validate() error

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

type LambdaActivity 

type LambdaActivity struct {

	// The number of messages passed to the Lambda function for processing.
	//
	// The AWS Lambda function must be able to process all of these messages within
	// five minutes, which is the maximum timeout duration for Lambda functions.
	//
	// BatchSize is a required field
	BatchSize *int64 `locationName:"batchSize" min:"1" type:"integer" required:"true"`

	// The name of the Lambda function that is run on the message.
	//
	// LambdaName is a required field
	LambdaName *string `locationName:"lambdaName" min:"1" type:"string" required:"true"`

	// The name of the 'lambda' activity.
	//
	// Name is a required field
	Name *string `locationName:"name" min:"1" type:"string" required:"true"`

	// The next activity in the pipeline.
	Next *string `locationName:"next" min:"1" type:"string"`
	// contains filtered or unexported fields
}

An activity that runs a Lambda function to modify the message. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/LambdaActivity

func (LambdaActivity) 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 ListDatasetContentsInput added in v0.5.0 

type ListDatasetContentsInput struct {

	// The name of the data set whose contents information you want to list.
	//
	// DatasetName is a required field
	DatasetName *string `location:"uri" locationName:"datasetName" min:"1" type:"string" required:"true"`

	// The maximum number of results to return in this request.
	MaxResults *int64 `location:"querystring" locationName:"maxResults" min:"1" type:"integer"`

	// The token for the next set of results.
	NextToken *string `location:"querystring" locationName:"nextToken" type:"string"`
	// contains filtered or unexported fields
}

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

func (ListDatasetContentsInput) GoString added in v0.5.0 

func (s ListDatasetContentsInput) GoString() string

GoString returns the string representation

func (ListDatasetContentsInput) MarshalFields added in v0.5.0 

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

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

func (ListDatasetContentsInput) String added in v0.5.0 

func (s ListDatasetContentsInput) String() string

String returns the string representation

func (*ListDatasetContentsInput) Validate added in v0.5.0 

func (s *ListDatasetContentsInput) Validate() error

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

type ListDatasetContentsOutput added in v0.5.0 

type ListDatasetContentsOutput struct {

	// Summary information about data set contents that have been created.
	DatasetContentSummaries []DatasetContentSummary `locationName:"datasetContentSummaries" type:"list"`

	// The token to retrieve the next set of results, or null if there are no more
	// results.
	NextToken *string `locationName:"nextToken" type:"string"`
	// contains filtered or unexported fields
}

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

func (ListDatasetContentsOutput) GoString added in v0.5.0 

func (s ListDatasetContentsOutput) GoString() string

GoString returns the string representation

func (ListDatasetContentsOutput) MarshalFields added in v0.5.0 

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

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

func (ListDatasetContentsOutput) SDKResponseMetadata added in v0.5.0 

func (s ListDatasetContentsOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

func (ListDatasetContentsOutput) String added in v0.5.0 

func (s ListDatasetContentsOutput) String() string

String returns the string representation

type ListDatasetContentsPager added in v0.5.0 

type ListDatasetContentsPager struct {
	aws.Pager
}

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

func (*ListDatasetContentsPager) CurrentPage added in v0.5.0 

func (p *ListDatasetContentsPager) CurrentPage() *ListDatasetContentsOutput

type ListDatasetContentsRequest added in v0.5.0 

type ListDatasetContentsRequest struct {
	*aws.Request
	Input *ListDatasetContentsInput
	Copy  func(*ListDatasetContentsInput) ListDatasetContentsRequest
}

ListDatasetContentsRequest is a API request type for the ListDatasetContents API operation.

func (*ListDatasetContentsRequest) Paginate added in v0.5.0 

func (p *ListDatasetContentsRequest) Paginate(opts ...aws.Option) ListDatasetContentsPager

Paginate pages iterates over the pages of a ListDatasetContentsRequest 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 ListDatasetContents operation.
		req := client.ListDatasetContentsRequest(input)
		p := req.Paginate()
		for p.Next() {
			page := p.CurrentPage()
		}

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

func (ListDatasetContentsRequest) Send added in v0.5.0 

func (r ListDatasetContentsRequest) Send() (*ListDatasetContentsOutput, error)

Send marshals and sends the ListDatasetContents 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 ListTagsForResourceInput added in v0.5.0 

type ListTagsForResourceInput struct {

	// The ARN of the resource whose tags you want to list.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"querystring" locationName:"resourceArn" min:"20" type:"string" required:"true"`
	// contains filtered or unexported fields
}

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

func (ListTagsForResourceInput) GoString added in v0.5.0 

func (s ListTagsForResourceInput) GoString() string

GoString returns the string representation

func (ListTagsForResourceInput) MarshalFields added in v0.5.0 

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

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

func (ListTagsForResourceInput) String added in v0.5.0 

func (s ListTagsForResourceInput) String() string

String returns the string representation

func (*ListTagsForResourceInput) Validate added in v0.5.0 

func (s *ListTagsForResourceInput) Validate() error

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

type ListTagsForResourceOutput added in v0.5.0 

type ListTagsForResourceOutput struct {

	// The tags (metadata) which you have assigned to the resource.
	Tags []Tag `locationName:"tags" min:"1" type:"list"`
	// contains filtered or unexported fields
}

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

func (ListTagsForResourceOutput) GoString added in v0.5.0 

func (s ListTagsForResourceOutput) GoString() string

GoString returns the string representation

func (ListTagsForResourceOutput) MarshalFields added in v0.5.0 

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

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

func (ListTagsForResourceOutput) SDKResponseMetadata added in v0.5.0 

func (s ListTagsForResourceOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

func (ListTagsForResourceOutput) String added in v0.5.0 

func (s ListTagsForResourceOutput) String() string

String returns the string representation

type ListTagsForResourceRequest added in v0.5.0 

type ListTagsForResourceRequest struct {
	*aws.Request
	Input *ListTagsForResourceInput
	Copy  func(*ListTagsForResourceInput) ListTagsForResourceRequest
}

ListTagsForResourceRequest is a API request type for the ListTagsForResource API operation.

func (ListTagsForResourceRequest) Send added in v0.5.0 

func (r ListTagsForResourceRequest) Send() (*ListTagsForResourceOutput, error)

Send marshals and sends the ListTagsForResource 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. Each "messageId" must be unique
	// within each batch sent.
	//
	// MessageId is a required field
	MessageId *string `locationName:"messageId" min:"1" type:"string" required:"true"`

	// The payload of the message. This may be a JSON string or a Base64-encoded
	// string representing binary data (in which case you must decode it by means
	// of a pipeline activity).
	//
	// Payload is automatically base64 encoded/decoded by the SDK.
	//
	// Payload is a required field
	Payload []byte `locationName:"payload" type:"blob" required:"true"`
	// contains filtered or unexported fields
}

Information about a message. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/Message

func (Message) 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 OutputFileUriValue added in v0.5.0 

type OutputFileUriValue struct {

	// The URI of the location where data set contents are stored, usually the URI
	// of a file in an S3 bucket.
	//
	// FileName is a required field
	FileName *string `locationName:"fileName" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The URI of the location where data set contents are stored, usually the URI of a file in an S3 bucket. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/OutputFileUriValue

func (OutputFileUriValue) GoString added in v0.5.0 

func (s OutputFileUriValue) GoString() string

GoString returns the string representation

func (OutputFileUriValue) MarshalFields added in v0.5.0 

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

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

func (OutputFileUriValue) String added in v0.5.0 

func (s OutputFileUriValue) String() string

String returns the string representation

func (*OutputFileUriValue) Validate added in v0.5.0 

func (s *OutputFileUriValue) Validate() error

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

type Pipeline 

type Pipeline struct {

	// The activities that perform transformations on the messages.
	Activities []PipelineActivity `locationName:"activities" min:"1" type:"list"`

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

	// When the pipeline was created.
	CreationTime *time.Time `locationName:"creationTime" type:"timestamp" timestampFormat:"unix"`

	// The last time the pipeline was updated.
	LastUpdateTime *time.Time `locationName:"lastUpdateTime" type:"timestamp" timestampFormat:"unix"`

	// The name of the pipeline.
	Name *string `locationName:"name" min:"1" type:"string"`

	// A summary of information about the pipeline reprocessing.
	ReprocessingSummaries []ReprocessingSummary `locationName:"reprocessingSummaries" type:"list"`
	// contains filtered or unexported fields
}

Contains information about a pipeline. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/Pipeline

func (Pipeline) 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 QueryFilter added in v0.5.0 

type QueryFilter struct {

	// Used to limit data to that which has arrived since the last execution of
	// the action. When you create data set contents using message data from a specified
	// time frame, some message data may still be "in flight" when processing begins,
	// and so will not arrive in time to be processed. Use this field to make allowances
	// for the "in flight" time of you message data, so that data not processed
	// from a previous time frame will be included with the next time frame. Without
	// this, missed message data would be excluded from processing during the next
	// time frame as well, because its timestamp places it within the previous time
	// frame.
	DeltaTime *DeltaTime `locationName:"deltaTime" type:"structure"`
	// contains filtered or unexported fields
}

Information which is used to filter message data, to segregate it according to the time frame in which it arrives. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/QueryFilter

func (QueryFilter) GoString added in v0.5.0 

func (s QueryFilter) GoString() string

GoString returns the string representation

func (QueryFilter) MarshalFields added in v0.5.0 

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

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

func (QueryFilter) String added in v0.5.0 

func (s QueryFilter) String() string

String returns the string representation

func (*QueryFilter) Validate added in v0.5.0 

func (s *QueryFilter) Validate() error

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

type RemoveAttributesActivity 

type RemoveAttributesActivity struct {

	// A list of 1-50 attributes to remove from the message.
	//
	// Attributes is a required field
	Attributes []string `locationName:"attributes" min:"1" type:"list" required:"true"`

	// The name of the 'removeAttributes' activity.
	//
	// Name is a required field
	Name *string `locationName:"name" min:"1" type:"string" required:"true"`

	// The next activity in the pipeline.
	Next *string `locationName:"next" min:"1" type:"string"`
	// contains filtered or unexported fields
}

An activity that removes attributes from a message. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/RemoveAttributesActivity

func (RemoveAttributesActivity) 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 ResourceConfiguration added in v0.5.0 

type ResourceConfiguration struct {

	// The type of the compute resource used to execute the "containerAction". Possible
	// values are: ACU_1 (vCPU=4, memory=16GiB) or ACU_2 (vCPU=8, memory=32GiB).
	//
	// ComputeType is a required field
	ComputeType ComputeType `locationName:"computeType" type:"string" required:"true" enum:"true"`

	// The size (in GB) of the persistent storage available to the resource instance
	// used to execute the "containerAction" (min: 1, max: 50).
	//
	// VolumeSizeInGB is a required field
	VolumeSizeInGB *int64 `locationName:"volumeSizeInGB" min:"1" type:"integer" required:"true"`
	// contains filtered or unexported fields
}

The configuration of the resource used to execute the "containerAction". Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/ResourceConfiguration

func (ResourceConfiguration) GoString added in v0.5.0 

func (s ResourceConfiguration) GoString() string

GoString returns the string representation

func (ResourceConfiguration) MarshalFields added in v0.5.0 

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

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

func (ResourceConfiguration) String added in v0.5.0 

func (s ResourceConfiguration) String() string

String returns the string representation

func (*ResourceConfiguration) Validate added in v0.5.0 

func (s *ResourceConfiguration) Validate() error

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

type RetentionPeriod 

type RetentionPeriod struct {

	// The number of days that message data is kept. The "unlimited" parameter must
	// be false.
	NumberOfDays *int64 `locationName:"numberOfDays" min:"1" type:"integer"`

	// If true, message data is kept indefinitely.
	Unlimited *bool `locationName:"unlimited" type:"boolean"`
	// contains filtered or unexported fields
}

How long, in days, message data is kept. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/RetentionPeriod

func (RetentionPeriod) 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 {

	// Pre-filters applied to message data.
	Filters []QueryFilter `locationName:"filters" type:"list"`

	// A SQL query string.
	//
	// SqlQuery is a required field
	SqlQuery *string `locationName:"sqlQuery" type:"string" required:"true"`
	// contains filtered or unexported fields
}

The SQL query to modify the message. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/SqlQueryDatasetAction

func (SqlQueryDatasetAction) 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 Tag added in v0.5.0 

type Tag struct {

	// The tag's key.
	//
	// Key is a required field
	Key *string `locationName:"key" min:"1" type:"string" required:"true"`

	// The tag's value.
	//
	// Value is a required field
	Value *string `locationName:"value" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

A set of key/value pairs which are used to manage the resource. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/Tag

func (Tag) GoString added in v0.5.0 

func (s Tag) GoString() string

GoString returns the string representation

func (Tag) MarshalFields added in v0.5.0 

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

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

func (Tag) String added in v0.5.0 

func (s Tag) String() string

String returns the string representation

func (*Tag) Validate added in v0.5.0 

func (s *Tag) Validate() error

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

type TagResourceInput added in v0.5.0 

type TagResourceInput struct {

	// The ARN of the resource whose tags will be modified.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"querystring" locationName:"resourceArn" min:"20" type:"string" required:"true"`

	// The new or modified tags for the resource.
	//
	// Tags is a required field
	Tags []Tag `locationName:"tags" min:"1" type:"list" required:"true"`
	// contains filtered or unexported fields
}

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

func (TagResourceInput) GoString added in v0.5.0 

func (s TagResourceInput) GoString() string

GoString returns the string representation

func (TagResourceInput) MarshalFields added in v0.5.0 

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

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

func (TagResourceInput) String added in v0.5.0 

func (s TagResourceInput) String() string

String returns the string representation

func (*TagResourceInput) Validate added in v0.5.0 

func (s *TagResourceInput) Validate() error

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

type TagResourceOutput added in v0.5.0 

type TagResourceOutput struct {
	// contains filtered or unexported fields
}

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

func (TagResourceOutput) GoString added in v0.5.0 

func (s TagResourceOutput) GoString() string

GoString returns the string representation

func (TagResourceOutput) MarshalFields added in v0.5.0 

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

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

func (TagResourceOutput) SDKResponseMetadata added in v0.5.0 

func (s TagResourceOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

func (TagResourceOutput) String added in v0.5.0 

func (s TagResourceOutput) String() string

String returns the string representation

type TagResourceRequest added in v0.5.0 

type TagResourceRequest struct {
	*aws.Request
	Input *TagResourceInput
	Copy  func(*TagResourceInput) TagResourceRequest
}

TagResourceRequest is a API request type for the TagResource API operation.

func (TagResourceRequest) Send added in v0.5.0 

func (r TagResourceRequest) Send() (*TagResourceOutput, error)

Send marshals and sends the TagResource API request.

type TriggeringDataset added in v0.5.0 

type TriggeringDataset struct {

	// The name of the data set whose content generation will trigger the new data
	// set content generation.
	//
	// Name is a required field
	Name *string `locationName:"name" min:"1" type:"string" required:"true"`
	// contains filtered or unexported fields
}

Information about the data set whose content generation will trigger the new data set content generation. Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/TriggeringDataset

func (TriggeringDataset) GoString added in v0.5.0 

func (s TriggeringDataset) GoString() string

GoString returns the string representation

func (TriggeringDataset) MarshalFields added in v0.5.0 

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

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

func (TriggeringDataset) String added in v0.5.0 

func (s TriggeringDataset) String() string

String returns the string representation

func (*TriggeringDataset) Validate added in v0.5.0 

func (s *TriggeringDataset) Validate() error

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

type UntagResourceInput added in v0.5.0 

type UntagResourceInput struct {

	// The ARN of the resource whose tags will be removed.
	//
	// ResourceArn is a required field
	ResourceArn *string `location:"querystring" locationName:"resourceArn" min:"20" type:"string" required:"true"`

	// The keys of those tags which will be removed.
	//
	// TagKeys is a required field
	TagKeys []string `location:"querystring" locationName:"tagKeys" min:"1" type:"list" required:"true"`
	// contains filtered or unexported fields
}

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

func (UntagResourceInput) GoString added in v0.5.0 

func (s UntagResourceInput) GoString() string

GoString returns the string representation

func (UntagResourceInput) MarshalFields added in v0.5.0 

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

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

func (UntagResourceInput) String added in v0.5.0 

func (s UntagResourceInput) String() string

String returns the string representation

func (*UntagResourceInput) Validate added in v0.5.0 

func (s *UntagResourceInput) Validate() error

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

type UntagResourceOutput added in v0.5.0 

type UntagResourceOutput struct {
	// contains filtered or unexported fields
}

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

func (UntagResourceOutput) GoString added in v0.5.0 

func (s UntagResourceOutput) GoString() string

GoString returns the string representation

func (UntagResourceOutput) MarshalFields added in v0.5.0 

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

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

func (UntagResourceOutput) SDKResponseMetadata added in v0.5.0 

func (s UntagResourceOutput) SDKResponseMetadata() aws.Response

SDKResponseMetdata return sthe response metadata for the API.

func (UntagResourceOutput) String added in v0.5.0 

func (s UntagResourceOutput) String() string

String returns the string representation

type UntagResourceRequest added in v0.5.0 

type UntagResourceRequest struct {
	*aws.Request
	Input *UntagResourceInput
	Copy  func(*UntagResourceInput) UntagResourceRequest
}

UntagResourceRequest is a API request type for the UntagResource API operation.

func (UntagResourceRequest) Send added in v0.5.0 

func (r UntagResourceRequest) Send() (*UntagResourceOutput, error)

Send marshals and sends the UntagResource 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.
	//
	// Actions is a required field
	Actions []DatasetAction `locationName:"actions" min:"1" type:"list" required:"true"`

	ContentDeliveryRules []DatasetContentDeliveryRule `locationName:"contentDeliveryRules" type:"list"`

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

	// How long, in days, message data is kept for the data set.
	RetentionPeriod *RetentionPeriod `locationName:"retentionPeriod" type:"structure"`

	// A list of "DatasetTrigger" objects. The list can be empty or can contain
	// up to five DataSetTrigger objects.
	Triggers []DatasetTrigger `locationName:"triggers" type:"list"`
	// 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.

type Variable added in v0.5.0 

type Variable struct {

	// The value of the variable as a structure that specifies a data set content
	// version.
	DatasetContentVersionValue *DatasetContentVersionValue `locationName:"datasetContentVersionValue" type:"structure"`

	// The value of the variable as a double (numeric).
	DoubleValue *float64 `locationName:"doubleValue" type:"double"`

	// The name of the variable.
	//
	// Name is a required field
	Name *string `locationName:"name" min:"1" type:"string" required:"true"`

	// The value of the variable as a structure that specifies an output file URI.
	OutputFileUriValue *OutputFileUriValue `locationName:"outputFileUriValue" type:"structure"`

	// The value of the variable as a string.
	StringValue *string `locationName:"stringValue" type:"string"`
	// contains filtered or unexported fields
}

An instance of a variable to be passed to the "containerAction" execution. Each variable must have a name and a value given by one of "stringValue", "datasetContentVersionValue", or "outputFileUriValue". Please also see https://docs.aws.amazon.com/goto/WebAPI/iotanalytics-2017-11-27/Variable

func (Variable) GoString added in v0.5.0 

func (s Variable) GoString() string

GoString returns the string representation

func (Variable) MarshalFields added in v0.5.0 

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

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

func (Variable) String added in v0.5.0 

func (s Variable) String() string

String returns the string representation

func (*Variable) Validate added in v0.5.0 

func (s *Variable) Validate() error

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

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.