types

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 .
	//
	// This member is required.
	Attributes map[string]string

	// The name of the addAttributes activity.
	//
	// This member is required.
	Name *string

	// The next activity in the pipeline.
	Next *string
	// contains filtered or unexported fields
}

type BatchPutMessageErrorEntry struct {

	// The code associated with the error.
	ErrorCode *string

	// The message associated with the error.
	ErrorMessage *string

	// The ID of the message that caused the error. See the value corresponding to the
	// messageId key in the message object.
	MessageId *string
	// contains filtered or unexported fields
}

type Channel struct {

	// The ARN of the channel.
	Arn *string

	// When the channel was created.
	CreationTime *time.Time

	// The last time when a new message arrived in the channel. IoT Analytics updates
	// this value at most once per minute for one channel. Hence, the
	// lastMessageArrivalTime value is an approximation. This feature only applies to
	// messages that arrived in the data store after October 23, 2020.
	LastMessageArrivalTime *time.Time

	// When the channel was last updated.
	LastUpdateTime *time.Time

	// The name of the channel.
	Name *string

	// How long, in days, message data is kept for the channel.
	RetentionPeriod *RetentionPeriod

	// The status of the channel.
	Status ChannelStatus

	// Where channel data is stored. You can choose one of serviceManagedS3 or
	// customerManagedS3 storage. If not specified, the default is serviceManagedS3 .
	// You can't change this storage option after the channel is created.
	Storage *ChannelStorage
	// contains filtered or unexported fields
}

type ChannelActivity struct {

	// The name of the channel from which the messages are processed.
	//
	// This member is required.
	ChannelName *string

	// The name of the channel activity.
	//
	// This member is required.
	Name *string

	// The next activity in the pipeline.
	Next *string
	// contains filtered or unexported fields
}

type ChannelMessages struct {

	// Specifies one or more keys that identify the Amazon Simple Storage Service
	// (Amazon S3) objects that save your channel messages. You must use the full path
	// for the key. Example path: channel/mychannel/__dt=2020-02-29
	// 00:00:00/1582940490000_1582940520000_123456789012_mychannel_0_2118.0.json.gz
	S3Paths []string
	// contains filtered or unexported fields
}

type ChannelStatistics struct {

	// The estimated size of the channel.
	Size *EstimatedResourceSize
	// contains filtered or unexported fields
}

type ChannelStatus string

type ChannelStorage struct {

	// Used to store channel data in an S3 bucket that you manage. If customer managed
	// storage is selected, the retentionPeriod parameter is ignored. You can't change
	// the choice of S3 storage after the data store is created.
	CustomerManagedS3 *CustomerManagedChannelS3Storage

	// Used to store channel data in an S3 bucket managed by IoT Analytics. You can't
	// change the choice of S3 storage after the data store is created.
	ServiceManagedS3 *ServiceManagedChannelS3Storage
	// contains filtered or unexported fields
}

type ChannelStorageSummary struct {

	// Used to store channel data in an S3 bucket that you manage.
	CustomerManagedS3 *CustomerManagedChannelS3StorageSummary

	// Used to store channel data in an S3 bucket managed by IoT Analytics.
	ServiceManagedS3 *ServiceManagedChannelS3StorageSummary
	// contains filtered or unexported fields
}

type ChannelSummary struct {

	// The name of the channel.
	ChannelName *string

	// Where channel data is stored.
	ChannelStorage *ChannelStorageSummary

	// When the channel was created.
	CreationTime *time.Time

	// The last time when a new message arrived in the channel. IoT Analytics updates
	// this value at most once per minute for one channel. Hence, the
	// lastMessageArrivalTime value is an approximation. This feature only applies to
	// messages that arrived in the data store after October 23, 2020.
	LastMessageArrivalTime *time.Time

	// The last time the channel was updated.
	LastUpdateTime *time.Time

	// The status of the channel.
	Status ChannelStatus
	// contains filtered or unexported fields
}

type Column struct {

	// The name of the column.
	//
	// This member is required.
	Name *string

	// The type of data. For more information about the supported data types, see
	// Common data types (https://docs.aws.amazon.com/glue/latest/dg/aws-glue-api-common.html)
	// in the Glue Developer Guide.
	//
	// This member is required.
	Type *string
	// contains filtered or unexported fields
}

type ComputeType string

type ContainerDatasetAction struct {

	// The ARN of the role that gives permission to the system to access required
	// resources to run the containerAction . This includes, at minimum, permission to
	// retrieve the dataset contents that are the input to the containerized
	// application.
	//
	// This member is required.
	ExecutionRoleArn *string

	// The ARN of the Docker container stored in your account. The Docker container
	// contains an application and required support libraries and is used to generate
	// dataset contents.
	//
	// This member is required.
	Image *string

	// Configuration of the resource that executes the containerAction .
	//
	// This member is required.
	ResourceConfiguration *ResourceConfiguration

	// The values of variables used in 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
	// contains filtered or unexported fields
}

type CustomerManagedChannelS3Storage struct {

	// The name of the S3 bucket in which channel data is stored.
	//
	// This member is required.
	Bucket *string

	// The ARN of the role that grants IoT Analytics permission to interact with your
	// Amazon S3 resources.
	//
	// This member is required.
	RoleArn *string

	// (Optional) The prefix used to create the keys of the channel data objects. Each
	// object in an S3 bucket has a key that is its unique identifier in the bucket.
	// Each object in a bucket has exactly one key. The prefix must end with a forward
	// slash (/).
	KeyPrefix *string
	// contains filtered or unexported fields
}

type CustomerManagedChannelS3StorageSummary struct {

	// The name of the S3 bucket in which channel data is stored.
	Bucket *string

	// (Optional) The prefix used to create the keys of the channel data objects. Each
	// object in an S3 bucket has a key that is its unique identifier within the bucket
	// (each object in a bucket has exactly one key). The prefix must end with a
	// forward slash (/).
	KeyPrefix *string

	// The ARN of the role that grants IoT Analytics permission to interact with your
	// Amazon S3 resources.
	RoleArn *string
	// contains filtered or unexported fields
}

type CustomerManagedDatastoreS3Storage struct {

	// The name of the Amazon S3 bucket where your data is stored.
	//
	// This member is required.
	Bucket *string

	// The ARN of the role that grants IoT Analytics permission to interact with your
	// Amazon S3 resources.
	//
	// This member is required.
	RoleArn *string

	// (Optional) The prefix used to create the keys of the data store data objects.
	// Each object in an Amazon S3 bucket has a key that is its unique identifier in
	// the bucket. Each object in a bucket has exactly one key. The prefix must end
	// with a forward slash (/).
	KeyPrefix *string
	// contains filtered or unexported fields
}

type CustomerManagedDatastoreS3StorageSummary struct {

	// The name of the Amazon S3 bucket where your data is stored.
	Bucket *string

	// (Optional) The prefix used to create the keys of the data store data objects.
	// Each object in an Amazon S3 bucket has a key that is its unique identifier in
	// the bucket. Each object in a bucket has exactly one key. The prefix must end
	// with a forward slash (/).
	KeyPrefix *string

	// The ARN of the role that grants IoT Analytics permission to interact with your
	// Amazon S3 resources.
	RoleArn *string
	// contains filtered or unexported fields
}

type Dataset struct {

	// The DatasetAction objects that automatically create the dataset contents.
	Actions []DatasetAction

	// The ARN of the dataset.
	Arn *string

	// When dataset contents are created they are delivered to destinations specified
	// here.
	ContentDeliveryRules []DatasetContentDeliveryRule

	// When the dataset was created.
	CreationTime *time.Time

	// The last time the dataset was updated.
	LastUpdateTime *time.Time

	// A list of data rules that send notifications to CloudWatch, when data arrives
	// late. To specify lateDataRules , the dataset must use a DeltaTimer (https://docs.aws.amazon.com/iotanalytics/latest/APIReference/API_DeltaTime.html)
	// filter.
	LateDataRules []LateDataRule

	// The name of the dataset.
	Name *string

	// Optional. How long, in days, message data is kept for the dataset.
	RetentionPeriod *RetentionPeriod

	// The status of the dataset.
	Status DatasetStatus

	// The DatasetTrigger objects that specify when the dataset is automatically
	// updated.
	Triggers []DatasetTrigger

	// Optional. How many versions of dataset contents are kept. If not specified or
	// set to null, only the latest version plus the latest succeeded version (if they
	// are different) are kept for the time period specified by the retentionPeriod
	// parameter. For more information, see Keeping Multiple Versions of IoT Analytics
	// datasets (https://docs.aws.amazon.com/iotanalytics/latest/userguide/getting-started.html#aws-iot-analytics-dataset-versions)
	// in the IoT Analytics User Guide.
	VersioningConfiguration *VersioningConfiguration
	// contains filtered or unexported fields
}

type DatasetAction struct {

	// The name of the dataset action by which dataset contents are automatically
	// created.
	ActionName *string

	// Information that allows the system to run a containerized application to create
	// the dataset contents. The application must be in a Docker container along with
	// any required support libraries.
	ContainerAction *ContainerDatasetAction

	// An SqlQueryDatasetAction object that uses an SQL query to automatically create
	// dataset contents.
	QueryAction *SqlQueryDatasetAction
	// contains filtered or unexported fields
}

type DatasetActionSummary struct {

	// The name of the action that automatically creates the dataset's contents.
	ActionName *string

	// The type of action by which the dataset's contents are automatically created.
	ActionType DatasetActionType
	// contains filtered or unexported fields
}

type DatasetActionType string

type DatasetContentDeliveryDestination struct {

	// Configuration information for delivery of dataset contents to IoT Events.
	IotEventsDestinationConfiguration *IotEventsDestinationConfiguration

	// Configuration information for delivery of dataset contents to Amazon S3.
	S3DestinationConfiguration *S3DestinationConfiguration
	// contains filtered or unexported fields
}

type DatasetContentDeliveryRule struct {

	// The destination to which dataset contents are delivered.
	//
	// This member is required.
	Destination *DatasetContentDeliveryDestination

	// The name of the dataset content delivery rules entry.
	EntryName *string
	// contains filtered or unexported fields
}

type DatasetContentState string

type DatasetContentStatus struct {

	// The reason the dataset contents are in this state.
	Reason *string

	// The state of the dataset contents. Can be one of READY, CREATING, SUCCEEDED, or
	// FAILED.
	State DatasetContentState
	// contains filtered or unexported fields
}

type DatasetContentSummary struct {

	// The time the dataset content status was updated to SUCCEEDED or FAILED.
	CompletionTime *time.Time

	// The actual time the creation of the dataset contents was started.
	CreationTime *time.Time

	// The time the creation of the dataset contents was scheduled to start.
	ScheduleTime *time.Time

	// The status of the dataset contents.
	Status *DatasetContentStatus

	// The version of the dataset contents.
	Version *string
	// contains filtered or unexported fields
}

type DatasetContentVersionValue struct {

	// The name of the dataset whose latest contents are used as input to the notebook
	// or application.
	//
	// This member is required.
	DatasetName *string
	// contains filtered or unexported fields
}

type DatasetEntry struct {

	// The presigned URI of the dataset item.
	DataURI *string

	// The name of the dataset item.
	EntryName *string
	// contains filtered or unexported fields
}

type DatasetStatus string

type DatasetSummary struct {

	// A list of DataActionSummary objects.
	Actions []DatasetActionSummary

	// The time the dataset was created.
	CreationTime *time.Time

	// The name of the dataset.
	DatasetName *string

	// The last time the dataset was updated.
	LastUpdateTime *time.Time

	// The status of the dataset.
	Status DatasetStatus

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

type DatasetTrigger struct {

	// The dataset whose content creation triggers the creation of this dataset's
	// contents.
	Dataset *TriggeringDataset

	// The Schedule when the trigger is initiated.
	Schedule *Schedule
	// contains filtered or unexported fields
}

type Datastore struct {

	// The ARN of the data store.
	Arn *string

	// When the data store was created.
	CreationTime *time.Time

	// Contains information about the partition dimensions in a data store.
	DatastorePartitions *DatastorePartitions

	// Contains the configuration information of file formats. IoT Analytics data
	// stores support JSON and Parquet (https://parquet.apache.org/) . The default file
	// format is JSON. You can specify only one format. You can't change the file
	// format after you create the data store.
	FileFormatConfiguration *FileFormatConfiguration

	// The last time when a new message arrived in the data store. IoT Analytics
	// updates this value at most once per minute for Amazon Simple Storage Service one
	// data store. Hence, the lastMessageArrivalTime value is an approximation. This
	// feature only applies to messages that arrived in the data store after October
	// 23, 2020.
	LastMessageArrivalTime *time.Time

	// The last time the data store was updated.
	LastUpdateTime *time.Time

	// The name of the data store.
	Name *string

	// How long, in days, message data is kept for the data store. When
	// customerManagedS3 storage is selected, this parameter is ignored.
	RetentionPeriod *RetentionPeriod

	// The status of a data store: CREATING The data store is being created. ACTIVE
	// The data store has been created and can be used. DELETING The data store is
	// being deleted.
	Status DatastoreStatus

	// Where data in a data store is stored.. You can choose serviceManagedS3 storage,
	// customerManagedS3 storage, or iotSiteWiseMultiLayerStorage storage. The default
	// is serviceManagedS3 . You can't change the choice of Amazon S3 storage after
	// your data store is created.
	Storage DatastoreStorage
	// contains filtered or unexported fields
}

type DatastoreActivity struct {

	// The name of the data store where processed messages are stored.
	//
	// This member is required.
	DatastoreName *string

	// The name of the datastore activity.
	//
	// This member is required.
	Name *string
	// contains filtered or unexported fields
}

type DatastoreIotSiteWiseMultiLayerStorage struct {

	// Used to store data used by IoT SiteWise in an Amazon S3 bucket that you manage.
	//
	// This member is required.
	CustomerManagedS3Storage *IotSiteWiseCustomerManagedDatastoreS3Storage
	// contains filtered or unexported fields
}

type DatastoreIotSiteWiseMultiLayerStorageSummary struct {

	// Used to store data used by IoT SiteWise in an Amazon S3 bucket that you manage.
	CustomerManagedS3Storage *IotSiteWiseCustomerManagedDatastoreS3StorageSummary
	// contains filtered or unexported fields
}

type DatastorePartition struct {

	// A partition dimension defined by an attributeName .
	AttributePartition *Partition

	// A partition dimension defined by a timestamp attribute.
	TimestampPartition *TimestampPartition
	// contains filtered or unexported fields
}

type DatastorePartitions struct {

	// A list of partition dimensions in a data store.
	Partitions []DatastorePartition
	// contains filtered or unexported fields
}

type DatastoreStatistics struct {

	// The estimated size of the data store.
	Size *EstimatedResourceSize
	// contains filtered or unexported fields
}

type DatastoreStatus string

type DatastoreStorage interface {
	// contains filtered or unexported methods
}

type DatastoreStorageMemberCustomerManagedS3 struct {
	Value CustomerManagedDatastoreS3Storage
	// contains filtered or unexported fields
}

type DatastoreStorageMemberIotSiteWiseMultiLayerStorage struct {
	Value DatastoreIotSiteWiseMultiLayerStorage
	// contains filtered or unexported fields
}

type DatastoreStorageMemberServiceManagedS3 struct {
	Value ServiceManagedDatastoreS3Storage
	// contains filtered or unexported fields
}

type DatastoreStorageSummary struct {

	// Used to store data in an Amazon S3 bucket managed by IoT Analytics.
	CustomerManagedS3 *CustomerManagedDatastoreS3StorageSummary

	// Used to store data used by IoT SiteWise in an Amazon S3 bucket that you manage.
	IotSiteWiseMultiLayerStorage *DatastoreIotSiteWiseMultiLayerStorageSummary

	// Used to store data in an Amazon S3 bucket managed by IoT Analytics.
	ServiceManagedS3 *ServiceManagedDatastoreS3StorageSummary
	// contains filtered or unexported fields
}

type DatastoreSummary struct {

	// When the data store was created.
	CreationTime *time.Time

	// The name of the data store.
	DatastoreName *string

	// Contains information about the partition dimensions in a data store.
	DatastorePartitions *DatastorePartitions

	// Where data in a data store is stored.
	DatastoreStorage *DatastoreStorageSummary

	// The file format of the data in the data store.
	FileFormatType FileFormatType

	// The last time when a new message arrived in the data store. IoT Analytics
	// updates this value at most once per minute for Amazon Simple Storage Service one
	// data store. Hence, the lastMessageArrivalTime value is an approximation. This
	// feature only applies to messages that arrived in the data store after October
	// 23, 2020.
	LastMessageArrivalTime *time.Time

	// The last time the data store was updated.
	LastUpdateTime *time.Time

	// The status of the data store.
	Status DatastoreStatus
	// contains filtered or unexported fields
}

type DeltaTime struct {

	// The number of seconds of estimated in-flight lag time of message data. When you
	// create dataset contents using message data from a specified timeframe, some
	// message data might still be in flight when processing begins, and so do not
	// arrive in time to be processed. Use this field to make allowances for the in
	// flight time of your message data, so that data not processed from a previous
	// timeframe is included with the next timeframe. Otherwise, missed message data
	// would be excluded from processing during the next timeframe too, because its
	// timestamp places it within the previous timeframe.
	//
	// This member is required.
	OffsetSeconds *int32

	// An expression by which the time of the message data might be determined. This
	// can be the name of a timestamp field or a SQL expression that is used to derive
	// the time the message data was generated.
	//
	// This member is required.
	TimeExpression *string
	// contains filtered or unexported fields
}

type DeltaTimeSessionWindowConfiguration struct {

	// A time interval. You can use timeoutInMinutes so that IoT Analytics can batch
	// up late data notifications that have been generated since the last execution.
	// IoT Analytics sends one batch of notifications to Amazon CloudWatch Events at
	// one time. For more information about how to write a timestamp expression, see
	// Date and Time Functions and Operators (https://prestodb.io/docs/0.172/functions/datetime.html)
	// , in the Presto 0.172 Documentation.
	//
	// This member is required.
	TimeoutInMinutes *int32
	// contains filtered or unexported fields
}

type DeviceRegistryEnrichActivity struct {

	// The name of the attribute that is added to the message.
	//
	// This member is required.
	Attribute *string

	// The name of the deviceRegistryEnrich activity.
	//
	// This member is required.
	Name *string

	// The ARN of the role that allows access to the device's registry information.
	//
	// This member is required.
	RoleArn *string

	// The name of the IoT device whose registry information is added to the message.
	//
	// This member is required.
	ThingName *string

	// The next activity in the pipeline.
	Next *string
	// contains filtered or unexported fields
}

type DeviceShadowEnrichActivity struct {

	// The name of the attribute that is added to the message.
	//
	// This member is required.
	Attribute *string

	// The name of the deviceShadowEnrich activity.
	//
	// This member is required.
	Name *string

	// The ARN of the role that allows access to the device's shadow.
	//
	// This member is required.
	RoleArn *string

	// The name of the IoT device whose shadow information is added to the message.
	//
	// This member is required.
	ThingName *string

	// The next activity in the pipeline.
	Next *string
	// contains filtered or unexported fields
}

type EstimatedResourceSize struct {

	// The time when the estimate of the size of the resource was made.
	EstimatedOn *time.Time

	// The estimated size of the resource, in bytes.
	EstimatedSizeInBytes *float64
	// contains filtered or unexported fields
}

type FileFormatConfiguration struct {

	// Contains the configuration information of the JSON format.
	JsonConfiguration *JsonConfiguration

	// Contains the configuration information of the Parquet format.
	ParquetConfiguration *ParquetConfiguration
	// contains filtered or unexported fields
}

type FileFormatType string

type FilterActivity struct {

	// An expression that looks like a SQL WHERE clause that must return a Boolean
	// value. Messages that satisfy the condition are passed to the next activity.
	//
	// This member is required.
	Filter *string

	// The name of the filter activity.
	//
	// This member is required.
	Name *string

	// The next activity in the pipeline.
	Next *string
	// contains filtered or unexported fields
}

type GlueConfiguration struct {

	// The name of the database in your Glue Data Catalog in which the table is
	// located. An Glue Data Catalog database contains metadata tables.
	//
	// This member is required.
	DatabaseName *string

	// The name of the table in your Glue Data Catalog that is used to perform the ETL
	// operations. An Glue Data Catalog table contains partitioned data and
	// descriptions of data sources and targets.
	//
	// This member is required.
	TableName *string
	// contains filtered or unexported fields
}

type InternalFailureException struct {
	Message *string

	ErrorCodeOverride *string
	// contains filtered or unexported fields
}

type InvalidRequestException struct {
	Message *string

	ErrorCodeOverride *string
	// contains filtered or unexported fields
}

type IotEventsDestinationConfiguration struct {

	// The name of the IoT Events input to which dataset contents are delivered.
	//
	// This member is required.
	InputName *string

	// The ARN of the role that grants IoT Analytics permission to deliver dataset
	// contents to an IoT Events input.
	//
	// This member is required.
	RoleArn *string
	// contains filtered or unexported fields
}

type IotSiteWiseCustomerManagedDatastoreS3Storage struct {

	// The name of the Amazon S3 bucket where your data is stored.
	//
	// This member is required.
	Bucket *string

	// (Optional) The prefix used to create the keys of the data store data objects.
	// Each object in an Amazon S3 bucket has a key that is its unique identifier in
	// the bucket. Each object in a bucket has exactly one key. The prefix must end
	// with a forward slash (/).
	KeyPrefix *string
	// contains filtered or unexported fields
}

type IotSiteWiseCustomerManagedDatastoreS3StorageSummary struct {

	// The name of the Amazon S3 bucket where your data is stored.
	Bucket *string

	// (Optional) The prefix used to create the keys of the data store data objects.
	// Each object in an Amazon S3 bucket has a key that is its unique identifier in
	// the bucket. Each object in a bucket has exactly one key. The prefix must end
	// with a forward slash (/).
	KeyPrefix *string
	// contains filtered or unexported fields
}

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

type LambdaActivity struct {

	// The number of messages passed to the Lambda function for processing. The Lambda
	// function must be able to process all of these messages within five minutes,
	// which is the maximum timeout duration for Lambda functions.
	//
	// This member is required.
	BatchSize *int32

	// The name of the Lambda function that is run on the message.
	//
	// This member is required.
	LambdaName *string

	// The name of the lambda activity.
	//
	// This member is required.
	Name *string

	// The next activity in the pipeline.
	Next *string
	// contains filtered or unexported fields
}

type LateDataRule struct {

	// The information needed to configure the late data rule.
	//
	// This member is required.
	RuleConfiguration *LateDataRuleConfiguration

	// The name of the late data rule.
	RuleName *string
	// contains filtered or unexported fields
}

type LateDataRuleConfiguration struct {

	// The information needed to configure a delta time session window.
	DeltaTimeSessionWindowConfiguration *DeltaTimeSessionWindowConfiguration
	// contains filtered or unexported fields
}

type LimitExceededException struct {
	Message *string

	ErrorCodeOverride *string
	// contains filtered or unexported fields
}

type LoggingLevel string

type LoggingOptions struct {

	// If true, logging is enabled for IoT Analytics.
	//
	// This member is required.
	Enabled bool

	// The logging level. Currently, only ERROR is supported.
	//
	// This member is required.
	Level LoggingLevel

	// The ARN of the role that grants permission to IoT Analytics to perform logging.
	//
	// This member is required.
	RoleArn *string
	// contains filtered or unexported fields
}

type MathActivity struct {

	// The name of the attribute that contains the result of the math operation.
	//
	// This member is required.
	Attribute *string

	// An expression that uses one or more existing attributes and must return an
	// integer value.
	//
	// This member is required.
	Math *string

	// The name of the math activity.
	//
	// This member is required.
	Name *string

	// The next activity in the pipeline.
	Next *string
	// contains filtered or unexported fields
}

type Message struct {

	// The ID you want to assign to the message. Each messageId must be unique within
	// each batch sent.
	//
	// This member is required.
	MessageId *string

	// The payload of the message. This can 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.
	//
	// This member is required.
	Payload []byte
	// contains filtered or unexported fields
}

type OutputFileUriValue struct {

	// The URI of the location where dataset contents are stored, usually the URI of a
	// file in an S3 bucket.
	//
	// This member is required.
	FileName *string
	// contains filtered or unexported fields
}

type ParquetConfiguration struct {

	// Information needed to define a schema.
	SchemaDefinition *SchemaDefinition
	// contains filtered or unexported fields
}

type Partition struct {

	// The name of the attribute that defines a partition dimension.
	//
	// This member is required.
	AttributeName *string
	// contains filtered or unexported fields
}

type Pipeline struct {

	// The activities that perform transformations on the messages.
	Activities []PipelineActivity

	// The ARN of the pipeline.
	Arn *string

	// When the pipeline was created.
	CreationTime *time.Time

	// The last time the pipeline was updated.
	LastUpdateTime *time.Time

	// The name of the pipeline.
	Name *string

	// A summary of information about the pipeline reprocessing.
	ReprocessingSummaries []ReprocessingSummary
	// contains filtered or unexported fields
}

type PipelineActivity struct {

	// Adds other attributes based on existing attributes in the message.
	AddAttributes *AddAttributesActivity

	// Determines the source of the messages to be processed.
	Channel *ChannelActivity

	// Specifies where to store the processed message data.
	Datastore *DatastoreActivity

	// Adds data from the IoT device registry to your message.
	DeviceRegistryEnrich *DeviceRegistryEnrichActivity

	// Adds information from the IoT Device Shadow service to a message.
	DeviceShadowEnrich *DeviceShadowEnrichActivity

	// Filters a message based on its attributes.
	Filter *FilterActivity

	// Runs a Lambda function to modify the message.
	Lambda *LambdaActivity

	// Computes an arithmetic expression using the message's attributes and adds it to
	// the message.
	Math *MathActivity

	// Removes attributes from a message.
	RemoveAttributes *RemoveAttributesActivity

	// Used to create a new message using only the specified attributes from the
	// original message.
	SelectAttributes *SelectAttributesActivity
	// contains filtered or unexported fields
}

type PipelineSummary struct {

	// When the pipeline was created.
	CreationTime *time.Time

	// When the pipeline was last updated.
	LastUpdateTime *time.Time

	// The name of the pipeline.
	PipelineName *string

	// A summary of information about the pipeline reprocessing.
	ReprocessingSummaries []ReprocessingSummary
	// contains filtered or unexported fields
}

type QueryFilter struct {

	// Used to limit data to that which has arrived since the last execution of the
	// action.
	DeltaTime *DeltaTime
	// contains filtered or unexported fields
}

type RemoveAttributesActivity struct {

	// A list of 1-50 attributes to remove from the message.
	//
	// This member is required.
	Attributes []string

	// The name of the removeAttributes activity.
	//
	// This member is required.
	Name *string

	// The next activity in the pipeline.
	Next *string
	// contains filtered or unexported fields
}

type ReprocessingStatus string

type ReprocessingSummary struct {

	// The time the pipeline reprocessing was created.
	CreationTime *time.Time

	// The reprocessingId returned by StartPipelineReprocessing .
	Id *string

	// The status of the pipeline reprocessing.
	Status ReprocessingStatus
	// contains filtered or unexported fields
}

type ResourceAlreadyExistsException struct {
	Message *string

	ErrorCodeOverride *string

	ResourceId  *string
	ResourceArn *string
	// contains filtered or unexported fields
}

type ResourceConfiguration struct {

	// The type of the compute resource used to execute the containerAction . Possible
	// values are: ACU_1 (vCPU=4, memory=16 GiB) or ACU_2 (vCPU=8, memory=32 GiB).
	//
	// This member is required.
	ComputeType ComputeType

	// The size, in GB, of the persistent storage available to the resource instance
	// used to execute the containerAction (min: 1, max: 50).
	//
	// This member is required.
	VolumeSizeInGB *int32
	// contains filtered or unexported fields
}

type ResourceNotFoundException struct {
	Message *string

	ErrorCodeOverride *string
	// contains filtered or unexported fields
}

type RetentionPeriod struct {

	// The number of days that message data is kept. The unlimited parameter must be
	// false.
	NumberOfDays *int32

	// If true, message data is kept indefinitely.
	Unlimited bool
	// contains filtered or unexported fields
}

type S3DestinationConfiguration struct {

	// The name of the S3 bucket to which dataset contents are delivered.
	//
	// This member is required.
	Bucket *string

	// The key of the dataset contents object in an S3 bucket. Each object has a key
	// that is a unique identifier. Each object has exactly one key. You can create a
	// unique key with the following options:
	//   - Use !{iotanalytics:scheduleTime} to insert the time of a scheduled SQL query
	//   run.
	//   - Use !{iotanalytics:versionId} to insert a unique hash that identifies a
	//   dataset content.
	//   - Use !{iotanalytics:creationTime} to insert the creation time of a dataset
	//   content.
	// The following example creates a unique key for a CSV file:
	// dataset/mydataset/!{iotanalytics:scheduleTime}/!{iotanalytics:versionId}.csv If
	// you don't use !{iotanalytics:versionId} to specify the key, you might get
	// duplicate keys. For example, you might have two dataset contents with the same
	// scheduleTime but different versionId s. This means that one dataset content
	// overwrites the other.
	//
	// This member is required.
	Key *string

	// The ARN of the role that grants IoT Analytics permission to interact with your
	// Amazon S3 and Glue resources.
	//
	// This member is required.
	RoleArn *string

	// Configuration information for coordination with Glue, a fully managed extract,
	// transform and load (ETL) service.
	GlueConfiguration *GlueConfiguration
	// contains filtered or unexported fields
}

type Schedule struct {

	// The expression that defines when to trigger an update. For more information,
	// see Schedule Expressions for Rules (https://docs.aws.amazon.com/AmazonCloudWatch/latest/events/ScheduledEvents.html)
	// in the Amazon CloudWatch Events User Guide.
	Expression *string
	// contains filtered or unexported fields
}

type SchemaDefinition struct {

	// Specifies one or more columns that store your data. Each schema can have up to
	// 100 columns. Each column can have up to 100 nested types.
	Columns []Column
	// contains filtered or unexported fields
}

type SelectAttributesActivity struct {

	// A list of the attributes to select from the message.
	//
	// This member is required.
	Attributes []string

	// The name of the selectAttributes activity.
	//
	// This member is required.
	Name *string

	// The next activity in the pipeline.
	Next *string
	// contains filtered or unexported fields
}

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

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

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

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

type ServiceUnavailableException struct {
	Message *string

	ErrorCodeOverride *string
	// contains filtered or unexported fields
}

type SqlQueryDatasetAction struct {

	// A SQL query string.
	//
	// This member is required.
	SqlQuery *string

	// Prefilters applied to message data.
	Filters []QueryFilter
	// contains filtered or unexported fields
}

type Tag struct {

	// The tag's key.
	//
	// This member is required.
	Key *string

	// The tag's value.
	//
	// This member is required.
	Value *string
	// contains filtered or unexported fields
}

type ThrottlingException struct {
	Message *string

	ErrorCodeOverride *string
	// contains filtered or unexported fields
}

type TimestampPartition struct {

	// The attribute name of the partition defined by a timestamp.
	//
	// This member is required.
	AttributeName *string

	// The timestamp format of a partition defined by a timestamp. The default format
	// is seconds since epoch (January 1, 1970 at midnight UTC time).
	TimestampFormat *string
	// contains filtered or unexported fields
}

type TriggeringDataset struct {

	// The name of the dataset whose content generation triggers the new dataset
	// content generation.
	//
	// This member is required.
	Name *string
	// contains filtered or unexported fields
}

type UnknownUnionMember struct {
	Tag   string
	Value []byte
	// contains filtered or unexported fields
}

type Variable struct {

	// The name of the variable.
	//
	// This member is required.
	Name *string

	// The value of the variable as a structure that specifies a dataset content
	// version.
	DatasetContentVersionValue *DatasetContentVersionValue

	// The value of the variable as a double (numeric).
	DoubleValue *float64

	// The value of the variable as a structure that specifies an output file URI.
	OutputFileUriValue *OutputFileUriValue

	// The value of the variable as a string.
	StringValue *string
	// contains filtered or unexported fields
}

type VersioningConfiguration struct {

	// How many versions of dataset contents are kept. The unlimited parameter must be
	// false .
	MaxVersions *int32

	// If true, unlimited versions of dataset contents are kept.
	Unlimited bool
	// contains filtered or unexported fields
}