[−][src]Enum pachyderm::pps::PipelineState
Variants
There is an EtcdPipelineInfo + spec commit, but no RC This happens when a pipeline has been created but not yet picked up by a PPS server.
A pipeline has a spec commit and a service + RC This is the normal state of a pipeline.
Equivalent to STARTING (there is an EtcdPipelineInfo + commit, but no RC) After some error caused runPipeline to exit, but before the pipeline is re-run. This is when the exponential backoff is in effect.
The pipeline has encountered unrecoverable errors and is no longer being retried. It won't leave this state until the pipeline is updated.
The pipeline has been explicitly paused by the user (the pipeline spec's Stopped field should be true if the pipeline is in this state)
The pipeline is fully functional, but there are no commits to process.
The pipeline's workers are crashing, or failing to come up, this may resolve itself, the pipeline may make progress while in this state if the problem is only being experienced by some workers.
Implementations
impl PipelineState
[src]
pub fn is_valid(value: i32) -> bool
[src]
Returns true
if value
is a variant of PipelineState
.
pub fn from_i32(value: i32) -> Option<PipelineState>
[src]
Converts an i32
to a PipelineState
, or None
if value
is not a valid variant.
Trait Implementations
impl Clone for PipelineState
[src]
fn clone(&self) -> PipelineState
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Copy for PipelineState
[src]
impl Debug for PipelineState
[src]
impl Default for PipelineState
[src]
fn default() -> PipelineState
[src]
impl Eq for PipelineState
[src]
impl From<PipelineState> for i32
[src]
fn from(value: PipelineState) -> i32
[src]
impl Hash for PipelineState
[src]
fn hash<__H: Hasher>(&self, state: &mut __H)
[src]
fn hash_slice<H>(data: &[Self], state: &mut H) where
H: Hasher,
1.3.0[src]
H: Hasher,
impl Ord for PipelineState
[src]
fn cmp(&self, other: &PipelineState) -> Ordering
[src]
#[must_use]fn max(self, other: Self) -> Self
1.21.0[src]
#[must_use]fn min(self, other: Self) -> Self
1.21.0[src]
#[must_use]fn clamp(self, min: Self, max: Self) -> Self
[src]
impl PartialEq<PipelineState> for PipelineState
[src]
fn eq(&self, other: &PipelineState) -> bool
[src]
#[must_use]fn ne(&self, other: &Rhs) -> bool
1.0.0[src]
impl PartialOrd<PipelineState> for PipelineState
[src]
fn partial_cmp(&self, other: &PipelineState) -> Option<Ordering>
[src]
#[must_use]fn lt(&self, other: &Rhs) -> bool
1.0.0[src]
#[must_use]fn le(&self, other: &Rhs) -> bool
1.0.0[src]
#[must_use]fn gt(&self, other: &Rhs) -> bool
1.0.0[src]
#[must_use]fn ge(&self, other: &Rhs) -> bool
1.0.0[src]
impl StructuralEq for PipelineState
[src]
impl StructuralPartialEq for PipelineState
[src]
Auto Trait Implementations
impl RefUnwindSafe for PipelineState
impl Send for PipelineState
impl Sync for PipelineState
impl Unpin for PipelineState
impl UnwindSafe for PipelineState
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<Q, K> Equivalent<K> for Q where
K: Borrow<Q> + ?Sized,
Q: Eq + ?Sized,
[src]
K: Borrow<Q> + ?Sized,
Q: Eq + ?Sized,
fn equivalent(&self, key: &K) -> bool
[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>,