amazonka-datapipeline 1.6.1 → 2.0

raw patch · 93 files changed

+7652/−5019 lines, 93 filesdep +case-insensitivedep ~amazonka-coredep ~amazonka-testdep ~basesetup-changedPVP ok

version bump matches the API change (PVP)

Dependencies added: case-insensitive

Dependency ranges changed: amazonka-core, amazonka-test, base

API changes (from Hackage documentation)

Files

• README.md +3/−4
• Setup.hs +0/−2
• amazonka-datapipeline.cabal +108/−93
• fixture/ActivatePipeline.yaml +10/−0
• fixture/AddTags.yaml +10/−0
• fixture/CreatePipeline.yaml +10/−0
• fixture/DeactivatePipeline.yaml +10/−0
• fixture/DeletePipeline.yaml +10/−0
• fixture/DescribeObjects.yaml +10/−0
• fixture/DescribePipelines.yaml +10/−0
• fixture/EvaluateExpression.yaml +10/−0
• fixture/GetPipelineDefinition.yaml +10/−0
• fixture/ListPipelines.yaml +10/−0
• fixture/PollForTask.yaml +10/−0
• fixture/PutPipelineDefinition.yaml +10/−0
• fixture/QueryObjects.yaml +10/−0
• fixture/RemoveTags.yaml +10/−0
• fixture/ReportTaskProgress.yaml +10/−0
• fixture/ReportTaskRunnerHeartbeat.yaml +10/−0
• fixture/SetStatus.yaml +10/−0
• fixture/SetTaskStatus.yaml +10/−0
• fixture/ValidatePipelineDefinition.yaml +10/−0
• gen/Amazonka/DataPipeline.hs +297/−0
• gen/Amazonka/DataPipeline/ActivatePipeline.hs +204/−0
• gen/Amazonka/DataPipeline/AddTags.hs +170/−0
• gen/Amazonka/DataPipeline/CreatePipeline.hs +271/−0
• gen/Amazonka/DataPipeline/DeactivatePipeline.hs +189/−0
• gen/Amazonka/DataPipeline/DeletePipeline.hs +141/−0
• gen/Amazonka/DataPipeline/DescribeObjects.hs +295/−0
• gen/Amazonka/DataPipeline/DescribePipelines.hs +188/−0
• gen/Amazonka/DataPipeline/EvaluateExpression.hs +216/−0
• gen/Amazonka/DataPipeline/GetPipelineDefinition.hs +231/−0
• gen/Amazonka/DataPipeline/Lens.hs +253/−0
• gen/Amazonka/DataPipeline/ListPipelines.hs +244/−0
• gen/Amazonka/DataPipeline/PollForTask.hs +261/−0
• gen/Amazonka/DataPipeline/PutPipelineDefinition.hs +286/−0
• gen/Amazonka/DataPipeline/QueryObjects.hs +309/−0
• gen/Amazonka/DataPipeline/RemoveTags.hs +170/−0
• gen/Amazonka/DataPipeline/ReportTaskProgress.hs +211/−0
• gen/Amazonka/DataPipeline/ReportTaskRunnerHeartbeat.hs +242/−0
• gen/Amazonka/DataPipeline/SetStatus.hs +176/−0
• gen/Amazonka/DataPipeline/SetTaskStatus.hs +252/−0
• gen/Amazonka/DataPipeline/Types.hs +260/−0
• gen/Amazonka/DataPipeline/Types/Field.hs +110/−0
• gen/Amazonka/DataPipeline/Types/InstanceIdentity.hs +99/−0
• gen/Amazonka/DataPipeline/Types/Operator.hs +180/−0
• gen/Amazonka/DataPipeline/Types/OperatorType.hs +86/−0
• gen/Amazonka/DataPipeline/Types/ParameterAttribute.hs +97/−0
• gen/Amazonka/DataPipeline/Types/ParameterObject.hs +95/−0
• gen/Amazonka/DataPipeline/Types/ParameterValue.hs +97/−0
• gen/Amazonka/DataPipeline/Types/PipelineDescription.hs +141/−0
• gen/Amazonka/DataPipeline/Types/PipelineIdName.hs +86/−0
• gen/Amazonka/DataPipeline/Types/PipelineObject.hs +113/−0
• gen/Amazonka/DataPipeline/Types/Query.hs +69/−0
• gen/Amazonka/DataPipeline/Types/Selector.hs +93/−0
• gen/Amazonka/DataPipeline/Types/Tag.hs +112/−0
• gen/Amazonka/DataPipeline/Types/TaskObject.hs +119/−0
• gen/Amazonka/DataPipeline/Types/TaskStatus.hs +76/−0
• gen/Amazonka/DataPipeline/Types/ValidationError.hs +85/−0
• gen/Amazonka/DataPipeline/Types/ValidationWarning.hs +85/−0
• gen/Amazonka/DataPipeline/ValidatePipelineDefinition.hs +261/−0
• gen/Amazonka/DataPipeline/Waiters.hs +24/−0
• gen/Network/AWS/DataPipeline.hs +0/−262
• gen/Network/AWS/DataPipeline/ActivatePipeline.hs +0/−157
• gen/Network/AWS/DataPipeline/AddTags.hs +0/−138
• gen/Network/AWS/DataPipeline/CreatePipeline.hs +0/−174
• gen/Network/AWS/DataPipeline/DeactivatePipeline.hs +0/−143
• gen/Network/AWS/DataPipeline/DeletePipeline.hs +0/−113
• gen/Network/AWS/DataPipeline/DescribeObjects.hs +0/−206
• gen/Network/AWS/DataPipeline/DescribePipelines.hs +0/−143
• gen/Network/AWS/DataPipeline/EvaluateExpression.hs +0/−170
• gen/Network/AWS/DataPipeline/GetPipelineDefinition.hs +0/−174
• gen/Network/AWS/DataPipeline/ListPipelines.hs +0/−169
• gen/Network/AWS/DataPipeline/PollForTask.hs +0/−165
• gen/Network/AWS/DataPipeline/PutPipelineDefinition.hs +0/−204
• gen/Network/AWS/DataPipeline/QueryObjects.hs +0/−216
• gen/Network/AWS/DataPipeline/RemoveTags.hs +0/−140
• gen/Network/AWS/DataPipeline/ReportTaskProgress.hs +0/−154
• gen/Network/AWS/DataPipeline/ReportTaskRunnerHeartbeat.hs +0/−167
• gen/Network/AWS/DataPipeline/SetStatus.hs +0/−133
• gen/Network/AWS/DataPipeline/SetTaskStatus.hs +0/−174
• gen/Network/AWS/DataPipeline/Types.hs +0/−209
• gen/Network/AWS/DataPipeline/Types/Product.hs +0/−770
• gen/Network/AWS/DataPipeline/Types/Sum.hs +0/−86
• gen/Network/AWS/DataPipeline/ValidatePipelineDefinition.hs +0/−200
• gen/Network/AWS/DataPipeline/Waiters.hs +0/−21
• test/Main.hs +11/−9
• test/Test/AWS/DataPipeline.hs +0/−26
• test/Test/AWS/DataPipeline/Internal.hs +0/−16
• test/Test/AWS/Gen/DataPipeline.hs +0/−381
• test/Test/Amazonka/DataPipeline.hs +20/−0
• test/Test/Amazonka/DataPipeline/Internal.hs +8/−0
• test/Test/Amazonka/Gen/DataPipeline.hs +418/−0

@@ -7,9 +7,8 @@   ## Version--`1.6.1`-+ +`2.0` - Derived from API version @2012-10-29@ of the AWS service descriptions, licensed under Apache 2.0.  ## Description @@ -26,7 +25,7 @@ The provided lenses should be compatible with any of the major lens libraries [lens](http://hackage.haskell.org/package/lens) or [lens-family-core](http://hackage.haskell.org/package/lens-family-core). -See [Network.AWS.DataPipeline](http://hackage.haskell.org/package/amazonka-datapipeline/docs/Network-AWS-DataPipeline.html)+See [Amazonka.DataPipeline](http://hackage.haskell.org/package/amazonka-datapipeline/docs/Amazonka-DataPipeline.html) or [the AWS documentation](https://aws.amazon.com/documentation/) to get started.  

@@ -1,2 +0,0 @@-import           Distribution.Simple-main = defaultMain

@@ -1,104 +1,119 @@-name:                  amazonka-datapipeline-version:               1.6.1-synopsis:              Amazon Data Pipeline SDK.-homepage:              https://github.com/brendanhay/amazonka-bug-reports:           https://github.com/brendanhay/amazonka/issues-license:               MPL-2.0-license-file:          LICENSE-author:                Brendan Hay-maintainer:            Brendan Hay <brendan.g.hay+amazonka@gmail.com>-copyright:             Copyright (c) 2013-2018 Brendan Hay-category:              Network, AWS, Cloud, Distributed Computing-build-type:            Simple-cabal-version:         >= 1.10-extra-source-files:    README.md fixture/*.yaml fixture/*.proto src/.gitkeep+cabal-version:      2.2+name:               amazonka-datapipeline+version:            2.0+synopsis:           Amazon Data Pipeline SDK.+homepage:           https://github.com/brendanhay/amazonka+bug-reports:        https://github.com/brendanhay/amazonka/issues+license:            MPL-2.0+license-file:       LICENSE+author:             Brendan Hay+maintainer:+  Brendan Hay <brendan.g.hay+amazonka@gmail.com>, Jack Kelly <jack@jackkelly.name>++copyright:          Copyright (c) 2013-2023 Brendan Hay+category:           AWS+build-type:         Simple+extra-source-files:+  fixture/*.proto+  fixture/*.yaml+  README.md+  src/.gitkeep+ description:-    The types from this library are intended to be used with-    <http://hackage.haskell.org/package/amazonka amazonka>, which provides-    mechanisms for specifying AuthN/AuthZ information, sending requests,-    and receiving responses.-    .-    Lenses are used for constructing and manipulating types,-    due to the depth of nesting of AWS types and transparency regarding-    de/serialisation into more palatable Haskell values.-    The provided lenses should be compatible with any of the major lens libraries-    such as <http://hackage.haskell.org/package/lens lens> or-    <http://hackage.haskell.org/package/lens-family-core lens-family-core>.-    .-    See "Network.AWS.DataPipeline" or <https://aws.amazon.com/documentation/ the AWS documentation>-    to get started.+  Derived from API version @2012-10-29@ of the AWS service descriptions, licensed under Apache 2.0.+  .+  The types from this library are intended to be used with <http://hackage.haskell.org/package/amazonka amazonka>,+  which provides mechanisms for specifying AuthN/AuthZ information, sending requests, and receiving responses.+  .+  It is recommended to use generic lenses or optics from packages such as <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify optional fields and deconstruct responses.+  .+  Generated lenses can be found in "Amazonka.DataPipeline.Lens" and are+  suitable for use with a lens package such as <http://hackage.haskell.org/package/lens lens> or <http://hackage.haskell.org/package/lens-family-core lens-family-core>.+  .+  See "Amazonka.DataPipeline" and the <https://aws.amazon.com/documentation/ AWS documentation> to get started.  source-repository head-    type:              git-    location:          git://github.com/brendanhay/amazonka.git-    subdir:            amazonka-datapipeline+  type:     git+  location: git://github.com/brendanhay/amazonka.git+  subdir:   amazonka-datapipeline  library-    default-language:  Haskell2010-    hs-source-dirs:    src gen--    ghc-options:-        -Wall-        -fwarn-incomplete-uni-patterns-        -fwarn-incomplete-record-updates-        -funbox-strict-fields--    exposed-modules:-          Network.AWS.DataPipeline-        , Network.AWS.DataPipeline.ActivatePipeline-        , Network.AWS.DataPipeline.AddTags-        , Network.AWS.DataPipeline.CreatePipeline-        , Network.AWS.DataPipeline.DeactivatePipeline-        , Network.AWS.DataPipeline.DeletePipeline-        , Network.AWS.DataPipeline.DescribeObjects-        , Network.AWS.DataPipeline.DescribePipelines-        , Network.AWS.DataPipeline.EvaluateExpression-        , Network.AWS.DataPipeline.GetPipelineDefinition-        , Network.AWS.DataPipeline.ListPipelines-        , Network.AWS.DataPipeline.PollForTask-        , Network.AWS.DataPipeline.PutPipelineDefinition-        , Network.AWS.DataPipeline.QueryObjects-        , Network.AWS.DataPipeline.RemoveTags-        , Network.AWS.DataPipeline.ReportTaskProgress-        , Network.AWS.DataPipeline.ReportTaskRunnerHeartbeat-        , Network.AWS.DataPipeline.SetStatus-        , Network.AWS.DataPipeline.SetTaskStatus-        , Network.AWS.DataPipeline.Types-        , Network.AWS.DataPipeline.ValidatePipelineDefinition-        , Network.AWS.DataPipeline.Waiters+  default-language: Haskell2010+  hs-source-dirs:   src gen+  ghc-options:+    -Wall -fwarn-incomplete-uni-patterns+    -fwarn-incomplete-record-updates -funbox-strict-fields -    other-modules:-          Network.AWS.DataPipeline.Types.Product-        , Network.AWS.DataPipeline.Types.Sum+  exposed-modules:+    Amazonka.DataPipeline+    Amazonka.DataPipeline.ActivatePipeline+    Amazonka.DataPipeline.AddTags+    Amazonka.DataPipeline.CreatePipeline+    Amazonka.DataPipeline.DeactivatePipeline+    Amazonka.DataPipeline.DeletePipeline+    Amazonka.DataPipeline.DescribeObjects+    Amazonka.DataPipeline.DescribePipelines+    Amazonka.DataPipeline.EvaluateExpression+    Amazonka.DataPipeline.GetPipelineDefinition+    Amazonka.DataPipeline.Lens+    Amazonka.DataPipeline.ListPipelines+    Amazonka.DataPipeline.PollForTask+    Amazonka.DataPipeline.PutPipelineDefinition+    Amazonka.DataPipeline.QueryObjects+    Amazonka.DataPipeline.RemoveTags+    Amazonka.DataPipeline.ReportTaskProgress+    Amazonka.DataPipeline.ReportTaskRunnerHeartbeat+    Amazonka.DataPipeline.SetStatus+    Amazonka.DataPipeline.SetTaskStatus+    Amazonka.DataPipeline.Types+    Amazonka.DataPipeline.Types.Field+    Amazonka.DataPipeline.Types.InstanceIdentity+    Amazonka.DataPipeline.Types.Operator+    Amazonka.DataPipeline.Types.OperatorType+    Amazonka.DataPipeline.Types.ParameterAttribute+    Amazonka.DataPipeline.Types.ParameterObject+    Amazonka.DataPipeline.Types.ParameterValue+    Amazonka.DataPipeline.Types.PipelineDescription+    Amazonka.DataPipeline.Types.PipelineIdName+    Amazonka.DataPipeline.Types.PipelineObject+    Amazonka.DataPipeline.Types.Query+    Amazonka.DataPipeline.Types.Selector+    Amazonka.DataPipeline.Types.Tag+    Amazonka.DataPipeline.Types.TaskObject+    Amazonka.DataPipeline.Types.TaskStatus+    Amazonka.DataPipeline.Types.ValidationError+    Amazonka.DataPipeline.Types.ValidationWarning+    Amazonka.DataPipeline.ValidatePipelineDefinition+    Amazonka.DataPipeline.Waiters -    build-depends:-          amazonka-core == 1.6.1.*-        , base          >= 4.7     && < 5+  build-depends:+    , amazonka-core  >=2.0  && <2.1+    , base           >=4.12 && <5  test-suite amazonka-datapipeline-test-    type:              exitcode-stdio-1.0-    default-language:  Haskell2010-    hs-source-dirs:    test-    main-is:           Main.hs--    ghc-options:       -Wall -threaded+  type:             exitcode-stdio-1.0+  default-language: Haskell2010+  hs-source-dirs:   test+  main-is:          Main.hs+  ghc-options:      -Wall -threaded -    -- This section is encoded by the template and any modules added by-    -- hand outside these namespaces will not correctly be added to the-    -- distribution package.-    other-modules:-          Test.AWS.DataPipeline-        , Test.AWS.Gen.DataPipeline-        , Test.AWS.DataPipeline.Internal+  -- This section is encoded by the template and any modules added by+  -- hand outside these namespaces will not correctly be added to the+  -- distribution package.+  other-modules:+    Test.Amazonka.DataPipeline+    Test.Amazonka.DataPipeline.Internal+    Test.Amazonka.Gen.DataPipeline -    build-depends:-          amazonka-core == 1.6.1.*-        , amazonka-test == 1.6.1.*-        , amazonka-datapipeline-        , base-        , bytestring-        , tasty-        , tasty-hunit-        , text-        , time-        , unordered-containers+  build-depends:+    , amazonka-core          >=2.0 && <2.1+    , amazonka-datapipeline+    , amazonka-test          >=2.0 && <2.1+    , base+    , bytestring+    , case-insensitive+    , tasty+    , tasty-hunit+    , text+    , time+    , unordered-containers

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,10 @@+---+method: POST+headers:+  Authorization:         AWS4-HMAC-SHA256 Credential=access/20091028/us-east-1/datapipeline/aws4_request, SignedHeaders=content-type;host;x-amz-content-sha256;x-amz-date, Signature=?+  Host:                  datapipeline.us-east-1.amazonaws.com+  Content-Type:          application/x-www-form-urlencoded; charset=utf-8+  X-Amz-Content-SHA256:  abcdef+  X-Amz-Date:            20091028T223200Z+body:+  ''

@@ -0,0 +1,297 @@+{-# OPTIONS_GHC -fno-warn-duplicate-exports #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}++-- |+-- Module      : Amazonka.DataPipeline+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Derived from API version @2012-10-29@ of the AWS service descriptions, licensed under Apache 2.0.+--+-- AWS Data Pipeline configures and manages a data-driven workflow called a+-- pipeline. AWS Data Pipeline handles the details of scheduling and+-- ensuring that data dependencies are met so that your application can+-- focus on processing the data.+--+-- AWS Data Pipeline provides a JAR implementation of a task runner called+-- AWS Data Pipeline Task Runner. AWS Data Pipeline Task Runner provides+-- logic for common data management scenarios, such as performing database+-- queries and running data analysis using Amazon Elastic MapReduce (Amazon+-- EMR). You can use AWS Data Pipeline Task Runner as your task runner, or+-- you can write your own task runner to provide custom data management.+--+-- AWS Data Pipeline implements two main sets of functionality. Use the+-- first set to create a pipeline and define data sources, schedules,+-- dependencies, and the transforms to be performed on the data. Use the+-- second set in your task runner application to receive the next task+-- ready for processing. The logic for performing the task, such as+-- querying the data, running data analysis, or converting the data from+-- one format to another, is contained within the task runner. The task+-- runner performs the task assigned to it by the web service, reporting+-- progress to the web service as it does so. When the task is done, the+-- task runner reports the final success or failure of the task to the web+-- service.+module Amazonka.DataPipeline+  ( -- * Service Configuration+    defaultService,++    -- * Errors+    -- $errors++    -- ** InternalServiceError+    _InternalServiceError,++    -- ** InvalidRequestException+    _InvalidRequestException,++    -- ** PipelineDeletedException+    _PipelineDeletedException,++    -- ** PipelineNotFoundException+    _PipelineNotFoundException,++    -- ** TaskNotFoundException+    _TaskNotFoundException,++    -- * Waiters+    -- $waiters++    -- * Operations+    -- $operations++    -- ** ActivatePipeline+    ActivatePipeline (ActivatePipeline'),+    newActivatePipeline,+    ActivatePipelineResponse (ActivatePipelineResponse'),+    newActivatePipelineResponse,++    -- ** AddTags+    AddTags (AddTags'),+    newAddTags,+    AddTagsResponse (AddTagsResponse'),+    newAddTagsResponse,++    -- ** CreatePipeline+    CreatePipeline (CreatePipeline'),+    newCreatePipeline,+    CreatePipelineResponse (CreatePipelineResponse'),+    newCreatePipelineResponse,++    -- ** DeactivatePipeline+    DeactivatePipeline (DeactivatePipeline'),+    newDeactivatePipeline,+    DeactivatePipelineResponse (DeactivatePipelineResponse'),+    newDeactivatePipelineResponse,++    -- ** DeletePipeline+    DeletePipeline (DeletePipeline'),+    newDeletePipeline,+    DeletePipelineResponse (DeletePipelineResponse'),+    newDeletePipelineResponse,++    -- ** DescribeObjects (Paginated)+    DescribeObjects (DescribeObjects'),+    newDescribeObjects,+    DescribeObjectsResponse (DescribeObjectsResponse'),+    newDescribeObjectsResponse,++    -- ** DescribePipelines+    DescribePipelines (DescribePipelines'),+    newDescribePipelines,+    DescribePipelinesResponse (DescribePipelinesResponse'),+    newDescribePipelinesResponse,++    -- ** EvaluateExpression+    EvaluateExpression (EvaluateExpression'),+    newEvaluateExpression,+    EvaluateExpressionResponse (EvaluateExpressionResponse'),+    newEvaluateExpressionResponse,++    -- ** GetPipelineDefinition+    GetPipelineDefinition (GetPipelineDefinition'),+    newGetPipelineDefinition,+    GetPipelineDefinitionResponse (GetPipelineDefinitionResponse'),+    newGetPipelineDefinitionResponse,++    -- ** ListPipelines (Paginated)+    ListPipelines (ListPipelines'),+    newListPipelines,+    ListPipelinesResponse (ListPipelinesResponse'),+    newListPipelinesResponse,++    -- ** PollForTask+    PollForTask (PollForTask'),+    newPollForTask,+    PollForTaskResponse (PollForTaskResponse'),+    newPollForTaskResponse,++    -- ** PutPipelineDefinition+    PutPipelineDefinition (PutPipelineDefinition'),+    newPutPipelineDefinition,+    PutPipelineDefinitionResponse (PutPipelineDefinitionResponse'),+    newPutPipelineDefinitionResponse,++    -- ** QueryObjects (Paginated)+    QueryObjects (QueryObjects'),+    newQueryObjects,+    QueryObjectsResponse (QueryObjectsResponse'),+    newQueryObjectsResponse,++    -- ** RemoveTags+    RemoveTags (RemoveTags'),+    newRemoveTags,+    RemoveTagsResponse (RemoveTagsResponse'),+    newRemoveTagsResponse,++    -- ** ReportTaskProgress+    ReportTaskProgress (ReportTaskProgress'),+    newReportTaskProgress,+    ReportTaskProgressResponse (ReportTaskProgressResponse'),+    newReportTaskProgressResponse,++    -- ** ReportTaskRunnerHeartbeat+    ReportTaskRunnerHeartbeat (ReportTaskRunnerHeartbeat'),+    newReportTaskRunnerHeartbeat,+    ReportTaskRunnerHeartbeatResponse (ReportTaskRunnerHeartbeatResponse'),+    newReportTaskRunnerHeartbeatResponse,++    -- ** SetStatus+    SetStatus (SetStatus'),+    newSetStatus,+    SetStatusResponse (SetStatusResponse'),+    newSetStatusResponse,++    -- ** SetTaskStatus+    SetTaskStatus (SetTaskStatus'),+    newSetTaskStatus,+    SetTaskStatusResponse (SetTaskStatusResponse'),+    newSetTaskStatusResponse,++    -- ** ValidatePipelineDefinition+    ValidatePipelineDefinition (ValidatePipelineDefinition'),+    newValidatePipelineDefinition,+    ValidatePipelineDefinitionResponse (ValidatePipelineDefinitionResponse'),+    newValidatePipelineDefinitionResponse,++    -- * Types++    -- ** OperatorType+    OperatorType (..),++    -- ** TaskStatus+    TaskStatus (..),++    -- ** Field+    Field (Field'),+    newField,++    -- ** InstanceIdentity+    InstanceIdentity (InstanceIdentity'),+    newInstanceIdentity,++    -- ** Operator+    Operator (Operator'),+    newOperator,++    -- ** ParameterAttribute+    ParameterAttribute (ParameterAttribute'),+    newParameterAttribute,++    -- ** ParameterObject+    ParameterObject (ParameterObject'),+    newParameterObject,++    -- ** ParameterValue+    ParameterValue (ParameterValue'),+    newParameterValue,++    -- ** PipelineDescription+    PipelineDescription (PipelineDescription'),+    newPipelineDescription,++    -- ** PipelineIdName+    PipelineIdName (PipelineIdName'),+    newPipelineIdName,++    -- ** PipelineObject+    PipelineObject (PipelineObject'),+    newPipelineObject,++    -- ** Query+    Query (Query'),+    newQuery,++    -- ** Selector+    Selector (Selector'),+    newSelector,++    -- ** Tag+    Tag (Tag'),+    newTag,++    -- ** TaskObject+    TaskObject (TaskObject'),+    newTaskObject,++    -- ** ValidationError+    ValidationError (ValidationError'),+    newValidationError,++    -- ** ValidationWarning+    ValidationWarning (ValidationWarning'),+    newValidationWarning,+  )+where++import Amazonka.DataPipeline.ActivatePipeline+import Amazonka.DataPipeline.AddTags+import Amazonka.DataPipeline.CreatePipeline+import Amazonka.DataPipeline.DeactivatePipeline+import Amazonka.DataPipeline.DeletePipeline+import Amazonka.DataPipeline.DescribeObjects+import Amazonka.DataPipeline.DescribePipelines+import Amazonka.DataPipeline.EvaluateExpression+import Amazonka.DataPipeline.GetPipelineDefinition+import Amazonka.DataPipeline.Lens+import Amazonka.DataPipeline.ListPipelines+import Amazonka.DataPipeline.PollForTask+import Amazonka.DataPipeline.PutPipelineDefinition+import Amazonka.DataPipeline.QueryObjects+import Amazonka.DataPipeline.RemoveTags+import Amazonka.DataPipeline.ReportTaskProgress+import Amazonka.DataPipeline.ReportTaskRunnerHeartbeat+import Amazonka.DataPipeline.SetStatus+import Amazonka.DataPipeline.SetTaskStatus+import Amazonka.DataPipeline.Types+import Amazonka.DataPipeline.ValidatePipelineDefinition+import Amazonka.DataPipeline.Waiters++-- $errors+-- Error matchers are designed for use with the functions provided by+-- <http://hackage.haskell.org/package/lens/docs/Control-Exception-Lens.html Control.Exception.Lens>.+-- This allows catching (and rethrowing) service specific errors returned+-- by 'DataPipeline'.++-- $operations+-- Some AWS operations return results that are incomplete and require subsequent+-- requests in order to obtain the entire result set. The process of sending+-- subsequent requests to continue where a previous request left off is called+-- pagination. For example, the 'ListObjects' operation of Amazon S3 returns up to+-- 1000 objects at a time, and you must send subsequent requests with the+-- appropriate Marker in order to retrieve the next page of results.+--+-- Operations that have an 'AWSPager' instance can transparently perform subsequent+-- requests, correctly setting Markers and other request facets to iterate through+-- the entire result set of a truncated API operation. Operations which support+-- this have an additional note in the documentation.+--+-- Many operations have the ability to filter results on the server side. See the+-- individual operation parameters for details.++-- $waiters+-- Waiters poll by repeatedly sending a request until some remote success condition+-- configured by the 'Wait' specification is fulfilled. The 'Wait' specification+-- determines how many attempts should be made, in addition to delay and retry strategies.

@@ -0,0 +1,204 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.ActivatePipeline+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Validates the specified pipeline and starts processing pipeline tasks.+-- If the pipeline does not pass validation, activation fails.+--+-- If you need to pause the pipeline to investigate an issue with a+-- component, such as a data source or script, call DeactivatePipeline.+--+-- To activate a finished pipeline, modify the end date for the pipeline+-- and then activate it.+module Amazonka.DataPipeline.ActivatePipeline+  ( -- * Creating a Request+    ActivatePipeline (..),+    newActivatePipeline,++    -- * Request Lenses+    activatePipeline_parameterValues,+    activatePipeline_startTimestamp,+    activatePipeline_pipelineId,++    -- * Destructuring the Response+    ActivatePipelineResponse (..),+    newActivatePipelineResponse,++    -- * Response Lenses+    activatePipelineResponse_httpStatus,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for ActivatePipeline.+--+-- /See:/ 'newActivatePipeline' smart constructor.+data ActivatePipeline = ActivatePipeline'+  { -- | A list of parameter values to pass to the pipeline at activation.+    parameterValues :: Prelude.Maybe [ParameterValue],+    -- | The date and time to resume the pipeline. By default, the pipeline+    -- resumes from the last completed execution.+    startTimestamp :: Prelude.Maybe Data.POSIX,+    -- | The ID of the pipeline.+    pipelineId :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'ActivatePipeline' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'parameterValues', 'activatePipeline_parameterValues' - A list of parameter values to pass to the pipeline at activation.+--+-- 'startTimestamp', 'activatePipeline_startTimestamp' - The date and time to resume the pipeline. By default, the pipeline+-- resumes from the last completed execution.+--+-- 'pipelineId', 'activatePipeline_pipelineId' - The ID of the pipeline.+newActivatePipeline ::+  -- | 'pipelineId'+  Prelude.Text ->+  ActivatePipeline+newActivatePipeline pPipelineId_ =+  ActivatePipeline'+    { parameterValues =+        Prelude.Nothing,+      startTimestamp = Prelude.Nothing,+      pipelineId = pPipelineId_+    }++-- | A list of parameter values to pass to the pipeline at activation.+activatePipeline_parameterValues :: Lens.Lens' ActivatePipeline (Prelude.Maybe [ParameterValue])+activatePipeline_parameterValues = Lens.lens (\ActivatePipeline' {parameterValues} -> parameterValues) (\s@ActivatePipeline' {} a -> s {parameterValues = a} :: ActivatePipeline) Prelude.. Lens.mapping Lens.coerced++-- | The date and time to resume the pipeline. By default, the pipeline+-- resumes from the last completed execution.+activatePipeline_startTimestamp :: Lens.Lens' ActivatePipeline (Prelude.Maybe Prelude.UTCTime)+activatePipeline_startTimestamp = Lens.lens (\ActivatePipeline' {startTimestamp} -> startTimestamp) (\s@ActivatePipeline' {} a -> s {startTimestamp = a} :: ActivatePipeline) Prelude.. Lens.mapping Data._Time++-- | The ID of the pipeline.+activatePipeline_pipelineId :: Lens.Lens' ActivatePipeline Prelude.Text+activatePipeline_pipelineId = Lens.lens (\ActivatePipeline' {pipelineId} -> pipelineId) (\s@ActivatePipeline' {} a -> s {pipelineId = a} :: ActivatePipeline)++instance Core.AWSRequest ActivatePipeline where+  type+    AWSResponse ActivatePipeline =+      ActivatePipelineResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveEmpty+      ( \s h x ->+          ActivatePipelineResponse'+            Prelude.<$> (Prelude.pure (Prelude.fromEnum s))+      )++instance Prelude.Hashable ActivatePipeline where+  hashWithSalt _salt ActivatePipeline' {..} =+    _salt+      `Prelude.hashWithSalt` parameterValues+      `Prelude.hashWithSalt` startTimestamp+      `Prelude.hashWithSalt` pipelineId++instance Prelude.NFData ActivatePipeline where+  rnf ActivatePipeline' {..} =+    Prelude.rnf parameterValues+      `Prelude.seq` Prelude.rnf startTimestamp+      `Prelude.seq` Prelude.rnf pipelineId++instance Data.ToHeaders ActivatePipeline where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "DataPipeline.ActivatePipeline" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON ActivatePipeline where+  toJSON ActivatePipeline' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("parameterValues" Data..=)+              Prelude.<$> parameterValues,+            ("startTimestamp" Data..=)+              Prelude.<$> startTimestamp,+            Prelude.Just ("pipelineId" Data..= pipelineId)+          ]+      )++instance Data.ToPath ActivatePipeline where+  toPath = Prelude.const "/"++instance Data.ToQuery ActivatePipeline where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of ActivatePipeline.+--+-- /See:/ 'newActivatePipelineResponse' smart constructor.+data ActivatePipelineResponse = ActivatePipelineResponse'+  { -- | The response's http status code.+    httpStatus :: Prelude.Int+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'ActivatePipelineResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'httpStatus', 'activatePipelineResponse_httpStatus' - The response's http status code.+newActivatePipelineResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  ActivatePipelineResponse+newActivatePipelineResponse pHttpStatus_ =+  ActivatePipelineResponse'+    { httpStatus =+        pHttpStatus_+    }++-- | The response's http status code.+activatePipelineResponse_httpStatus :: Lens.Lens' ActivatePipelineResponse Prelude.Int+activatePipelineResponse_httpStatus = Lens.lens (\ActivatePipelineResponse' {httpStatus} -> httpStatus) (\s@ActivatePipelineResponse' {} a -> s {httpStatus = a} :: ActivatePipelineResponse)++instance Prelude.NFData ActivatePipelineResponse where+  rnf ActivatePipelineResponse' {..} =+    Prelude.rnf httpStatus

@@ -0,0 +1,170 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.AddTags+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Adds or modifies tags for the specified pipeline.+module Amazonka.DataPipeline.AddTags+  ( -- * Creating a Request+    AddTags (..),+    newAddTags,++    -- * Request Lenses+    addTags_pipelineId,+    addTags_tags,++    -- * Destructuring the Response+    AddTagsResponse (..),+    newAddTagsResponse,++    -- * Response Lenses+    addTagsResponse_httpStatus,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for AddTags.+--+-- /See:/ 'newAddTags' smart constructor.+data AddTags = AddTags'+  { -- | The ID of the pipeline.+    pipelineId :: Prelude.Text,+    -- | The tags to add, as key\/value pairs.+    tags :: [Tag]+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'AddTags' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'pipelineId', 'addTags_pipelineId' - The ID of the pipeline.+--+-- 'tags', 'addTags_tags' - The tags to add, as key\/value pairs.+newAddTags ::+  -- | 'pipelineId'+  Prelude.Text ->+  AddTags+newAddTags pPipelineId_ =+  AddTags'+    { pipelineId = pPipelineId_,+      tags = Prelude.mempty+    }++-- | The ID of the pipeline.+addTags_pipelineId :: Lens.Lens' AddTags Prelude.Text+addTags_pipelineId = Lens.lens (\AddTags' {pipelineId} -> pipelineId) (\s@AddTags' {} a -> s {pipelineId = a} :: AddTags)++-- | The tags to add, as key\/value pairs.+addTags_tags :: Lens.Lens' AddTags [Tag]+addTags_tags = Lens.lens (\AddTags' {tags} -> tags) (\s@AddTags' {} a -> s {tags = a} :: AddTags) Prelude.. Lens.coerced++instance Core.AWSRequest AddTags where+  type AWSResponse AddTags = AddTagsResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveEmpty+      ( \s h x ->+          AddTagsResponse'+            Prelude.<$> (Prelude.pure (Prelude.fromEnum s))+      )++instance Prelude.Hashable AddTags where+  hashWithSalt _salt AddTags' {..} =+    _salt+      `Prelude.hashWithSalt` pipelineId+      `Prelude.hashWithSalt` tags++instance Prelude.NFData AddTags where+  rnf AddTags' {..} =+    Prelude.rnf pipelineId+      `Prelude.seq` Prelude.rnf tags++instance Data.ToHeaders AddTags where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ("DataPipeline.AddTags" :: Prelude.ByteString),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON AddTags where+  toJSON AddTags' {..} =+    Data.object+      ( Prelude.catMaybes+          [ Prelude.Just ("pipelineId" Data..= pipelineId),+            Prelude.Just ("tags" Data..= tags)+          ]+      )++instance Data.ToPath AddTags where+  toPath = Prelude.const "/"++instance Data.ToQuery AddTags where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of AddTags.+--+-- /See:/ 'newAddTagsResponse' smart constructor.+data AddTagsResponse = AddTagsResponse'+  { -- | The response's http status code.+    httpStatus :: Prelude.Int+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'AddTagsResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'httpStatus', 'addTagsResponse_httpStatus' - The response's http status code.+newAddTagsResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  AddTagsResponse+newAddTagsResponse pHttpStatus_ =+  AddTagsResponse' {httpStatus = pHttpStatus_}++-- | The response's http status code.+addTagsResponse_httpStatus :: Lens.Lens' AddTagsResponse Prelude.Int+addTagsResponse_httpStatus = Lens.lens (\AddTagsResponse' {httpStatus} -> httpStatus) (\s@AddTagsResponse' {} a -> s {httpStatus = a} :: AddTagsResponse)++instance Prelude.NFData AddTagsResponse where+  rnf AddTagsResponse' {..} = Prelude.rnf httpStatus

@@ -0,0 +1,271 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.CreatePipeline+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Creates a new, empty pipeline. Use PutPipelineDefinition to populate the+-- pipeline.+module Amazonka.DataPipeline.CreatePipeline+  ( -- * Creating a Request+    CreatePipeline (..),+    newCreatePipeline,++    -- * Request Lenses+    createPipeline_description,+    createPipeline_tags,+    createPipeline_name,+    createPipeline_uniqueId,++    -- * Destructuring the Response+    CreatePipelineResponse (..),+    newCreatePipelineResponse,++    -- * Response Lenses+    createPipelineResponse_httpStatus,+    createPipelineResponse_pipelineId,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for CreatePipeline.+--+-- /See:/ 'newCreatePipeline' smart constructor.+data CreatePipeline = CreatePipeline'+  { -- | The description for the pipeline.+    description :: Prelude.Maybe Prelude.Text,+    -- | A list of tags to associate with the pipeline at creation. Tags let you+    -- control access to pipelines. For more information, see+    -- <http://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-control-access.html Controlling User Access to Pipelines>+    -- in the /AWS Data Pipeline Developer Guide/.+    tags :: Prelude.Maybe [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 :: Prelude.Text,+    -- | 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 :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'CreatePipeline' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'description', 'createPipeline_description' - The description for the pipeline.+--+-- 'tags', 'createPipeline_tags' - A list of tags to associate with the pipeline at creation. Tags let you+-- control access to pipelines. For more information, see+-- <http://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-control-access.html Controlling User Access to Pipelines>+-- in the /AWS Data Pipeline Developer Guide/.+--+-- 'name', 'createPipeline_name' - 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.+--+-- 'uniqueId', 'createPipeline_uniqueId' - 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.+newCreatePipeline ::+  -- | 'name'+  Prelude.Text ->+  -- | 'uniqueId'+  Prelude.Text ->+  CreatePipeline+newCreatePipeline pName_ pUniqueId_ =+  CreatePipeline'+    { description = Prelude.Nothing,+      tags = Prelude.Nothing,+      name = pName_,+      uniqueId = pUniqueId_+    }++-- | The description for the pipeline.+createPipeline_description :: Lens.Lens' CreatePipeline (Prelude.Maybe Prelude.Text)+createPipeline_description = Lens.lens (\CreatePipeline' {description} -> description) (\s@CreatePipeline' {} a -> s {description = a} :: CreatePipeline)++-- | A list of tags to associate with the pipeline at creation. Tags let you+-- control access to pipelines. For more information, see+-- <http://docs.aws.amazon.com/datapipeline/latest/DeveloperGuide/dp-control-access.html Controlling User Access to Pipelines>+-- in the /AWS Data Pipeline Developer Guide/.+createPipeline_tags :: Lens.Lens' CreatePipeline (Prelude.Maybe [Tag])+createPipeline_tags = Lens.lens (\CreatePipeline' {tags} -> tags) (\s@CreatePipeline' {} a -> s {tags = a} :: CreatePipeline) Prelude.. Lens.mapping Lens.coerced++-- | 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.+createPipeline_name :: Lens.Lens' CreatePipeline Prelude.Text+createPipeline_name = Lens.lens (\CreatePipeline' {name} -> name) (\s@CreatePipeline' {} a -> s {name = a} :: CreatePipeline)++-- | 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.+createPipeline_uniqueId :: Lens.Lens' CreatePipeline Prelude.Text+createPipeline_uniqueId = Lens.lens (\CreatePipeline' {uniqueId} -> uniqueId) (\s@CreatePipeline' {} a -> s {uniqueId = a} :: CreatePipeline)++instance Core.AWSRequest CreatePipeline where+  type+    AWSResponse CreatePipeline =+      CreatePipelineResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          CreatePipelineResponse'+            Prelude.<$> (Prelude.pure (Prelude.fromEnum s))+            Prelude.<*> (x Data..:> "pipelineId")+      )++instance Prelude.Hashable CreatePipeline where+  hashWithSalt _salt CreatePipeline' {..} =+    _salt+      `Prelude.hashWithSalt` description+      `Prelude.hashWithSalt` tags+      `Prelude.hashWithSalt` name+      `Prelude.hashWithSalt` uniqueId++instance Prelude.NFData CreatePipeline where+  rnf CreatePipeline' {..} =+    Prelude.rnf description+      `Prelude.seq` Prelude.rnf tags+      `Prelude.seq` Prelude.rnf name+      `Prelude.seq` Prelude.rnf uniqueId++instance Data.ToHeaders CreatePipeline where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "DataPipeline.CreatePipeline" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON CreatePipeline where+  toJSON CreatePipeline' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("description" Data..=) Prelude.<$> description,+            ("tags" Data..=) Prelude.<$> tags,+            Prelude.Just ("name" Data..= name),+            Prelude.Just ("uniqueId" Data..= uniqueId)+          ]+      )++instance Data.ToPath CreatePipeline where+  toPath = Prelude.const "/"++instance Data.ToQuery CreatePipeline where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of CreatePipeline.+--+-- /See:/ 'newCreatePipelineResponse' smart constructor.+data CreatePipelineResponse = CreatePipelineResponse'+  { -- | The response's http status code.+    httpStatus :: Prelude.Int,+    -- | The ID that AWS Data Pipeline assigns the newly created pipeline. For+    -- example, @df-06372391ZG65EXAMPLE@.+    pipelineId :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'CreatePipelineResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'httpStatus', 'createPipelineResponse_httpStatus' - The response's http status code.+--+-- 'pipelineId', 'createPipelineResponse_pipelineId' - The ID that AWS Data Pipeline assigns the newly created pipeline. For+-- example, @df-06372391ZG65EXAMPLE@.+newCreatePipelineResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  -- | 'pipelineId'+  Prelude.Text ->+  CreatePipelineResponse+newCreatePipelineResponse pHttpStatus_ pPipelineId_ =+  CreatePipelineResponse'+    { httpStatus = pHttpStatus_,+      pipelineId = pPipelineId_+    }++-- | The response's http status code.+createPipelineResponse_httpStatus :: Lens.Lens' CreatePipelineResponse Prelude.Int+createPipelineResponse_httpStatus = Lens.lens (\CreatePipelineResponse' {httpStatus} -> httpStatus) (\s@CreatePipelineResponse' {} a -> s {httpStatus = a} :: CreatePipelineResponse)++-- | The ID that AWS Data Pipeline assigns the newly created pipeline. For+-- example, @df-06372391ZG65EXAMPLE@.+createPipelineResponse_pipelineId :: Lens.Lens' CreatePipelineResponse Prelude.Text+createPipelineResponse_pipelineId = Lens.lens (\CreatePipelineResponse' {pipelineId} -> pipelineId) (\s@CreatePipelineResponse' {} a -> s {pipelineId = a} :: CreatePipelineResponse)++instance Prelude.NFData CreatePipelineResponse where+  rnf CreatePipelineResponse' {..} =+    Prelude.rnf httpStatus+      `Prelude.seq` Prelude.rnf pipelineId

@@ -0,0 +1,189 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.DeactivatePipeline+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Deactivates the specified running pipeline. The pipeline is set to the+-- @DEACTIVATING@ state until the deactivation process completes.+--+-- To resume a deactivated pipeline, use ActivatePipeline. By default, the+-- pipeline resumes from the last completed execution. Optionally, you can+-- specify the date and time to resume the pipeline.+module Amazonka.DataPipeline.DeactivatePipeline+  ( -- * Creating a Request+    DeactivatePipeline (..),+    newDeactivatePipeline,++    -- * Request Lenses+    deactivatePipeline_cancelActive,+    deactivatePipeline_pipelineId,++    -- * Destructuring the Response+    DeactivatePipelineResponse (..),+    newDeactivatePipelineResponse,++    -- * Response Lenses+    deactivatePipelineResponse_httpStatus,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for DeactivatePipeline.+--+-- /See:/ 'newDeactivatePipeline' smart constructor.+data DeactivatePipeline = DeactivatePipeline'+  { -- | 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 :: Prelude.Maybe Prelude.Bool,+    -- | The ID of the pipeline.+    pipelineId :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DeactivatePipeline' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'cancelActive', 'deactivatePipeline_cancelActive' - 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.+--+-- 'pipelineId', 'deactivatePipeline_pipelineId' - The ID of the pipeline.+newDeactivatePipeline ::+  -- | 'pipelineId'+  Prelude.Text ->+  DeactivatePipeline+newDeactivatePipeline pPipelineId_ =+  DeactivatePipeline'+    { cancelActive = Prelude.Nothing,+      pipelineId = pPipelineId_+    }++-- | 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.+deactivatePipeline_cancelActive :: Lens.Lens' DeactivatePipeline (Prelude.Maybe Prelude.Bool)+deactivatePipeline_cancelActive = Lens.lens (\DeactivatePipeline' {cancelActive} -> cancelActive) (\s@DeactivatePipeline' {} a -> s {cancelActive = a} :: DeactivatePipeline)++-- | The ID of the pipeline.+deactivatePipeline_pipelineId :: Lens.Lens' DeactivatePipeline Prelude.Text+deactivatePipeline_pipelineId = Lens.lens (\DeactivatePipeline' {pipelineId} -> pipelineId) (\s@DeactivatePipeline' {} a -> s {pipelineId = a} :: DeactivatePipeline)++instance Core.AWSRequest DeactivatePipeline where+  type+    AWSResponse DeactivatePipeline =+      DeactivatePipelineResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveEmpty+      ( \s h x ->+          DeactivatePipelineResponse'+            Prelude.<$> (Prelude.pure (Prelude.fromEnum s))+      )++instance Prelude.Hashable DeactivatePipeline where+  hashWithSalt _salt DeactivatePipeline' {..} =+    _salt+      `Prelude.hashWithSalt` cancelActive+      `Prelude.hashWithSalt` pipelineId++instance Prelude.NFData DeactivatePipeline where+  rnf DeactivatePipeline' {..} =+    Prelude.rnf cancelActive+      `Prelude.seq` Prelude.rnf pipelineId++instance Data.ToHeaders DeactivatePipeline where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "DataPipeline.DeactivatePipeline" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON DeactivatePipeline where+  toJSON DeactivatePipeline' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("cancelActive" Data..=) Prelude.<$> cancelActive,+            Prelude.Just ("pipelineId" Data..= pipelineId)+          ]+      )++instance Data.ToPath DeactivatePipeline where+  toPath = Prelude.const "/"++instance Data.ToQuery DeactivatePipeline where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of DeactivatePipeline.+--+-- /See:/ 'newDeactivatePipelineResponse' smart constructor.+data DeactivatePipelineResponse = DeactivatePipelineResponse'+  { -- | The response's http status code.+    httpStatus :: Prelude.Int+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DeactivatePipelineResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'httpStatus', 'deactivatePipelineResponse_httpStatus' - The response's http status code.+newDeactivatePipelineResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  DeactivatePipelineResponse+newDeactivatePipelineResponse pHttpStatus_ =+  DeactivatePipelineResponse'+    { httpStatus =+        pHttpStatus_+    }++-- | The response's http status code.+deactivatePipelineResponse_httpStatus :: Lens.Lens' DeactivatePipelineResponse Prelude.Int+deactivatePipelineResponse_httpStatus = Lens.lens (\DeactivatePipelineResponse' {httpStatus} -> httpStatus) (\s@DeactivatePipelineResponse' {} a -> s {httpStatus = a} :: DeactivatePipelineResponse)++instance Prelude.NFData DeactivatePipelineResponse where+  rnf DeactivatePipelineResponse' {..} =+    Prelude.rnf httpStatus

@@ -0,0 +1,141 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.DeletePipeline+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Deletes a pipeline, its pipeline definition, and its run history. AWS+-- Data Pipeline attempts to cancel instances associated with the pipeline+-- that are currently being processed by task runners.+--+-- Deleting a pipeline cannot be undone. You cannot query or restore a+-- deleted pipeline. To temporarily pause a pipeline instead of deleting+-- it, call SetStatus with the status set to @PAUSE@ on individual+-- components. Components that are paused by SetStatus can be resumed.+module Amazonka.DataPipeline.DeletePipeline+  ( -- * Creating a Request+    DeletePipeline (..),+    newDeletePipeline,++    -- * Request Lenses+    deletePipeline_pipelineId,++    -- * Destructuring the Response+    DeletePipelineResponse (..),+    newDeletePipelineResponse,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for DeletePipeline.+--+-- /See:/ 'newDeletePipeline' smart constructor.+data DeletePipeline = DeletePipeline'+  { -- | The ID of the pipeline.+    pipelineId :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DeletePipeline' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'pipelineId', 'deletePipeline_pipelineId' - The ID of the pipeline.+newDeletePipeline ::+  -- | 'pipelineId'+  Prelude.Text ->+  DeletePipeline+newDeletePipeline pPipelineId_ =+  DeletePipeline' {pipelineId = pPipelineId_}++-- | The ID of the pipeline.+deletePipeline_pipelineId :: Lens.Lens' DeletePipeline Prelude.Text+deletePipeline_pipelineId = Lens.lens (\DeletePipeline' {pipelineId} -> pipelineId) (\s@DeletePipeline' {} a -> s {pipelineId = a} :: DeletePipeline)++instance Core.AWSRequest DeletePipeline where+  type+    AWSResponse DeletePipeline =+      DeletePipelineResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveNull DeletePipelineResponse'++instance Prelude.Hashable DeletePipeline where+  hashWithSalt _salt DeletePipeline' {..} =+    _salt `Prelude.hashWithSalt` pipelineId++instance Prelude.NFData DeletePipeline where+  rnf DeletePipeline' {..} = Prelude.rnf pipelineId++instance Data.ToHeaders DeletePipeline where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "DataPipeline.DeletePipeline" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON DeletePipeline where+  toJSON DeletePipeline' {..} =+    Data.object+      ( Prelude.catMaybes+          [Prelude.Just ("pipelineId" Data..= pipelineId)]+      )++instance Data.ToPath DeletePipeline where+  toPath = Prelude.const "/"++instance Data.ToQuery DeletePipeline where+  toQuery = Prelude.const Prelude.mempty++-- | /See:/ 'newDeletePipelineResponse' smart constructor.+data DeletePipelineResponse = DeletePipelineResponse'+  {+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DeletePipelineResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+newDeletePipelineResponse ::+  DeletePipelineResponse+newDeletePipelineResponse = DeletePipelineResponse'++instance Prelude.NFData DeletePipelineResponse where+  rnf _ = ()

@@ -0,0 +1,295 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.DescribeObjects+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Gets the object definitions for a set of objects associated with the+-- pipeline. Object definitions are composed of a set of fields that define+-- the properties of the object.+--+-- This operation returns paginated results.+module Amazonka.DataPipeline.DescribeObjects+  ( -- * Creating a Request+    DescribeObjects (..),+    newDescribeObjects,++    -- * Request Lenses+    describeObjects_evaluateExpressions,+    describeObjects_marker,+    describeObjects_pipelineId,+    describeObjects_objectIds,++    -- * Destructuring the Response+    DescribeObjectsResponse (..),+    newDescribeObjectsResponse,++    -- * Response Lenses+    describeObjectsResponse_hasMoreResults,+    describeObjectsResponse_marker,+    describeObjectsResponse_httpStatus,+    describeObjectsResponse_pipelineObjects,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for DescribeObjects.+--+-- /See:/ 'newDescribeObjects' smart constructor.+data DescribeObjects = DescribeObjects'+  { -- | Indicates whether any expressions in the object should be evaluated when+    -- the object descriptions are returned.+    evaluateExpressions :: Prelude.Maybe Prelude.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 :: Prelude.Maybe Prelude.Text,+    -- | The ID of the pipeline that contains the object definitions.+    pipelineId :: Prelude.Text,+    -- | 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 :: [Prelude.Text]+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DescribeObjects' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'evaluateExpressions', 'describeObjects_evaluateExpressions' - Indicates whether any expressions in the object should be evaluated when+-- the object descriptions are returned.+--+-- 'marker', 'describeObjects_marker' - 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.+--+-- 'pipelineId', 'describeObjects_pipelineId' - The ID of the pipeline that contains the object definitions.+--+-- 'objectIds', 'describeObjects_objectIds' - 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@.+newDescribeObjects ::+  -- | 'pipelineId'+  Prelude.Text ->+  DescribeObjects+newDescribeObjects pPipelineId_ =+  DescribeObjects'+    { evaluateExpressions =+        Prelude.Nothing,+      marker = Prelude.Nothing,+      pipelineId = pPipelineId_,+      objectIds = Prelude.mempty+    }++-- | Indicates whether any expressions in the object should be evaluated when+-- the object descriptions are returned.+describeObjects_evaluateExpressions :: Lens.Lens' DescribeObjects (Prelude.Maybe Prelude.Bool)+describeObjects_evaluateExpressions = Lens.lens (\DescribeObjects' {evaluateExpressions} -> evaluateExpressions) (\s@DescribeObjects' {} a -> s {evaluateExpressions = a} :: DescribeObjects)++-- | 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.+describeObjects_marker :: Lens.Lens' DescribeObjects (Prelude.Maybe Prelude.Text)+describeObjects_marker = Lens.lens (\DescribeObjects' {marker} -> marker) (\s@DescribeObjects' {} a -> s {marker = a} :: DescribeObjects)++-- | The ID of the pipeline that contains the object definitions.+describeObjects_pipelineId :: Lens.Lens' DescribeObjects Prelude.Text+describeObjects_pipelineId = Lens.lens (\DescribeObjects' {pipelineId} -> pipelineId) (\s@DescribeObjects' {} a -> s {pipelineId = a} :: DescribeObjects)++-- | 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@.+describeObjects_objectIds :: Lens.Lens' DescribeObjects [Prelude.Text]+describeObjects_objectIds = Lens.lens (\DescribeObjects' {objectIds} -> objectIds) (\s@DescribeObjects' {} a -> s {objectIds = a} :: DescribeObjects) Prelude.. Lens.coerced++instance Core.AWSPager DescribeObjects where+  page rq rs+    | Core.stop+        ( rs+            Lens.^? describeObjectsResponse_hasMoreResults+            Prelude.. Lens._Just+        ) =+        Prelude.Nothing+    | Prelude.isNothing+        ( rs+            Lens.^? describeObjectsResponse_marker+            Prelude.. Lens._Just+        ) =+        Prelude.Nothing+    | Prelude.otherwise =+        Prelude.Just+          Prelude.$ rq+          Prelude.& describeObjects_marker+          Lens..~ rs+          Lens.^? describeObjectsResponse_marker+          Prelude.. Lens._Just++instance Core.AWSRequest DescribeObjects where+  type+    AWSResponse DescribeObjects =+      DescribeObjectsResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          DescribeObjectsResponse'+            Prelude.<$> (x Data..?> "hasMoreResults")+            Prelude.<*> (x Data..?> "marker")+            Prelude.<*> (Prelude.pure (Prelude.fromEnum s))+            Prelude.<*> ( x+                            Data..?> "pipelineObjects"+                            Core..!@ Prelude.mempty+                        )+      )++instance Prelude.Hashable DescribeObjects where+  hashWithSalt _salt DescribeObjects' {..} =+    _salt+      `Prelude.hashWithSalt` evaluateExpressions+      `Prelude.hashWithSalt` marker+      `Prelude.hashWithSalt` pipelineId+      `Prelude.hashWithSalt` objectIds++instance Prelude.NFData DescribeObjects where+  rnf DescribeObjects' {..} =+    Prelude.rnf evaluateExpressions+      `Prelude.seq` Prelude.rnf marker+      `Prelude.seq` Prelude.rnf pipelineId+      `Prelude.seq` Prelude.rnf objectIds++instance Data.ToHeaders DescribeObjects where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "DataPipeline.DescribeObjects" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON DescribeObjects where+  toJSON DescribeObjects' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("evaluateExpressions" Data..=)+              Prelude.<$> evaluateExpressions,+            ("marker" Data..=) Prelude.<$> marker,+            Prelude.Just ("pipelineId" Data..= pipelineId),+            Prelude.Just ("objectIds" Data..= objectIds)+          ]+      )++instance Data.ToPath DescribeObjects where+  toPath = Prelude.const "/"++instance Data.ToQuery DescribeObjects where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of DescribeObjects.+--+-- /See:/ 'newDescribeObjectsResponse' smart constructor.+data DescribeObjectsResponse = DescribeObjectsResponse'+  { -- | Indicates whether there are more results to return.+    hasMoreResults :: Prelude.Maybe Prelude.Bool,+    -- | 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 :: Prelude.Maybe Prelude.Text,+    -- | The response's http status code.+    httpStatus :: Prelude.Int,+    -- | An array of object definitions.+    pipelineObjects :: [PipelineObject]+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DescribeObjectsResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'hasMoreResults', 'describeObjectsResponse_hasMoreResults' - Indicates whether there are more results to return.+--+-- 'marker', 'describeObjectsResponse_marker' - 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.+--+-- 'httpStatus', 'describeObjectsResponse_httpStatus' - The response's http status code.+--+-- 'pipelineObjects', 'describeObjectsResponse_pipelineObjects' - An array of object definitions.+newDescribeObjectsResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  DescribeObjectsResponse+newDescribeObjectsResponse pHttpStatus_ =+  DescribeObjectsResponse'+    { hasMoreResults =+        Prelude.Nothing,+      marker = Prelude.Nothing,+      httpStatus = pHttpStatus_,+      pipelineObjects = Prelude.mempty+    }++-- | Indicates whether there are more results to return.+describeObjectsResponse_hasMoreResults :: Lens.Lens' DescribeObjectsResponse (Prelude.Maybe Prelude.Bool)+describeObjectsResponse_hasMoreResults = Lens.lens (\DescribeObjectsResponse' {hasMoreResults} -> hasMoreResults) (\s@DescribeObjectsResponse' {} a -> s {hasMoreResults = a} :: DescribeObjectsResponse)++-- | 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.+describeObjectsResponse_marker :: Lens.Lens' DescribeObjectsResponse (Prelude.Maybe Prelude.Text)+describeObjectsResponse_marker = Lens.lens (\DescribeObjectsResponse' {marker} -> marker) (\s@DescribeObjectsResponse' {} a -> s {marker = a} :: DescribeObjectsResponse)++-- | The response's http status code.+describeObjectsResponse_httpStatus :: Lens.Lens' DescribeObjectsResponse Prelude.Int+describeObjectsResponse_httpStatus = Lens.lens (\DescribeObjectsResponse' {httpStatus} -> httpStatus) (\s@DescribeObjectsResponse' {} a -> s {httpStatus = a} :: DescribeObjectsResponse)++-- | An array of object definitions.+describeObjectsResponse_pipelineObjects :: Lens.Lens' DescribeObjectsResponse [PipelineObject]+describeObjectsResponse_pipelineObjects = Lens.lens (\DescribeObjectsResponse' {pipelineObjects} -> pipelineObjects) (\s@DescribeObjectsResponse' {} a -> s {pipelineObjects = a} :: DescribeObjectsResponse) Prelude.. Lens.coerced++instance Prelude.NFData DescribeObjectsResponse where+  rnf DescribeObjectsResponse' {..} =+    Prelude.rnf hasMoreResults+      `Prelude.seq` Prelude.rnf marker+      `Prelude.seq` Prelude.rnf httpStatus+      `Prelude.seq` Prelude.rnf pipelineObjects

@@ -0,0 +1,188 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.DescribePipelines+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Retrieves metadata about one or more pipelines. The information+-- retrieved includes the name of the pipeline, the pipeline identifier,+-- its current state, and the user account that owns the pipeline. Using+-- account credentials, you can retrieve metadata about pipelines that you+-- or your IAM users have created. If you are using an IAM user account,+-- you can retrieve metadata about only those pipelines for which you have+-- read permissions.+--+-- To retrieve the full pipeline definition instead of metadata about the+-- pipeline, call GetPipelineDefinition.+module Amazonka.DataPipeline.DescribePipelines+  ( -- * Creating a Request+    DescribePipelines (..),+    newDescribePipelines,++    -- * Request Lenses+    describePipelines_pipelineIds,++    -- * Destructuring the Response+    DescribePipelinesResponse (..),+    newDescribePipelinesResponse,++    -- * Response Lenses+    describePipelinesResponse_httpStatus,+    describePipelinesResponse_pipelineDescriptionList,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for DescribePipelines.+--+-- /See:/ 'newDescribePipelines' smart constructor.+data DescribePipelines = DescribePipelines'+  { -- | 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 :: [Prelude.Text]+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DescribePipelines' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'pipelineIds', 'describePipelines_pipelineIds' - 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.+newDescribePipelines ::+  DescribePipelines+newDescribePipelines =+  DescribePipelines' {pipelineIds = Prelude.mempty}++-- | 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.+describePipelines_pipelineIds :: Lens.Lens' DescribePipelines [Prelude.Text]+describePipelines_pipelineIds = Lens.lens (\DescribePipelines' {pipelineIds} -> pipelineIds) (\s@DescribePipelines' {} a -> s {pipelineIds = a} :: DescribePipelines) Prelude.. Lens.coerced++instance Core.AWSRequest DescribePipelines where+  type+    AWSResponse DescribePipelines =+      DescribePipelinesResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          DescribePipelinesResponse'+            Prelude.<$> (Prelude.pure (Prelude.fromEnum s))+            Prelude.<*> ( x+                            Data..?> "pipelineDescriptionList"+                            Core..!@ Prelude.mempty+                        )+      )++instance Prelude.Hashable DescribePipelines where+  hashWithSalt _salt DescribePipelines' {..} =+    _salt `Prelude.hashWithSalt` pipelineIds++instance Prelude.NFData DescribePipelines where+  rnf DescribePipelines' {..} = Prelude.rnf pipelineIds++instance Data.ToHeaders DescribePipelines where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "DataPipeline.DescribePipelines" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON DescribePipelines where+  toJSON DescribePipelines' {..} =+    Data.object+      ( Prelude.catMaybes+          [Prelude.Just ("pipelineIds" Data..= pipelineIds)]+      )++instance Data.ToPath DescribePipelines where+  toPath = Prelude.const "/"++instance Data.ToQuery DescribePipelines where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of DescribePipelines.+--+-- /See:/ 'newDescribePipelinesResponse' smart constructor.+data DescribePipelinesResponse = DescribePipelinesResponse'+  { -- | The response's http status code.+    httpStatus :: Prelude.Int,+    -- | An array of descriptions for the specified pipelines.+    pipelineDescriptionList :: [PipelineDescription]+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'DescribePipelinesResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'httpStatus', 'describePipelinesResponse_httpStatus' - The response's http status code.+--+-- 'pipelineDescriptionList', 'describePipelinesResponse_pipelineDescriptionList' - An array of descriptions for the specified pipelines.+newDescribePipelinesResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  DescribePipelinesResponse+newDescribePipelinesResponse pHttpStatus_ =+  DescribePipelinesResponse'+    { httpStatus =+        pHttpStatus_,+      pipelineDescriptionList = Prelude.mempty+    }++-- | The response's http status code.+describePipelinesResponse_httpStatus :: Lens.Lens' DescribePipelinesResponse Prelude.Int+describePipelinesResponse_httpStatus = Lens.lens (\DescribePipelinesResponse' {httpStatus} -> httpStatus) (\s@DescribePipelinesResponse' {} a -> s {httpStatus = a} :: DescribePipelinesResponse)++-- | An array of descriptions for the specified pipelines.+describePipelinesResponse_pipelineDescriptionList :: Lens.Lens' DescribePipelinesResponse [PipelineDescription]+describePipelinesResponse_pipelineDescriptionList = Lens.lens (\DescribePipelinesResponse' {pipelineDescriptionList} -> pipelineDescriptionList) (\s@DescribePipelinesResponse' {} a -> s {pipelineDescriptionList = a} :: DescribePipelinesResponse) Prelude.. Lens.coerced++instance Prelude.NFData DescribePipelinesResponse where+  rnf DescribePipelinesResponse' {..} =+    Prelude.rnf httpStatus+      `Prelude.seq` Prelude.rnf pipelineDescriptionList

@@ -0,0 +1,216 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.EvaluateExpression+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Task runners call @EvaluateExpression@ to evaluate a string in the+-- context of the specified object. For example, a task runner can evaluate+-- SQL queries stored in Amazon S3.+module Amazonka.DataPipeline.EvaluateExpression+  ( -- * Creating a Request+    EvaluateExpression (..),+    newEvaluateExpression,++    -- * Request Lenses+    evaluateExpression_pipelineId,+    evaluateExpression_objectId,+    evaluateExpression_expression,++    -- * Destructuring the Response+    EvaluateExpressionResponse (..),+    newEvaluateExpressionResponse,++    -- * Response Lenses+    evaluateExpressionResponse_httpStatus,+    evaluateExpressionResponse_evaluatedExpression,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for EvaluateExpression.+--+-- /See:/ 'newEvaluateExpression' smart constructor.+data EvaluateExpression = EvaluateExpression'+  { -- | The ID of the pipeline.+    pipelineId :: Prelude.Text,+    -- | The ID of the object.+    objectId :: Prelude.Text,+    -- | The expression to evaluate.+    expression :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'EvaluateExpression' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'pipelineId', 'evaluateExpression_pipelineId' - The ID of the pipeline.+--+-- 'objectId', 'evaluateExpression_objectId' - The ID of the object.+--+-- 'expression', 'evaluateExpression_expression' - The expression to evaluate.+newEvaluateExpression ::+  -- | 'pipelineId'+  Prelude.Text ->+  -- | 'objectId'+  Prelude.Text ->+  -- | 'expression'+  Prelude.Text ->+  EvaluateExpression+newEvaluateExpression+  pPipelineId_+  pObjectId_+  pExpression_ =+    EvaluateExpression'+      { pipelineId = pPipelineId_,+        objectId = pObjectId_,+        expression = pExpression_+      }++-- | The ID of the pipeline.+evaluateExpression_pipelineId :: Lens.Lens' EvaluateExpression Prelude.Text+evaluateExpression_pipelineId = Lens.lens (\EvaluateExpression' {pipelineId} -> pipelineId) (\s@EvaluateExpression' {} a -> s {pipelineId = a} :: EvaluateExpression)++-- | The ID of the object.+evaluateExpression_objectId :: Lens.Lens' EvaluateExpression Prelude.Text+evaluateExpression_objectId = Lens.lens (\EvaluateExpression' {objectId} -> objectId) (\s@EvaluateExpression' {} a -> s {objectId = a} :: EvaluateExpression)++-- | The expression to evaluate.+evaluateExpression_expression :: Lens.Lens' EvaluateExpression Prelude.Text+evaluateExpression_expression = Lens.lens (\EvaluateExpression' {expression} -> expression) (\s@EvaluateExpression' {} a -> s {expression = a} :: EvaluateExpression)++instance Core.AWSRequest EvaluateExpression where+  type+    AWSResponse EvaluateExpression =+      EvaluateExpressionResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          EvaluateExpressionResponse'+            Prelude.<$> (Prelude.pure (Prelude.fromEnum s))+            Prelude.<*> (x Data..:> "evaluatedExpression")+      )++instance Prelude.Hashable EvaluateExpression where+  hashWithSalt _salt EvaluateExpression' {..} =+    _salt+      `Prelude.hashWithSalt` pipelineId+      `Prelude.hashWithSalt` objectId+      `Prelude.hashWithSalt` expression++instance Prelude.NFData EvaluateExpression where+  rnf EvaluateExpression' {..} =+    Prelude.rnf pipelineId+      `Prelude.seq` Prelude.rnf objectId+      `Prelude.seq` Prelude.rnf expression++instance Data.ToHeaders EvaluateExpression where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "DataPipeline.EvaluateExpression" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON EvaluateExpression where+  toJSON EvaluateExpression' {..} =+    Data.object+      ( Prelude.catMaybes+          [ Prelude.Just ("pipelineId" Data..= pipelineId),+            Prelude.Just ("objectId" Data..= objectId),+            Prelude.Just ("expression" Data..= expression)+          ]+      )++instance Data.ToPath EvaluateExpression where+  toPath = Prelude.const "/"++instance Data.ToQuery EvaluateExpression where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of EvaluateExpression.+--+-- /See:/ 'newEvaluateExpressionResponse' smart constructor.+data EvaluateExpressionResponse = EvaluateExpressionResponse'+  { -- | The response's http status code.+    httpStatus :: Prelude.Int,+    -- | The evaluated expression.+    evaluatedExpression :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'EvaluateExpressionResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'httpStatus', 'evaluateExpressionResponse_httpStatus' - The response's http status code.+--+-- 'evaluatedExpression', 'evaluateExpressionResponse_evaluatedExpression' - The evaluated expression.+newEvaluateExpressionResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  -- | 'evaluatedExpression'+  Prelude.Text ->+  EvaluateExpressionResponse+newEvaluateExpressionResponse+  pHttpStatus_+  pEvaluatedExpression_ =+    EvaluateExpressionResponse'+      { httpStatus =+          pHttpStatus_,+        evaluatedExpression = pEvaluatedExpression_+      }++-- | The response's http status code.+evaluateExpressionResponse_httpStatus :: Lens.Lens' EvaluateExpressionResponse Prelude.Int+evaluateExpressionResponse_httpStatus = Lens.lens (\EvaluateExpressionResponse' {httpStatus} -> httpStatus) (\s@EvaluateExpressionResponse' {} a -> s {httpStatus = a} :: EvaluateExpressionResponse)++-- | The evaluated expression.+evaluateExpressionResponse_evaluatedExpression :: Lens.Lens' EvaluateExpressionResponse Prelude.Text+evaluateExpressionResponse_evaluatedExpression = Lens.lens (\EvaluateExpressionResponse' {evaluatedExpression} -> evaluatedExpression) (\s@EvaluateExpressionResponse' {} a -> s {evaluatedExpression = a} :: EvaluateExpressionResponse)++instance Prelude.NFData EvaluateExpressionResponse where+  rnf EvaluateExpressionResponse' {..} =+    Prelude.rnf httpStatus+      `Prelude.seq` Prelude.rnf evaluatedExpression

@@ -0,0 +1,231 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.GetPipelineDefinition+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Gets the definition of the specified pipeline. You can call+-- @GetPipelineDefinition@ to retrieve the pipeline definition that you+-- provided using PutPipelineDefinition.+module Amazonka.DataPipeline.GetPipelineDefinition+  ( -- * Creating a Request+    GetPipelineDefinition (..),+    newGetPipelineDefinition,++    -- * Request Lenses+    getPipelineDefinition_version,+    getPipelineDefinition_pipelineId,++    -- * Destructuring the Response+    GetPipelineDefinitionResponse (..),+    newGetPipelineDefinitionResponse,++    -- * Response Lenses+    getPipelineDefinitionResponse_parameterObjects,+    getPipelineDefinitionResponse_parameterValues,+    getPipelineDefinitionResponse_pipelineObjects,+    getPipelineDefinitionResponse_httpStatus,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for GetPipelineDefinition.+--+-- /See:/ 'newGetPipelineDefinition' smart constructor.+data GetPipelineDefinition = GetPipelineDefinition'+  { -- | 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 :: Prelude.Maybe Prelude.Text,+    -- | The ID of the pipeline.+    pipelineId :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'GetPipelineDefinition' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'version', 'getPipelineDefinition_version' - 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.+--+-- 'pipelineId', 'getPipelineDefinition_pipelineId' - The ID of the pipeline.+newGetPipelineDefinition ::+  -- | 'pipelineId'+  Prelude.Text ->+  GetPipelineDefinition+newGetPipelineDefinition pPipelineId_ =+  GetPipelineDefinition'+    { version = Prelude.Nothing,+      pipelineId = pPipelineId_+    }++-- | 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.+getPipelineDefinition_version :: Lens.Lens' GetPipelineDefinition (Prelude.Maybe Prelude.Text)+getPipelineDefinition_version = Lens.lens (\GetPipelineDefinition' {version} -> version) (\s@GetPipelineDefinition' {} a -> s {version = a} :: GetPipelineDefinition)++-- | The ID of the pipeline.+getPipelineDefinition_pipelineId :: Lens.Lens' GetPipelineDefinition Prelude.Text+getPipelineDefinition_pipelineId = Lens.lens (\GetPipelineDefinition' {pipelineId} -> pipelineId) (\s@GetPipelineDefinition' {} a -> s {pipelineId = a} :: GetPipelineDefinition)++instance Core.AWSRequest GetPipelineDefinition where+  type+    AWSResponse GetPipelineDefinition =+      GetPipelineDefinitionResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          GetPipelineDefinitionResponse'+            Prelude.<$> ( x+                            Data..?> "parameterObjects"+                            Core..!@ Prelude.mempty+                        )+            Prelude.<*> ( x+                            Data..?> "parameterValues"+                            Core..!@ Prelude.mempty+                        )+            Prelude.<*> ( x+                            Data..?> "pipelineObjects"+                            Core..!@ Prelude.mempty+                        )+            Prelude.<*> (Prelude.pure (Prelude.fromEnum s))+      )++instance Prelude.Hashable GetPipelineDefinition where+  hashWithSalt _salt GetPipelineDefinition' {..} =+    _salt+      `Prelude.hashWithSalt` version+      `Prelude.hashWithSalt` pipelineId++instance Prelude.NFData GetPipelineDefinition where+  rnf GetPipelineDefinition' {..} =+    Prelude.rnf version+      `Prelude.seq` Prelude.rnf pipelineId++instance Data.ToHeaders GetPipelineDefinition where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "DataPipeline.GetPipelineDefinition" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON GetPipelineDefinition where+  toJSON GetPipelineDefinition' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("version" Data..=) Prelude.<$> version,+            Prelude.Just ("pipelineId" Data..= pipelineId)+          ]+      )++instance Data.ToPath GetPipelineDefinition where+  toPath = Prelude.const "/"++instance Data.ToQuery GetPipelineDefinition where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of GetPipelineDefinition.+--+-- /See:/ 'newGetPipelineDefinitionResponse' smart constructor.+data GetPipelineDefinitionResponse = GetPipelineDefinitionResponse'+  { -- | The parameter objects used in the pipeline definition.+    parameterObjects :: Prelude.Maybe [ParameterObject],+    -- | The parameter values used in the pipeline definition.+    parameterValues :: Prelude.Maybe [ParameterValue],+    -- | The objects defined in the pipeline.+    pipelineObjects :: Prelude.Maybe [PipelineObject],+    -- | The response's http status code.+    httpStatus :: Prelude.Int+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'GetPipelineDefinitionResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'parameterObjects', 'getPipelineDefinitionResponse_parameterObjects' - The parameter objects used in the pipeline definition.+--+-- 'parameterValues', 'getPipelineDefinitionResponse_parameterValues' - The parameter values used in the pipeline definition.+--+-- 'pipelineObjects', 'getPipelineDefinitionResponse_pipelineObjects' - The objects defined in the pipeline.+--+-- 'httpStatus', 'getPipelineDefinitionResponse_httpStatus' - The response's http status code.+newGetPipelineDefinitionResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  GetPipelineDefinitionResponse+newGetPipelineDefinitionResponse pHttpStatus_ =+  GetPipelineDefinitionResponse'+    { parameterObjects =+        Prelude.Nothing,+      parameterValues = Prelude.Nothing,+      pipelineObjects = Prelude.Nothing,+      httpStatus = pHttpStatus_+    }++-- | The parameter objects used in the pipeline definition.+getPipelineDefinitionResponse_parameterObjects :: Lens.Lens' GetPipelineDefinitionResponse (Prelude.Maybe [ParameterObject])+getPipelineDefinitionResponse_parameterObjects = Lens.lens (\GetPipelineDefinitionResponse' {parameterObjects} -> parameterObjects) (\s@GetPipelineDefinitionResponse' {} a -> s {parameterObjects = a} :: GetPipelineDefinitionResponse) Prelude.. Lens.mapping Lens.coerced++-- | The parameter values used in the pipeline definition.+getPipelineDefinitionResponse_parameterValues :: Lens.Lens' GetPipelineDefinitionResponse (Prelude.Maybe [ParameterValue])+getPipelineDefinitionResponse_parameterValues = Lens.lens (\GetPipelineDefinitionResponse' {parameterValues} -> parameterValues) (\s@GetPipelineDefinitionResponse' {} a -> s {parameterValues = a} :: GetPipelineDefinitionResponse) Prelude.. Lens.mapping Lens.coerced++-- | The objects defined in the pipeline.+getPipelineDefinitionResponse_pipelineObjects :: Lens.Lens' GetPipelineDefinitionResponse (Prelude.Maybe [PipelineObject])+getPipelineDefinitionResponse_pipelineObjects = Lens.lens (\GetPipelineDefinitionResponse' {pipelineObjects} -> pipelineObjects) (\s@GetPipelineDefinitionResponse' {} a -> s {pipelineObjects = a} :: GetPipelineDefinitionResponse) Prelude.. Lens.mapping Lens.coerced++-- | The response's http status code.+getPipelineDefinitionResponse_httpStatus :: Lens.Lens' GetPipelineDefinitionResponse Prelude.Int+getPipelineDefinitionResponse_httpStatus = Lens.lens (\GetPipelineDefinitionResponse' {httpStatus} -> httpStatus) (\s@GetPipelineDefinitionResponse' {} a -> s {httpStatus = a} :: GetPipelineDefinitionResponse)++instance Prelude.NFData GetPipelineDefinitionResponse where+  rnf GetPipelineDefinitionResponse' {..} =+    Prelude.rnf parameterObjects+      `Prelude.seq` Prelude.rnf parameterValues+      `Prelude.seq` Prelude.rnf pipelineObjects+      `Prelude.seq` Prelude.rnf httpStatus

@@ -0,0 +1,253 @@+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-duplicate-exports #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.Lens+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+module Amazonka.DataPipeline.Lens+  ( -- * Operations++    -- ** ActivatePipeline+    activatePipeline_parameterValues,+    activatePipeline_startTimestamp,+    activatePipeline_pipelineId,+    activatePipelineResponse_httpStatus,++    -- ** AddTags+    addTags_pipelineId,+    addTags_tags,+    addTagsResponse_httpStatus,++    -- ** CreatePipeline+    createPipeline_description,+    createPipeline_tags,+    createPipeline_name,+    createPipeline_uniqueId,+    createPipelineResponse_httpStatus,+    createPipelineResponse_pipelineId,++    -- ** DeactivatePipeline+    deactivatePipeline_cancelActive,+    deactivatePipeline_pipelineId,+    deactivatePipelineResponse_httpStatus,++    -- ** DeletePipeline+    deletePipeline_pipelineId,++    -- ** DescribeObjects+    describeObjects_evaluateExpressions,+    describeObjects_marker,+    describeObjects_pipelineId,+    describeObjects_objectIds,+    describeObjectsResponse_hasMoreResults,+    describeObjectsResponse_marker,+    describeObjectsResponse_httpStatus,+    describeObjectsResponse_pipelineObjects,++    -- ** DescribePipelines+    describePipelines_pipelineIds,+    describePipelinesResponse_httpStatus,+    describePipelinesResponse_pipelineDescriptionList,++    -- ** EvaluateExpression+    evaluateExpression_pipelineId,+    evaluateExpression_objectId,+    evaluateExpression_expression,+    evaluateExpressionResponse_httpStatus,+    evaluateExpressionResponse_evaluatedExpression,++    -- ** GetPipelineDefinition+    getPipelineDefinition_version,+    getPipelineDefinition_pipelineId,+    getPipelineDefinitionResponse_parameterObjects,+    getPipelineDefinitionResponse_parameterValues,+    getPipelineDefinitionResponse_pipelineObjects,+    getPipelineDefinitionResponse_httpStatus,++    -- ** ListPipelines+    listPipelines_marker,+    listPipelinesResponse_hasMoreResults,+    listPipelinesResponse_marker,+    listPipelinesResponse_httpStatus,+    listPipelinesResponse_pipelineIdList,++    -- ** PollForTask+    pollForTask_hostname,+    pollForTask_instanceIdentity,+    pollForTask_workerGroup,+    pollForTaskResponse_taskObject,+    pollForTaskResponse_httpStatus,++    -- ** PutPipelineDefinition+    putPipelineDefinition_parameterObjects,+    putPipelineDefinition_parameterValues,+    putPipelineDefinition_pipelineId,+    putPipelineDefinition_pipelineObjects,+    putPipelineDefinitionResponse_validationErrors,+    putPipelineDefinitionResponse_validationWarnings,+    putPipelineDefinitionResponse_httpStatus,+    putPipelineDefinitionResponse_errored,++    -- ** QueryObjects+    queryObjects_limit,+    queryObjects_marker,+    queryObjects_query,+    queryObjects_pipelineId,+    queryObjects_sphere,+    queryObjectsResponse_hasMoreResults,+    queryObjectsResponse_ids,+    queryObjectsResponse_marker,+    queryObjectsResponse_httpStatus,++    -- ** RemoveTags+    removeTags_pipelineId,+    removeTags_tagKeys,+    removeTagsResponse_httpStatus,++    -- ** ReportTaskProgress+    reportTaskProgress_fields,+    reportTaskProgress_taskId,+    reportTaskProgressResponse_httpStatus,+    reportTaskProgressResponse_canceled,++    -- ** ReportTaskRunnerHeartbeat+    reportTaskRunnerHeartbeat_hostname,+    reportTaskRunnerHeartbeat_workerGroup,+    reportTaskRunnerHeartbeat_taskrunnerId,+    reportTaskRunnerHeartbeatResponse_httpStatus,+    reportTaskRunnerHeartbeatResponse_terminate,++    -- ** SetStatus+    setStatus_pipelineId,+    setStatus_objectIds,+    setStatus_status,++    -- ** SetTaskStatus+    setTaskStatus_errorId,+    setTaskStatus_errorMessage,+    setTaskStatus_errorStackTrace,+    setTaskStatus_taskId,+    setTaskStatus_taskStatus,+    setTaskStatusResponse_httpStatus,++    -- ** ValidatePipelineDefinition+    validatePipelineDefinition_parameterObjects,+    validatePipelineDefinition_parameterValues,+    validatePipelineDefinition_pipelineId,+    validatePipelineDefinition_pipelineObjects,+    validatePipelineDefinitionResponse_validationErrors,+    validatePipelineDefinitionResponse_validationWarnings,+    validatePipelineDefinitionResponse_httpStatus,+    validatePipelineDefinitionResponse_errored,++    -- * Types++    -- ** Field+    field_refValue,+    field_stringValue,+    field_key,++    -- ** InstanceIdentity+    instanceIdentity_document,+    instanceIdentity_signature,++    -- ** Operator+    operator_type,+    operator_values,++    -- ** ParameterAttribute+    parameterAttribute_key,+    parameterAttribute_stringValue,++    -- ** ParameterObject+    parameterObject_id,+    parameterObject_attributes,++    -- ** ParameterValue+    parameterValue_id,+    parameterValue_stringValue,++    -- ** PipelineDescription+    pipelineDescription_description,+    pipelineDescription_tags,+    pipelineDescription_pipelineId,+    pipelineDescription_name,+    pipelineDescription_fields,++    -- ** PipelineIdName+    pipelineIdName_id,+    pipelineIdName_name,++    -- ** PipelineObject+    pipelineObject_id,+    pipelineObject_name,+    pipelineObject_fields,++    -- ** Query+    query_selectors,++    -- ** Selector+    selector_fieldName,+    selector_operator,++    -- ** Tag+    tag_key,+    tag_value,++    -- ** TaskObject+    taskObject_attemptId,+    taskObject_objects,+    taskObject_pipelineId,+    taskObject_taskId,++    -- ** ValidationError+    validationError_errors,+    validationError_id,++    -- ** ValidationWarning+    validationWarning_id,+    validationWarning_warnings,+  )+where++import Amazonka.DataPipeline.ActivatePipeline+import Amazonka.DataPipeline.AddTags+import Amazonka.DataPipeline.CreatePipeline+import Amazonka.DataPipeline.DeactivatePipeline+import Amazonka.DataPipeline.DeletePipeline+import Amazonka.DataPipeline.DescribeObjects+import Amazonka.DataPipeline.DescribePipelines+import Amazonka.DataPipeline.EvaluateExpression+import Amazonka.DataPipeline.GetPipelineDefinition+import Amazonka.DataPipeline.ListPipelines+import Amazonka.DataPipeline.PollForTask+import Amazonka.DataPipeline.PutPipelineDefinition+import Amazonka.DataPipeline.QueryObjects+import Amazonka.DataPipeline.RemoveTags+import Amazonka.DataPipeline.ReportTaskProgress+import Amazonka.DataPipeline.ReportTaskRunnerHeartbeat+import Amazonka.DataPipeline.SetStatus+import Amazonka.DataPipeline.SetTaskStatus+import Amazonka.DataPipeline.Types.Field+import Amazonka.DataPipeline.Types.InstanceIdentity+import Amazonka.DataPipeline.Types.Operator+import Amazonka.DataPipeline.Types.ParameterAttribute+import Amazonka.DataPipeline.Types.ParameterObject+import Amazonka.DataPipeline.Types.ParameterValue+import Amazonka.DataPipeline.Types.PipelineDescription+import Amazonka.DataPipeline.Types.PipelineIdName+import Amazonka.DataPipeline.Types.PipelineObject+import Amazonka.DataPipeline.Types.Query+import Amazonka.DataPipeline.Types.Selector+import Amazonka.DataPipeline.Types.Tag+import Amazonka.DataPipeline.Types.TaskObject+import Amazonka.DataPipeline.Types.ValidationError+import Amazonka.DataPipeline.Types.ValidationWarning+import Amazonka.DataPipeline.ValidatePipelineDefinition

@@ -0,0 +1,244 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.ListPipelines+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Lists the pipeline identifiers for all active pipelines that you have+-- permission to access.+--+-- This operation returns paginated results.+module Amazonka.DataPipeline.ListPipelines+  ( -- * Creating a Request+    ListPipelines (..),+    newListPipelines,++    -- * Request Lenses+    listPipelines_marker,++    -- * Destructuring the Response+    ListPipelinesResponse (..),+    newListPipelinesResponse,++    -- * Response Lenses+    listPipelinesResponse_hasMoreResults,+    listPipelinesResponse_marker,+    listPipelinesResponse_httpStatus,+    listPipelinesResponse_pipelineIdList,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for ListPipelines.+--+-- /See:/ 'newListPipelines' smart constructor.+data ListPipelines = ListPipelines'+  { -- | 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 :: Prelude.Maybe Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'ListPipelines' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'marker', 'listPipelines_marker' - 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.+newListPipelines ::+  ListPipelines+newListPipelines =+  ListPipelines' {marker = Prelude.Nothing}++-- | 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.+listPipelines_marker :: Lens.Lens' ListPipelines (Prelude.Maybe Prelude.Text)+listPipelines_marker = Lens.lens (\ListPipelines' {marker} -> marker) (\s@ListPipelines' {} a -> s {marker = a} :: ListPipelines)++instance Core.AWSPager ListPipelines where+  page rq rs+    | Core.stop+        ( rs+            Lens.^? listPipelinesResponse_hasMoreResults+            Prelude.. Lens._Just+        ) =+        Prelude.Nothing+    | Prelude.isNothing+        ( rs+            Lens.^? listPipelinesResponse_marker+            Prelude.. Lens._Just+        ) =+        Prelude.Nothing+    | Prelude.otherwise =+        Prelude.Just+          Prelude.$ rq+          Prelude.& listPipelines_marker+          Lens..~ rs+          Lens.^? listPipelinesResponse_marker+          Prelude.. Lens._Just++instance Core.AWSRequest ListPipelines where+  type+    AWSResponse ListPipelines =+      ListPipelinesResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          ListPipelinesResponse'+            Prelude.<$> (x Data..?> "hasMoreResults")+            Prelude.<*> (x Data..?> "marker")+            Prelude.<*> (Prelude.pure (Prelude.fromEnum s))+            Prelude.<*> ( x+                            Data..?> "pipelineIdList"+                            Core..!@ Prelude.mempty+                        )+      )++instance Prelude.Hashable ListPipelines where+  hashWithSalt _salt ListPipelines' {..} =+    _salt `Prelude.hashWithSalt` marker++instance Prelude.NFData ListPipelines where+  rnf ListPipelines' {..} = Prelude.rnf marker++instance Data.ToHeaders ListPipelines where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ("DataPipeline.ListPipelines" :: Prelude.ByteString),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON ListPipelines where+  toJSON ListPipelines' {..} =+    Data.object+      ( Prelude.catMaybes+          [("marker" Data..=) Prelude.<$> marker]+      )++instance Data.ToPath ListPipelines where+  toPath = Prelude.const "/"++instance Data.ToQuery ListPipelines where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of ListPipelines.+--+-- /See:/ 'newListPipelinesResponse' smart constructor.+data ListPipelinesResponse = ListPipelinesResponse'+  { -- | Indicates whether there are more results that can be obtained by a+    -- subsequent call.+    hasMoreResults :: Prelude.Maybe Prelude.Bool,+    -- | 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 :: Prelude.Maybe Prelude.Text,+    -- | The response's http status code.+    httpStatus :: Prelude.Int,+    -- | The pipeline identifiers. If you require additional information about+    -- the pipelines, you can use these identifiers to call DescribePipelines+    -- and GetPipelineDefinition.+    pipelineIdList :: [PipelineIdName]+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'ListPipelinesResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'hasMoreResults', 'listPipelinesResponse_hasMoreResults' - Indicates whether there are more results that can be obtained by a+-- subsequent call.+--+-- 'marker', 'listPipelinesResponse_marker' - 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.+--+-- 'httpStatus', 'listPipelinesResponse_httpStatus' - The response's http status code.+--+-- 'pipelineIdList', 'listPipelinesResponse_pipelineIdList' - The pipeline identifiers. If you require additional information about+-- the pipelines, you can use these identifiers to call DescribePipelines+-- and GetPipelineDefinition.+newListPipelinesResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  ListPipelinesResponse+newListPipelinesResponse pHttpStatus_ =+  ListPipelinesResponse'+    { hasMoreResults =+        Prelude.Nothing,+      marker = Prelude.Nothing,+      httpStatus = pHttpStatus_,+      pipelineIdList = Prelude.mempty+    }++-- | Indicates whether there are more results that can be obtained by a+-- subsequent call.+listPipelinesResponse_hasMoreResults :: Lens.Lens' ListPipelinesResponse (Prelude.Maybe Prelude.Bool)+listPipelinesResponse_hasMoreResults = Lens.lens (\ListPipelinesResponse' {hasMoreResults} -> hasMoreResults) (\s@ListPipelinesResponse' {} a -> s {hasMoreResults = a} :: ListPipelinesResponse)++-- | 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.+listPipelinesResponse_marker :: Lens.Lens' ListPipelinesResponse (Prelude.Maybe Prelude.Text)+listPipelinesResponse_marker = Lens.lens (\ListPipelinesResponse' {marker} -> marker) (\s@ListPipelinesResponse' {} a -> s {marker = a} :: ListPipelinesResponse)++-- | The response's http status code.+listPipelinesResponse_httpStatus :: Lens.Lens' ListPipelinesResponse Prelude.Int+listPipelinesResponse_httpStatus = Lens.lens (\ListPipelinesResponse' {httpStatus} -> httpStatus) (\s@ListPipelinesResponse' {} a -> s {httpStatus = a} :: ListPipelinesResponse)++-- | The pipeline identifiers. If you require additional information about+-- the pipelines, you can use these identifiers to call DescribePipelines+-- and GetPipelineDefinition.+listPipelinesResponse_pipelineIdList :: Lens.Lens' ListPipelinesResponse [PipelineIdName]+listPipelinesResponse_pipelineIdList = Lens.lens (\ListPipelinesResponse' {pipelineIdList} -> pipelineIdList) (\s@ListPipelinesResponse' {} a -> s {pipelineIdList = a} :: ListPipelinesResponse) Prelude.. Lens.coerced++instance Prelude.NFData ListPipelinesResponse where+  rnf ListPipelinesResponse' {..} =+    Prelude.rnf hasMoreResults+      `Prelude.seq` Prelude.rnf marker+      `Prelude.seq` Prelude.rnf httpStatus+      `Prelude.seq` Prelude.rnf pipelineIdList

@@ -0,0 +1,261 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.PollForTask+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Task runners call @PollForTask@ to receive a task to perform from AWS+-- Data Pipeline. The task runner specifies which tasks it can perform by+-- setting a value for the @workerGroup@ parameter. The task returned can+-- come from any of the pipelines that match the @workerGroup@ value passed+-- in by the task runner and that was launched using the IAM user+-- credentials specified by the task runner.+--+-- If tasks are ready in the work queue, @PollForTask@ returns a response+-- immediately. If no tasks are available in the queue, @PollForTask@ uses+-- long-polling and holds on to a poll connection for up to a 90 seconds,+-- during which time the first newly scheduled task is handed to the task+-- runner. To accomodate this, set the socket timeout in your task runner+-- to 90 seconds. The task runner should not call @PollForTask@ again on+-- the same @workerGroup@ until it receives a response, and this can take+-- up to 90 seconds.+module Amazonka.DataPipeline.PollForTask+  ( -- * Creating a Request+    PollForTask (..),+    newPollForTask,++    -- * Request Lenses+    pollForTask_hostname,+    pollForTask_instanceIdentity,+    pollForTask_workerGroup,++    -- * Destructuring the Response+    PollForTaskResponse (..),+    newPollForTaskResponse,++    -- * Response Lenses+    pollForTaskResponse_taskObject,+    pollForTaskResponse_httpStatus,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for PollForTask.+--+-- /See:/ 'newPollForTask' smart constructor.+data PollForTask = PollForTask'+  { -- | The public DNS name of the calling task runner.+    hostname :: Prelude.Maybe Prelude.Text,+    -- | 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+    -- <http://docs.aws.amazon.com/AWSEC2/latest/UserGuide/AESDG-chapter-instancedata.html Instance Metadata>+    -- 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 :: Prelude.Maybe InstanceIdentity,+    -- | 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 :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'PollForTask' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'hostname', 'pollForTask_hostname' - The public DNS name of the calling task runner.+--+-- 'instanceIdentity', 'pollForTask_instanceIdentity' - 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+-- <http://docs.aws.amazon.com/AWSEC2/latest/UserGuide/AESDG-chapter-instancedata.html Instance Metadata>+-- 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.+--+-- 'workerGroup', 'pollForTask_workerGroup' - 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.+newPollForTask ::+  -- | 'workerGroup'+  Prelude.Text ->+  PollForTask+newPollForTask pWorkerGroup_ =+  PollForTask'+    { hostname = Prelude.Nothing,+      instanceIdentity = Prelude.Nothing,+      workerGroup = pWorkerGroup_+    }++-- | The public DNS name of the calling task runner.+pollForTask_hostname :: Lens.Lens' PollForTask (Prelude.Maybe Prelude.Text)+pollForTask_hostname = Lens.lens (\PollForTask' {hostname} -> hostname) (\s@PollForTask' {} a -> s {hostname = a} :: PollForTask)++-- | 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+-- <http://docs.aws.amazon.com/AWSEC2/latest/UserGuide/AESDG-chapter-instancedata.html Instance Metadata>+-- 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.+pollForTask_instanceIdentity :: Lens.Lens' PollForTask (Prelude.Maybe InstanceIdentity)+pollForTask_instanceIdentity = Lens.lens (\PollForTask' {instanceIdentity} -> instanceIdentity) (\s@PollForTask' {} a -> s {instanceIdentity = a} :: PollForTask)++-- | 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.+pollForTask_workerGroup :: Lens.Lens' PollForTask Prelude.Text+pollForTask_workerGroup = Lens.lens (\PollForTask' {workerGroup} -> workerGroup) (\s@PollForTask' {} a -> s {workerGroup = a} :: PollForTask)++instance Core.AWSRequest PollForTask where+  type AWSResponse PollForTask = PollForTaskResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          PollForTaskResponse'+            Prelude.<$> (x Data..?> "taskObject")+            Prelude.<*> (Prelude.pure (Prelude.fromEnum s))+      )++instance Prelude.Hashable PollForTask where+  hashWithSalt _salt PollForTask' {..} =+    _salt+      `Prelude.hashWithSalt` hostname+      `Prelude.hashWithSalt` instanceIdentity+      `Prelude.hashWithSalt` workerGroup++instance Prelude.NFData PollForTask where+  rnf PollForTask' {..} =+    Prelude.rnf hostname+      `Prelude.seq` Prelude.rnf instanceIdentity+      `Prelude.seq` Prelude.rnf workerGroup++instance Data.ToHeaders PollForTask where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ("DataPipeline.PollForTask" :: Prelude.ByteString),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON PollForTask where+  toJSON PollForTask' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("hostname" Data..=) Prelude.<$> hostname,+            ("instanceIdentity" Data..=)+              Prelude.<$> instanceIdentity,+            Prelude.Just ("workerGroup" Data..= workerGroup)+          ]+      )++instance Data.ToPath PollForTask where+  toPath = Prelude.const "/"++instance Data.ToQuery PollForTask where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of PollForTask.+--+-- /See:/ 'newPollForTaskResponse' smart constructor.+data PollForTaskResponse = PollForTaskResponse'+  { -- | 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 :: Prelude.Maybe TaskObject,+    -- | The response's http status code.+    httpStatus :: Prelude.Int+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'PollForTaskResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'taskObject', 'pollForTaskResponse_taskObject' - 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.+--+-- 'httpStatus', 'pollForTaskResponse_httpStatus' - The response's http status code.+newPollForTaskResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  PollForTaskResponse+newPollForTaskResponse pHttpStatus_ =+  PollForTaskResponse'+    { taskObject = Prelude.Nothing,+      httpStatus = pHttpStatus_+    }++-- | 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.+pollForTaskResponse_taskObject :: Lens.Lens' PollForTaskResponse (Prelude.Maybe TaskObject)+pollForTaskResponse_taskObject = Lens.lens (\PollForTaskResponse' {taskObject} -> taskObject) (\s@PollForTaskResponse' {} a -> s {taskObject = a} :: PollForTaskResponse)++-- | The response's http status code.+pollForTaskResponse_httpStatus :: Lens.Lens' PollForTaskResponse Prelude.Int+pollForTaskResponse_httpStatus = Lens.lens (\PollForTaskResponse' {httpStatus} -> httpStatus) (\s@PollForTaskResponse' {} a -> s {httpStatus = a} :: PollForTaskResponse)++instance Prelude.NFData PollForTaskResponse where+  rnf PollForTaskResponse' {..} =+    Prelude.rnf taskObject+      `Prelude.seq` Prelude.rnf httpStatus

@@ -0,0 +1,286 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.PutPipelineDefinition+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Adds tasks, schedules, and preconditions to the specified pipeline. You+-- can use @PutPipelineDefinition@ to populate a new pipeline.+--+-- @PutPipelineDefinition@ also validates the configuration as it adds it+-- to the pipeline. Changes to the pipeline are saved unless one of the+-- following three validation errors exists in the pipeline.+--+-- 1.  An object is missing a name or identifier field.+-- 2.  A string or reference field is empty.+-- 3.  The number of objects in the pipeline exceeds the maximum allowed+--     objects.+-- 4.  The pipeline is in a FINISHED state.+--+-- Pipeline object definitions are passed to the @PutPipelineDefinition@+-- action and returned by the GetPipelineDefinition action.+module Amazonka.DataPipeline.PutPipelineDefinition+  ( -- * Creating a Request+    PutPipelineDefinition (..),+    newPutPipelineDefinition,++    -- * Request Lenses+    putPipelineDefinition_parameterObjects,+    putPipelineDefinition_parameterValues,+    putPipelineDefinition_pipelineId,+    putPipelineDefinition_pipelineObjects,++    -- * Destructuring the Response+    PutPipelineDefinitionResponse (..),+    newPutPipelineDefinitionResponse,++    -- * Response Lenses+    putPipelineDefinitionResponse_validationErrors,+    putPipelineDefinitionResponse_validationWarnings,+    putPipelineDefinitionResponse_httpStatus,+    putPipelineDefinitionResponse_errored,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for PutPipelineDefinition.+--+-- /See:/ 'newPutPipelineDefinition' smart constructor.+data PutPipelineDefinition = PutPipelineDefinition'+  { -- | The parameter objects used with the pipeline.+    parameterObjects :: Prelude.Maybe [ParameterObject],+    -- | The parameter values used with the pipeline.+    parameterValues :: Prelude.Maybe [ParameterValue],+    -- | The ID of the pipeline.+    pipelineId :: Prelude.Text,+    -- | The objects that define the pipeline. These objects overwrite the+    -- existing pipeline definition.+    pipelineObjects :: [PipelineObject]+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'PutPipelineDefinition' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'parameterObjects', 'putPipelineDefinition_parameterObjects' - The parameter objects used with the pipeline.+--+-- 'parameterValues', 'putPipelineDefinition_parameterValues' - The parameter values used with the pipeline.+--+-- 'pipelineId', 'putPipelineDefinition_pipelineId' - The ID of the pipeline.+--+-- 'pipelineObjects', 'putPipelineDefinition_pipelineObjects' - The objects that define the pipeline. These objects overwrite the+-- existing pipeline definition.+newPutPipelineDefinition ::+  -- | 'pipelineId'+  Prelude.Text ->+  PutPipelineDefinition+newPutPipelineDefinition pPipelineId_ =+  PutPipelineDefinition'+    { parameterObjects =+        Prelude.Nothing,+      parameterValues = Prelude.Nothing,+      pipelineId = pPipelineId_,+      pipelineObjects = Prelude.mempty+    }++-- | The parameter objects used with the pipeline.+putPipelineDefinition_parameterObjects :: Lens.Lens' PutPipelineDefinition (Prelude.Maybe [ParameterObject])+putPipelineDefinition_parameterObjects = Lens.lens (\PutPipelineDefinition' {parameterObjects} -> parameterObjects) (\s@PutPipelineDefinition' {} a -> s {parameterObjects = a} :: PutPipelineDefinition) Prelude.. Lens.mapping Lens.coerced++-- | The parameter values used with the pipeline.+putPipelineDefinition_parameterValues :: Lens.Lens' PutPipelineDefinition (Prelude.Maybe [ParameterValue])+putPipelineDefinition_parameterValues = Lens.lens (\PutPipelineDefinition' {parameterValues} -> parameterValues) (\s@PutPipelineDefinition' {} a -> s {parameterValues = a} :: PutPipelineDefinition) Prelude.. Lens.mapping Lens.coerced++-- | The ID of the pipeline.+putPipelineDefinition_pipelineId :: Lens.Lens' PutPipelineDefinition Prelude.Text+putPipelineDefinition_pipelineId = Lens.lens (\PutPipelineDefinition' {pipelineId} -> pipelineId) (\s@PutPipelineDefinition' {} a -> s {pipelineId = a} :: PutPipelineDefinition)++-- | The objects that define the pipeline. These objects overwrite the+-- existing pipeline definition.+putPipelineDefinition_pipelineObjects :: Lens.Lens' PutPipelineDefinition [PipelineObject]+putPipelineDefinition_pipelineObjects = Lens.lens (\PutPipelineDefinition' {pipelineObjects} -> pipelineObjects) (\s@PutPipelineDefinition' {} a -> s {pipelineObjects = a} :: PutPipelineDefinition) Prelude.. Lens.coerced++instance Core.AWSRequest PutPipelineDefinition where+  type+    AWSResponse PutPipelineDefinition =+      PutPipelineDefinitionResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          PutPipelineDefinitionResponse'+            Prelude.<$> ( x+                            Data..?> "validationErrors"+                            Core..!@ Prelude.mempty+                        )+            Prelude.<*> ( x+                            Data..?> "validationWarnings"+                            Core..!@ Prelude.mempty+                        )+            Prelude.<*> (Prelude.pure (Prelude.fromEnum s))+            Prelude.<*> (x Data..:> "errored")+      )++instance Prelude.Hashable PutPipelineDefinition where+  hashWithSalt _salt PutPipelineDefinition' {..} =+    _salt+      `Prelude.hashWithSalt` parameterObjects+      `Prelude.hashWithSalt` parameterValues+      `Prelude.hashWithSalt` pipelineId+      `Prelude.hashWithSalt` pipelineObjects++instance Prelude.NFData PutPipelineDefinition where+  rnf PutPipelineDefinition' {..} =+    Prelude.rnf parameterObjects+      `Prelude.seq` Prelude.rnf parameterValues+      `Prelude.seq` Prelude.rnf pipelineId+      `Prelude.seq` Prelude.rnf pipelineObjects++instance Data.ToHeaders PutPipelineDefinition where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "DataPipeline.PutPipelineDefinition" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON PutPipelineDefinition where+  toJSON PutPipelineDefinition' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("parameterObjects" Data..=)+              Prelude.<$> parameterObjects,+            ("parameterValues" Data..=)+              Prelude.<$> parameterValues,+            Prelude.Just ("pipelineId" Data..= pipelineId),+            Prelude.Just+              ("pipelineObjects" Data..= pipelineObjects)+          ]+      )++instance Data.ToPath PutPipelineDefinition where+  toPath = Prelude.const "/"++instance Data.ToQuery PutPipelineDefinition where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of PutPipelineDefinition.+--+-- /See:/ 'newPutPipelineDefinitionResponse' smart constructor.+data PutPipelineDefinitionResponse = PutPipelineDefinitionResponse'+  { -- | The validation errors that are associated with the objects defined in+    -- @pipelineObjects@.+    validationErrors :: Prelude.Maybe [ValidationError],+    -- | The validation warnings that are associated with the objects defined in+    -- @pipelineObjects@.+    validationWarnings :: Prelude.Maybe [ValidationWarning],+    -- | The response's http status code.+    httpStatus :: Prelude.Int,+    -- | 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 :: Prelude.Bool+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'PutPipelineDefinitionResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'validationErrors', 'putPipelineDefinitionResponse_validationErrors' - The validation errors that are associated with the objects defined in+-- @pipelineObjects@.+--+-- 'validationWarnings', 'putPipelineDefinitionResponse_validationWarnings' - The validation warnings that are associated with the objects defined in+-- @pipelineObjects@.+--+-- 'httpStatus', 'putPipelineDefinitionResponse_httpStatus' - The response's http status code.+--+-- 'errored', 'putPipelineDefinitionResponse_errored' - 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.+newPutPipelineDefinitionResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  -- | 'errored'+  Prelude.Bool ->+  PutPipelineDefinitionResponse+newPutPipelineDefinitionResponse+  pHttpStatus_+  pErrored_ =+    PutPipelineDefinitionResponse'+      { validationErrors =+          Prelude.Nothing,+        validationWarnings = Prelude.Nothing,+        httpStatus = pHttpStatus_,+        errored = pErrored_+      }++-- | The validation errors that are associated with the objects defined in+-- @pipelineObjects@.+putPipelineDefinitionResponse_validationErrors :: Lens.Lens' PutPipelineDefinitionResponse (Prelude.Maybe [ValidationError])+putPipelineDefinitionResponse_validationErrors = Lens.lens (\PutPipelineDefinitionResponse' {validationErrors} -> validationErrors) (\s@PutPipelineDefinitionResponse' {} a -> s {validationErrors = a} :: PutPipelineDefinitionResponse) Prelude.. Lens.mapping Lens.coerced++-- | The validation warnings that are associated with the objects defined in+-- @pipelineObjects@.+putPipelineDefinitionResponse_validationWarnings :: Lens.Lens' PutPipelineDefinitionResponse (Prelude.Maybe [ValidationWarning])+putPipelineDefinitionResponse_validationWarnings = Lens.lens (\PutPipelineDefinitionResponse' {validationWarnings} -> validationWarnings) (\s@PutPipelineDefinitionResponse' {} a -> s {validationWarnings = a} :: PutPipelineDefinitionResponse) Prelude.. Lens.mapping Lens.coerced++-- | The response's http status code.+putPipelineDefinitionResponse_httpStatus :: Lens.Lens' PutPipelineDefinitionResponse Prelude.Int+putPipelineDefinitionResponse_httpStatus = Lens.lens (\PutPipelineDefinitionResponse' {httpStatus} -> httpStatus) (\s@PutPipelineDefinitionResponse' {} a -> s {httpStatus = a} :: PutPipelineDefinitionResponse)++-- | 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.+putPipelineDefinitionResponse_errored :: Lens.Lens' PutPipelineDefinitionResponse Prelude.Bool+putPipelineDefinitionResponse_errored = Lens.lens (\PutPipelineDefinitionResponse' {errored} -> errored) (\s@PutPipelineDefinitionResponse' {} a -> s {errored = a} :: PutPipelineDefinitionResponse)++instance Prelude.NFData PutPipelineDefinitionResponse where+  rnf PutPipelineDefinitionResponse' {..} =+    Prelude.rnf validationErrors+      `Prelude.seq` Prelude.rnf validationWarnings+      `Prelude.seq` Prelude.rnf httpStatus+      `Prelude.seq` Prelude.rnf errored

@@ -0,0 +1,309 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.QueryObjects+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Queries the specified pipeline for the names of objects that match the+-- specified set of conditions.+--+-- This operation returns paginated results.+module Amazonka.DataPipeline.QueryObjects+  ( -- * Creating a Request+    QueryObjects (..),+    newQueryObjects,++    -- * Request Lenses+    queryObjects_limit,+    queryObjects_marker,+    queryObjects_query,+    queryObjects_pipelineId,+    queryObjects_sphere,++    -- * Destructuring the Response+    QueryObjectsResponse (..),+    newQueryObjectsResponse,++    -- * Response Lenses+    queryObjectsResponse_hasMoreResults,+    queryObjectsResponse_ids,+    queryObjectsResponse_marker,+    queryObjectsResponse_httpStatus,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for QueryObjects.+--+-- /See:/ 'newQueryObjects' smart constructor.+data QueryObjects = QueryObjects'+  { -- | The maximum number of object names that @QueryObjects@ will return in a+    -- single call. The default value is 100.+    limit :: Prelude.Maybe Prelude.Int,+    -- | 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 :: Prelude.Maybe Prelude.Text,+    -- | 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 :: Prelude.Maybe Query,+    -- | The ID of the pipeline.+    pipelineId :: Prelude.Text,+    -- | Indicates whether the query applies to components or instances. The+    -- possible values are: @COMPONENT@, @INSTANCE@, and @ATTEMPT@.+    sphere :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'QueryObjects' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'limit', 'queryObjects_limit' - The maximum number of object names that @QueryObjects@ will return in a+-- single call. The default value is 100.+--+-- 'marker', 'queryObjects_marker' - 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.+--+-- 'query', 'queryObjects_query' - 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.+--+-- 'pipelineId', 'queryObjects_pipelineId' - The ID of the pipeline.+--+-- 'sphere', 'queryObjects_sphere' - Indicates whether the query applies to components or instances. The+-- possible values are: @COMPONENT@, @INSTANCE@, and @ATTEMPT@.+newQueryObjects ::+  -- | 'pipelineId'+  Prelude.Text ->+  -- | 'sphere'+  Prelude.Text ->+  QueryObjects+newQueryObjects pPipelineId_ pSphere_ =+  QueryObjects'+    { limit = Prelude.Nothing,+      marker = Prelude.Nothing,+      query = Prelude.Nothing,+      pipelineId = pPipelineId_,+      sphere = pSphere_+    }++-- | The maximum number of object names that @QueryObjects@ will return in a+-- single call. The default value is 100.+queryObjects_limit :: Lens.Lens' QueryObjects (Prelude.Maybe Prelude.Int)+queryObjects_limit = Lens.lens (\QueryObjects' {limit} -> limit) (\s@QueryObjects' {} a -> s {limit = a} :: QueryObjects)++-- | 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.+queryObjects_marker :: Lens.Lens' QueryObjects (Prelude.Maybe Prelude.Text)+queryObjects_marker = Lens.lens (\QueryObjects' {marker} -> marker) (\s@QueryObjects' {} a -> s {marker = a} :: QueryObjects)++-- | 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.+queryObjects_query :: Lens.Lens' QueryObjects (Prelude.Maybe Query)+queryObjects_query = Lens.lens (\QueryObjects' {query} -> query) (\s@QueryObjects' {} a -> s {query = a} :: QueryObjects)++-- | The ID of the pipeline.+queryObjects_pipelineId :: Lens.Lens' QueryObjects Prelude.Text+queryObjects_pipelineId = Lens.lens (\QueryObjects' {pipelineId} -> pipelineId) (\s@QueryObjects' {} a -> s {pipelineId = a} :: QueryObjects)++-- | Indicates whether the query applies to components or instances. The+-- possible values are: @COMPONENT@, @INSTANCE@, and @ATTEMPT@.+queryObjects_sphere :: Lens.Lens' QueryObjects Prelude.Text+queryObjects_sphere = Lens.lens (\QueryObjects' {sphere} -> sphere) (\s@QueryObjects' {} a -> s {sphere = a} :: QueryObjects)++instance Core.AWSPager QueryObjects where+  page rq rs+    | Core.stop+        ( rs+            Lens.^? queryObjectsResponse_hasMoreResults+            Prelude.. Lens._Just+        ) =+        Prelude.Nothing+    | Prelude.isNothing+        ( rs+            Lens.^? queryObjectsResponse_marker+            Prelude.. Lens._Just+        ) =+        Prelude.Nothing+    | Prelude.otherwise =+        Prelude.Just+          Prelude.$ rq+          Prelude.& queryObjects_marker+          Lens..~ rs+          Lens.^? queryObjectsResponse_marker+          Prelude.. Lens._Just++instance Core.AWSRequest QueryObjects where+  type AWSResponse QueryObjects = QueryObjectsResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          QueryObjectsResponse'+            Prelude.<$> (x Data..?> "hasMoreResults")+            Prelude.<*> (x Data..?> "ids" Core..!@ Prelude.mempty)+            Prelude.<*> (x Data..?> "marker")+            Prelude.<*> (Prelude.pure (Prelude.fromEnum s))+      )++instance Prelude.Hashable QueryObjects where+  hashWithSalt _salt QueryObjects' {..} =+    _salt+      `Prelude.hashWithSalt` limit+      `Prelude.hashWithSalt` marker+      `Prelude.hashWithSalt` query+      `Prelude.hashWithSalt` pipelineId+      `Prelude.hashWithSalt` sphere++instance Prelude.NFData QueryObjects where+  rnf QueryObjects' {..} =+    Prelude.rnf limit+      `Prelude.seq` Prelude.rnf marker+      `Prelude.seq` Prelude.rnf query+      `Prelude.seq` Prelude.rnf pipelineId+      `Prelude.seq` Prelude.rnf sphere++instance Data.ToHeaders QueryObjects where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ("DataPipeline.QueryObjects" :: Prelude.ByteString),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON QueryObjects where+  toJSON QueryObjects' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("limit" Data..=) Prelude.<$> limit,+            ("marker" Data..=) Prelude.<$> marker,+            ("query" Data..=) Prelude.<$> query,+            Prelude.Just ("pipelineId" Data..= pipelineId),+            Prelude.Just ("sphere" Data..= sphere)+          ]+      )++instance Data.ToPath QueryObjects where+  toPath = Prelude.const "/"++instance Data.ToQuery QueryObjects where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of QueryObjects.+--+-- /See:/ 'newQueryObjectsResponse' smart constructor.+data QueryObjectsResponse = QueryObjectsResponse'+  { -- | Indicates whether there are more results that can be obtained by a+    -- subsequent call.+    hasMoreResults :: Prelude.Maybe Prelude.Bool,+    -- | The identifiers that match the query selectors.+    ids :: Prelude.Maybe [Prelude.Text],+    -- | 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 :: Prelude.Maybe Prelude.Text,+    -- | The response's http status code.+    httpStatus :: Prelude.Int+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'QueryObjectsResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'hasMoreResults', 'queryObjectsResponse_hasMoreResults' - Indicates whether there are more results that can be obtained by a+-- subsequent call.+--+-- 'ids', 'queryObjectsResponse_ids' - The identifiers that match the query selectors.+--+-- 'marker', 'queryObjectsResponse_marker' - 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.+--+-- 'httpStatus', 'queryObjectsResponse_httpStatus' - The response's http status code.+newQueryObjectsResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  QueryObjectsResponse+newQueryObjectsResponse pHttpStatus_ =+  QueryObjectsResponse'+    { hasMoreResults =+        Prelude.Nothing,+      ids = Prelude.Nothing,+      marker = Prelude.Nothing,+      httpStatus = pHttpStatus_+    }++-- | Indicates whether there are more results that can be obtained by a+-- subsequent call.+queryObjectsResponse_hasMoreResults :: Lens.Lens' QueryObjectsResponse (Prelude.Maybe Prelude.Bool)+queryObjectsResponse_hasMoreResults = Lens.lens (\QueryObjectsResponse' {hasMoreResults} -> hasMoreResults) (\s@QueryObjectsResponse' {} a -> s {hasMoreResults = a} :: QueryObjectsResponse)++-- | The identifiers that match the query selectors.+queryObjectsResponse_ids :: Lens.Lens' QueryObjectsResponse (Prelude.Maybe [Prelude.Text])+queryObjectsResponse_ids = Lens.lens (\QueryObjectsResponse' {ids} -> ids) (\s@QueryObjectsResponse' {} a -> s {ids = a} :: QueryObjectsResponse) Prelude.. Lens.mapping Lens.coerced++-- | 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.+queryObjectsResponse_marker :: Lens.Lens' QueryObjectsResponse (Prelude.Maybe Prelude.Text)+queryObjectsResponse_marker = Lens.lens (\QueryObjectsResponse' {marker} -> marker) (\s@QueryObjectsResponse' {} a -> s {marker = a} :: QueryObjectsResponse)++-- | The response's http status code.+queryObjectsResponse_httpStatus :: Lens.Lens' QueryObjectsResponse Prelude.Int+queryObjectsResponse_httpStatus = Lens.lens (\QueryObjectsResponse' {httpStatus} -> httpStatus) (\s@QueryObjectsResponse' {} a -> s {httpStatus = a} :: QueryObjectsResponse)++instance Prelude.NFData QueryObjectsResponse where+  rnf QueryObjectsResponse' {..} =+    Prelude.rnf hasMoreResults+      `Prelude.seq` Prelude.rnf ids+      `Prelude.seq` Prelude.rnf marker+      `Prelude.seq` Prelude.rnf httpStatus

@@ -0,0 +1,170 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.RemoveTags+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Removes existing tags from the specified pipeline.+module Amazonka.DataPipeline.RemoveTags+  ( -- * Creating a Request+    RemoveTags (..),+    newRemoveTags,++    -- * Request Lenses+    removeTags_pipelineId,+    removeTags_tagKeys,++    -- * Destructuring the Response+    RemoveTagsResponse (..),+    newRemoveTagsResponse,++    -- * Response Lenses+    removeTagsResponse_httpStatus,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for RemoveTags.+--+-- /See:/ 'newRemoveTags' smart constructor.+data RemoveTags = RemoveTags'+  { -- | The ID of the pipeline.+    pipelineId :: Prelude.Text,+    -- | The keys of the tags to remove.+    tagKeys :: [Prelude.Text]+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'RemoveTags' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'pipelineId', 'removeTags_pipelineId' - The ID of the pipeline.+--+-- 'tagKeys', 'removeTags_tagKeys' - The keys of the tags to remove.+newRemoveTags ::+  -- | 'pipelineId'+  Prelude.Text ->+  RemoveTags+newRemoveTags pPipelineId_ =+  RemoveTags'+    { pipelineId = pPipelineId_,+      tagKeys = Prelude.mempty+    }++-- | The ID of the pipeline.+removeTags_pipelineId :: Lens.Lens' RemoveTags Prelude.Text+removeTags_pipelineId = Lens.lens (\RemoveTags' {pipelineId} -> pipelineId) (\s@RemoveTags' {} a -> s {pipelineId = a} :: RemoveTags)++-- | The keys of the tags to remove.+removeTags_tagKeys :: Lens.Lens' RemoveTags [Prelude.Text]+removeTags_tagKeys = Lens.lens (\RemoveTags' {tagKeys} -> tagKeys) (\s@RemoveTags' {} a -> s {tagKeys = a} :: RemoveTags) Prelude.. Lens.coerced++instance Core.AWSRequest RemoveTags where+  type AWSResponse RemoveTags = RemoveTagsResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveEmpty+      ( \s h x ->+          RemoveTagsResponse'+            Prelude.<$> (Prelude.pure (Prelude.fromEnum s))+      )++instance Prelude.Hashable RemoveTags where+  hashWithSalt _salt RemoveTags' {..} =+    _salt+      `Prelude.hashWithSalt` pipelineId+      `Prelude.hashWithSalt` tagKeys++instance Prelude.NFData RemoveTags where+  rnf RemoveTags' {..} =+    Prelude.rnf pipelineId+      `Prelude.seq` Prelude.rnf tagKeys++instance Data.ToHeaders RemoveTags where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ("DataPipeline.RemoveTags" :: Prelude.ByteString),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON RemoveTags where+  toJSON RemoveTags' {..} =+    Data.object+      ( Prelude.catMaybes+          [ Prelude.Just ("pipelineId" Data..= pipelineId),+            Prelude.Just ("tagKeys" Data..= tagKeys)+          ]+      )++instance Data.ToPath RemoveTags where+  toPath = Prelude.const "/"++instance Data.ToQuery RemoveTags where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of RemoveTags.+--+-- /See:/ 'newRemoveTagsResponse' smart constructor.+data RemoveTagsResponse = RemoveTagsResponse'+  { -- | The response's http status code.+    httpStatus :: Prelude.Int+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'RemoveTagsResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'httpStatus', 'removeTagsResponse_httpStatus' - The response's http status code.+newRemoveTagsResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  RemoveTagsResponse+newRemoveTagsResponse pHttpStatus_ =+  RemoveTagsResponse' {httpStatus = pHttpStatus_}++-- | The response's http status code.+removeTagsResponse_httpStatus :: Lens.Lens' RemoveTagsResponse Prelude.Int+removeTagsResponse_httpStatus = Lens.lens (\RemoveTagsResponse' {httpStatus} -> httpStatus) (\s@RemoveTagsResponse' {} a -> s {httpStatus = a} :: RemoveTagsResponse)++instance Prelude.NFData RemoveTagsResponse where+  rnf RemoveTagsResponse' {..} = Prelude.rnf httpStatus

@@ -0,0 +1,211 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.ReportTaskProgress+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Task runners call @ReportTaskProgress@ when assigned a task to+-- acknowledge that it has the task. If the web service does not receive+-- this acknowledgement within 2 minutes, it assigns the task in a+-- subsequent PollForTask call. After this initial acknowledgement, the+-- task runner only needs to report progress every 15 minutes to maintain+-- its ownership of the task. You can change this reporting time from 15+-- minutes by specifying a @reportProgressTimeout@ field in your pipeline.+--+-- If a task runner does not report its status after 5 minutes, AWS Data+-- Pipeline assumes that the task runner is unable to process the task and+-- reassigns the task in a subsequent response to PollForTask. Task runners+-- should call @ReportTaskProgress@ every 60 seconds.+module Amazonka.DataPipeline.ReportTaskProgress+  ( -- * Creating a Request+    ReportTaskProgress (..),+    newReportTaskProgress,++    -- * Request Lenses+    reportTaskProgress_fields,+    reportTaskProgress_taskId,++    -- * Destructuring the Response+    ReportTaskProgressResponse (..),+    newReportTaskProgressResponse,++    -- * Response Lenses+    reportTaskProgressResponse_httpStatus,+    reportTaskProgressResponse_canceled,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for ReportTaskProgress.+--+-- /See:/ 'newReportTaskProgress' smart constructor.+data ReportTaskProgress = ReportTaskProgress'+  { -- | Key-value pairs that define the properties of the+    -- ReportTaskProgressInput object.+    fields :: Prelude.Maybe [Field],+    -- | The ID of the task assigned to the task runner. This value is provided+    -- in the response for PollForTask.+    taskId :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'ReportTaskProgress' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'fields', 'reportTaskProgress_fields' - Key-value pairs that define the properties of the+-- ReportTaskProgressInput object.+--+-- 'taskId', 'reportTaskProgress_taskId' - The ID of the task assigned to the task runner. This value is provided+-- in the response for PollForTask.+newReportTaskProgress ::+  -- | 'taskId'+  Prelude.Text ->+  ReportTaskProgress+newReportTaskProgress pTaskId_ =+  ReportTaskProgress'+    { fields = Prelude.Nothing,+      taskId = pTaskId_+    }++-- | Key-value pairs that define the properties of the+-- ReportTaskProgressInput object.+reportTaskProgress_fields :: Lens.Lens' ReportTaskProgress (Prelude.Maybe [Field])+reportTaskProgress_fields = Lens.lens (\ReportTaskProgress' {fields} -> fields) (\s@ReportTaskProgress' {} a -> s {fields = a} :: ReportTaskProgress) Prelude.. Lens.mapping Lens.coerced++-- | The ID of the task assigned to the task runner. This value is provided+-- in the response for PollForTask.+reportTaskProgress_taskId :: Lens.Lens' ReportTaskProgress Prelude.Text+reportTaskProgress_taskId = Lens.lens (\ReportTaskProgress' {taskId} -> taskId) (\s@ReportTaskProgress' {} a -> s {taskId = a} :: ReportTaskProgress)++instance Core.AWSRequest ReportTaskProgress where+  type+    AWSResponse ReportTaskProgress =+      ReportTaskProgressResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          ReportTaskProgressResponse'+            Prelude.<$> (Prelude.pure (Prelude.fromEnum s))+            Prelude.<*> (x Data..:> "canceled")+      )++instance Prelude.Hashable ReportTaskProgress where+  hashWithSalt _salt ReportTaskProgress' {..} =+    _salt+      `Prelude.hashWithSalt` fields+      `Prelude.hashWithSalt` taskId++instance Prelude.NFData ReportTaskProgress where+  rnf ReportTaskProgress' {..} =+    Prelude.rnf fields `Prelude.seq` Prelude.rnf taskId++instance Data.ToHeaders ReportTaskProgress where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "DataPipeline.ReportTaskProgress" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON ReportTaskProgress where+  toJSON ReportTaskProgress' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("fields" Data..=) Prelude.<$> fields,+            Prelude.Just ("taskId" Data..= taskId)+          ]+      )++instance Data.ToPath ReportTaskProgress where+  toPath = Prelude.const "/"++instance Data.ToQuery ReportTaskProgress where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of ReportTaskProgress.+--+-- /See:/ 'newReportTaskProgressResponse' smart constructor.+data ReportTaskProgressResponse = ReportTaskProgressResponse'+  { -- | The response's http status code.+    httpStatus :: Prelude.Int,+    -- | 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 :: Prelude.Bool+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'ReportTaskProgressResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'httpStatus', 'reportTaskProgressResponse_httpStatus' - The response's http status code.+--+-- 'canceled', 'reportTaskProgressResponse_canceled' - If true, the calling task runner should cancel processing of the task.+-- The task runner does not need to call SetTaskStatus for canceled tasks.+newReportTaskProgressResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  -- | 'canceled'+  Prelude.Bool ->+  ReportTaskProgressResponse+newReportTaskProgressResponse pHttpStatus_ pCanceled_ =+  ReportTaskProgressResponse'+    { httpStatus =+        pHttpStatus_,+      canceled = pCanceled_+    }++-- | The response's http status code.+reportTaskProgressResponse_httpStatus :: Lens.Lens' ReportTaskProgressResponse Prelude.Int+reportTaskProgressResponse_httpStatus = Lens.lens (\ReportTaskProgressResponse' {httpStatus} -> httpStatus) (\s@ReportTaskProgressResponse' {} a -> s {httpStatus = a} :: ReportTaskProgressResponse)++-- | If true, the calling task runner should cancel processing of the task.+-- The task runner does not need to call SetTaskStatus for canceled tasks.+reportTaskProgressResponse_canceled :: Lens.Lens' ReportTaskProgressResponse Prelude.Bool+reportTaskProgressResponse_canceled = Lens.lens (\ReportTaskProgressResponse' {canceled} -> canceled) (\s@ReportTaskProgressResponse' {} a -> s {canceled = a} :: ReportTaskProgressResponse)++instance Prelude.NFData ReportTaskProgressResponse where+  rnf ReportTaskProgressResponse' {..} =+    Prelude.rnf httpStatus+      `Prelude.seq` Prelude.rnf canceled

@@ -0,0 +1,242 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.ReportTaskRunnerHeartbeat+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Task runners call @ReportTaskRunnerHeartbeat@ every 15 minutes to+-- indicate that they are operational. If the AWS Data Pipeline Task Runner+-- is launched on a resource managed by AWS Data Pipeline, the web service+-- can use this call to detect when the task runner application has failed+-- and restart a new instance.+module Amazonka.DataPipeline.ReportTaskRunnerHeartbeat+  ( -- * Creating a Request+    ReportTaskRunnerHeartbeat (..),+    newReportTaskRunnerHeartbeat,++    -- * Request Lenses+    reportTaskRunnerHeartbeat_hostname,+    reportTaskRunnerHeartbeat_workerGroup,+    reportTaskRunnerHeartbeat_taskrunnerId,++    -- * Destructuring the Response+    ReportTaskRunnerHeartbeatResponse (..),+    newReportTaskRunnerHeartbeatResponse,++    -- * Response Lenses+    reportTaskRunnerHeartbeatResponse_httpStatus,+    reportTaskRunnerHeartbeatResponse_terminate,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for ReportTaskRunnerHeartbeat.+--+-- /See:/ 'newReportTaskRunnerHeartbeat' smart constructor.+data ReportTaskRunnerHeartbeat = ReportTaskRunnerHeartbeat'+  { -- | The public DNS name of the task runner.+    hostname :: Prelude.Maybe Prelude.Text,+    -- | 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 :: Prelude.Maybe Prelude.Text,+    -- | 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 :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'ReportTaskRunnerHeartbeat' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'hostname', 'reportTaskRunnerHeartbeat_hostname' - The public DNS name of the task runner.+--+-- 'workerGroup', 'reportTaskRunnerHeartbeat_workerGroup' - 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.+--+-- 'taskrunnerId', 'reportTaskRunnerHeartbeat_taskrunnerId' - 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.+newReportTaskRunnerHeartbeat ::+  -- | 'taskrunnerId'+  Prelude.Text ->+  ReportTaskRunnerHeartbeat+newReportTaskRunnerHeartbeat pTaskrunnerId_ =+  ReportTaskRunnerHeartbeat'+    { hostname =+        Prelude.Nothing,+      workerGroup = Prelude.Nothing,+      taskrunnerId = pTaskrunnerId_+    }++-- | The public DNS name of the task runner.+reportTaskRunnerHeartbeat_hostname :: Lens.Lens' ReportTaskRunnerHeartbeat (Prelude.Maybe Prelude.Text)+reportTaskRunnerHeartbeat_hostname = Lens.lens (\ReportTaskRunnerHeartbeat' {hostname} -> hostname) (\s@ReportTaskRunnerHeartbeat' {} a -> s {hostname = a} :: ReportTaskRunnerHeartbeat)++-- | 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.+reportTaskRunnerHeartbeat_workerGroup :: Lens.Lens' ReportTaskRunnerHeartbeat (Prelude.Maybe Prelude.Text)+reportTaskRunnerHeartbeat_workerGroup = Lens.lens (\ReportTaskRunnerHeartbeat' {workerGroup} -> workerGroup) (\s@ReportTaskRunnerHeartbeat' {} a -> s {workerGroup = a} :: ReportTaskRunnerHeartbeat)++-- | 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.+reportTaskRunnerHeartbeat_taskrunnerId :: Lens.Lens' ReportTaskRunnerHeartbeat Prelude.Text+reportTaskRunnerHeartbeat_taskrunnerId = Lens.lens (\ReportTaskRunnerHeartbeat' {taskrunnerId} -> taskrunnerId) (\s@ReportTaskRunnerHeartbeat' {} a -> s {taskrunnerId = a} :: ReportTaskRunnerHeartbeat)++instance Core.AWSRequest ReportTaskRunnerHeartbeat where+  type+    AWSResponse ReportTaskRunnerHeartbeat =+      ReportTaskRunnerHeartbeatResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveJSON+      ( \s h x ->+          ReportTaskRunnerHeartbeatResponse'+            Prelude.<$> (Prelude.pure (Prelude.fromEnum s))+            Prelude.<*> (x Data..:> "terminate")+      )++instance Prelude.Hashable ReportTaskRunnerHeartbeat where+  hashWithSalt _salt ReportTaskRunnerHeartbeat' {..} =+    _salt+      `Prelude.hashWithSalt` hostname+      `Prelude.hashWithSalt` workerGroup+      `Prelude.hashWithSalt` taskrunnerId++instance Prelude.NFData ReportTaskRunnerHeartbeat where+  rnf ReportTaskRunnerHeartbeat' {..} =+    Prelude.rnf hostname+      `Prelude.seq` Prelude.rnf workerGroup+      `Prelude.seq` Prelude.rnf taskrunnerId++instance Data.ToHeaders ReportTaskRunnerHeartbeat where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ( "DataPipeline.ReportTaskRunnerHeartbeat" ::+                          Prelude.ByteString+                      ),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON ReportTaskRunnerHeartbeat where+  toJSON ReportTaskRunnerHeartbeat' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("hostname" Data..=) Prelude.<$> hostname,+            ("workerGroup" Data..=) Prelude.<$> workerGroup,+            Prelude.Just ("taskrunnerId" Data..= taskrunnerId)+          ]+      )++instance Data.ToPath ReportTaskRunnerHeartbeat where+  toPath = Prelude.const "/"++instance Data.ToQuery ReportTaskRunnerHeartbeat where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of ReportTaskRunnerHeartbeat.+--+-- /See:/ 'newReportTaskRunnerHeartbeatResponse' smart constructor.+data ReportTaskRunnerHeartbeatResponse = ReportTaskRunnerHeartbeatResponse'+  { -- | The response's http status code.+    httpStatus :: Prelude.Int,+    -- | Indicates whether the calling task runner should terminate.+    terminate :: Prelude.Bool+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'ReportTaskRunnerHeartbeatResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'httpStatus', 'reportTaskRunnerHeartbeatResponse_httpStatus' - The response's http status code.+--+-- 'terminate', 'reportTaskRunnerHeartbeatResponse_terminate' - Indicates whether the calling task runner should terminate.+newReportTaskRunnerHeartbeatResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  -- | 'terminate'+  Prelude.Bool ->+  ReportTaskRunnerHeartbeatResponse+newReportTaskRunnerHeartbeatResponse+  pHttpStatus_+  pTerminate_ =+    ReportTaskRunnerHeartbeatResponse'+      { httpStatus =+          pHttpStatus_,+        terminate = pTerminate_+      }++-- | The response's http status code.+reportTaskRunnerHeartbeatResponse_httpStatus :: Lens.Lens' ReportTaskRunnerHeartbeatResponse Prelude.Int+reportTaskRunnerHeartbeatResponse_httpStatus = Lens.lens (\ReportTaskRunnerHeartbeatResponse' {httpStatus} -> httpStatus) (\s@ReportTaskRunnerHeartbeatResponse' {} a -> s {httpStatus = a} :: ReportTaskRunnerHeartbeatResponse)++-- | Indicates whether the calling task runner should terminate.+reportTaskRunnerHeartbeatResponse_terminate :: Lens.Lens' ReportTaskRunnerHeartbeatResponse Prelude.Bool+reportTaskRunnerHeartbeatResponse_terminate = Lens.lens (\ReportTaskRunnerHeartbeatResponse' {terminate} -> terminate) (\s@ReportTaskRunnerHeartbeatResponse' {} a -> s {terminate = a} :: ReportTaskRunnerHeartbeatResponse)++instance+  Prelude.NFData+    ReportTaskRunnerHeartbeatResponse+  where+  rnf ReportTaskRunnerHeartbeatResponse' {..} =+    Prelude.rnf httpStatus+      `Prelude.seq` Prelude.rnf terminate

@@ -0,0 +1,176 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.SetStatus+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Requests that the status of the specified physical or logical pipeline+-- objects be updated in the specified pipeline. This update might not+-- occur immediately, but is eventually consistent. The status that can be+-- set depends on the type of object (for example, DataNode or Activity).+-- You cannot perform this operation on @FINISHED@ pipelines and attempting+-- to do so returns @InvalidRequestException@.+module Amazonka.DataPipeline.SetStatus+  ( -- * Creating a Request+    SetStatus (..),+    newSetStatus,++    -- * Request Lenses+    setStatus_pipelineId,+    setStatus_objectIds,+    setStatus_status,++    -- * Destructuring the Response+    SetStatusResponse (..),+    newSetStatusResponse,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for SetStatus.+--+-- /See:/ 'newSetStatus' smart constructor.+data SetStatus = SetStatus'+  { -- | The ID of the pipeline that contains the objects.+    pipelineId :: Prelude.Text,+    -- | The IDs of the objects. The corresponding objects can be either physical+    -- or components, but not a mix of both types.+    objectIds :: [Prelude.Text],+    -- | 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 :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'SetStatus' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'pipelineId', 'setStatus_pipelineId' - The ID of the pipeline that contains the objects.+--+-- 'objectIds', 'setStatus_objectIds' - The IDs of the objects. The corresponding objects can be either physical+-- or components, but not a mix of both types.+--+-- 'status', 'setStatus_status' - 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@.+newSetStatus ::+  -- | 'pipelineId'+  Prelude.Text ->+  -- | 'status'+  Prelude.Text ->+  SetStatus+newSetStatus pPipelineId_ pStatus_ =+  SetStatus'+    { pipelineId = pPipelineId_,+      objectIds = Prelude.mempty,+      status = pStatus_+    }++-- | The ID of the pipeline that contains the objects.+setStatus_pipelineId :: Lens.Lens' SetStatus Prelude.Text+setStatus_pipelineId = Lens.lens (\SetStatus' {pipelineId} -> pipelineId) (\s@SetStatus' {} a -> s {pipelineId = a} :: SetStatus)++-- | The IDs of the objects. The corresponding objects can be either physical+-- or components, but not a mix of both types.+setStatus_objectIds :: Lens.Lens' SetStatus [Prelude.Text]+setStatus_objectIds = Lens.lens (\SetStatus' {objectIds} -> objectIds) (\s@SetStatus' {} a -> s {objectIds = a} :: SetStatus) Prelude.. Lens.coerced++-- | 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@.+setStatus_status :: Lens.Lens' SetStatus Prelude.Text+setStatus_status = Lens.lens (\SetStatus' {status} -> status) (\s@SetStatus' {} a -> s {status = a} :: SetStatus)++instance Core.AWSRequest SetStatus where+  type AWSResponse SetStatus = SetStatusResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response = Response.receiveNull SetStatusResponse'++instance Prelude.Hashable SetStatus where+  hashWithSalt _salt SetStatus' {..} =+    _salt+      `Prelude.hashWithSalt` pipelineId+      `Prelude.hashWithSalt` objectIds+      `Prelude.hashWithSalt` status++instance Prelude.NFData SetStatus where+  rnf SetStatus' {..} =+    Prelude.rnf pipelineId+      `Prelude.seq` Prelude.rnf objectIds+      `Prelude.seq` Prelude.rnf status++instance Data.ToHeaders SetStatus where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ("DataPipeline.SetStatus" :: Prelude.ByteString),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON SetStatus where+  toJSON SetStatus' {..} =+    Data.object+      ( Prelude.catMaybes+          [ Prelude.Just ("pipelineId" Data..= pipelineId),+            Prelude.Just ("objectIds" Data..= objectIds),+            Prelude.Just ("status" Data..= status)+          ]+      )++instance Data.ToPath SetStatus where+  toPath = Prelude.const "/"++instance Data.ToQuery SetStatus where+  toQuery = Prelude.const Prelude.mempty++-- | /See:/ 'newSetStatusResponse' smart constructor.+data SetStatusResponse = SetStatusResponse'+  {+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'SetStatusResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+newSetStatusResponse ::+  SetStatusResponse+newSetStatusResponse = SetStatusResponse'++instance Prelude.NFData SetStatusResponse where+  rnf _ = ()

@@ -0,0 +1,252 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE TypeFamilies #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-binds #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.SetTaskStatus+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+--+-- Task runners call @SetTaskStatus@ to notify AWS Data Pipeline that a+-- task is completed and provide information about the final status. A task+-- runner makes this call regardless of whether the task was sucessful. A+-- task runner does not need to call @SetTaskStatus@ for tasks that are+-- canceled by the web service during a call to ReportTaskProgress.+module Amazonka.DataPipeline.SetTaskStatus+  ( -- * Creating a Request+    SetTaskStatus (..),+    newSetTaskStatus,++    -- * Request Lenses+    setTaskStatus_errorId,+    setTaskStatus_errorMessage,+    setTaskStatus_errorStackTrace,+    setTaskStatus_taskId,+    setTaskStatus_taskStatus,++    -- * Destructuring the Response+    SetTaskStatusResponse (..),+    newSetTaskStatusResponse,++    -- * Response Lenses+    setTaskStatusResponse_httpStatus,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import Amazonka.DataPipeline.Types+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Request as Request+import qualified Amazonka.Response as Response++-- | Contains the parameters for SetTaskStatus.+--+-- /See:/ 'newSetTaskStatus' smart constructor.+data SetTaskStatus = SetTaskStatus'+  { -- | 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 :: Prelude.Maybe Prelude.Text,+    -- | 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 :: Prelude.Maybe Prelude.Text,+    -- | 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 :: Prelude.Maybe Prelude.Text,+    -- | The ID of the task assigned to the task runner. This value is provided+    -- in the response for PollForTask.+    taskId :: Prelude.Text,+    -- | If @FINISHED@, the task successfully completed. If @FAILED@, the task+    -- ended unsuccessfully. Preconditions use false.+    taskStatus :: TaskStatus+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'SetTaskStatus' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'errorId', 'setTaskStatus_errorId' - 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.+--+-- 'errorMessage', 'setTaskStatus_errorMessage' - 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.+--+-- 'errorStackTrace', 'setTaskStatus_errorStackTrace' - 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.+--+-- 'taskId', 'setTaskStatus_taskId' - The ID of the task assigned to the task runner. This value is provided+-- in the response for PollForTask.+--+-- 'taskStatus', 'setTaskStatus_taskStatus' - If @FINISHED@, the task successfully completed. If @FAILED@, the task+-- ended unsuccessfully. Preconditions use false.+newSetTaskStatus ::+  -- | 'taskId'+  Prelude.Text ->+  -- | 'taskStatus'+  TaskStatus ->+  SetTaskStatus+newSetTaskStatus pTaskId_ pTaskStatus_ =+  SetTaskStatus'+    { errorId = Prelude.Nothing,+      errorMessage = Prelude.Nothing,+      errorStackTrace = Prelude.Nothing,+      taskId = pTaskId_,+      taskStatus = pTaskStatus_+    }++-- | 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.+setTaskStatus_errorId :: Lens.Lens' SetTaskStatus (Prelude.Maybe Prelude.Text)+setTaskStatus_errorId = Lens.lens (\SetTaskStatus' {errorId} -> errorId) (\s@SetTaskStatus' {} a -> s {errorId = a} :: SetTaskStatus)++-- | 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.+setTaskStatus_errorMessage :: Lens.Lens' SetTaskStatus (Prelude.Maybe Prelude.Text)+setTaskStatus_errorMessage = Lens.lens (\SetTaskStatus' {errorMessage} -> errorMessage) (\s@SetTaskStatus' {} a -> s {errorMessage = a} :: SetTaskStatus)++-- | 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.+setTaskStatus_errorStackTrace :: Lens.Lens' SetTaskStatus (Prelude.Maybe Prelude.Text)+setTaskStatus_errorStackTrace = Lens.lens (\SetTaskStatus' {errorStackTrace} -> errorStackTrace) (\s@SetTaskStatus' {} a -> s {errorStackTrace = a} :: SetTaskStatus)++-- | The ID of the task assigned to the task runner. This value is provided+-- in the response for PollForTask.+setTaskStatus_taskId :: Lens.Lens' SetTaskStatus Prelude.Text+setTaskStatus_taskId = Lens.lens (\SetTaskStatus' {taskId} -> taskId) (\s@SetTaskStatus' {} a -> s {taskId = a} :: SetTaskStatus)++-- | If @FINISHED@, the task successfully completed. If @FAILED@, the task+-- ended unsuccessfully. Preconditions use false.+setTaskStatus_taskStatus :: Lens.Lens' SetTaskStatus TaskStatus+setTaskStatus_taskStatus = Lens.lens (\SetTaskStatus' {taskStatus} -> taskStatus) (\s@SetTaskStatus' {} a -> s {taskStatus = a} :: SetTaskStatus)++instance Core.AWSRequest SetTaskStatus where+  type+    AWSResponse SetTaskStatus =+      SetTaskStatusResponse+  request overrides =+    Request.postJSON (overrides defaultService)+  response =+    Response.receiveEmpty+      ( \s h x ->+          SetTaskStatusResponse'+            Prelude.<$> (Prelude.pure (Prelude.fromEnum s))+      )++instance Prelude.Hashable SetTaskStatus where+  hashWithSalt _salt SetTaskStatus' {..} =+    _salt+      `Prelude.hashWithSalt` errorId+      `Prelude.hashWithSalt` errorMessage+      `Prelude.hashWithSalt` errorStackTrace+      `Prelude.hashWithSalt` taskId+      `Prelude.hashWithSalt` taskStatus++instance Prelude.NFData SetTaskStatus where+  rnf SetTaskStatus' {..} =+    Prelude.rnf errorId+      `Prelude.seq` Prelude.rnf errorMessage+      `Prelude.seq` Prelude.rnf errorStackTrace+      `Prelude.seq` Prelude.rnf taskId+      `Prelude.seq` Prelude.rnf taskStatus++instance Data.ToHeaders SetTaskStatus where+  toHeaders =+    Prelude.const+      ( Prelude.mconcat+          [ "X-Amz-Target"+              Data.=# ("DataPipeline.SetTaskStatus" :: Prelude.ByteString),+            "Content-Type"+              Data.=# ( "application/x-amz-json-1.1" ::+                          Prelude.ByteString+                      )+          ]+      )++instance Data.ToJSON SetTaskStatus where+  toJSON SetTaskStatus' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("errorId" Data..=) Prelude.<$> errorId,+            ("errorMessage" Data..=) Prelude.<$> errorMessage,+            ("errorStackTrace" Data..=)+              Prelude.<$> errorStackTrace,+            Prelude.Just ("taskId" Data..= taskId),+            Prelude.Just ("taskStatus" Data..= taskStatus)+          ]+      )++instance Data.ToPath SetTaskStatus where+  toPath = Prelude.const "/"++instance Data.ToQuery SetTaskStatus where+  toQuery = Prelude.const Prelude.mempty++-- | Contains the output of SetTaskStatus.+--+-- /See:/ 'newSetTaskStatusResponse' smart constructor.+data SetTaskStatusResponse = SetTaskStatusResponse'+  { -- | The response's http status code.+    httpStatus :: Prelude.Int+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'SetTaskStatusResponse' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'httpStatus', 'setTaskStatusResponse_httpStatus' - The response's http status code.+newSetTaskStatusResponse ::+  -- | 'httpStatus'+  Prelude.Int ->+  SetTaskStatusResponse+newSetTaskStatusResponse pHttpStatus_ =+  SetTaskStatusResponse' {httpStatus = pHttpStatus_}++-- | The response's http status code.+setTaskStatusResponse_httpStatus :: Lens.Lens' SetTaskStatusResponse Prelude.Int+setTaskStatusResponse_httpStatus = Lens.lens (\SetTaskStatusResponse' {httpStatus} -> httpStatus) (\s@SetTaskStatusResponse' {} a -> s {httpStatus = a} :: SetTaskStatusResponse)++instance Prelude.NFData SetTaskStatusResponse where+  rnf SetTaskStatusResponse' {..} =+    Prelude.rnf httpStatus

@@ -0,0 +1,260 @@+{-# LANGUAGE DisambiguateRecordFields #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.Types+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+module Amazonka.DataPipeline.Types+  ( -- * Service Configuration+    defaultService,++    -- * Errors+    _InternalServiceError,+    _InvalidRequestException,+    _PipelineDeletedException,+    _PipelineNotFoundException,+    _TaskNotFoundException,++    -- * OperatorType+    OperatorType (..),++    -- * TaskStatus+    TaskStatus (..),++    -- * Field+    Field (..),+    newField,+    field_refValue,+    field_stringValue,+    field_key,++    -- * InstanceIdentity+    InstanceIdentity (..),+    newInstanceIdentity,+    instanceIdentity_document,+    instanceIdentity_signature,++    -- * Operator+    Operator (..),+    newOperator,+    operator_type,+    operator_values,++    -- * ParameterAttribute+    ParameterAttribute (..),+    newParameterAttribute,+    parameterAttribute_key,+    parameterAttribute_stringValue,++    -- * ParameterObject+    ParameterObject (..),+    newParameterObject,+    parameterObject_id,+    parameterObject_attributes,++    -- * ParameterValue+    ParameterValue (..),+    newParameterValue,+    parameterValue_id,+    parameterValue_stringValue,++    -- * PipelineDescription+    PipelineDescription (..),+    newPipelineDescription,+    pipelineDescription_description,+    pipelineDescription_tags,+    pipelineDescription_pipelineId,+    pipelineDescription_name,+    pipelineDescription_fields,++    -- * PipelineIdName+    PipelineIdName (..),+    newPipelineIdName,+    pipelineIdName_id,+    pipelineIdName_name,++    -- * PipelineObject+    PipelineObject (..),+    newPipelineObject,+    pipelineObject_id,+    pipelineObject_name,+    pipelineObject_fields,++    -- * Query+    Query (..),+    newQuery,+    query_selectors,++    -- * Selector+    Selector (..),+    newSelector,+    selector_fieldName,+    selector_operator,++    -- * Tag+    Tag (..),+    newTag,+    tag_key,+    tag_value,++    -- * TaskObject+    TaskObject (..),+    newTaskObject,+    taskObject_attemptId,+    taskObject_objects,+    taskObject_pipelineId,+    taskObject_taskId,++    -- * ValidationError+    ValidationError (..),+    newValidationError,+    validationError_errors,+    validationError_id,++    -- * ValidationWarning+    ValidationWarning (..),+    newValidationWarning,+    validationWarning_id,+    validationWarning_warnings,+  )+where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import Amazonka.DataPipeline.Types.Field+import Amazonka.DataPipeline.Types.InstanceIdentity+import Amazonka.DataPipeline.Types.Operator+import Amazonka.DataPipeline.Types.OperatorType+import Amazonka.DataPipeline.Types.ParameterAttribute+import Amazonka.DataPipeline.Types.ParameterObject+import Amazonka.DataPipeline.Types.ParameterValue+import Amazonka.DataPipeline.Types.PipelineDescription+import Amazonka.DataPipeline.Types.PipelineIdName+import Amazonka.DataPipeline.Types.PipelineObject+import Amazonka.DataPipeline.Types.Query+import Amazonka.DataPipeline.Types.Selector+import Amazonka.DataPipeline.Types.Tag+import Amazonka.DataPipeline.Types.TaskObject+import Amazonka.DataPipeline.Types.TaskStatus+import Amazonka.DataPipeline.Types.ValidationError+import Amazonka.DataPipeline.Types.ValidationWarning+import qualified Amazonka.Prelude as Prelude+import qualified Amazonka.Sign.V4 as Sign++-- | API version @2012-10-29@ of the Amazon Data Pipeline SDK configuration.+defaultService :: Core.Service+defaultService =+  Core.Service+    { Core.abbrev = "DataPipeline",+      Core.signer = Sign.v4,+      Core.endpointPrefix = "datapipeline",+      Core.signingName = "datapipeline",+      Core.version = "2012-10-29",+      Core.s3AddressingStyle = Core.S3AddressingStyleAuto,+      Core.endpoint = Core.defaultEndpoint defaultService,+      Core.timeout = Prelude.Just 70,+      Core.check = Core.statusSuccess,+      Core.error = Core.parseJSONError "DataPipeline",+      Core.retry = retry+    }+  where+    retry =+      Core.Exponential+        { Core.base = 5.0e-2,+          Core.growth = 2,+          Core.attempts = 5,+          Core.check = check+        }+    check e+      | Lens.has (Core.hasStatus 502) e =+          Prelude.Just "bad_gateway"+      | Lens.has (Core.hasStatus 504) e =+          Prelude.Just "gateway_timeout"+      | Lens.has (Core.hasStatus 500) e =+          Prelude.Just "general_server_error"+      | Lens.has (Core.hasStatus 509) e =+          Prelude.Just "limit_exceeded"+      | Lens.has+          ( Core.hasCode "RequestThrottledException"+              Prelude.. Core.hasStatus 400+          )+          e =+          Prelude.Just "request_throttled_exception"+      | Lens.has (Core.hasStatus 503) e =+          Prelude.Just "service_unavailable"+      | Lens.has+          ( Core.hasCode "ThrottledException"+              Prelude.. Core.hasStatus 400+          )+          e =+          Prelude.Just "throttled_exception"+      | Lens.has+          ( Core.hasCode "Throttling"+              Prelude.. Core.hasStatus 400+          )+          e =+          Prelude.Just "throttling"+      | Lens.has+          ( Core.hasCode "ThrottlingException"+              Prelude.. Core.hasStatus 400+          )+          e =+          Prelude.Just "throttling_exception"+      | Lens.has+          ( Core.hasCode+              "ProvisionedThroughputExceededException"+              Prelude.. Core.hasStatus 400+          )+          e =+          Prelude.Just "throughput_exceeded"+      | Lens.has (Core.hasStatus 429) e =+          Prelude.Just "too_many_requests"+      | Prelude.otherwise = Prelude.Nothing++-- | An internal service error occurred.+_InternalServiceError :: (Core.AsError a) => Lens.Fold a Core.ServiceError+_InternalServiceError =+  Core._MatchServiceError+    defaultService+    "InternalServiceError"++-- | The request was not valid. Verify that your request was properly+-- formatted, that the signature was generated with the correct+-- credentials, and that you haven\'t exceeded any of the service limits+-- for your account.+_InvalidRequestException :: (Core.AsError a) => Lens.Fold a Core.ServiceError+_InvalidRequestException =+  Core._MatchServiceError+    defaultService+    "InvalidRequestException"++-- | The specified pipeline has been deleted.+_PipelineDeletedException :: (Core.AsError a) => Lens.Fold a Core.ServiceError+_PipelineDeletedException =+  Core._MatchServiceError+    defaultService+    "PipelineDeletedException"++-- | The specified pipeline was not found. Verify that you used the correct+-- user and account identifiers.+_PipelineNotFoundException :: (Core.AsError a) => Lens.Fold a Core.ServiceError+_PipelineNotFoundException =+  Core._MatchServiceError+    defaultService+    "PipelineNotFoundException"++-- | The specified task was not found.+_TaskNotFoundException :: (Core.AsError a) => Lens.Fold a Core.ServiceError+_TaskNotFoundException =+  Core._MatchServiceError+    defaultService+    "TaskNotFoundException"

@@ -0,0 +1,110 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.Types.Field+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+module Amazonka.DataPipeline.Types.Field where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import qualified Amazonka.Prelude as Prelude++-- | A key-value pair that describes a property of a pipeline object. The+-- value is specified as either a string value (@StringValue@) or a+-- reference to another object (@RefValue@) but not as both.+--+-- /See:/ 'newField' smart constructor.+data Field = Field'+  { -- | The field value, expressed as the identifier of another object.+    refValue :: Prelude.Maybe Prelude.Text,+    -- | The field value, expressed as a String.+    stringValue :: Prelude.Maybe Prelude.Text,+    -- | The field identifier.+    key :: Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'Field' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'refValue', 'field_refValue' - The field value, expressed as the identifier of another object.+--+-- 'stringValue', 'field_stringValue' - The field value, expressed as a String.+--+-- 'key', 'field_key' - The field identifier.+newField ::+  -- | 'key'+  Prelude.Text ->+  Field+newField pKey_ =+  Field'+    { refValue = Prelude.Nothing,+      stringValue = Prelude.Nothing,+      key = pKey_+    }++-- | The field value, expressed as the identifier of another object.+field_refValue :: Lens.Lens' Field (Prelude.Maybe Prelude.Text)+field_refValue = Lens.lens (\Field' {refValue} -> refValue) (\s@Field' {} a -> s {refValue = a} :: Field)++-- | The field value, expressed as a String.+field_stringValue :: Lens.Lens' Field (Prelude.Maybe Prelude.Text)+field_stringValue = Lens.lens (\Field' {stringValue} -> stringValue) (\s@Field' {} a -> s {stringValue = a} :: Field)++-- | The field identifier.+field_key :: Lens.Lens' Field Prelude.Text+field_key = Lens.lens (\Field' {key} -> key) (\s@Field' {} a -> s {key = a} :: Field)++instance Data.FromJSON Field where+  parseJSON =+    Data.withObject+      "Field"+      ( \x ->+          Field'+            Prelude.<$> (x Data..:? "refValue")+            Prelude.<*> (x Data..:? "stringValue")+            Prelude.<*> (x Data..: "key")+      )++instance Prelude.Hashable Field where+  hashWithSalt _salt Field' {..} =+    _salt+      `Prelude.hashWithSalt` refValue+      `Prelude.hashWithSalt` stringValue+      `Prelude.hashWithSalt` key++instance Prelude.NFData Field where+  rnf Field' {..} =+    Prelude.rnf refValue+      `Prelude.seq` Prelude.rnf stringValue+      `Prelude.seq` Prelude.rnf key++instance Data.ToJSON Field where+  toJSON Field' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("refValue" Data..=) Prelude.<$> refValue,+            ("stringValue" Data..=) Prelude.<$> stringValue,+            Prelude.Just ("key" Data..= key)+          ]+      )

@@ -0,0 +1,99 @@+{-# LANGUAGE DeriveGeneric #-}+{-# LANGUAGE DuplicateRecordFields #-}+{-# LANGUAGE NamedFieldPuns #-}+{-# LANGUAGE OverloadedStrings #-}+{-# LANGUAGE RecordWildCards #-}+{-# LANGUAGE StrictData #-}+{-# LANGUAGE NoImplicitPrelude #-}+{-# OPTIONS_GHC -fno-warn-unused-imports #-}+{-# OPTIONS_GHC -fno-warn-unused-matches #-}++-- Derived from AWS service descriptions, licensed under Apache 2.0.++-- |+-- Module      : Amazonka.DataPipeline.Types.InstanceIdentity+-- Copyright   : (c) 2013-2023 Brendan Hay+-- License     : Mozilla Public License, v. 2.0.+-- Maintainer  : Brendan Hay+-- Stability   : auto-generated+-- Portability : non-portable (GHC extensions)+module Amazonka.DataPipeline.Types.InstanceIdentity where++import qualified Amazonka.Core as Core+import qualified Amazonka.Core.Lens.Internal as Lens+import qualified Amazonka.Data as Data+import qualified Amazonka.Prelude as Prelude++-- | Identity information for the EC2 instance that is hosting the task+-- runner. You can get this value by calling a metadata URI from the EC2+-- instance. For more information, see+-- <http://docs.aws.amazon.com/AWSEC2/latest/UserGuide/AESDG-chapter-instancedata.html Instance Metadata>+-- 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.+--+-- /See:/ 'newInstanceIdentity' smart constructor.+data InstanceIdentity = InstanceIdentity'+  { -- | A description of an EC2 instance that is generated when the instance is+    -- launched and exposed to the instance via the instance metadata service+    -- in the form of a JSON representation of an object.+    document :: Prelude.Maybe Prelude.Text,+    -- | A signature which can be used to verify the accuracy and authenticity of+    -- the information provided in the instance identity document.+    signature :: Prelude.Maybe Prelude.Text+  }+  deriving (Prelude.Eq, Prelude.Read, Prelude.Show, Prelude.Generic)++-- |+-- Create a value of 'InstanceIdentity' with all optional fields omitted.+--+-- Use <https://hackage.haskell.org/package/generic-lens generic-lens> or <https://hackage.haskell.org/package/optics optics> to modify other optional fields.+--+-- The following record fields are available, with the corresponding lenses provided+-- for backwards compatibility:+--+-- 'document', 'instanceIdentity_document' - A description of an EC2 instance that is generated when the instance is+-- launched and exposed to the instance via the instance metadata service+-- in the form of a JSON representation of an object.+--+-- 'signature', 'instanceIdentity_signature' - A signature which can be used to verify the accuracy and authenticity of+-- the information provided in the instance identity document.+newInstanceIdentity ::+  InstanceIdentity+newInstanceIdentity =+  InstanceIdentity'+    { document = Prelude.Nothing,+      signature = Prelude.Nothing+    }++-- | A description of an EC2 instance that is generated when the instance is+-- launched and exposed to the instance via the instance metadata service+-- in the form of a JSON representation of an object.+instanceIdentity_document :: Lens.Lens' InstanceIdentity (Prelude.Maybe Prelude.Text)+instanceIdentity_document = Lens.lens (\InstanceIdentity' {document} -> document) (\s@InstanceIdentity' {} a -> s {document = a} :: InstanceIdentity)++-- | A signature which can be used to verify the accuracy and authenticity of+-- the information provided in the instance identity document.+instanceIdentity_signature :: Lens.Lens' InstanceIdentity (Prelude.Maybe Prelude.Text)+instanceIdentity_signature = Lens.lens (\InstanceIdentity' {signature} -> signature) (\s@InstanceIdentity' {} a -> s {signature = a} :: InstanceIdentity)++instance Prelude.Hashable InstanceIdentity where+  hashWithSalt _salt InstanceIdentity' {..} =+    _salt+      `Prelude.hashWithSalt` document+      `Prelude.hashWithSalt` signature++instance Prelude.NFData InstanceIdentity where+  rnf InstanceIdentity' {..} =+    Prelude.rnf document+      `Prelude.seq` Prelude.rnf signature++instance Data.ToJSON InstanceIdentity where+  toJSON InstanceIdentity' {..} =+    Data.object+      ( Prelude.catMaybes+          [ ("document" Data..=) Prelude.<$> document,+            ("signature" Data..=) Prelude.<$> signature+          ]+      )