Trait subspace_farmer::farm::Farm

pub trait Farm {
    // Required methods
    fn id(&self) -> &FarmId;
    fn total_sectors_count(&self) -> SectorIndex;
    fn plotted_sectors(&self) -> Arc<dyn PlottedSectors + 'static>;
    fn piece_reader(&self) -> Arc<dyn PieceReader + 'static>;
    fn on_sector_update(
        &self,
        callback: HandlerFn<(SectorIndex, SectorUpdate)>,
    ) -> Box<dyn HandlerId>;
    fn on_farming_notification(
        &self,
        callback: HandlerFn<FarmingNotification>,
    ) -> Box<dyn HandlerId>;
    fn on_solution(
        &self,
        callback: HandlerFn<SolutionResponse>,
    ) -> Box<dyn HandlerId>;
    fn run(self: Box<Self>) -> Pin<Box<dyn Future<Output = Result<()>> + Send>>;
}

Abstract farm implementation

Required Methods

fn id(&self) -> &FarmId

ID of this farm

fn total_sectors_count(&self) -> SectorIndex

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

Implementations on Foreign Types

impl<T> Farm for Box<T>

where T: Farm + ?Sized,

fn id(&self) -> &FarmId

fn total_sectors_count(&self) -> SectorIndex

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

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

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

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

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

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

Implementors

impl Farm for ClusterFarm

impl Farm for SingleDiskFarm