Struct jormungandr_automation::jormungandr::grpc::server::JormungandrServerImpl

pub struct JormungandrServerImpl {
    data: Arc<RwLock<MockServerData>>,
}

Fields

data: Arc<RwLock<MockServerData>>

Implementations

impl JormungandrServerImpl

pub fn new(data: Arc<RwLock<MockServerData>>) -> Self

Trait Implementations

impl Node for JormungandrServerImpl

type PullBlocksStream = ReceiverStream<Result<Block, Status>>

Server streaming response type for the PullBlocks method.

type PullBlocksToTipStream = ReceiverStream<Result<Block, Status>>

Server streaming response type for the PullBlocksToTip method.

type GetBlocksStream = ReceiverStream<Result<Block, Status>>

Server streaming response type for the GetBlocks method.

type PullHeadersStream = ReceiverStream<Result<Header, Status>>

Server streaming response type for the PullHeaders method.

type GetHeadersStream = ReceiverStream<Result<Header, Status>>

Server streaming response type for the GetHeaders method.

type GetFragmentsStream = ReceiverStream<Result<Fragment, Status>>

Server streaming response type for the GetFragments method.

type BlockSubscriptionStream = ReceiverStream<Result<BlockEvent, Status>>

Server streaming response type for the BlockSubscription method.

type FragmentSubscriptionStream = ReceiverStream<Result<Fragment, Status>>

Server streaming response type for the FragmentSubscription method.

type GossipSubscriptionStream = ReceiverStream<Result<Gossip, Status>>

Server streaming response type for the GossipSubscription method.

fn handshake<'life0, 'async_trait>( &'life0 self, request: Request<HandshakeRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<HandshakeResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Initial handshake and authentication of the server node.

fn client_auth<'life0, 'async_trait>( &'life0 self, request: Request<ClientAuthRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<ClientAuthResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Optional authentication of the client node. Called after Handshake.

fn tip<'life0, 'async_trait>( &'life0 self, _request: Request<TipRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<TipResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn peers<'life0, 'async_trait>( &'life0 self, _request: Request<PeersRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<PeersResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Requests for some peers

fn get_blocks<'life0, 'async_trait>( &'life0 self, request: Request<BlockIds> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::GetBlocksStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn get_headers<'life0, 'async_trait>( &'life0 self, _request: Request<BlockIds> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::GetHeadersStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn get_fragments<'life0, 'async_trait>( &'life0 self, _request: Request<FragmentIds> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::GetFragmentsStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn pull_headers<'life0, 'async_trait>( &'life0 self, _request: Request<PullHeadersRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::PullHeadersStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Requests headers of blocks in the chain in the chronological order, given a selection of possible starting blocks known by the requester, and the identifier of the end block to be included in the returned sequence.

fn pull_blocks<'life0, 'async_trait>( &'life0 self, request: Request<PullBlocksRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::PullBlocksStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Requests blocks in the chain in the chronological order, given a selection of possible starting blocks known by the requester, and the identifier of the end block to be included in the returned sequence.

fn pull_blocks_to_tip<'life0, 'async_trait>( &'life0 self, _request: Request<PullBlocksToTipRequest> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::PullBlocksToTipStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

fn push_headers<'life0, 'async_trait>( &'life0 self, _request: Request<Streaming<Header>> ) -> Pin<Box<dyn Future<Output = Result<Response<PushHeadersResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Sends headers of blocks to the service in response to a missing item received from the BlockSubscription response stream. The headers are streamed the in chronological order of the chain.

fn upload_blocks<'life0, 'async_trait>( &'life0 self, _request: Request<Streaming<Block>> ) -> Pin<Box<dyn Future<Output = Result<Response<UploadBlocksResponse>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Uploads blocks to the service in response to a solicit item received from the BlockSubscription response stream.

fn block_subscription<'life0, 'async_trait>( &'life0 self, _request: Request<Streaming<Header>> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::BlockSubscriptionStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Establishes a bidirectional stream to exchange information on new blocks created or accepted by the peers.

fn fragment_subscription<'life0, 'async_trait>( &'life0 self, _request: Request<Streaming<Fragment>> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::FragmentSubscriptionStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Establishes a bidirectional stream to exchange information on new block fragments created or accepted by the peers.

fn gossip_subscription<'life0, 'async_trait>( &'life0 self, _request: Request<Streaming<Gossip>> ) -> Pin<Box<dyn Future<Output = Result<Response<Self::GossipSubscriptionStream>, Status>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Establishes a bidirectional stream to exchange information on new network peers.