Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 6 additions & 4 deletions controllers/consoleplugin/config/static-frontend-config.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -175,8 +175,9 @@ columns:
tooltip: Network name, such as Secondary network or UDN.
field: SrcK8S_NetworkName
filter: src_network
default: false
default: true
width: 15
feature: multiNetworks
- id: DstK8S_Name
group: Destination
name: Name
Expand Down Expand Up @@ -315,8 +316,9 @@ columns:
tooltip: Network name, such as Secondary network or UDN.
field: DstK8S_NetworkName
filter: dst_network
default: false
default: true
width: 15
feature: multiNetworks
- id: K8S_Name
name: Names
calculated: '[SrcK8S_Name,DstK8S_Name]'
Expand Down Expand Up @@ -458,7 +460,7 @@ columns:
tooltip: The list of User Defined Networks.
field: Udns
filter: udns
default: true
default: false
width: 15
feature: udnMapping
- id: FlowDirInts
Expand Down Expand Up @@ -1094,7 +1096,7 @@ scopes:
labels:
- SrcK8S_NetworkName
- DstK8S_NetworkName
feature: udnMapping
feature: multiNetworks
filters:
- src_network
- dst_network
Expand Down
4 changes: 4 additions & 0 deletions controllers/consoleplugin/consoleplugin_objects.go
Original file line number Diff line number Diff line change
Expand Up @@ -455,6 +455,10 @@ func (b *builder) setFrontendConfig(fconf *cfg.FrontendConfig) error {
fconf.Features = append(fconf.Features, "udnMapping")
}

if helper.IsUDNMappingEnabled(&b.desired.Agent.EBPF) || helper.HasSecondaryIndexes(&b.desired.Processor) {
fconf.Features = append(fconf.Features, "multiNetworks")
}

if helper.IsIPSecEnabled(&b.desired.Agent.EBPF) {
fconf.Features = append(fconf.Features, "ipsec")
}
Expand Down
4 changes: 4 additions & 0 deletions pkg/helper/flowcollector.go
Original file line number Diff line number Diff line change
Expand Up @@ -166,6 +166,10 @@ func IsEBPFFlowFilterEnabled(spec *flowslatest.FlowCollectorEBPF) bool {
return spec.FlowFilter != nil && spec.FlowFilter.Enable != nil && *spec.FlowFilter.Enable
}

func HasSecondaryIndexes(spec *flowslatest.FlowCollectorFLP) bool {
return spec.Advanced != nil && len(spec.Advanced.SecondaryNetworks) > 0
}

func GetEBPFMetricsPort(spec *flowslatest.FlowCollectorEBPF) int32 {
port := int32(constants.EBPFMetricPort)
if spec.Metrics.Server.Port != nil {
Expand Down