Struct TaskConfig 

pub struct TaskConfig {
    pub task_type: i16,
    pub priority: TaskPriority,
    pub topic: String,
    pub timeout_seconds: u64,
    pub max_retries: u32,
    pub retry_strategy: RetryStrategy,
    pub retry_delay_seconds: u64,
    pub max_retry_delay_seconds: u64,
    pub description: &'static str,
    pub dead_letter_topic: Option<String>,
}

任务配置 —— 每种 task_type 对应一份配置

Fields

task_type: i16

任务类型标识

priority: TaskPriority

任务优先级

topic: String

Kafka topic 名称

timeout_seconds: u64

任务执行超时时间（秒）

max_retries: u32

最大重试次数

retry_strategy: RetryStrategy

重试策略

retry_delay_seconds: u64

重试延迟基础时间（秒）

max_retry_delay_seconds: u64

最大重试延迟时间（秒）

description: &'static str

任务描述

dead_letter_topic: Option<String>

死信队列 topic —— 超过 max_retries 后转发到此 topic（None 则不启用）

Trait Implementations

impl Clone for TaskConfig

fn clone(&self) -> TaskConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TaskConfig

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

Formats the value using the given formatter.