Skip to content

Commit 5219a48

Browse files
authored
NETOBSERV-1777: Allow DNS tracking to use configurable port for tracking (netobserv#753)
Signed-off-by: Mohamed Mahmoud <mmahmoud@redhat.com> (cherry picked from commit 192b5b9)
1 parent c9413e7 commit 5219a48

File tree

1 file changed

+10
-4
lines changed

1 file changed

+10
-4
lines changed

controllers/ebpf/agent_controller.go

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -94,10 +94,12 @@ const (
9494
)
9595

9696
const (
97-
EnvDedupeJustMark = "DEDUPER_JUST_MARK"
98-
EnvDedupeMerge = "DEDUPER_MERGE"
99-
DedupeJustMarkDefault = "false"
100-
DedupeMergeDefault = "true"
97+
EnvDedupeJustMark = "DEDUPER_JUST_MARK"
98+
EnvDedupeMerge = "DEDUPER_MERGE"
99+
envDNSTrackingPort = "DNS_TRACKING_PORT"
100+
DedupeJustMarkDefault = "false"
101+
DedupeMergeDefault = "true"
102+
defaultDNSTrackingPort = "53"
101103
)
102104

103105
// AgentController reconciles the status of the eBPF agent Daemonset, as well as the
@@ -615,6 +617,7 @@ func (c *AgentController) setEnvConfig(coll *flowslatest.FlowCollector) []corev1
615617
dedup := dedupeDefault
616618
dedupJustMark := DedupeJustMarkDefault
617619
dedupMerge := DedupeMergeDefault
620+
dnsTrackingPort := defaultDNSTrackingPort
618621
// we need to sort env map to keep idempotency,
619622
// as equal maps could be iterated in different order
620623
advancedConfig := helper.GetAdvancedAgentConfig(coll.Spec.Agent.EBPF.Advanced)
@@ -626,13 +629,16 @@ func (c *AgentController) setEnvConfig(coll *flowslatest.FlowCollector) []corev1
626629
dedupJustMark = v
627630
} else if k == EnvDedupeMerge {
628631
dedupMerge = v
632+
} else if k == envDNSTrackingPort {
633+
dnsTrackingPort = v
629634
} else {
630635
config = append(config, corev1.EnvVar{Name: k, Value: v})
631636
}
632637
}
633638

634639
config = append(config, corev1.EnvVar{Name: envDedupe, Value: dedup})
635640
config = append(config, corev1.EnvVar{Name: EnvDedupeJustMark, Value: dedupJustMark})
641+
config = append(config, corev1.EnvVar{Name: envDNSTrackingPort, Value: dnsTrackingPort})
636642
config = append(config, corev1.EnvVar{
637643
Name: envAgentIP,
638644
ValueFrom: &corev1.EnvVarSource{

0 commit comments

Comments
 (0)