- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for Lange (0.12 sec)
-
istioctl/pkg/waypoint/waypoint.go
defer ticker.Stop() for range ticker.C { programmed := false gwc, err := kubeClient.GatewayAPI().GatewayV1().Gateways(ctx.NamespaceOrDefault(ctx.Namespace())).Get(context.TODO(), gw.Name, metav1.GetOptions{}) if err == nil { // Check if gateway has Programmed condition set to true for _, cond := range gwc.Status.Conditions {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 19:45:58 GMT 2024 - 15.5K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
if cfg.cfg.EnableIPv6 { iptablesVariant = append(iptablesVariant, cfg.ipt6V) } for _, iptVer := range iptablesVariant { for _, cmd := range deleteCmds { delErrs = append(delErrs, cfg.ext.Run(iptablesconstants.IPTables, &iptVer, nil, cmd...)) } for _, cmd := range optionalDeleteCmds { err := cfg.ext.Run(iptablesconstants.IPTables, &iptVer, nil, cmd...) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue May 07 19:54:50 GMT 2024 - 19.7K bytes - Viewed (0) -
cni/pkg/plugin/plugin_test.go
want: []string{}, }, { name: "Non-parseable", args: args{ports: []string{"abcd", "2345", "abcd"}}, want: []string{"abcd", "2345"}, }, } for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { if got := dedupPorts(tt.args.ports); !reflect.DeepEqual(got, tt.want) { t.Errorf("dedupPorts() = %v, want %v", got, tt.want) } }) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 17.5K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
log := log.WithLabels("pod", podNamespace+"/"+podName) if podNamespace == "" || podName == "" { log.Debugf("Not a kubernetes pod") return nil } for _, excludeNs := range conf.Kubernetes.ExcludeNamespaces { if podNamespace == excludeNs { log.Infof("pod namespace excluded") return nil } } // Begin ambient plugin logic
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 10.5K bytes - Viewed (0)