[−][src]Struct pachyderm::pps::EtcdJobInfo
EtcdJobInfo is the portion of the JobInfo that gets stored in etcd during job execution. It contains fields which change over the lifetime of the job but aren't used in the execution of the job.
Fields
job: Option<Job>
pipeline: Option<Pipeline>
output_commit: Option<Commit>
restart: u64
Job restart count (e.g. due to datum failure)
data_processed: i64
Counts of how many times we processed or skipped a datum
data_skipped: i64
data_total: i64
data_failed: i64
data_recovered: i64
stats: Option<ProcessStats>
Download/process/upload time and download/upload bytes
stats_commit: Option<Commit>
state: i32
reason: String
started: Option<Timestamp>
finished: Option<Timestamp>
Implementations
impl EtcdJobInfo
[src]
pub fn state(&self) -> JobState
[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: JobState)
[src]
Sets state
to the provided enum value.
Trait Implementations
impl Clone for EtcdJobInfo
[src]
fn clone(&self) -> EtcdJobInfo
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for EtcdJobInfo
[src]
impl Default for EtcdJobInfo
[src]
fn default() -> EtcdJobInfo
[src]
impl Message for EtcdJobInfo
[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<EtcdJobInfo> for EtcdJobInfo
[src]
fn eq(&self, other: &EtcdJobInfo) -> bool
[src]
fn ne(&self, other: &EtcdJobInfo) -> bool
[src]
impl StructuralPartialEq for EtcdJobInfo
[src]
Auto Trait Implementations
impl RefUnwindSafe for EtcdJobInfo
impl Send for EtcdJobInfo
impl Sync for EtcdJobInfo
impl Unpin for EtcdJobInfo
impl UnwindSafe for EtcdJobInfo
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>,