Struct RpcNodeClient 

pub struct RpcNodeClient { /* private fields */ }

Node client implementation that connects to node via RPC (WebSockets).

This implementation is supposed to be used on local network and not via public Internet due to sensitive contents.

Implementations

impl RpcNodeClient

pub async fn new(url: &str) -> Result<Self, JsonError>

Create a new instance of NodeClient.

Trait Implementations

impl Clone for RpcNodeClient

fn clone(&self) -> RpcNodeClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RpcNodeClient

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

Formats the value using the given formatter.

impl NodeClient for RpcNodeClient

fn submit_block_seal<'life0, 'async_trait>( &'life0 self, block_seal: BlockSealResponse, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Submit a block seal

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

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

Get farmer app info

fn subscribe_slot_info<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = SlotInfo> + Send + 'static>>>> + Send + 'async_trait>>

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

Subscribe to slot

fn submit_solution_response<'life0, 'async_trait>( &'life0 self, solution_response: SolutionResponse, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Submit a slot solution

fn subscribe_block_sealing<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = BlockSealInfo> + Send + 'static>>>> + Send + 'async_trait>>

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

Subscribe to block sealing requests

fn subscribe_archived_segment_headers<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = SegmentHeader> + Send + 'static>>>> + Send + 'async_trait>>

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

Subscribe to archived segment headers

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

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

Get segment headers for the segments

fn piece<'life0, 'async_trait>( &'life0 self, piece_index: PieceIndex, ) -> Pin<Box<dyn Future<Output = Result<Option<Piece>>> + Send + 'async_trait>>

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

Get piece by index.

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

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

Acknowledge segment header.

impl NodeClientExt for RpcNodeClient

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

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

Get the cached segment headers for the given segment indices. If there is a cache, it is not updated, to avoid remote denial of service.

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

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

Get up to limit most recent segment headers. If there is a cache, it is not updated, to avoid remote denial of service.