[−][src]Struct pachyderm::pps::EtcdPipelineInfo
EtcdPipelineInfo is proto that Pachd stores in etcd for each pipeline. It tracks the state of the pipeline, and points to its metadata in PFS (and, by pointing to a PFS commit, de facto tracks the pipeline's version)
Fields
state: i32
reason: String
spec_commit: Option<Commit>
job_counts: HashMap<i32, i32>
auth_token: String
last_job_state: i32
parallelism: u64
parallelism tracks the literal number of workers that this pipeline should run. Unlike PipelineInfo.ParallelismSpec, this accounts for the number of nodes in the k8s cluster if Coefficient parallelism is used (i.e. if Coefficient is 2 and the cluster has 5 nodes, this will be set to 10 by pachd). This allows the worker master to shard work correctly without k8s privileges and without knowing the number of cluster nodes in the Coefficient case.
Implementations
impl EtcdPipelineInfo
[src]
pub fn state(&self) -> PipelineState
[src]
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)
[src]
Sets state
to the provided enum value.
pub fn last_job_state(&self) -> JobState
[src]
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)
[src]
Sets last_job_state
to the provided enum value.
Trait Implementations
impl Clone for EtcdPipelineInfo
[src]
fn clone(&self) -> EtcdPipelineInfo
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for EtcdPipelineInfo
[src]
impl Default for EtcdPipelineInfo
[src]
fn default() -> EtcdPipelineInfo
[src]
impl Message for EtcdPipelineInfo
[src]
fn encode_raw<B>(&self, buf: &mut B) where
B: BufMut,
[src]
B: BufMut,
fn merge_field<B>(
&mut self,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError> where
B: Buf,
[src]
&mut self,
tag: u32,
wire_type: WireType,
buf: &mut B,
ctx: DecodeContext
) -> Result<(), DecodeError> where
B: Buf,
fn encoded_len(&self) -> usize
[src]
fn clear(&mut self)
[src]
fn encode<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
B: BufMut,
[src]
B: BufMut,
fn encode_length_delimited<B>(&self, buf: &mut B) -> Result<(), EncodeError> where
B: BufMut,
[src]
B: BufMut,
fn decode<B>(buf: B) -> Result<Self, DecodeError> where
B: Buf,
Self: Default,
[src]
B: Buf,
Self: Default,
fn decode_length_delimited<B>(buf: B) -> Result<Self, DecodeError> where
B: Buf,
Self: Default,
[src]
B: Buf,
Self: Default,
fn merge<B>(&mut self, buf: B) -> Result<(), DecodeError> where
B: Buf,
[src]
B: Buf,
fn merge_length_delimited<B>(&mut self, buf: B) -> Result<(), DecodeError> where
B: Buf,
[src]
B: Buf,
impl PartialEq<EtcdPipelineInfo> for EtcdPipelineInfo
[src]
fn eq(&self, other: &EtcdPipelineInfo) -> bool
[src]
fn ne(&self, other: &EtcdPipelineInfo) -> bool
[src]
impl StructuralPartialEq for EtcdPipelineInfo
[src]
Auto Trait Implementations
impl RefUnwindSafe for EtcdPipelineInfo
impl Send for EtcdPipelineInfo
impl Sync for EtcdPipelineInfo
impl Unpin for EtcdPipelineInfo
impl UnwindSafe for EtcdPipelineInfo
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T> Instrument for T
[src]
fn instrument(self, span: Span) -> Instrumented<Self>
[src]
fn in_current_span(self) -> Instrumented<Self>
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> IntoRequest<T> for T
[src]
fn into_request(self) -> Request<T>
[src]
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,
type Error = <U as TryFrom<T>>::Error
The type returned in the event of a conversion error.
fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>
[src]
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
V: MultiLane<T>,
fn vzip(self) -> V
impl<T> WithSubscriber for T
[src]
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,
[src]
S: Into<Dispatch>,