Current section
Files
Jump to
Current section
Files
web/controllers/retries_controller.ex
defmodule VerkWeb.RetriesController do
use VerkWeb.Web, :controller
alias Verk.RetrySet
require Logger
def index(conn, params) do
paginator = VerkWeb.RangePaginator.new(RetrySet.count!, params["page"], params["per_page"])
render conn, "index.html",
failed_jobs: RetrySet.range_with_score!(paginator.from, paginator.to),
has_next: paginator.has_next,
has_prev: paginator.has_prev,
page: paginator.page,
per_page: paginator.per_page
end
def destroy(conn, %{ "jobs_to_remove" => jobs_to_remove }) do
jobs_to_remove = jobs_to_remove || []
for job <- jobs_to_remove, do: RetrySet.delete_job!(job)
redirect conn, to: retries_path(conn, :index)
end
def destroy(conn, _params) do
RetrySet.clear!
redirect conn, to: retries_path(conn, :index)
end
end