Struct JobsConfig 

pub struct JobsConfig {
    pub retention_seconds: u64,
    pub max_live_per_project: i64,
    pub retry_after_seconds: u64,
    pub lease_seconds: u64,
    pub poll_interval_ms: u64,
    pub max_concurrent: usize,
    pub maintenance_interval_seconds: u64,
}

Asynchronous jobs: an operation invoked with Prefer: respond-async today, Bulk Data exports next. The first three apply to the server’s kick-off and status endpoints; the rest to the worker that runs the jobs.

Fields

retention_seconds: u64

How long a finished job and its result stay available to poll, in seconds, and how long a job that never ran waits before it is cleared.

max_live_per_project: i64

Queued or running jobs one project may have at once. A kick-off past this is refused with 429 Too Many Requests, as the Bulk Data specification allows.

retry_after_seconds: u64

What a polling client is told to wait, in seconds (Retry-After), while its job is still queued or running.

lease_seconds: u64

How long one claim or lease renewal holds a job for a worker, in seconds. A worker that stops renewing for this long loses the job.

poll_interval_ms: u64

How often an idle worker looks for queued jobs, in milliseconds.

max_concurrent: usize

Jobs one worker runs at once.

maintenance_interval_seconds: u64

How often a worker sweeps abandoned and expired jobs, in seconds.

Implementations

impl JobsConfig

pub fn retention(&self) -> Duration

pub fn worker_config(&self) -> AsyncJobWorkerConfig

Trait Implementations

impl Clone for JobsConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for JobsConfig

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

Formats the value using the given formatter.

impl Default for JobsConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for JobsConfig

where JobsConfig: Default,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for JobsConfig

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

where __S: Serializer,

Serialize this value into the given Serde serializer.