conductor.mapper-utils — io.orkes/conductor-clojure 0.1.6

camel->kebab clj

(camel->kebab k)

clj-rerun-workflow-request->RerunWorkflowRequest clj

(clj-rerun-workflow-request->RerunWorkflowRequest rerun-workflow-request)

clj-start-workflow-request->StartWorkflowRequest clj

(clj-start-workflow-request->StartWorkflowRequest
  {:keys [name version correlation-id external-input-payload-storage-path
          priority input task-domain workflow-def]})

Returns a Start workflow request

clj-task->TaskDef clj

(clj-task->TaskDef {:keys [name description owner-email retry-count
                           timeout-seconds response-timeout-seconds]})

clj-task-type->TaskType clj

(clj-task-type->TaskType type)

clj-worker->Worker clj

(clj-worker->Worker worker)

Returns a Worker instance for a worker provided in the form of a map

clj-workflow->WorkflowDef clj

(clj-workflow->WorkflowDef
  {:keys [name description version tasks input-parameters output-parameters
          schema-version restartable owner-email timeout-policy timeout-seconds]
   :or {restartable true timeout-policy :alert-only}})

clj-workflow-task->WorkflowTask clj

(clj-workflow-task->WorkflowTask
  {:keys [name task-reference-name description input-parameters type fork-tasks
          join-on decision-cases default-case loop-condition loop-over
          dynamic-fork-tasks-input-param-name dynamic-fork-tasks-param
          dynamic-task-name-param async-complete case-value-param]})

java-map->clj clj

(java-map->clj m)

kebab->camel clj

(kebab->camel k)

kebab->capitalizedash clj

(kebab->capitalizedash w)

kebab-all-map-keys clj

(kebab-all-map-keys o)

MapToClojure clj protocol

->clj clj

(->clj o)

status->task-result-status clj

(status->task-result-status s)

TaskResultStatus clj protocol

->task-result-status clj

(->task-result-status trs)

TaskTypeEnum clj protocol

->task-type clj

(->task-type tp)

timeout-policy->TimeoutPolicy clj

(timeout-policy->TimeoutPolicy timeout-policy)

TimeoutPolicy clj protocol

->timeout-policy clj

(->timeout-policy tp)