Enum Join 

pub enum Join {
    WaitForAll {},
    Quorum {
        count: usize,
    },
    FirstSuccess {},
}

What it takes for a wave to count as finished.

The default waits for every node, which is the only correct answer when later waves read every output. The other two exist for the fan-out shape the reference calls out: several nodes attacking the same question, where the run does not need all the answers to proceed.

Variants

WaitForAll

Every node in the wave must finish.

Quorum

Proceed once this many nodes have finished successfully. Nodes still running are left to finish; their output is used if it arrives in time.

Fields

count: usize

FirstSuccess

Proceed as soon as any one node succeeds.

Implementations

impl Join

pub fn required_successes(self, wave_width: usize) -> usize

How many successes release the wave, given its width.

Trait Implementations

impl Clone for Join

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Join

impl Debug for Join

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

Formats the value using the given formatter.

impl Default for Join

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Join

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Eq for Join

impl JsonSchema for Join

fn schema_name() -> String

The name of the generated JSON Schema.

fn schema_id() -> Cow<'static, str>

Returns a string that uniquely identifies the schema produced by this type.

fn json_schema(generator: &mut SchemaGenerator) -> Schema

Generates a JSON Schema for this type.

fn is_referenceable() -> bool

Whether JSON Schemas generated for this type should be re-used where possible using the $ref keyword.

impl PartialEq for Join

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

Equality operator ==.

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

Inequality operator !=.

impl Serialize for Join

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Join