Struct BinaryOperatorAggregate 

pub struct BinaryOperatorAggregate { /* private fields */ }

Applies a binary operator to accumulate values.

Created when a state key uses a reducer (e.g., Annotated[list, add_messages]). Supports Overwrite to bypass the reducer.

Implementations

impl BinaryOperatorAggregate

pub fn new(key: impl Into<String>, reducer: ReducerFn) -> Self

Trait Implementations

impl Channel for BinaryOperatorAggregate

fn checkpoint(&self) -> Option<JsonValue>

Return a serializable checkpoint of this channel’s state. Returns None if the channel is empty (MISSING).

fn from_checkpoint(&self, checkpoint: Option<&JsonValue>) -> Box<dyn Channel>

Restore channel state from a checkpoint.

fn update(&self, values: &[JsonValue]) -> Result<bool, ChannelError>

Apply a batch of updates. Returns true if the channel was modified.

fn get(&self) -> Result<JsonValue, ChannelError>

Get the current value. Returns Err(EmptyChannel) if empty.

fn is_available(&self) -> bool

Return true if the channel has a value available.

fn clone_channel(&self) -> Box<dyn Channel>

Clone this channel (for checkpoint restoration).

fn name(&self) -> &str

Return the name/key for this channel.

fn consume(&self) -> bool

Notify that a subscribed task consumed the value. Returns true if the channel was modified.

fn finish(&self) -> bool

Notify that the Pregel run is finishing. Returns true if the channel was modified.