From 50a657f5c87cbbcf25231ab2fddbdcf453f4c905 Mon Sep 17 00:00:00 2001
From: Herbert Wolverson <herberticus@gmail.com>
Date: Thu, 12 Mar 2026 15:02:52 -0500
Subject: [PATCH] Chore: rename flow endpoint startup helpers

---
 .../flow_data/flow_analysis/finished_flows.rs               | 2 +-
 src/rust/lqosd/src/throughput_tracker/flow_data/mod.rs      | 6 +++---
 .../lqosd/src/throughput_tracker/flow_data/netflow5/mod.rs  | 2 +-
 .../lqosd/src/throughput_tracker/flow_data/netflow9/mod.rs  | 2 +-
 4 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/rust/lqosd/src/throughput_tracker/flow_data/flow_analysis/finished_flows.rs b/src/rust/lqosd/src/throughput_tracker/flow_data/flow_analysis/finished_flows.rs
index 648d95df..854abbf0 100644
--- a/src/rust/lqosd/src/throughput_tracker/flow_data/flow_analysis/finished_flows.rs
+++ b/src/rust/lqosd/src/throughput_tracker/flow_data/flow_analysis/finished_flows.rs
@@ -437,7 +437,7 @@ pub static RECENT_FLOWS: Lazy<TimeBuffer> = Lazy::new(TimeBuffer::new);
 pub struct FinishedFlowAnalysis {}
 
 impl FinishedFlowAnalysis {
-    pub fn new() -> Sender<(FlowbeeKey, (FlowbeeLocalData, FlowAnalysis))> {
+    pub fn start() -> Sender<(FlowbeeKey, (FlowbeeLocalData, FlowAnalysis))> {
         debug!("Created Flow Analysis Endpoint");
         let (tx, rx) =
             crossbeam_channel::bounded::<(FlowbeeKey, (FlowbeeLocalData, FlowAnalysis))>(65535);
diff --git a/src/rust/lqosd/src/throughput_tracker/flow_data/mod.rs b/src/rust/lqosd/src/throughput_tracker/flow_data/mod.rs
index d25894d9..c7fea529 100644
--- a/src/rust/lqosd/src/throughput_tracker/flow_data/mod.rs
+++ b/src/rust/lqosd/src/throughput_tracker/flow_data/mod.rs
@@ -38,7 +38,7 @@ pub fn setup_netflow_tracker() -> Result<Sender<(FlowbeeKey, (FlowbeeLocalData,
             // Build the endpoints list
             let mut endpoints: Vec<Sender<(FlowbeeKey, (FlowbeeLocalData, FlowAnalysis))>> =
                 Vec::new();
-            endpoints.push(FinishedFlowAnalysis::new());
+            endpoints.push(FinishedFlowAnalysis::start());
 
             if let Some(flow_config) = &config.flows
                 && let (Some(ip), Some(port), Some(version)) = (
@@ -52,13 +52,13 @@ pub fn setup_netflow_tracker() -> Result<Sender<(FlowbeeKey, (FlowbeeLocalData,
                 match version {
                     5 => {
                         let endpoint =
-                            Netflow5::new(target).expect("Cannot parse endpoint for netflow v5");
+                            Netflow5::start(target).expect("Cannot parse endpoint for netflow v5");
                         endpoints.push(endpoint);
                         info!("Netflow 5 endpoint added");
                     }
                     9 => {
                         let endpoint =
-                            Netflow9::new(target).expect("Cannot parse endpoint for netflow v9");
+                            Netflow9::start(target).expect("Cannot parse endpoint for netflow v9");
                         endpoints.push(endpoint);
                         info!("Netflow 9 endpoint added");
                     }
diff --git a/src/rust/lqosd/src/throughput_tracker/flow_data/netflow5/mod.rs b/src/rust/lqosd/src/throughput_tracker/flow_data/netflow5/mod.rs
index 57a9efee..a2ffe9d9 100644
--- a/src/rust/lqosd/src/throughput_tracker/flow_data/netflow5/mod.rs
+++ b/src/rust/lqosd/src/throughput_tracker/flow_data/netflow5/mod.rs
@@ -10,7 +10,7 @@ use std::{net::UdpSocket, sync::atomic::AtomicU32};
 pub(crate) struct Netflow5 {}
 
 impl Netflow5 {
-    pub(crate) fn new(
+    pub(crate) fn start(
         target: String,
     ) -> anyhow::Result<Sender<(FlowbeeKey, (FlowbeeLocalData, FlowAnalysis))>> {
         let (tx, rx) =
diff --git a/src/rust/lqosd/src/throughput_tracker/flow_data/netflow9/mod.rs b/src/rust/lqosd/src/throughput_tracker/flow_data/netflow9/mod.rs
index a325682d..23b65df6 100644
--- a/src/rust/lqosd/src/throughput_tracker/flow_data/netflow9/mod.rs
+++ b/src/rust/lqosd/src/throughput_tracker/flow_data/netflow9/mod.rs
@@ -11,7 +11,7 @@ mod protocol;
 pub(crate) struct Netflow9 {}
 
 impl Netflow9 {
-    pub(crate) fn new(
+    pub(crate) fn start(
         target: String,
     ) -> anyhow::Result<Sender<(FlowbeeKey, (FlowbeeLocalData, FlowAnalysis))>> {
         let (tx, rx) =