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

src/MassTransit/JobService/JobSaga.cs
97 строк3 KB
Chris Patterson
Reworked Job Properties, Job Type Properties, and Instance Properties to allow better differentiation when building job distribution strategies.
07 окт 2024, 20:47
07 окт 2024, 20:47448db29
namespace MassTransit
{
    using System;
    using System.Collections.Generic;


    /// <summary>
    /// Individual turnout jobs are tracked by this state
    /// </summary>
    public class JobSaga :
        SagaStateMachineInstance,
        ISagaVersion
    {
        public int CurrentState { get; set; }

        public DateTime? Submitted { get; set; }
        public Uri ServiceAddress { get; set; }
        public TimeSpan? JobTimeout { get; set; }
        public Dictionary<string, object> Job { get; set; }
        public Guid JobTypeId { get; set; }

        public Guid AttemptId { get; set; }
        public int RetryAttempt { get; set; }

        public DateTime? Started { get; set; }

        public DateTime? Completed { get; set; }
        public TimeSpan? Duration { get; set; }

        public DateTime? Faulted { get; set; }
        public string Reason { get; set; }

        public Guid? JobSlotWaitToken { get; set; }
        public Guid? JobRetryDelayToken { get; set; }

        /// <summary>
        /// If present, keeps track of any previously faulted attempts so that the faulted job attempt saga instances can be removed when finalized
        /// </summary>
        public List<Guid> IncompleteAttempts { get; set; }

        /// <summary>
        /// If present, the last reported progress value
        /// </summary>
        public long? LastProgressValue { get; set; }

        /// <summary>
        /// If present, the maximum value (can be used to show a percentage)
        /// </summary>
        public long? LastProgressLimit { get; set; }

        /// <summary>
        /// The last reported sequence number for the current job attempt
        /// </summary>
        public long? LastProgressSequenceNumber { get; set; }

        /// <summary>
        /// The job state, saved from a previous job attempt
        /// </summary>
        public Dictionary<string, object> JobState { get; set; }

        /// <summary>
        /// The job properties, supplied by the submitted job
        /// </summary>
        public Dictionary<string, object> JobProperties { get; set; }

        /// <summary>
        /// For recurring jobs, the cron expression used to determine the next start date after the job has completed.
        /// </summary>
        public string CronExpression { get; set; }

        /// <summary>
        /// The time zone for the cron expression
        /// </summary>
        public string TimeZoneId { get; set; }

        /// <summary>
        /// If a state date is specified, the job won't start until after the start date.
        /// </summary>
        public DateTimeOffset? StartDate { get; set; }

        /// <summary>
        /// For recurring jobs, if the <see cref="NextStartDate"/> is after the end date the job will be completed.
        /// </summary>
        public DateTimeOffset? EndDate { get; set; }

        /// <summary>
        /// For recurring jobs, the next start date based on the cron expression (and <see cref="StartDate"/>, if specified).
        /// </summary>
        public DateTimeOffset? NextStartDate { get; set; }

        public byte[] RowVersion { get; set; }

        public int Version { get; set; }

        public Guid CorrelationId { get; set; }
    }
}