const ServiceAPIVersion = "2017-11-27"

const ServiceID = "IoTAnalytics"

type BatchPutMessageInput struct {

	// The list of messages to be sent. Each message has format: '{ "messageId":
	// "string", "payload": "string"}'. Note that the field names of message payloads
	// (data) that you send to AWS IoT Analytics:
	//
	//     * Must contain only alphanumeric
	// characters and undescores (_); no other special characters are allowed.
	//
	//     *
	// Must begin with an alphabetic character or single underscore (_).
	//
	//     * Cannot
	// contain hyphens (-).
	//
	//     * In regular expression terms:
	// "^[A-Za-z_]([A-Za-z0-9]*|[A-Za-z0-9][A-Za-z0-9_]*)$".
	//
	//     * Cannot be greater
	// than 255 characters.
	//
	//     * Are case-insensitive. (Fields named "foo" and "FOO"
	// in the same payload are considered duplicates.)
	//
	// For example, {"temp_01": 29} or
	// {"_temp_01": 29} are valid, but {"temp-01": 29}, {"01_temp": 29} or
	// {"__temp_01": 29} are invalid in message payloads.
	//
	// This member is required.
	Messages []*types.Message

	// The name of the channel where the messages are sent.
	//
	// This member is required.
	ChannelName *string
}

type BatchPutMessageOutput struct {

	// A list of any errors encountered when sending the messages to the channel.
	BatchPutMessageErrorEntries []*types.BatchPutMessageErrorEntry

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type CancelPipelineReprocessingInput struct {

	// The name of pipeline for which data reprocessing is canceled.
	//
	// This member is required.
	PipelineName *string

	// The ID of the reprocessing task (returned by "StartPipelineReprocessing").
	//
	// This member is required.
	ReprocessingId *string
}

type CancelPipelineReprocessingOutput struct {
	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

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

type CreateChannelInput struct {

	// Where channel data is stored. You may choose one of "serviceManagedS3" or
	// "customerManagedS3" storage. If not specified, the default is
	// "serviceManagedS3". This cannot be changed after creation of the channel.
	ChannelStorage *types.ChannelStorage

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

	// Metadata which can be used to manage the channel.
	Tags []*types.Tag

	// The name of the channel.
	//
	// This member is required.
	ChannelName *string
}

type CreateChannelOutput struct {

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

	// The ARN of the channel.
	ChannelArn *string

	// The name of the channel.
	ChannelName *string

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type CreateDatasetContentInput struct {

	// The name of the data set.
	//
	// This member is required.
	DatasetName *string
}

type CreateDatasetContentOutput struct {

	// The version ID of the data set contents which are being created.
	VersionId *string

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type CreateDatasetInput struct {

	// [Optional] How many versions of data set contents are kept. If not specified or
	// set to null, only the latest version plus the latest succeeded version (if they
	// are different) are kept for the time period specified by the "retentionPeriod"
	// parameter. (For more information, see
	// https://docs.aws.amazon.com/iotanalytics/latest/userguide/getting-started.html#aws-iot-analytics-dataset-versions)
	VersioningConfiguration *types.VersioningConfiguration

	// A list of actions that create the data set contents.
	//
	// This member is required.
	Actions []*types.DatasetAction

	// When data set contents are created they are delivered to destinations specified
	// here.
	ContentDeliveryRules []*types.DatasetContentDeliveryRule

	// The name of the data set.
	//
	// This member is required.
	DatasetName *string

	// 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 []*types.DatasetTrigger

	// Metadata which can be used to manage the data set.
	Tags []*types.Tag

	// [Optional] How long, in days, versions of data set contents are kept for the
	// data set. If not specified or set to null, versions of data set contents are
	// retained for at most 90 days. The number of versions of data set contents
	// retained is determined by the versioningConfiguration parameter. (For more
	// information, see
	// https://docs.aws.amazon.com/iotanalytics/latest/userguide/getting-started.html#aws-iot-analytics-dataset-versions)
	RetentionPeriod *types.RetentionPeriod
}

type CreateDatasetOutput struct {

	// How long, in days, data set contents are kept for the data set.
	RetentionPeriod *types.RetentionPeriod

	// The name of the data set.
	DatasetName *string

	// The ARN of the data set.
	DatasetArn *string

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type CreateDatastoreInput struct {

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

	// The name of the data store.
	//
	// This member is required.
	DatastoreName *string

	// Metadata which can be used to manage the data store.
	Tags []*types.Tag

	// Where data store data is stored. You may choose one of "serviceManagedS3" or
	// "customerManagedS3" storage. If not specified, the default is
	// "serviceManagedS3". This cannot be changed after the data store is created.
	DatastoreStorage *types.DatastoreStorage
}

type CreateDatastoreOutput struct {

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

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

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

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type CreatePipelineInput struct {

	// Metadata which can be used to manage the pipeline.
	Tags []*types.Tag

	// A list of "PipelineActivity" objects. Activities perform transformations on your
	// messages, such as removing, renaming or adding message attributes; filtering
	// messages based on attribute values; invoking your Lambda functions on messages
	// for advanced processing; or performing mathematical transformations to normalize
	// device data. The list can be 2-25 PipelineActivity objects and must contain both
	// a channel and a datastore activity. Each entry in the list must contain only one
	// activity, for example: pipelineActivities = [ { "channel": { ... } }, {
	// "lambda": { ... } }, ... ]
	//
	// This member is required.
	PipelineActivities []*types.PipelineActivity

	// The name of the pipeline.
	//
	// This member is required.
	PipelineName *string
}

type CreatePipelineOutput struct {

	// The name of the pipeline.
	PipelineName *string

	// The ARN of the pipeline.
	PipelineArn *string

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type DeleteChannelInput struct {

	// The name of the channel to delete.
	//
	// This member is required.
	ChannelName *string
}

type DeleteChannelOutput struct {
	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type DeleteDatasetContentInput struct {

	// The name of the data set whose content is deleted.
	//
	// This member is required.
	DatasetName *string

	// 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
}

type DeleteDatasetContentOutput struct {
	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type DeleteDatasetInput struct {

	// The name of the data set to delete.
	//
	// This member is required.
	DatasetName *string
}

type DeleteDatasetOutput struct {
	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type DeleteDatastoreInput struct {

	// The name of the data store to delete.
	//
	// This member is required.
	DatastoreName *string
}

type DeleteDatastoreOutput struct {
	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type DeletePipelineInput struct {

	// The name of the pipeline to delete.
	//
	// This member is required.
	PipelineName *string
}

type DeletePipelineOutput struct {
	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type DescribeChannelInput struct {

	// The name of the channel whose information is retrieved.
	//
	// This member is required.
	ChannelName *string

	// If true, additional statistical information about the channel is included in the
	// response. This feature cannot be used with a channel whose S3 storage is
	// customer-managed.
	IncludeStatistics *bool
}

type DescribeChannelOutput struct {

	// Statistics about the channel. Included if the 'includeStatistics' parameter is
	// set to true in the request.
	Statistics *types.ChannelStatistics

	// An object that contains information about the channel.
	Channel *types.Channel

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type DescribeDatasetInput struct {

	// The name of the data set whose information is retrieved.
	//
	// This member is required.
	DatasetName *string
}

type DescribeDatasetOutput struct {

	// An object that contains information about the data set.
	Dataset *types.Dataset

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type DescribeDatastoreInput struct {

	// The name of the data store
	//
	// This member is required.
	DatastoreName *string

	// If true, additional statistical information about the data store is included in
	// the response. This feature cannot be used with a data store whose S3 storage is
	// customer-managed.
	IncludeStatistics *bool
}

type DescribeDatastoreOutput struct {

	// Information about the data store.
	Datastore *types.Datastore

	// Additional statistical information about the data store. Included if the
	// 'includeStatistics' parameter is set to true in the request.
	Statistics *types.DatastoreStatistics

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type DescribeLoggingOptionsInput struct {
}

type DescribeLoggingOptionsOutput struct {

	// The current settings of the AWS IoT Analytics logging options.
	LoggingOptions *types.LoggingOptions

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type DescribePipelineInput struct {

	// The name of the pipeline whose information is retrieved.
	//
	// This member is required.
	PipelineName *string
}

type DescribePipelineOutput struct {

	// A "Pipeline" object that contains information about the pipeline.
	Pipeline *types.Pipeline

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type EndpointResolver interface {
	ResolveEndpoint(region string, options ResolverOptions) (aws.Endpoint, error)
}

type EndpointResolverFunc func(region string, options ResolverOptions) (aws.Endpoint, error)

type GetDatasetContentInput struct {

	// The name of the data set whose contents are retrieved.
	//
	// This member is required.
	DatasetName *string

	// 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
}

type GetDatasetContentOutput struct {

	// A list of "DatasetEntry" objects.
	Entries []*types.DatasetEntry

	// The time when the request was made.
	Timestamp *time.Time

	// The status of the data set content.
	Status *types.DatasetContentStatus

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type HTTPClient interface {
	Do(*http.Request) (*http.Response, error)
}

type HTTPSignerV4 interface {
	SignHTTP(ctx context.Context, credentials aws.Credentials, r *http.Request, payloadHash string, service string, region string, signingTime time.Time) error
}

type ListChannelsInput struct {

	// The maximum number of results to return in this request. The default value is
	// 100.
	MaxResults *int32

	// The token for the next set of results.
	NextToken *string
}

type ListChannelsOutput struct {

	// A list of "ChannelSummary" objects.
	ChannelSummaries []*types.ChannelSummary

	// The token to retrieve the next set of results, or null if there are no more
	// results.
	NextToken *string

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type ListDatasetContentsInput struct {

	// The token for the next set of results.
	NextToken *string

	// The name of the data set whose contents information you want to list.
	//
	// This member is required.
	DatasetName *string

	// A filter to limit results to those data set contents whose creation is scheduled
	// on or after the given time. See the field triggers.schedule in the CreateDataset
	// request. (timestamp)
	ScheduledOnOrAfter *time.Time

	// The maximum number of results to return in this request.
	MaxResults *int32

	// A filter to limit results to those data set contents whose creation is scheduled
	// before the given time. See the field triggers.schedule in the CreateDataset
	// request. (timestamp)
	ScheduledBefore *time.Time
}

type ListDatasetContentsOutput struct {

	// Summary information about data set contents that have been created.
	DatasetContentSummaries []*types.DatasetContentSummary

	// The token to retrieve the next set of results, or null if there are no more
	// results.
	NextToken *string

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type ListDatasetsInput struct {

	// The token for the next set of results.
	NextToken *string

	// The maximum number of results to return in this request. The default value is
	// 100.
	MaxResults *int32
}

type ListDatasetsOutput struct {

	// The token to retrieve the next set of results, or null if there are no more
	// results.
	NextToken *string

	// A list of "DatasetSummary" objects.
	DatasetSummaries []*types.DatasetSummary

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type ListDatastoresInput struct {

	// The token for the next set of results.
	NextToken *string

	// The maximum number of results to return in this request. The default value is
	// 100.
	MaxResults *int32
}

type ListDatastoresOutput struct {

	// A list of "DatastoreSummary" objects.
	DatastoreSummaries []*types.DatastoreSummary

	// The token to retrieve the next set of results, or null if there are no more
	// results.
	NextToken *string

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type ListPipelinesInput struct {

	// The token for the next set of results.
	NextToken *string

	// The maximum number of results to return in this request. The default value is
	// 100.
	MaxResults *int32
}

type ListPipelinesOutput struct {

	// The token to retrieve the next set of results, or null if there are no more
	// results.
	NextToken *string

	// A list of "PipelineSummary" objects.
	PipelineSummaries []*types.PipelineSummary

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type ListTagsForResourceInput struct {

	// The ARN of the resource whose tags you want to list.
	//
	// This member is required.
	ResourceArn *string
}

type ListTagsForResourceOutput struct {

	// The tags (metadata) which you have assigned to the resource.
	Tags []*types.Tag

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type Options struct {
	// Set of options to modify how an operation is invoked. These apply to all
	// operations invoked for this client. Use functional options on operation call to
	// modify this list for per operation behavior.
	APIOptions []func(*middleware.Stack) error

	// The credentials object to use when signing requests.
	Credentials aws.CredentialsProvider

	// The endpoint options to be used when attempting to resolve an endpoint.
	EndpointOptions ResolverOptions

	// The service endpoint resolver.
	EndpointResolver EndpointResolver

	// Signature Version 4 (SigV4) Signer
	HTTPSignerV4 HTTPSignerV4

	// The region to send requests to. (Required)
	Region string

	// Retryer guides how HTTP requests should be retried in case of recoverable
	// failures. When nil the API client will use a default retryer.
	Retryer retry.Retryer

	// The HTTP client to invoke API calls with. Defaults to client's default HTTP
	// implementation if nil.
	HTTPClient HTTPClient
}

type PutLoggingOptionsInput struct {

	// The new values of the AWS IoT Analytics logging options.
	//
	// This member is required.
	LoggingOptions *types.LoggingOptions
}

type PutLoggingOptionsOutput struct {
	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type ResolveEndpoint struct {
	Resolver EndpointResolver
	Options  ResolverOptions
}

type ResolveEndpointMiddlewareOptions interface {
	GetEndpointResolver() EndpointResolver
	GetEndpointOptions() ResolverOptions
}

type ResolverOptions = internalendpoints.Options

type RunPipelineActivityInput struct {

	// 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.
	//
	// This member is required.
	PipelineActivity *types.PipelineActivity

	// The sample message payloads on which the pipeline activity is run.
	//
	// This member is required.
	Payloads [][]byte
}

type RunPipelineActivityOutput struct {

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

	// In case the pipeline activity fails, the log message that is generated.
	LogResult *string

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type SampleChannelDataInput struct {

	// The end of the time window from which sample messages are retrieved.
	EndTime *time.Time

	// The start of the time window from which sample messages are retrieved.
	StartTime *time.Time

	// The name of the channel whose message samples are retrieved.
	//
	// This member is required.
	ChannelName *string

	// The number of sample messages to be retrieved. The limit is 10, the default is
	// also 10.
	MaxMessages *int32
}

type SampleChannelDataOutput struct {

	// The list of message samples. Each sample message is returned as a base64-encoded
	// string.
	Payloads [][]byte

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type StartPipelineReprocessingInput struct {

	// The end time (exclusive) of raw message data that is reprocessed.
	EndTime *time.Time

	// The name of the pipeline on which to start reprocessing.
	//
	// This member is required.
	PipelineName *string

	// The start time (inclusive) of raw message data that is reprocessed.
	StartTime *time.Time
}

type StartPipelineReprocessingOutput struct {

	// The ID of the pipeline reprocessing activity that was started.
	ReprocessingId *string

	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type TagResourceInput struct {

	// The new or modified tags for the resource.
	//
	// This member is required.
	Tags []*types.Tag

	// The ARN of the resource whose tags you want to modify.
	//
	// This member is required.
	ResourceArn *string
}

type TagResourceOutput struct {
	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type UntagResourceInput struct {

	// The keys of those tags which you want to remove.
	//
	// This member is required.
	TagKeys []*string

	// The ARN of the resource whose tags you want to remove.
	//
	// This member is required.
	ResourceArn *string
}

type UntagResourceOutput struct {
	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type UpdateChannelInput struct {

	// The name of the channel to be updated.
	//
	// This member is required.
	ChannelName *string

	// How long, in days, message data is kept for the channel. The retention period
	// cannot be updated if the channel's S3 storage is customer-managed.
	RetentionPeriod *types.RetentionPeriod

	// Where channel data is stored. You may choose one of "serviceManagedS3" or
	// "customerManagedS3" storage. If not specified, the default is
	// "serviceManagedS3". This cannot be changed after creation of the channel.
	ChannelStorage *types.ChannelStorage
}

type UpdateChannelOutput struct {
	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type UpdateDatasetInput struct {

	// The name of the data set to update.
	//
	// This member is required.
	DatasetName *string

	// [Optional] How many versions of data set contents are kept. If not specified or
	// set to null, only the latest version plus the latest succeeded version (if they
	// are different) are kept for the time period specified by the "retentionPeriod"
	// parameter. (For more information, see
	// https://docs.aws.amazon.com/iotanalytics/latest/userguide/getting-started.html#aws-iot-analytics-dataset-versions)
	VersioningConfiguration *types.VersioningConfiguration

	// When data set contents are created they are delivered to destinations specified
	// here.
	ContentDeliveryRules []*types.DatasetContentDeliveryRule

	// A list of "DatasetAction" objects.
	//
	// This member is required.
	Actions []*types.DatasetAction

	// How long, in days, data set contents are kept for the data set.
	RetentionPeriod *types.RetentionPeriod

	// A list of "DatasetTrigger" objects. The list can be empty or can contain up to
	// five DataSetTrigger objects.
	Triggers []*types.DatasetTrigger
}

type UpdateDatasetOutput struct {
	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type UpdateDatastoreInput struct {

	// The name of the data store to be updated.
	//
	// This member is required.
	DatastoreName *string

	// Where data store data is stored. You may choose one of "serviceManagedS3" or
	// "customerManagedS3" storage. If not specified, the default is
	// "serviceManagedS3". This cannot be changed after the data store is created.
	DatastoreStorage *types.DatastoreStorage

	// How long, in days, message data is kept for the data store. The retention period
	// cannot be updated if the data store's S3 storage is customer-managed.
	RetentionPeriod *types.RetentionPeriod
}

type UpdateDatastoreOutput struct {
	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}

type UpdatePipelineInput struct {

	// The name of the pipeline to update.
	//
	// This member is required.
	PipelineName *string

	// A list of "PipelineActivity" objects. Activities perform transformations on your
	// messages, such as removing, renaming or adding message attributes; filtering
	// messages based on attribute values; invoking your Lambda functions on messages
	// for advanced processing; or performing mathematical transformations to normalize
	// device data. The list can be 2-25 PipelineActivity objects and must contain both
	// a channel and a datastore activity. Each entry in the list must contain only one
	// activity, for example: pipelineActivities = [ { "channel": { ... } }, {
	// "lambda": { ... } }, ... ]
	//
	// This member is required.
	PipelineActivities []*types.PipelineActivity
}

type UpdatePipelineOutput struct {
	// Metadata pertaining to the operation's result.
	ResultMetadata middleware.Metadata
}