web-faith 1.0.1

A browser-shaped HTTP client
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

//! Request counters.

use std::sync::atomic::{AtomicU64, Ordering};

/// The live counters, shared with every response the agent produces: a body finishing
/// settles two of them.
#[derive(Debug, Default)]
pub(crate) struct InnerAgentStats {
	pub requests_sent: AtomicU64,
	pub responses_received: AtomicU64,
	pub bodies_started: AtomicU64,
	pub bodies_finished: AtomicU64,
}

impl InnerAgentStats {
	pub fn snapshot(&self) -> AgentStats {
		AgentStats {
			requests_sent: self.requests_sent.load(Ordering::Relaxed),
			responses_received: self.responses_received.load(Ordering::Relaxed),
			bodies_started: self.bodies_started.load(Ordering::Relaxed),
			bodies_finished: self.bodies_finished.load(Ordering::Relaxed),
		}
	}
}

/// Statistics gathered by the agent.
///
/// A snapshot taken when [`Agent::stats`](crate::Agent::stats) is called; it does not update live.
#[derive(Debug, Clone, Copy, Default, PartialEq, Eq)]
#[non_exhaustive]
pub struct AgentStats {
	/// Requests that have gone out.
	pub requests_sent: u64,
	/// Responses whose headers have come back.
	pub responses_received: u64,
	/// Response body streams that have been started. Reading a body starts one.
	pub bodies_started: u64,
	/// Response body streams read to the end. The gap against `bodies_started` is how many bodies
	/// are holding a connection open.
	pub bodies_finished: u64,
}