Enum garage_block::manager::BlockRpc

pub enum BlockRpc {
    Ok,
    GetBlock(Hash, Option<OrderTag>),
    PutBlock {
        hash: Hash,
        header: DataBlockHeader,
    },
    NeedBlockQuery(Hash),
    NeedBlockReply(bool),
}

RPC messages used to share blocks of data between nodes

Variants

Ok

GetBlock(Hash, Option<OrderTag>)

Message to ask for a block of data, by hash

PutBlock

Message to send a block of data, either because requested, of for first delivery of new block

Fields

hash: Hash

header: DataBlockHeader

NeedBlockQuery(Hash)

Ask other node if they should have this block, but don’t actually have it

NeedBlockReply(bool)

Response : whether the node do require that block

Trait Implementations

impl Debug for BlockRpc

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for BlockRpc

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Message for BlockRpc

type Response = Result<BlockRpc, Error>

The type of the response that is sent in response to this message

impl Serialize for BlockRpc

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StreamingEndpointHandler<BlockRpc> for BlockManager

fn handle<'life0, 'async_trait>( self: &'life0 Arc<Self>, message: Req<BlockRpc>, _from: NodeID ) -> Pin<Box<dyn Future<Output = Resp<BlockRpc>> + Send + 'async_trait>>

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