const ServiceAPIVersion = "2012-10-29"

const ServiceID = "Data Pipeline"

type ActivatePipelineInput struct {
	// A list of parameter values to pass to the pipeline at activation.
	ParameterValues []*types.ParameterValue
	// The ID of the pipeline.
	PipelineId *string
	// The date and time to resume the pipeline. By default, the pipeline resumes from
	// the last completed execution.
	StartTimestamp *time.Time
}

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

type AddTagsInput struct {
	// The ID of the pipeline.
	PipelineId *string
	// The tags to add, as key/value pairs.
	Tags []*types.Tag
}

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

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

type CreatePipelineInput struct {
	// A list of tags to associate with the pipeline at creation. Tags let you control
	// access to pipelines. For more information, see Controlling User Access to
	// Pipelines
	// (https://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-control-access.html)
	// in the AWS Data Pipeline Developer Guide.
	Tags []*types.Tag
	// The name for the pipeline. You can use the same name for multiple pipelines
	// associated with your AWS account, because AWS Data Pipeline assigns each
	// pipeline a unique pipeline identifier.
	Name *string
	// A unique identifier. This identifier is not the same as the pipeline identifier
	// assigned by AWS Data Pipeline. You are responsible for defining the format and
	// ensuring the uniqueness of this identifier. You use this parameter to ensure
	// idempotency during repeated calls to CreatePipeline. For example, if the first
	// call to CreatePipeline does not succeed, you can pass in the same unique
	// identifier and pipeline name combination on a subsequent call to CreatePipeline.
	// CreatePipeline ensures that if a pipeline already exists with the same name and
	// unique identifier, a new pipeline is not created. Instead, you'll receive the
	// pipeline identifier from the previous attempt. The uniqueness of the name and
	// unique identifier combination is scoped to the AWS account or IAM user
	// credentials.
	UniqueId *string
	// The description for the pipeline.
	Description *string
}

type CreatePipelineOutput struct {
	// The ID that AWS Data Pipeline assigns the newly created pipeline. For example,
	// df-06372391ZG65EXAMPLE.
	PipelineId *string

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

type DeactivatePipelineInput struct {
	// Indicates whether to cancel any running objects. The default is true, which sets
	// the state of any running objects to CANCELED. If this value is false, the
	// pipeline is deactivated after all running objects finish.
	CancelActive *bool
	// The ID of the pipeline.
	PipelineId *string
}

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

type DeletePipelineInput struct {
	// The ID of the pipeline.
	PipelineId *string
}

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

type DescribeObjectsInput struct {
	// The ID of the pipeline that contains the object definitions.
	PipelineId *string
	// The IDs of the pipeline objects that contain the definitions to be described.
	// You can pass as many as 25 identifiers in a single call to DescribeObjects.
	ObjectIds []*string
	// Indicates whether any expressions in the object should be evaluated when the
	// object descriptions are returned.
	EvaluateExpressions *bool
	// The starting point for the results to be returned. For the first call, this
	// value should be empty. As long as there are more results, continue to call
	// DescribeObjects with the marker value from the previous call to retrieve the
	// next set of results.
	Marker *string
}

type DescribeObjectsOutput struct {
	// The starting point for the next page of results. To view the next page of
	// results, call DescribeObjects again with this marker value. If the value is
	// null, there are no more results.
	Marker *string
	// An array of object definitions.
	PipelineObjects []*types.PipelineObject
	// Indicates whether there are more results to return.
	HasMoreResults *bool

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

type DescribePipelinesInput struct {
	// The IDs of the pipelines to describe. You can pass as many as 25 identifiers in
	// a single call. To obtain pipeline IDs, call ListPipelines ().
	PipelineIds []*string
}

type DescribePipelinesOutput struct {
	// An array of descriptions for the specified pipelines.
	PipelineDescriptionList []*types.PipelineDescription

	// 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 EvaluateExpressionInput struct {
	// The ID of the pipeline.
	PipelineId *string
	// The expression to evaluate.
	Expression *string
	// The ID of the object.
	ObjectId *string
}

type EvaluateExpressionOutput struct {
	// The evaluated expression.
	EvaluatedExpression *string

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

type GetPipelineDefinitionInput struct {
	// The version of the pipeline definition to retrieve. Set this parameter to latest
	// (default) to use the last definition saved to the pipeline or active to use the
	// last definition that was activated.
	Version *string
	// The ID of the pipeline.
	PipelineId *string
}

type GetPipelineDefinitionOutput struct {
	// The objects defined in the pipeline.
	PipelineObjects []*types.PipelineObject
	// The parameter values used in the pipeline definition.
	ParameterValues []*types.ParameterValue
	// The parameter objects used in the pipeline definition.
	ParameterObjects []*types.ParameterObject

	// 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 ListPipelinesInput struct {
	// The starting point for the results to be returned. For the first call, this
	// value should be empty. As long as there are more results, continue to call
	// ListPipelines with the marker value from the previous call to retrieve the next
	// set of results.
	Marker *string
}

type ListPipelinesOutput struct {
	// Indicates whether there are more results that can be obtained by a subsequent
	// call.
	HasMoreResults *bool
	// The pipeline identifiers. If you require additional information about the
	// pipelines, you can use these identifiers to call DescribePipelines () and
	// GetPipelineDefinition ().
	PipelineIdList []*types.PipelineIdName
	// The starting point for the next page of results. To view the next page of
	// results, call ListPipelinesOutput again with this marker value. If the value is
	// null, there are no more results.
	Marker *string

	// 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 PollForTaskInput struct {
	// The type of task the task runner is configured to accept and process. The worker
	// group is set as a field on objects in the pipeline when they are created. You
	// can only specify a single value for workerGroup in the call to PollForTask.
	// There are no wildcard values permitted in workerGroup; the string must be an
	// exact, case-sensitive, match.
	WorkerGroup *string
	// Identity information for the EC2 instance that is hosting the task runner. You
	// can get this value from the instance using
	// http://169.254.169.254/latest/meta-data/instance-id. For more information, see
	// Instance Metadata
	// (https://docs.aws.amazon.com/AWSEC2/latest/UserGuide/AESDG-chapter-instancedata.html)
	// in the Amazon Elastic Compute Cloud User Guide. Passing in this value proves
	// that your task runner is running on an EC2 instance, and ensures the proper AWS
	// Data Pipeline service charges are applied to your pipeline.
	InstanceIdentity *types.InstanceIdentity
	// The public DNS name of the calling task runner.
	Hostname *string
}

type PollForTaskOutput struct {
	// The information needed to complete the task that is being assigned to the task
	// runner. One of the fields returned in this object is taskId, which contains an
	// identifier for the task being assigned. The calling task runner uses taskId in
	// subsequent calls to ReportTaskProgress () and SetTaskStatus ().
	TaskObject *types.TaskObject

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

type PutPipelineDefinitionInput struct {
	// The objects that define the pipeline. These objects overwrite the existing
	// pipeline definition.
	PipelineObjects []*types.PipelineObject
	// The ID of the pipeline.
	PipelineId *string
	// The parameter objects used with the pipeline.
	ParameterObjects []*types.ParameterObject
	// The parameter values used with the pipeline.
	ParameterValues []*types.ParameterValue
}

type PutPipelineDefinitionOutput struct {
	// Indicates whether there were validation errors, and the pipeline definition is
	// stored but cannot be activated until you correct the pipeline and call
	// PutPipelineDefinition to commit the corrected pipeline.
	Errored *bool
	// The validation errors that are associated with the objects defined in
	// pipelineObjects.
	ValidationErrors []*types.ValidationError
	// The validation warnings that are associated with the objects defined in
	// pipelineObjects.
	ValidationWarnings []*types.ValidationWarning

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

type QueryObjectsInput struct {
	// Indicates whether the query applies to components or instances. The possible
	// values are: COMPONENT, INSTANCE, and ATTEMPT.
	Sphere *string
	// The maximum number of object names that QueryObjects will return in a single
	// call. The default value is 100.
	Limit *int32
	// The query that defines the objects to be returned. The Query object can contain
	// a maximum of ten selectors. The conditions in the query are limited to top-level
	// String fields in the object. These filters can be applied to components,
	// instances, and attempts.
	Query *types.Query
	// The starting point for the results to be returned. For the first call, this
	// value should be empty. As long as there are more results, continue to call
	// QueryObjects with the marker value from the previous call to retrieve the next
	// set of results.
	Marker *string
	// The ID of the pipeline.
	PipelineId *string
}

type QueryObjectsOutput struct {
	// The starting point for the next page of results. To view the next page of
	// results, call QueryObjects again with this marker value. If the value is null,
	// there are no more results.
	Marker *string
	// The identifiers that match the query selectors.
	Ids []*string
	// Indicates whether there are more results that can be obtained by a subsequent
	// call.
	HasMoreResults *bool

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

type RemoveTagsInput struct {
	// The keys of the tags to remove.
	TagKeys []*string
	// The ID of the pipeline.
	PipelineId *string
}

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

type ReportTaskProgressInput struct {
	// Key-value pairs that define the properties of the ReportTaskProgressInput
	// object.
	Fields []*types.Field
	// The ID of the task assigned to the task runner. This value is provided in the
	// response for PollForTask ().
	TaskId *string
}

type ReportTaskProgressOutput struct {
	// If true, the calling task runner should cancel processing of the task. The task
	// runner does not need to call SetTaskStatus () for canceled tasks.
	Canceled *bool

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

type ReportTaskRunnerHeartbeatInput struct {
	// The public DNS name of the task runner.
	Hostname *string
	// The ID of the task runner. This value should be unique across your AWS account.
	// In the case of AWS Data Pipeline Task Runner launched on a resource managed by
	// AWS Data Pipeline, the web service provides a unique identifier when it launches
	// the application. If you have written a custom task runner, you should assign a
	// unique identifier for the task runner.
	TaskrunnerId *string
	// The type of task the task runner is configured to accept and process. The worker
	// group is set as a field on objects in the pipeline when they are created. You
	// can only specify a single value for workerGroup. There are no wildcard values
	// permitted in workerGroup; the string must be an exact, case-sensitive, match.
	WorkerGroup *string
}

type ReportTaskRunnerHeartbeatOutput struct {
	// Indicates whether the calling task runner should terminate.
	Terminate *bool

	// 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 SetStatusInput struct {
	// The status to be set on all the objects specified in objectIds. For components,
	// use PAUSE or RESUME. For instances, use TRY_CANCEL, RERUN, or MARK_FINISHED.
	Status *string
	// The ID of the pipeline that contains the objects.
	PipelineId *string
	// The IDs of the objects. The corresponding objects can be either physical or
	// components, but not a mix of both types.
	ObjectIds []*string
}

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

type SetTaskStatusInput struct {
	// If an error occurred during the task, this value specifies the stack trace
	// associated with the error. This value is set on the physical attempt object. It
	// is used to display error information to the user. The web service does not parse
	// this value.
	ErrorStackTrace *string
	// If FINISHED, the task successfully completed. If FAILED, the task ended
	// unsuccessfully. Preconditions use false.
	TaskStatus types.TaskStatus
	// If an error occurred during the task, this value specifies the error code. This
	// value is set on the physical attempt object. It is used to display error
	// information to the user. It should not start with string "Service_" which is
	// reserved by the system.
	ErrorId *string
	// The ID of the task assigned to the task runner. This value is provided in the
	// response for PollForTask ().
	TaskId *string
	// If an error occurred during the task, this value specifies a text description of
	// the error. This value is set on the physical attempt object. It is used to
	// display error information to the user. The web service does not parse this
	// value.
	ErrorMessage *string
}

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

type ValidatePipelineDefinitionInput struct {
	// The objects that define the pipeline changes to validate against the pipeline.
	PipelineObjects []*types.PipelineObject
	// The parameter objects used with the pipeline.
	ParameterObjects []*types.ParameterObject
	// The ID of the pipeline.
	PipelineId *string
	// The parameter values used with the pipeline.
	ParameterValues []*types.ParameterValue
}

type ValidatePipelineDefinitionOutput struct {
	// Any validation errors that were found.
	ValidationErrors []*types.ValidationError
	// Indicates whether there were validation errors.
	Errored *bool
	// Any validation warnings that were found.
	ValidationWarnings []*types.ValidationWarning

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