Trait CheckpointDataBroadcaster

pub trait CheckpointDataBroadcaster {
    // Required method
    fn send(&self, data: &CheckpointData) -> Result<()>;
}

Trait for broadcasting checkpoint data

Required Methods

fn send(&self, data: &CheckpointData) -> Result<()>

Implementations on Foreign Types

impl CheckpointDataBroadcaster for ()

No-op implementation for unit type (used in tests and when broadcasting is disabled)

fn send(&self, _data: &CheckpointData) -> Result<()>

impl CheckpointDataBroadcaster for Sender<Arc<CheckpointData>>

Implementation for tokio broadcast sender

fn send(&self, data: &CheckpointData) -> Result<()>

Implementors

impl CheckpointDataBroadcaster for GrpcCheckpointDataBroadcaster