Packages

step_flow

0.2.7
1.9.0-rc2 1.9.0-rc1 1.9.0-rc0 1.8.2 1.8.1 1.8.1-rc8 1.8.1-rc7 1.8.1-rc6 1.8.1-rc5 1.8.1-rc4 1.8.1-rc3 1.8.1-rc2 1.8.1-rc1 1.8.1-rc0 1.8.0 1.8.0-rc3 1.8.0-rc2 1.8.0-rc1 1.8.0-rc0 1.7.3 1.7.3-rc4 1.7.3-rc3 1.7.3-rc2 1.7.3-rc1 1.7.3-rc0 1.7.2 1.7.2-rc4 1.7.2-rc3 1.7.2-rc2 1.7.2-rc1 1.7.2-rc0 1.7.1 1.7.0 1.7.0-rc1 1.7.0-rc0 1.6.1 1.6.1-rc1 1.6.1-rc0 1.6.0 1.6.0-rc9 1.6.0-rc8 1.6.0-rc7 1.6.0-rc6 1.6.0-rc5 1.6.0-rc4 1.6.0-rc3 1.6.0-rc20 1.6.0-rc2 1.6.0-rc19 1.6.0-rc18 1.6.0-rc17 1.6.0-rc16 1.6.0-rc15 1.6.0-rc14 1.6.0-rc13 1.6.0-rc12 1.6.0-rc11 1.6.0-rc10 1.6.0-rc1 1.5.0 1.5.0-rc1 1.4.2-rc2 1.4.2-rc1 1.4.1 1.4.1-rc1 1.4.0 1.4.0-rc4 1.4.0-rc3 1.4.0-rc2 1.4.0-rc1 1.3.1 1.3.0 1.3.0-rc 1.2.0 1.1.0 1.0.0 1.0.0-rc9 1.0.0-rc8 1.0.0-rc7 1.0.0-rc6 1.0.0-rc5 1.0.0-rc1 0.2.13 0.2.12 0.2.11 0.2.10 0.2.9 0.2.8 0.2.7 0.2.6 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.8 0.1.7 0.1.6 0.1.5 0.1.4 0.1.3 0.1.2 0.1.1 0.1.0 0.0.24 0.0.23 0.0.22 0.0.21 0.0.20 0.0.19 0.0.18 0.0.17 0.0.16 0.0.15 0.0.14 0.0.13 0.0.12 0.0.11 0.0.10 0.0.9 0.0.8 0.0.7 0.0.6 0.0.4 0.0.3 0.0.2 0.0.1

Step flow manager for Elixir applications

HexDocs

Current section

Files

Jump to
Readme
128 Versions
18 Dependencies
Dependants
Files
Activity
step_flow lib step_flow router.ex
Raw

lib/step_flow/router.ex 

defmodule StepFlow.Router do

  use StepFlow, :router



  plug(:match)

  plug(:dispatch)



  plug(Plug.Parsers,

    parsers: [:json],

    pass: ["application/json"],

    json_decoder: Jason

  )



  get("/", do: send_resp(conn, 200, "Welcome to Step Flow"))



  get "/definitions" do

    StepFlow.WorkflowDefinitionController.index(conn, conn.params)

  end



  post "/definitions" do

    StepFlow.WorkflowDefinitionController.create(conn, conn.params)

  end



  get "/definitions/:identifier" do

    StepFlow.WorkflowDefinitionController.show(conn, conn.params)

  end



  post "/launch_workflow" do

    StepFlow.WorkflowController.create(conn, conn.params)

  end



  post "/workflows" do

    StepFlow.WorkflowController.create(conn, conn.params)

  end



  get "/workflows" do

    StepFlow.WorkflowController.index(conn, conn.params)

  end



  get "/workflows/:id" do

    StepFlow.WorkflowController.show(conn, conn.params)

  end



  put "/workflows/:id" do

    StepFlow.WorkflowController.update(conn, conn.params)

  end



  delete "/workflows/:id" do

    StepFlow.WorkflowController.delete(conn, conn.params)

  end



  post "/workflows/:id/events" do

    StepFlow.WorkflowEventsController.handle(conn, conn.params)

  end



  get "/workflows_statistics" do

    StepFlow.WorkflowController.statistics(conn, conn.path_params)

  end



  post "/worker_definitions" do

    StepFlow.WorkerDefinitionController.create(conn, conn.params)

  end



  get "/worker_definitions" do

    StepFlow.WorkerDefinitionController.index(conn, conn.params)

  end



  get "/worker_definitions/:id" do

    StepFlow.WorkerDefinitionController.show(conn, conn.params)

  end



  get "/jobs" do

    StepFlow.JobController.index(conn, conn.params)

  end



  if StepFlow.Configuration.metrics_enabled?() do

    get("/metrics", to: StepFlow.Metrics.PrometheusExporter)

  end



  match(_, do: send_resp(conn, 404, "Not found"))

end