Struct ImportJob 

pub struct ImportJob {
    pub run_id: i64,
    pub resource: String,
    pub spec: RunSpec,
    pub actor: Actor,
    pub hash: String,
}

The job an import runs as: the run’s id and everything the worker needs to pick the file up and write the rows. Pushed by start; the handler [job_reg] builds reads the file from the private disk.

Fields

run_id: i64

resource: String

The resource’s path as its descriptor declares it (/products).

spec: RunSpec

actor: Actor

hash: String

The stored file’s hash on the private disk.

Trait Implementations

impl Clone for ImportJob

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 ImportJob

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ImportJob

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Job for ImportJob

fn run<'life0, 'life1, 'async_trait>( &'life0 self, _cx: &'life1 JobCx, ) -> Pin<Box<dyn Future<Output = Result<(), JobError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Never called: the handler registered by the admin router runs the job, since it needs the resource’s prepared form and the disk.

fn tries(&self) -> u32

One attempt: rows written before a failure stay, so a second pass would write them again.

fn timeout(&self) -> Option<Duration>

A large file takes as long as it takes.

const NAME: &'static str = "laterite.import::run"

The job’s name, unique across the application: acme.blog::send_digest.

fn unique_key(&self) -> Option<String>

A key no two pending jobs may share: a push while one with the same key waits is dropped. None unless overridden.

fn queue(&self) -> String

The queue the job lands on. DEFAULT_QUEUE unless overridden.

fn backoff(&self, attempt: u32) -> Duration

How long to wait before attempt attempt + 1, after attempt attempt failed. Ten seconds, doubling each time, unless overridden.

fn retry_until(&self) -> Option<DateTime<Utc>>

Keep retrying until this moment, whatever tries says. None unless overridden.

impl Serialize for ImportJob

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

where __S: Serializer,

Serialize this value into the given Serde serializer.