Struct pachyderm::pps::JobInfo

pub struct JobInfo {
    pub job: Option<Job>,
    pub transform: Option<Transform>,
    pub pipeline: Option<Pipeline>,
    pub pipeline_version: u64,
    pub spec_commit: Option<Commit>,
    pub parallelism_spec: Option<ParallelismSpec>,
    pub egress: Option<Egress>,
    pub parent_job: Option<Job>,
    pub started: Option<Timestamp>,
    pub finished: Option<Timestamp>,
    pub output_commit: Option<Commit>,
    pub state: i32,
    pub reason: String,
    pub service: Option<Service>,
    pub spout: Option<Spout>,
    pub output_repo: Option<Repo>,
    pub output_branch: String,
    pub restart: u64,
    pub data_processed: i64,
    pub data_skipped: i64,
    pub data_failed: i64,
    pub data_recovered: i64,
    pub data_total: i64,
    pub stats: Option<ProcessStats>,
    pub worker_status: Vec<WorkerStatus>,
    pub resource_requests: Option<ResourceSpec>,
    pub resource_limits: Option<ResourceSpec>,
    pub sidecar_resource_limits: Option<ResourceSpec>,
    pub input: Option<Input>,
    pub new_branch: Option<BranchInfo>,
    pub stats_commit: Option<Commit>,
    pub enable_stats: bool,
    pub salt: String,
    pub chunk_spec: Option<ChunkSpec>,
    pub datum_timeout: Option<Duration>,
    pub job_timeout: Option<Duration>,
    pub datum_tries: i64,
    pub scheduling_spec: Option<SchedulingSpec>,
    pub pod_spec: String,
    pub pod_patch: String,
}

Fields

job: Option<Job>

transform: Option<Transform>

requires ListJobRequest.Full

pipeline: Option<Pipeline>

pipeline_version: u64

requires ListJobRequest.Full

spec_commit: Option<Commit>

parallelism_spec: Option<ParallelismSpec>

requires ListJobRequest.Full

egress: Option<Egress>

requires ListJobRequest.Full

parent_job: Option<Job>

started: Option<Timestamp>

finished: Option<Timestamp>

output_commit: Option<Commit>

state: i32

reason: String

reason explains why the job is in the current state

service: Option<Service>

requires ListJobRequest.Full

spout: Option<Spout>

requires ListJobRequest.Full

output_repo: Option<Repo>

output_branch: String

requires ListJobRequest.Full

restart: u64

data_processed: i64

data_skipped: i64

data_failed: i64

data_recovered: i64

data_total: i64

stats: Option<ProcessStats>

worker_status: Vec<WorkerStatus>

resource_requests: Option<ResourceSpec>

requires ListJobRequest.Full

resource_limits: Option<ResourceSpec>

requires ListJobRequest.Full

sidecar_resource_limits: Option<ResourceSpec>

requires ListJobRequest.Full

input: Option<Input>

requires ListJobRequest.Full

new_branch: Option<BranchInfo>

stats_commit: Option<Commit>

enable_stats: bool

requires ListJobRequest.Full

salt: String

requires ListJobRequest.Full

chunk_spec: Option<ChunkSpec>

requires ListJobRequest.Full

datum_timeout: Option<Duration>

requires ListJobRequest.Full

job_timeout: Option<Duration>

requires ListJobRequest.Full

datum_tries: i64

requires ListJobRequest.Full

scheduling_spec: Option<SchedulingSpec>

requires ListJobRequest.Full

pod_spec: String

requires ListJobRequest.Full

pod_patch: String

requires ListJobRequest.Full

Implementations

impl JobInfo

pub fn state(&self) -> JobState

Returns the enum value of state, or the default if the field is set to an invalid enum value.

pub fn set_state(&mut self, value: JobState)

Sets state to the provided enum value.

Trait Implementations

impl Clone for JobInfo

fn clone(&self) -> JobInfo

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for JobInfo

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

Formats the value using the given formatter.

impl Default for JobInfo

fn default() -> JobInfo

Returns the "default value" for a type.

impl Message for JobInfo

fn encode_raw<B>(&self, buf: &mut B) where
    B: BufMut, 

fn merge_field<B>(
    &mut self,
    tag: u32,
    wire_type: WireType,
    buf: &mut B,
    ctx: DecodeContext
) -> Result<(), DecodeError> where
    B: Buf, 

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
    B: BufMut, 

Encodes the message to a buffer.

fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
    B: BufMut, 

Encodes the message with a length-delimiter to a buffer.

fn decode<B>(buf: B) -> Result<Self, DecodeError> where
    B: Buf,
    Self: Default, 

Decodes an instance of the message from a buffer.

fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
    B: Buf,
    Self: Default, 

Decodes a length-delimited instance of the message from the buffer.

fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError> where
    B: Buf, 

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError> where
    B: Buf, 

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq<JobInfo> for JobInfo

fn eq(&self, other: &JobInfo) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &JobInfo) -> bool

This method tests for !=.

impl StructuralPartialEq for JobInfo