Struct RetryableTask 

pub struct RetryableTask {

    pub task_id: String,
    pub retry_count: i32,
    pub max_retries: i32,
    pub retry_after_hours: f64,
    pub retry_after_time: DateTime<Utc>,
    pub task_data: String,
    pub task_type: String,
    pub last_error_obj: Option<String>,
    pub last_job_error: Option<JobErrorReturn>,
    pub rate_limit_group: Option<String>,
    pub max_per_minute: Option<i32>,
    pub auto_dedupe: Option<bool>,
    pub urgency_score: Option<f64>,
    pub payload_hash: Option<String>,
    pub deleted_at: Option<DateTime<Utc>>,
    pub execute_at: DateTime<Utc>,
    pub cron_expression: Option<String>,
    pub webhook_url: Option<String>,
    pub max_execution_seconds: Option<u64>,
    pub created_at: DateTime<Utc>,
    pub updated_at: DateTime<Utc>,
}

Fields

task_id: String

retry_count: i32

max_retries: i32

retry_after_hours: f64

retry_after_time: DateTime<Utc>

task_data: String

task_type: String

last_error_obj: Option<String>

last_job_error: Option<JobErrorReturn>

rate_limit_group: Option<String>

max_per_minute: Option<i32>

auto_dedupe: Option<bool>

urgency_score: Option<f64>

payload_hash: Option<String>

deleted_at: Option<DateTime<Utc>>

execute_at: DateTime<Utc>

cron_expression: Option<String>

webhook_url: Option<String>

max_execution_seconds: Option<u64>

created_at: DateTime<Utc>

updated_at: DateTime<Utc>

Implementations

impl RetryableTask

pub fn new( task_id: String, task_type: String, task_data: String, max_retries: i32, retry_after_hours: f64, rate_limit_group: Option<String>, max_per_minute: Option<i32>, auto_dedupe: Option<bool>, urgency_score: Option<f64>, execute_at_opt: Option<String>, cron_opt: Option<String>, webhook_url: Option<String>, max_execution_seconds: Option<u64>, ) -> Self

pub fn mark_deleted(&mut self)

pub fn update_retry_config(&mut self, error_msg: Option<String>)

Trait Implementations

impl Clone for RetryableTask

fn clone(&self) -> RetryableTask

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RetryableTask

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for RetryableTask

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for RetryableTask

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.