amazonica.aws.datapipeline — com.signal-ai/amazonica 0.3.165-signal-1

activate-pipeline clj

(activate-pipeline &
                   {:keys [parameter-values pipeline-id start-timestamp]
                    :as activate-pipeline-request})

add-tags clj

(add-tags & {:keys [pipeline-id tags] :as add-tags-request})

client-class clj

create-pipeline clj

(create-pipeline &
                 {:keys [description name tags unique-id]
                  :as create-pipeline-request})

deactivate-pipeline clj

(deactivate-pipeline &
                     {:keys [cancel-active pipeline-id]
                      :as deactivate-pipeline-request})

delete-pipeline clj

(delete-pipeline & {:keys [pipeline-id] :as delete-pipeline-request})

describe-objects clj

(describe-objects &
                  {:keys [evaluate-expressions marker object-ids pipeline-id]
                   :as describe-objects-request})

describe-pipelines clj

(describe-pipelines & {:keys [pipeline-ids] :as describe-pipelines-request})

evaluate-expression clj

(evaluate-expression &
                     {:keys [expression object-id pipeline-id]
                      :as evaluate-expression-request})

get-cached-response-metadata clj

(get-cached-response-metadata & [amazon-web-service-request])

get-pipeline-definition clj

(get-pipeline-definition &
                         {:keys [pipeline-id version]
                          :as get-pipeline-definition-request})

list-pipelines clj

(list-pipelines)

(list-pipelines & {:keys [marker] :as list-pipelines-request})

poll-for-task clj

(poll-for-task &
               {:keys [hostname instance-identity worker-group]
                :as poll-for-task-request})

put-pipeline-definition clj

(put-pipeline-definition &
                         {:keys [parameter-objects parameter-values pipeline-id
                                 pipeline-objects]
                          :as put-pipeline-definition-request})

query-objects clj

(query-objects &
               {:keys [limit marker pipeline-id query sphere]
                :as query-objects-request})

remove-tags clj

(remove-tags & {:keys [pipeline-id tag-keys] :as remove-tags-request})

report-task-progress clj

(report-task-progress &
                      {:keys [fields task-id] :as report-task-progress-request})

report-task-runner-heartbeat clj

(report-task-runner-heartbeat &
                              {:keys [hostname taskrunner-id worker-group]
                               :as report-task-runner-heartbeat-request})

set-status clj

(set-status & {:keys [object-ids pipeline-id status] :as set-status-request})

set-task-status clj

(set-task-status &
                 {:keys [error-id error-message error-stack-trace task-id
                         task-status]
                  :as set-task-status-request})

show-functions clj

shutdown clj

(shutdown)

validate-pipeline-definition clj

(validate-pipeline-definition &
                              {:keys [parameter-objects parameter-values
                                      pipeline-id pipeline-objects]
                               :as validate-pipeline-definition-request})