JobManager 1.0.0-previe.2

ToolWheel JobManager

A modular, extensible and testable infrastructure for defining, scheduling, executing and safeguarding background jobs in .NET 8 applications.

Overview

Projects

Quick Start

1. Register the Job Manager

var builder = Host.CreateApplicationBuilder(args);

builder.Services.AddJobManager(configure =>
{
    configure.ConfigureJobs(jobs =>
    {
        var worker = new MyWorker();

        jobs.Add("my-job", worker.DoWork)
            .Name("My Job")
            .Description("Processes pending items")
            .Enabled();
    });
});

var app = builder.Build();
await app.RunAsync();

2. Using the Startup Class Pattern

builder.Services.AddJobManager<MyJobManagerStartup>();

public class MyJobManagerStartup : JobManagerStartup
{
    public override void ConfigureJobManager(IJobManagerConfigurationBuilder configure)
    {
        // Register middleware, execution conditions, services …
    }

    public override void ConfigureJobs(IJobDescriptionCollection collection)
    {
        var worker = new MyWorker();

        collection.Add("import-job", worker.ImportData)
            .Name("Data Import")
            .Enabled();
    }
}

3. Adding Triggers

jobs.Add("scheduled-job", worker.Process)
    .Name("Scheduled Job")
    .Enabled()
    .Trigger()
        .WithInterval(TimeSpan.FromMinutes(5), fireImmediately: true)
        .And();

4. Executing Jobs Manually

public class MyController
{
    private readonly IJobService _jobService;

    public MyController(IJobService jobService)
    {
        _jobService = jobService;
    }

    public async Task RunJobAsync(string jobId, CancellationToken ct)
    {
        var job = _jobService.ReadById(jobId);
        IJobTask task = await _jobService.ExecuteAsync(job, ct);
        // task.Status, task.Journal, task.CancellationToken …
    }
}

Key Concepts

• Job – An IJob wraps a MethodInfo + optional target instance that represents the unit of work.
• JobTask – An IJobTask is a runtime handle for a single execution, tracking status (Pending, Running, Success, Canceled, Failed), cancellation token, result and journal entries.
• Execution Condition – An IExecutionCondition is evaluated before a job runs. If any condition sets the result to not ready, execution is skipped.
• Middleware – IExecutionMiddleware components form a pipeline around each job task execution (e.g. resolving the target object, evaluating conditions).
• Trigger – An ITrigger decides autonomously whether to fire. ISchedulableTrigger additionally predicts its next fire time for adaptive polling.
• Trigger Filter – An ITriggerFilter can block a trigger based on time windows, day-of-week, month/quarter boundaries etc.
• Job Group – Groups ensure mutual exclusion: only one job within a group may run at a time.

Extensibility

• Implement IExecutionCondition or IExecutionMiddleware and register them via the configuration builder.
• Implement ITrigger / ISchedulableTrigger for custom scheduling strategies.
• Implement ITriggerFilter for custom trigger-level gating logic.
• Add persistence integrations (e.g. database-backed job stores) through DI.
• The IAutoFeatureConfigurator interface enables packages to self-register into the pipeline on assembly load.