Skip to content

Codex/ingestion semantics foundation#92

Merged
Str-Gen merged 34 commits intomainfrom
codex/ingestion-semantics-foundation
Mar 26, 2026
Merged

Codex/ingestion semantics foundation#92
Str-Gen merged 34 commits intomainfrom
codex/ingestion-semantics-foundation

Conversation

@Str-Gen
Copy link
Collaborator

@Str-Gen Str-Gen commented Mar 26, 2026

Cleanup, testing, polish, minor new features and improvements

Str-Gen added 30 commits March 25, 2026 15:04

fn close_flow(&mut self, _timestamp_us: i64, _cause: FlowExpireCause) -> () {
// No active state to close
fn close_flow(&mut self, _timestamp_us: i64, cause: FlowExpireCause) -> () {

Check warning

Code scanning / clippy

unneeded unit return type Warning

unneeded unit return type
fn get_features() -> String {
// Add here the features of the custom flow.
format!("flow_id,icmp_type,icmp_code")
format!("flow_id,icmp_type,icmp_code,icmp_echo_request_count,icmp_echo_reply_count,icmp_error_count,icmp_destination_unreachable_count")

Check warning

Code scanning / clippy

useless use of format! Warning

useless use of format!
fn get_features_without_contamination() -> String {
// Add here the features of the custom flow without contaminant features.
format!("icmp_type,icmp_code")
format!("icmp_type,icmp_code,icmp_echo_request_count,icmp_echo_reply_count,icmp_error_count,icmp_destination_unreachable_count")

Check warning

Code scanning / clippy

useless use of format! Warning

useless use of format!
self.error_count += 1;
self.destination_unreachable_count += 1;
}
Some(2 | 3 | 4) => self.error_count += 1,

Check warning

Code scanning / clippy

this OR pattern can be rewritten using a range Warning

this OR pattern can be rewritten using a range
let packet_counter_clone = Arc::clone(&packet_counter);
let packet_tx_clone = packet_tx.clone();
let packet_graph = packet_graph.clone();
let realtime_offset_us = realtime_offset_us;

Check warning

Code scanning / clippy

redundant redefinition of a binding realtime_offset_us Warning

redundant redefinition of a binding realtime_offset_us
let packet_counter_clone = Arc::clone(&packet_counter);
let packet_tx_clone = packet_tx.clone();
let packet_graph = packet_graph.clone();
let realtime_offset_us = realtime_offset_us;

Check warning

Code scanning / clippy

redundant redefinition of a binding realtime_offset_us Warning

redundant redefinition of a binding realtime_offset_us
@Str-Gen Str-Gen merged commit 8346fb2 into main Mar 26, 2026
3 checks passed
@Str-Gen Str-Gen deleted the codex/ingestion-semantics-foundation branch March 26, 2026 19:19
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant