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
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
// SPDX-License-Identifier: MIT
use futures::Stream;
use netlink_packet_core::NetlinkMessage;
use netlink_packet_route::RtnlMessage;
use netlink_proto::{sys::SocketAddr, ConnectionHandle};
use crate::{
AddressHandle, Error, LinkHandle, NeighbourHandle, QDiscHandle,
RouteHandle, RuleHandle, TrafficChainHandle, TrafficClassHandle,
TrafficFilterHandle,
};
#[derive(Clone, Debug)]
pub struct Handle(ConnectionHandle<RtnlMessage>);
impl Handle {
pub(crate) fn new(conn: ConnectionHandle<RtnlMessage>) -> Self {
Handle(conn)
}
pub fn request(
&mut self,
message: NetlinkMessage<RtnlMessage>,
) -> Result<impl Stream<Item = NetlinkMessage<RtnlMessage>>, Error> {
self.0
.request(message, SocketAddr::new(0, 0))
.map_err(|_| Error::RequestFailed)
}
pub fn notify(
&mut self,
msg: NetlinkMessage<RtnlMessage>,
) -> Result<(), Error> {
self.0
.notify(msg, SocketAddr::new(0, 0))
.map_err(|_| Error::RequestFailed)?;
Ok(())
}
/// Create a new handle, specifically for link requests (equivalent to `ip
/// link` commands)
pub fn link(&self) -> LinkHandle {
LinkHandle::new(self.clone())
}
/// Create a new handle, specifically for address requests (equivalent to
/// `ip addr` commands)
pub fn address(&self) -> AddressHandle {
AddressHandle::new(self.clone())
}
/// Create a new handle, specifically for routing table requests (equivalent
/// to `ip route` commands)
pub fn route(&self) -> RouteHandle {
RouteHandle::new(self.clone())
}
/// Create a new handle, specifically for routing rule requests (equivalent
/// to `ip rule` commands)
pub fn rule(&self) -> RuleHandle {
RuleHandle::new(self.clone())
}
/// Create a new handle, specifically for routing neighbours requests
/// (equivalent to `ip neighbour` commands)
pub fn neighbours(&self) -> NeighbourHandle {
NeighbourHandle::new(self.clone())
}
/// Create a new handle, specifically for traffic control qdisc requests
/// (equivalent to `tc qdisc show` commands)
pub fn qdisc(&self) -> QDiscHandle {
QDiscHandle::new(self.clone())
}
/// Create a new handle, specifically for traffic control class requests
/// (equivalent to `tc class show dev <interface_name>` commands)
pub fn traffic_class(&self, ifindex: i32) -> TrafficClassHandle {
TrafficClassHandle::new(self.clone(), ifindex)
}
/// Create a new handle, specifically for traffic control filter requests
/// (equivalent to `tc filter show dev <interface_name>` commands)
pub fn traffic_filter(&self, ifindex: i32) -> TrafficFilterHandle {
TrafficFilterHandle::new(self.clone(), ifindex)
}
/// Create a new handle, specifically for traffic control chain requests
/// (equivalent to `tc chain show dev <interface_name>` commands)
pub fn traffic_chain(&self, ifindex: i32) -> TrafficChainHandle {
TrafficChainHandle::new(self.clone(), ifindex)
}
}