Struct ClusterPlotter 

pub struct ClusterPlotter { /* private fields */ }

Cluster plotter

Implementations

impl ClusterPlotter

pub fn new( nats_client: NatsClient, sector_encoding_concurrency: NonZeroUsize, retry_backoff_policy: ExponentialBackoff, ) -> Self

Create a new instance

pub fn on_plotting_progress( &self, callback: HandlerFn3<Ed25519PublicKey, SectorIndex, SectorPlottingProgress>, ) -> HandlerId

Subscribe to plotting progress notifications

Trait Implementations

impl Debug for ClusterPlotter

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

Formats the value using the given formatter.

impl Drop for ClusterPlotter

fn drop(&mut self)

Executes the destructor for this type.

impl Plotter for ClusterPlotter

fn has_free_capacity<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<bool, String>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Whether plotter has free capacity to encode more sectors

fn plot_sector<'life0, 'async_trait>( &'life0 self, public_key: Ed25519PublicKey, sector_index: SectorIndex, farmer_protocol_info: FarmerProtocolInfo, pieces_in_sector: u16, _replotting: bool, progress_sender: Sender<SectorPlottingProgress>, ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Plot one sector, sending sector plotting events via the provided stream.

fn try_plot_sector<'life0, 'async_trait>( &'life0 self, public_key: Ed25519PublicKey, sector_index: SectorIndex, farmer_protocol_info: FarmerProtocolInfo, pieces_in_sector: u16, _replotting: bool, progress_sender: Sender<SectorPlottingProgress>, ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Try to plot one sector, sending sector plotting events via the provided stream.