Struct pachyderm::pps::PipelineInfo

pub struct PipelineInfo {
    pub id: String,
    pub pipeline: Option<Pipeline>,
    pub version: u64,
    pub transform: Option<Transform>,
    pub tf_job: Option<TfJob>,
    pub parallelism_spec: Option<ParallelismSpec>,
    pub hashtree_spec: Option<HashtreeSpec>,
    pub egress: Option<Egress>,
    pub created_at: Option<Timestamp>,
    pub state: i32,
    pub stopped: bool,
    pub recent_error: String,
    pub workers_requested: i64,
    pub workers_available: i64,
    pub job_counts: HashMap<i32, i32>,
    pub last_job_state: i32,
    pub output_branch: String,
    pub resource_requests: Option<ResourceSpec>,
    pub resource_limits: Option<ResourceSpec>,
    pub sidecar_resource_limits: Option<ResourceSpec>,
    pub input: Option<Input>,
    pub description: String,
    pub cache_size: String,
    pub enable_stats: bool,
    pub salt: String,
    pub reason: String,
    pub max_queue_size: i64,
    pub service: Option<Service>,
    pub spout: Option<Spout>,
    pub chunk_spec: Option<ChunkSpec>,
    pub datum_timeout: Option<Duration>,
    pub job_timeout: Option<Duration>,
    pub githook_url: String,
    pub spec_commit: Option<Commit>,
    pub standby: bool,
    pub datum_tries: i64,
    pub scheduling_spec: Option<SchedulingSpec>,
    pub pod_spec: String,
    pub pod_patch: String,
    pub s3_out: bool,
    pub metadata: Option<Metadata>,
}

Fields

id: String

pipeline: Option<Pipeline>

version: u64

transform: Option<Transform>

tf_job: Option<TfJob>

tf_job encodes a Kubeflow TFJob spec. Pachyderm uses this to create TFJobs when running in a kubernetes cluster on which kubeflow has been installed. Exactly one of 'tf_job' and 'transform' should be set

parallelism_spec: Option<ParallelismSpec>

hashtree_spec: Option<HashtreeSpec>

egress: Option<Egress>

created_at: Option<Timestamp>

state: i32

state indicates the current state of the pipeline. This is not stored in PFS along with the rest of this data structure--PPS.InspectPipeline fills it in

stopped: bool

same for stopped field

recent_error: String

workers_requested: i64

workers_available: i64

job_counts: HashMap<i32, i32>

job_counts and last_job_state indicates the number of jobs within this pipeline in a given state and the state of the most recently created job, respectively. This is not stored in PFS along with the rest of this data structure--PPS.InspectPipeline fills it in from the EtcdPipelineInfo.

last_job_state: i32

output_branch: String

resource_requests: Option<ResourceSpec>

resource_limits: Option<ResourceSpec>

sidecar_resource_limits: Option<ResourceSpec>

input: Option<Input>

description: String

cache_size: String

enable_stats: bool

salt: String

reason: String

reason includes any error messages associated with a failed pipeline

max_queue_size: i64

service: Option<Service>

spout: Option<Spout>

chunk_spec: Option<ChunkSpec>

datum_timeout: Option<Duration>

job_timeout: Option<Duration>

githook_url: String

spec_commit: Option<Commit>

standby: bool

datum_tries: i64

scheduling_spec: Option<SchedulingSpec>

pod_spec: String

pod_patch: String

s3_out: bool

metadata: Option<Metadata>

Implementations

impl PipelineInfo

pub fn state(&self) -> PipelineState

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: PipelineState)

Sets state to the provided enum value.

pub fn last_job_state(&self) -> JobState

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

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

Sets last_job_state to the provided enum value.

Trait Implementations

impl Clone for PipelineInfo

fn clone(&self) -> PipelineInfo

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for PipelineInfo

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

Formats the value using the given formatter.

impl Default for PipelineInfo

fn default() -> PipelineInfo

Returns the "default value" for a type.

impl Message for PipelineInfo

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<PipelineInfo> for PipelineInfo

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

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

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

This method tests for !=.

impl StructuralPartialEq for PipelineInfo