@spec count_by_state([Kathikon.Job.t()]) :: %{required(atom()) => non_neg_integer()}

Groups jobs by state and returns a count map.

Used by reporting helpers and available for custom dashboards.

@spec dead_letter_summary(keyword()) :: {:ok, map()} | {:error, term()}

Summarizes dead-letter queue jobs.

Options

• :queue — filter by queue

Examples

{:ok, %{count: count, jobs: jobs}} = Kathikon.Report.dead_letter_summary()

@spec failure_summary(keyword()) :: {:ok, [map()]} | {:error, term()}

Summarizes failures by worker module.

Examples

{:ok, summary} = Kathikon.Report.failure_summary()

hd(summary)
#=> %{worker: MyApp.FailWorker, count: 3, last_error: "..."}

@spec job_counts(keyword()) :: {:ok, map()} | {:error, term()}

Returns global job counts grouped by state.

Examples

{:ok, counts} = Kathikon.Report.job_counts()
counts[:completed]

@spec latency(keyword()) :: {:ok, map()} | {:error, term()}

Returns average runtime for completed jobs (microseconds).

Examples

{:ok, %{samples: n, average_microseconds: avg}} = Kathikon.Report.latency()

@spec queue_summary(keyword()) :: {:ok, [map()]} | {:error, term()}

Summarizes each configured queue with job counts by state.

Options are reserved for future filtering and are currently ignored.

Examples

{:ok, summaries} = Kathikon.Report.queue_summary()

hd(summaries)
#=> %{queue: :default, paused: false, counts: %{available: 2, completed: 10}}

@spec throughput(keyword()) :: {:ok, [map()]} | {:error, term()}

Returns completed job counts per queue (throughput proxy).

Examples

{:ok, throughput} = Kathikon.Report.throughput()
#=> [%{queue: :default, completed: 42}]