Struct ClusterFarm 

pub struct ClusterFarm { /* private fields */ }

Cluster farm implementation

Implementations

impl ClusterFarm

pub async fn new( farm_id: FarmId, total_sectors_count: u16, nats_client: NatsClient, ) -> Result<Self>

Create a new instance using information from previously received ClusterFarmerIdentifyBroadcast

pub async fn run(self) -> Result<()>

Run and wait for background tasks to exit or return an error

Trait Implementations

impl Debug for ClusterFarm

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

Formats the value using the given formatter.

impl Farm for ClusterFarm

fn id(&self) -> &FarmId

ID of this farm

fn total_sectors_count(&self) -> u16

Number of sectors in this farm

fn plotted_sectors(&self) -> Arc<dyn PlottedSectors + 'static>

Get plotted sectors instance

fn piece_reader(&self) -> Arc<dyn PieceReader + 'static>

Get piece reader to read plotted pieces later

fn on_sector_update( &self, callback: HandlerFn<(SectorIndex, SectorUpdate)>, ) -> Box<dyn HandlerId>

Subscribe to sector updates

fn on_farming_notification( &self, callback: HandlerFn<FarmingNotification>, ) -> Box<dyn HandlerId>

Subscribe to farming notifications

fn on_solution( &self, callback: HandlerFn<SolutionResponse>, ) -> Box<dyn HandlerId>

Subscribe to new solution notification

fn run(self: Box<Self>) -> Pin<Box<dyn Future<Output = Result<()>> + Send>>

Run and wait for background threads to exit or return an error