lb.conntrack — org.clojars.pgdad/clj-ebpf-lb 0.9.0

Connection tracking management for the load balancer. Provides utilities for monitoring, cleaning, and querying connection state.

aggregate-stats clj

(aggregate-stats conntrack-map)

Aggregate statistics across all connections.

cleanup-stale-connections! clj

(cleanup-stale-connections! conntrack-map timeout-seconds)

Remove connections older than the timeout.

Returns the number of connections removed.

clear-all-connections! clj

(clear-all-connections! conntrack-map)

Remove all connections from the tracking map.

Returns the number of connections removed.

connection->map clj

(connection->map conn)

Convert a Connection to a human-readable map.

connection-age-ns clj

(connection-age-ns conn current-time-ns)

Get the age of a connection in nanoseconds. Returns nil if created-ns is 0 (not set).

connection-age-seconds clj

(connection-age-seconds conn current-time-ns)

Get the age of a connection in seconds.

connection-expired? clj

(connection-expired? conn current-time-ns timeout-ns)

Check if a connection has expired based on idle timeout.

connection-idle-ns clj

(connection-idle-ns conn current-time-ns)

Get the idle time of a connection in nanoseconds (time since last packet).

connection-idle-seconds clj

(connection-idle-seconds conn current-time-ns)

Get the idle time of a connection in seconds.

count-connections clj

(count-connections conntrack-map)

Get the number of active connections.

format-connection clj

(format-connection conn)

(format-connection conn current-time-ns)

Format a connection for display.

format-duration clj

(format-duration seconds)

Format a duration in seconds to a human-readable string.

get-all-connections clj

(get-all-connections conntrack-map)

Get all active connections as Connection records.

get-connection clj

(get-connection conntrack-map
                {:keys [src-ip dst-ip src-port dst-port protocol]})

Get a specific connection by 5-tuple.

get-connections-by-source clj

(get-connections-by-source conntrack-map src-ip)

Get all connections from a specific source IP.

get-connections-by-target clj

(get-connections-by-target conntrack-map target-ip)

Get all connections to a specific NAT target.

get-stale-connections clj

(get-stale-connections conntrack-map current-time-ns timeout-ns)

Get connections that haven't been seen within the timeout period.

print-connection-stats clj

(print-connection-stats conntrack-map)

Print aggregated connection statistics.

print-connections clj

(print-connections conntrack-map)

Print all connections to stdout.

raw-entry->connection clj

(raw-entry->connection {:keys [key value]})

Convert raw map entry to Connection record.

start-cleanup-daemon clj

(start-cleanup-daemon conntrack-map
                      settings-map
                      &
                      {:keys [interval-seconds] :or {interval-seconds 60}})

Start a background daemon that periodically cleans up stale connections.

Returns a control map with :stop-fn to stop the daemon.

stats-by-protocol clj

(stats-by-protocol conntrack-map)

Aggregate statistics grouped by protocol.

stats-by-source clj

(stats-by-source conntrack-map)

Aggregate statistics grouped by source IP.

stats-by-target clj

(stats-by-target conntrack-map)

Aggregate statistics grouped by NAT target.

stop-cleanup-daemon clj

(stop-cleanup-daemon {:keys [stop-fn]})

Stop the cleanup daemon.