Struct CoordinatorConfig 

pub struct CoordinatorConfig {
    pub listen_addr: String,
    pub max_retries: u32,
    pub task_timeout_secs: u64,
    pub worker_timeout_secs: u64,
    pub result_buffer_size: usize,
}

Coordinator configuration.

Fields

listen_addr: String

Listen address for Flight server.

max_retries: u32

Maximum task retry attempts.

task_timeout_secs: u64

Task timeout in seconds.

worker_timeout_secs: u64

Worker heartbeat timeout in seconds.

result_buffer_size: usize

Result buffer size.

Implementations

impl CoordinatorConfig

pub fn new(listen_addr: String) -> Self

Create a new coordinator configuration.

pub fn with_max_retries(self, retries: u32) -> Self

Set the maximum retry attempts.

pub fn with_task_timeout(self, timeout_secs: u64) -> Self

Set the task timeout.

Trait Implementations

impl Clone for CoordinatorConfig

fn clone(&self) -> CoordinatorConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CoordinatorConfig

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

Formats the value using the given formatter.