Jobs

Jobs represent long-running operations the Chronicle Kernel performs in the background — replaying a projection, rebuilding a read model, and similar work that runs in steps over time rather than completing instantly. Use the jobs API to see what’s running, check progress, and stop, resume, or delete a job.

List all jobs

C#

using Cratis.Chronicle;
using Cratis.Chronicle.Jobs;

public class JobsIndexListAll(IEventStore eventStore)
{
    public async Task<IEnumerable<Job>> GetAllJobs() => await eventStore.Jobs.GetJobs();
}

Kotlin

Kotlin does not support this workflow yet.

Java

Java does not support this workflow yet.

Elixir

defmodule MyApp.JobsIndexListAll do
  def get_all_jobs do
    Chronicle.Jobs.all()
  end
end

TypeScript

import { IEventStore } from '@cratis/chronicle';
import { Job } from '@cratis/chronicle.contracts';

class JobsIndexListAll {
    constructor(private readonly store: IEventStore) {}

    async getAllJobs(): Promise<Job[]> {
        return this.store.jobs.getJobs();
    }
}

Get a single job

C#

using Cratis.Chronicle;
using Cratis.Chronicle.Jobs;

public class JobsIndexGetOne(IEventStore eventStore)
{
    public async Task<Job?> GetJob(JobId jobId) => await eventStore.Jobs.GetJob(jobId);
}

Kotlin

Kotlin does not support this workflow yet.

Java

Java does not support this workflow yet.

Elixir

defmodule MyApp.JobsIndexGetOne do
  def get_job(job_id) do
    Chronicle.Jobs.get(job_id)
  end
end

TypeScript

import { IEventStore } from '@cratis/chronicle';
import { Job } from '@cratis/chronicle.contracts';

class JobsIndexGetOne {
    constructor(private readonly store: IEventStore) {}

    async getJob(jobId: string): Promise<Job | undefined> {
        return this.store.jobs.getJob(jobId);
    }
}

A missing job resolves to nothing rather than an error — check for that before using the result.

Get the steps for a job

A job is made up of one or more steps. Get them to see fine-grained progress:

C#

using Cratis.Chronicle;
using Cratis.Chronicle.Jobs;

public class JobsIndexGetSteps(IEventStore eventStore)
{
    public async Task<IEnumerable<JobStep>?> GetSteps(JobId jobId)
    {
        var job = await eventStore.Jobs.GetJob(jobId);
        return job is null ? null : await job.GetJobSteps();
    }
}

Kotlin

Kotlin does not support this workflow yet.

Java

Java does not support this workflow yet.

Elixir

defmodule MyApp.JobsIndexGetSteps do
  def get_steps(job_id) do
    Chronicle.Jobs.steps(job_id)
  end
end

TypeScript

import { IEventStore } from '@cratis/chronicle';
import { JobStep } from '@cratis/chronicle.contracts';

class JobsIndexGetSteps {
    constructor(private readonly store: IEventStore) {}

    async getSteps(jobId: string): Promise<JobStep[]> {
        return this.store.jobs.getJobSteps(jobId);
    }
}

Stop, resume, and delete

C#

using Cratis.Chronicle;
using Cratis.Chronicle.Jobs;

public class JobsIndexStopResumeDelete(IEventStore eventStore)
{
    public async Task StopJob(JobId jobId) => await eventStore.Jobs.Stop(jobId);

    public async Task ResumeJob(JobId jobId) => await eventStore.Jobs.Resume(jobId);

    public async Task DeleteJob(JobId jobId) => await eventStore.Jobs.Delete(jobId);
}

Kotlin

Kotlin does not support this workflow yet.

Java

Java does not support this workflow yet.

Elixir

defmodule MyApp.JobsIndexStopResumeDelete do
  def stop_job(job_id), do: Chronicle.Jobs.stop(job_id)
  def resume_job(job_id), do: Chronicle.Jobs.resume(job_id)
  def delete_job(job_id), do: Chronicle.Jobs.delete(job_id)
end

TypeScript

import { IEventStore } from '@cratis/chronicle';

class JobsIndexStopResumeDelete {
    constructor(private readonly store: IEventStore) {}

    async stopJob(jobId: string): Promise<void> {
        await this.store.jobs.stop(jobId);
    }

    async resumeJob(jobId: string): Promise<void> {
        await this.store.jobs.resume(jobId);
    }

    async deleteJob(jobId: string): Promise<void> {
        await this.store.jobs.delete(jobId);
    }
}

Kotlin and Java don’t currently have a jobs API — there’s no equivalent anywhere in the Kotlin client SDK yet.

Related topics

• Webhooks — pushing observed events to external HTTP endpoints, the other kernel-managed background concern.