Struct FarmerRpc 

pub struct FarmerRpc<CI, CSS>
where
    CI: ChainInfo<OwnedBeaconChainBlock>,
    CSS: ChainSyncStatus,
{ /* private fields */ }

Implements the FarmerRpcApiServer trait for farmer to connect to

Implementations

impl<CI, CSS> FarmerRpc<CI, CSS>

where CI: ChainInfo<OwnedBeaconChainBlock>, CSS: ChainSyncStatus,

FarmerRpc is used for notifying subscribers about the arrival of new slots and for submission of solutions (or lack thereof).

Internally every time slot notifier emits information about a new slot, a notification is sent to every subscriber, after which the RPC server waits for the same number of submitSolutionResponse requests with SolutionResponse in them or until timeout is exceeded. The first valid solution for a particular slot wins, others are ignored.

pub fn new(config: FarmerRpcConfig<CI, CSS>) -> (Self, FarmerRpcWorker)

Creates a new instance of the FarmerRpc handler.

Trait Implementations

impl<CI, CSS> Debug for FarmerRpc<CI, CSS>

where CI: ChainInfo<OwnedBeaconChainBlock> + Debug, CSS: ChainSyncStatus + Debug,

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

Formats the value using the given formatter.

impl<CI, CSS> FarmerRpcApiServer for FarmerRpc<CI, CSS>

where CI: ChainInfo<OwnedBeaconChainBlock>, CSS: ChainSyncStatus,

fn get_farmer_app_info(&self) -> Result<FarmerAppInfo, Error>

Get metadata necessary for farmer operation

fn submit_solution_response( &self, solution_response: SolutionResponse, ) -> Result<(), Error>

fn subscribe_slot_info<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

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

Slot info subscription

fn subscribe_block_seal<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

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

Sign block subscription

fn submit_block_seal(&self, block_seal: BlockSealResponse) -> Result<(), Error>

fn subscribe_archived_segment_header<'life0, 'async_trait>( &'life0 self, pending: PendingSubscriptionSink, ) -> Pin<Box<dyn Future<Output = SubscriptionResult> + Send + 'async_trait>>

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

Archived segment header subscription

fn acknowledge_archived_segment_header<'life0, 'async_trait>( &'life0 self, segment_index: SegmentIndex, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

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

fn piece( &self, requested_piece_index: PieceIndex, ) -> Result<Option<Piece>, Error>

fn segment_headers<'life0, 'async_trait>( &'life0 self, segment_indices: Vec<SegmentIndex>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Option<SegmentHeader>>, Error>> + Send + 'async_trait>>

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

fn last_segment_headers<'life0, 'async_trait>( &'life0 self, limit: u32, ) -> Pin<Box<dyn Future<Output = Result<Vec<Option<SegmentHeader>>, Error>> + Send + 'async_trait>>

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

fn into_rpc(self) -> RpcModule<Self>

Collects all the methods and subscriptions defined in the trait and adds them into a single RpcModule.