Enum Op 

pub enum Op {
    Ingress,
    Presence,
    Decide {
        validate: Core,
    },
    Fold {
        step: Core,
        init: Core,
    },
    Durable,
    Map {
        f: Core,
    },
    Map2 {
        f: Core,
    },
    PerSession {
        f: Core,
    },
    FilterMap {
        f: Core,
    },
    Alias,
}

What a vertex does. One variant per construct in §3.7’s signal vocabulary.

Variants

Ingress

merge_clients() — the one place time and nondeterminism enter.

Presence

presence() — who is connected now.

A source like Op::Ingress and a Signal rather than a Stream: connections are a value defined at all times, not occurrences. It is the only vertex here that is neither the log nor derived from it, which is the one fact everything else about it follows from — see crate::split for what that forbids and crate::plan for what it costs.

Decide

decide(proposals, state, validate) — §3.5’s authority chokepoint, as a node.

Fields

validate: Core

Fold

fold(step, init, stream). The accumulator, and the point at which a cycle bottoms out.

Fields

step: Core

init: Core

Durable

durable(signal) — the accumulator that survives a restart, and therefore the one the log is of.

Map

signal_map(s, f).

Fields

f: Core

Map2

map2(f, a, b).

Fields

f: Core

PerSession

per_session(s, f) — §3.8’s fanout point, first-class so that Phase 3 can share the arrangement above it.

Fields

f: Core

FilterMap

filter_map(s, f) on a stream.

Fields

f: Core

Alias

A signal declared as another signal: mirror: Signal[T] = todos.

Implementations

impl Op

pub fn name(&self) -> &'static str

pub fn is_stream(&self) -> bool

Whether this vertex carries a Stream rather than a Signal — occurrences rather than a value defined at all times (§3.7). A view is a function of signals, so a stream vertex on a view’s path is an error rather than a missing feature.

Trait Implementations

impl Clone for Op

fn clone(&self) -> Op

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Op

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

Formats the value using the given formatter.