diff options
| author | tv <tv@krebsco.de> | 2026-10-26 21:48:54 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-26 21:48:54 +0100 |
| commit | ecdb3ee944f5c171faac3a71117e2ff27e064295 (patch) | |
| tree | a8e35f4dec4de93c7d53416da43fc4f9a3a381ed /src/transport/firewall.rs | |
| parent | 7135c860db4169bfc9a06838cf637350ef68c0c0 (diff) | |
turn all pub into pub(crate)
Diffstat (limited to 'src/transport/firewall.rs')
| -rw-r--r-- | src/transport/firewall.rs | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/transport/firewall.rs b/src/transport/firewall.rs index 037e739..2cc1dba 100644 --- a/src/transport/firewall.rs +++ b/src/transport/firewall.rs @@ -10,18 +10,18 @@ use crate::transport::EncodedMessage; use crate::transport::{MessageHandler, ParsedMessage, Transport}; #[derive(Debug, Clone, Default, Serialize, Deserialize)] -pub struct FirewallRules { +pub(crate) struct FirewallRules { /// Messages from these peers are dropped before the application sees them. #[serde(default)] - pub inbound: HashSet<String>, + pub(crate) inbound: HashSet<String>, /// Messages to these peers are silently dropped, like a lossy network. #[serde(default)] - pub outbound: HashSet<String>, + pub(crate) outbound: HashSet<String>, } /// Uses a std lock: checks are tiny and the guard is never held across an await. #[derive(Default)] -pub struct Firewall { +pub(crate) struct Firewall { rules: RwLock<FirewallRules>, } @@ -30,30 +30,30 @@ impl Firewall { self.rules.read_or_recover() } - pub fn rules(&self) -> FirewallRules { + pub(crate) fn rules(&self) -> FirewallRules { self.read().clone() } - pub fn set_rules(&self, rules: FirewallRules) { + pub(crate) fn set_rules(&self, rules: FirewallRules) { *self.rules.write_or_recover() = rules; } - pub fn blocks_inbound(&self, peer: &str) -> bool { + pub(crate) fn blocks_inbound(&self, peer: &str) -> bool { self.read().inbound.contains(peer) } - pub fn blocks_outbound(&self, peer: &str) -> bool { + pub(crate) fn blocks_outbound(&self, peer: &str) -> bool { self.read().outbound.contains(peer) } } -pub struct FirewallTransport { +pub(crate) struct FirewallTransport { inner: Arc<dyn Transport>, firewall: Arc<Firewall>, } impl FirewallTransport { - pub fn new(inner: Arc<dyn Transport>, firewall: Arc<Firewall>) -> Self { + pub(crate) fn new(inner: Arc<dyn Transport>, firewall: Arc<Firewall>) -> Self { Self { inner, firewall } } } |
