Struct FetchStateSummary

pub struct FetchStateSummary {
    pub pending_requests: HashMap<OpId, Vec<Url>>,
    pub peers_on_backoff: HashMap<Url, Timestamp>,
}

Summary of the fetch state.

Fields

pending_requests: HashMap<OpId, Vec<Url>>

The op ids that are currently being fetched.

Each op id is associated with one or more peer URL from which the op data could be requested.

peers_on_backoff: HashMap<Url, Timestamp>

The peer URL for nodes that are currently on backoff because of failed fetch requests, and the timestamp when that backoff will expire.

If peers are in here then they are not being used as potential sources in FetchStateSummary::pending_requests.

Trait Implementations

impl Clone for FetchStateSummary

fn clone(&self) -> FetchStateSummary

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for FetchStateSummary

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for FetchStateSummary

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for FetchStateSummary

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

where __S: Serializer,

Serialize this value into the given Serde serializer.