summaryrefslogtreecommitdiffstats
path: root/src/transport/firewall.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-26 21:48:54 +0100
committertv <tv@krebsco.de>2026-10-26 21:48:54 +0100
commitecdb3ee944f5c171faac3a71117e2ff27e064295 (patch)
treea8e35f4dec4de93c7d53416da43fc4f9a3a381ed /src/transport/firewall.rs
parent7135c860db4169bfc9a06838cf637350ef68c0c0 (diff)
turn all pub into pub(crate)
Diffstat (limited to 'src/transport/firewall.rs')
-rw-r--r--src/transport/firewall.rs20
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 }
}
}