src/MassTransit/JobService/JobTypeSaga.cs - develop - vshmidt/masstransit

src/MassTransit/JobService/JobTypeSaga.cs
79 строк2 KB
Chris Patterson
Fixes after trying out the sample with the latest
04 окт 2024, 01:31
04 окт 2024, 01:31c81f850
namespace MassTransit;

using System;
using System.Collections.Generic;


/// <summary>
/// Every job type has one entry in this state machine
/// </summary>
public class JobTypeSaga :
    SagaStateMachineInstance,
    JobTypeInfo,
    ISagaVersion
{
    public JobTypeSaga()
    {
        ConcurrentJobLimit = 1;

        Instances = new Dictionary<Uri, JobTypeInstance>();
        ActiveJobs = [];
    }

    public int CurrentState { get; set; }

    public int ActiveJobCount { get; set; }

    /// <summary>
    /// The concurrent job limit, which is configured by the job options. Initially, it defaults to one when the state machine
    /// is created. Once a service endpoint starts, that endpoint sends a command to set the configure concurrent job limit.
    /// </summary>
    public int ConcurrentJobLimit { get; set; }

    /// <summary>
    /// The job limit may be overridden temporarily, to either reduce or increase the number of concurrent jobs. Once the
    /// override job limit expires, the concurrent job limit returns to the original value.
    /// </summary>
    public int? OverrideJobLimit { get; set; }

    /// <summary>
    /// If an <see cref="OverrideJobLimit" /> is specified, the time when the override job limit expires
    /// </summary>
    public DateTime? OverrideLimitExpiration { get; set; }

    /// <summary>
    /// The last known active jobs
    /// </summary>
    public List<ActiveJob> ActiveJobs { get; set; }

    /// <summary>
    /// Tracks the instances, when they were last updated
    /// </summary>
    public Dictionary<Uri, JobTypeInstance> Instances { get; set; }

    /// <summary>
    /// Job properties passed by the <see cref="JobOptions{TJob}" /> configuration
    /// </summary>
    public Dictionary<string, object> Properties { get; set; }

    public byte[] RowVersion { get; set; }

    public int? GlobalConcurrentJobLimit { get; set; }

    public int Version { get; set; }

    /// <summary>
    /// The name of the job type
    /// </summary>
    public string Name { get; set; }

    int JobTypeInfo.ConcurrentJobLimit => OverrideJobLimit ?? ConcurrentJobLimit;
    IReadOnlyList<ActiveJob> JobTypeInfo.ActiveJobs => ActiveJobs;
    IReadOnlyDictionary<Uri, JobTypeInstance> JobTypeInfo.Instances => Instances;
    IReadOnlyDictionary<string, object> JobTypeInfo.Properties => Properties ?? [];

    /// <summary>
    /// The MD5 hash of the job type
    /// </summary>
    public Guid CorrelationId { get; set; }
}