Struct Fanout 

pub struct Fanout { /* private fields */ }

Sends an incoming EventBatch to multiple downstream receivers. Because EventBatch contains Arcs internally (like RecordBatch and ArcEventMetadata), cloning it is very cheap and does not duplicate the underlying columnar data.

Implementations

impl Fanout

pub fn new() -> Self

Create a new empty Fanout.

pub fn add_sender(&self, sender: BufferSender)

Add a new downstream destination.

pub fn replace_senders(&self, new_senders: Vec<BufferSender>)

Replace all existing downstream destinations with a new set.

pub fn is_empty(&self) -> bool

Is the fanout empty?

pub fn get_senders(&self) -> Vec<BufferSender>

Returns a copy of the current list of downstream senders.

pub fn clone_to_sender(&self, component_id: String) -> BufferSender

Creates a BufferSender that feeds into this Fanout. This spawns a background task to relay batches from the channel to the fanout.

pub async fn send(&self, batch: EventBatch)

Sends a batch to all downstream consumers.

Trait Implementations

impl Clone for Fanout

fn clone(&self) -> Fanout

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Fanout

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

Formats the value using the given formatter.

impl Default for Fanout

fn default() -> Fanout

Returns the “default value” for a type.