Struct PregelNode 

pub struct PregelNode<S: State> {
    pub name: String,
    pub channels: Vec<String>,
    pub triggers: Vec<String>,
    pub bound: NodeArc<S>,
    pub writers: Vec<ChannelWrite>,
}

A node in the Pregel execution engine.

PregelNode wraps a user’s node with metadata about which channels it reads from and writes to, and what triggers it.

Fields

name: String

The name of this node

channels: Vec<String>

The channels this node reads from

triggers: Vec<String>

The channels that trigger this node when written to

bound: NodeArc<S>

The actual node computation

writers: Vec<ChannelWrite>

The channels this node writes to

Implementations

impl<S: State> PregelNode<S>

pub fn new( name: impl Into<String>, channels: Vec<String>, triggers: Vec<String>, bound: NodeArc<S>, writers: Vec<ChannelWrite>, ) -> Self

Create a new PregelNode

pub fn from_node( name: impl Into<String>, channels: Vec<String>, triggers: Vec<String>, bound: impl Node<S> + 'static, writers: Vec<ChannelWrite>, ) -> Self

Create a PregelNode from a concrete node implementation

pub fn is_triggered(&self, written_channels: &[String]) -> bool

Check if this node is triggered by the given channel writes

Trait Implementations

impl<S: Clone + State> Clone for PregelNode<S>

fn clone(&self) -> PregelNode<S>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<S: State> Debug for PregelNode<S>

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

Formats the value using the given formatter.