Struct kitsune_p2p::gossip::sharded_gossip::MissingOps

pub struct MissingOps {
    pub ops: Vec<(Arc<KitsuneOpHash>, Vec<u8>)>,
    pub finished: u8,
}

Any ops that were missing from the remote bloom.

Fields

ops: Vec<(Arc<KitsuneOpHash>, Vec<u8>)>

The missing ops

finished: u8

Ops that are missing from a bloom that you have sent. These will be chunked into a maximum size of about 16MB. If the amount of missing ops is larger then the [ShardedGossipLocal::UPPER_BATCH_BOUND] then the set of missing ops chunks will be sent in batches. Each batch will require a reply message of OpsBatchReceived in order to get the next batch. This is to prevent overloading the receiver with too much incoming data.

0: There is more chunks in this batch to come. No reply is needed. 1: This chunk is done but there is more batches to come and you should reply with OpsBatchReceived when you are ready to get the next batch. 2: This is the final missing ops and there are no more ops to come. No reply is needed.

See MissingOpsStatus

Trait Implementations

impl Clone for MissingOps

fn clone(&self) -> MissingOps

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Codec for MissingOps

fn variant_type(&self) -> &'static str

Variant identifier (for debugging or as a cheap discriminant).

fn encode<W>(&self, w: &mut W) -> Result<()> where
    W: Write, 

Encode this item to given writer. You may wish to first wrap your writer in a BufWriter.

fn decode<R>(r: &mut R) -> Result<Self> where
    R: Read, 

Decode a reader into this item. You may wish to first wrap your reader in a BufReader.

fn encode_vec(&self) -> Result<Vec<u8, Global>, Error>

Encode this item to an owned vector of bytes. Uses encode() internally.

fn decode_ref(r: &[u8]) -> Result<(u64, Self), Error>

Decode a range of bytes into this item. Will also return the byte count read. Uses decode() internally.

impl Debug for MissingOps

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MissingOps

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.

impl PartialEq<MissingOps> for MissingOps

fn eq(&self, other: &MissingOps) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &MissingOps) -> bool

This method tests for !=.

impl Serialize for MissingOps

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

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for MissingOps