Skip to content

Commit 20d402f

Browse files
authored
Merge pull request #718 from l1b0k/fix/lb
policy: remove disable-per-package-lb config
2 parents 964340a + c79305c commit 20d402f

File tree

3 files changed

+28
-0
lines changed

3 files changed

+28
-0
lines changed

cmd/terway-cli/cni_linux.go

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -63,3 +63,15 @@ func allowEBPFNetworkPolicy(require bool) (bool, error) {
6363
func checkKernelVersion(k, major, minor int) bool {
6464
return kernel.CheckKernelVersion(k, major, minor)
6565
}
66+
67+
func isOldNode() (bool, error) {
68+
_, err := netlink.LinkByName("cilium_net")
69+
if err == nil {
70+
fmt.Printf("link cilium_net exist\n")
71+
return true, nil
72+
}
73+
if !errors.As(err, &netlink.LinkNotFoundError{}) {
74+
return false, err
75+
}
76+
return false, nil
77+
}

cmd/terway-cli/cni_unsupport.go

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -13,3 +13,7 @@ func checkKernelVersion(k, major, minor int) bool {
1313
func allowEBPFNetworkPolicy(enable bool) (bool, error) {
1414
return enable, nil
1515
}
16+
17+
func isOldNode() (bool, error) {
18+
return false, nil
19+
}

cmd/terway-cli/policy.go

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -284,6 +284,18 @@ func policyConfig(container *gabs.Container) ([]string, error) {
284284
ciliumArgs = append(ciliumArgs, extractArgs(h.CiliumExtraArgs)...)
285285
}
286286

287+
old, err := isOldNode()
288+
if err != nil {
289+
return nil, err
290+
}
291+
292+
// check the extra args
293+
lo.Filter(ciliumArgs, func(item string, index int) bool {
294+
if strings.Contains(item, "disable-per-package-lb") {
295+
return old
296+
}
297+
return true
298+
})
287299
return ciliumArgs, nil
288300
}
289301

0 commit comments

Comments
 (0)