Struct pachyderm::pps::ParallelismSpec

pub struct ParallelismSpec {
    pub constant: u64,
    pub coefficient: f64,
}

Fields

constant: u64

Starts the pipeline/job with a 'constant' workers, unless 'constant' is zero. If 'constant' is zero (which is the zero value of ParallelismSpec), then Pachyderm will choose the number of workers that is started, (currently it chooses the number of workers in the cluster)

coefficient: f64

Starts the pipeline/job with number of workers equal to 'coefficient' * N, where N is the number of nodes in the kubernetes cluster.

For example, if each Kubernetes node has four CPUs, you might set 'coefficient' to four, so that there are four Pachyderm workers per Kubernetes node, and each Pachyderm worker gets one CPU. If you want to reserve half the nodes in your cluster for other tasks, you might set 'coefficient' to 0.5.

Trait Implementations

impl Clone for ParallelismSpec

fn clone(&self) -> ParallelismSpec

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ParallelismSpec

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

Formats the value using the given formatter.

impl Default for ParallelismSpec

fn default() -> ParallelismSpec

Returns the "default value" for a type.

impl Message for ParallelismSpec

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

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

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

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

This method tests for !=.

impl StructuralPartialEq for ParallelismSpec