Merge pull request #121 from LorenzoTettamanti/identity_enhancements

Identity service improvements (pt.1)

Author: LorenzoTettamanti

core/Cargo.lock

@@ -26,9 +26,9 @@ tracing = "0.1.40"
 futures = "0.3.31"
 anyhow = "1.0.93"
 schemas = "0.4.0"
-yaml-rust2 = "0.9.0"
-kube = { version = "0.96.0", features = ["runtime", "derive", "ws"] }
-k8s-openapi = { version = "0.23.0", features = ["latest"] }
+yaml-rust2 = "0.10.3"
+kube = { version = "1.1.0", features = ["runtime", "derive", "ws"] }
+k8s-openapi = { version = "0.25.0", features = ["latest"] }
 serde_json = "1.0.133"
 tokio-util = { version = "0.7.8", features = ["io"] }
 tokio-stream = { version = "0.1.9", features = ["net"] }
@@ -38,19 +38,19 @@ hyper-util = "0.1.10"
 tower = "0.5.1"
 ipnet = "2.10.1"
 iptables = "0.5.2"
-itertools = "0.13.0"
+itertools = "0.14.0"
 libc = "0.2.164"
 libloading = "0.8.5"
-libp2p = "0.54.1"
+libp2p = "0.56.0"
 serde_yaml = "0.9.34"
 pnet = "0.35.0"
 bytes = "1.9.0"
-prost = "0.13.4"
+prost = "0.14.1"
 trust-dns-server = "0.23.2"
 dirs = "6.0.0"
 
 [dev-dependencies]
 wiremock = "0.6.0"
 
 [build-dependencies]
-prost-build = "0.13.4"
+prost-build = "0.14.1"

core/Cargo.toml

@@ -11,9 +11,9 @@ tracing = "0.1.40"
 futures = "0.3.31"
 anyhow = "1.0.93"
 schemas = "0.4.0"
-yaml-rust2 = "0.9.0"
-kube = { version = "0.98.0", features = ["runtime", "derive", "ws"]}
-k8s-openapi = { version = "0.24.0", features = ["latest"] }
+yaml-rust2 = "0.10.3"
+kube = { version = "1.1.0", features = ["runtime", "derive", "ws"]}
+k8s-openapi = { version = "0.25.0", features = ["latest"] }
 serde_json = "1.0.133"
 tokio-util = { version = "0.7.8", features = ["io"] }
 tokio-stream = { version = "0.1.9", features = ["net"] }
@@ -23,15 +23,15 @@ hyper-util = "0.1.10"
 tower = "0.5.1"
 ipnet = "2.10.1"
 iptables = "0.5.2"
-itertools = "0.13.0"
+itertools = "0.14.0"
 libc = "0.2.164"
 libloading = "0.8.5"
-libp2p = "0.54.1"
+libp2p = "0.56.0"
 serde_yaml = "0.9.34"
 pnet = "0.35.0"
 bytes = "1.9.0"
-prost = "0.13.4"
-rdkafka = "0.37.0"
+prost = "0.14.1"
+rdkafka = "0.38.0"
 trust-dns-server = "0.23.2"
 dirs = "6.0.0"
 

core/src/client/Cargo.toml

@@ -7,8 +7,6 @@ edition = "2021"
 [dependencies]
 aya-ebpf = { git = "https://github.com/aya-rs/aya" }
 aya-log-ebpf = { git = "https://github.com/aya-rs/aya" }
-bytemuck = {version ="1.23.0",features = ["derive"]}
-network-types = "0.0.8"
 
 [build-dependencies]
 which = { version = "7.0.0", default-features = false }

core/src/components/conntracker/Cargo.toml

@@ -0,0 +1,50 @@
+use aya_ebpf::{macros::map, maps::{LruPerCpuHashMap, PerfEventArray}};
+
+#[repr(C)]
+#[derive(Clone, Copy)]
+pub struct PacketLog {
+    pub proto: u8,
+    pub src_ip: u32,
+    pub src_port: u16,
+    pub dst_ip: u32,
+    pub dst_port: u16,
+    pub pid: u32
+}
+
+// This structure is only for active connections
+#[repr(C)]
+#[derive(Clone, Copy)]
+pub struct ConnArray {
+    pub src_ip: u32,
+    pub dst_ip: u32,
+    pub src_port: u16,
+    pub dst_port: u16,
+    pub proto: u8,
+}
+
+#[repr(C)]
+#[derive(Clone, Copy, Debug)]
+pub struct VethLog {
+    pub name: [u8; 16],
+    pub state: u64, //state var type: long unsigned int
+    pub dev_addr: [u32; 8],
+    pub event_type: u8, //i choose 1 for veth creation or 2 for veth destruction
+    pub netns: u32,
+    pub pid: u32
+
+}
+
+#[map(name = "EventsMap")]
+pub static mut EVENTS: PerfEventArray<PacketLog> = PerfEventArray::new(0);
+
+//TODO: ConnectionMap needs a rework after implementing issue #105
+#[map(name = "ConnectionMap")]
+pub static mut ACTIVE_CONNECTIONS: LruPerCpuHashMap<u16, ConnArray> =
+    LruPerCpuHashMap::with_max_entries(65536, 0);
+
+#[map(name = "ConnectionTrackerMap")]
+pub static mut CONNTRACKER: LruPerCpuHashMap<ConnArray, u8> =
+    LruPerCpuHashMap::with_max_entries(65536, 0);
+
+#[map(name = "veth_identity_map")]
+pub static mut VETH_EVENTS: PerfEventArray<VethLog> = PerfEventArray::new(0);