EonaCat.JobScheduler 1.0.0

EonaCat.JobScheduler

Schedule Jobs to execute using EonaCat.JobScheduler.

Jobs example:

public class EmailJob : IJob
{
    public string Id { get; } = Guid.NewGuid().ToString();
    public string Name { get; } = "Email Job";
    public string To { get; set; }
    public string Subject { get; set; }
    public string Body { get; set; }

    public async Task ExecuteAsync(CancellationToken cancellationToken = default)
    {
        // Simulate sending email
        await Task.Delay(2000, cancellationToken);
        Console.WriteLine($"Email sent to {To}: {Subject}");
    }
}

    public class DataBackupJob : IJob
    {
        public string Id { get; } = Guid.NewGuid().ToString();
        public string Name { get; } = "Data Backup Job";
        public string BackupPath { get; set; }

        public async Task ExecuteAsync(CancellationToken cancellationToken = default)
        {
            // Simulate backup process
            await Task.Delay(5000, cancellationToken);
            Console.WriteLine($"Data backup completed to {BackupPath}");
        }
    }

Usage example:

public static class SchedulerExample
{
    public static async Task Example()
    {
        var scheduler = new JobScheduler();

        // Subscribe to events
        scheduler.JobCompleted += (s, e) => 
            Console.WriteLine($"Job {e.JobName} completed in {e.Duration}");
            
        scheduler.JobFailed += (s, e) => 
            Console.WriteLine($"Job {e.JobName} failed: {e.ErrorMessage}");

        // Schedule immediate job
        await scheduler.RunJobNowAsync<EmailJob>("Welcome Email", new Dictionary<string, object>
        {
            ["To"] = "user@example.com",
            ["Subject"] = "Welcome!",
            ["Body"] = "Welcome to our service!"
        });

        // Schedule recurring backup job (daily at 2 AM)
        await scheduler.ScheduleRecurringJobAsync<DataBackupJob>(
            "Daily Backup", 
            "0 0 2 * * *", 
            new Dictionary<string, object>
            {
                ["BackupPath"] = "/backups/daily"
            });

        // Schedule one-time job for later
        var jobDef = JobDefinition.Create<EmailJob>("Reminder Email")
            .ScheduleAt(DateTime.UtcNow.AddHours(24))
            .WithPriority(JobPriority.High)
            .WithRetry(new RetryPolicy { MaxAttempts = 5 })
            .WithTimeout(TimeSpan.FromMinutes(5))
            .WithParameter("To", "admin@example.com")
            .WithParameter("Subject", "Daily Report")
            .WithParameter("Body", "Please review the daily report.");

        await scheduler.ScheduleJobAsync(jobDef);

        Console.WriteLine("Jobs scheduled. Press any key to exit...");
        Console.ReadKey();
    }
}