- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 99 for Franke (0.14 sec)
-
cni/pkg/iptables/iptables_test.go
cfg.RedirectDNS = true }, }, } probeSNATipv4 := netip.MustParseAddr("169.254.7.127") probeSNATipv6 := netip.MustParseAddr("e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164") for _, tt := range cases { for _, ipv6 := range []bool{false, true} { t.Run(tt.name+"_"+ipstr(ipv6), func(t *testing.T) { cfg := constructTestConfig() cfg.EnableIPv6 = ipv6 tt.config(cfg) ext := &dep.DependenciesStub{}
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 3.7K bytes - Viewed (0) -
istioctl/pkg/writer/pilot/status.go
mappedResp := map[string]string{} w := new(tabwriter.Writer).Init(s.Writer, 0, 8, 5, ' ', 0) _, _ = fmt.Fprintln(w, "NAME\tCLUSTER\tCDS\tLDS\tEDS\tRDS\tECDS\tISTIOD\tVERSION") for _, dr := range drs { for _, resource := range dr.Resources { clientConfig := xdsstatus.ClientConfig{} err := resource.UnmarshalTo(&clientConfig) if err != nil { return nil, nil, fmt.Errorf("could not unmarshal ClientConfig: %w", err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 04:16:55 GMT 2024 - 6.1K bytes - Viewed (0) -
istioctl/pkg/completion/completion.go
podList, err := client.Kube().CoreV1().Pods(ns).List(context.Background(), metav1.ListOptions{}) if err != nil { return nil, err } var podsName []string for _, pod := range podList.Items { if toComplete == "" || strings.HasPrefix(pod.Name, toComplete) { podsName = append(podsName, pod.Name) } } return podsName, nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 4.9K bytes - Viewed (0) -
istioctl/pkg/proxyconfig/clusters.go
if err != nil { return err } w := new(tabwriter.Writer).Init(out, 0, 8, 5, ' ', 0) _, _ = fmt.Fprintln(w, "NAME\tSECRET\tSTATUS\tISTIOD") for istiod, clusters := range statuses { for _, c := range clusters { _, _ = fmt.Fprintf(w, "%s\t%s\t%s\t%s\n", c.ID, c.SecretName, c.SyncStatus, istiod) } } _ = w.Flush() return nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 2.3K bytes - Viewed (0) -
istioctl/pkg/tag/tag_test.go
}, }, }, }, outputMatches: []string{"test", "revision", "dependent"}, error: "", }, } for _, tc := range tcs { t.Run(tc.name, func(t *testing.T) { var out bytes.Buffer client := fake.NewSimpleClientset(tc.webhooks.DeepCopyObject(), tc.namespaces.DeepCopyObject()) outputFormat = util.JSONFormat
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Nov 17 22:41:06 GMT 2023 - 8.7K bytes - Viewed (0) -
operator/cmd/mesh/manifest-generate.go
mgArgs.Force, mgArgs.Filter, kubeClient, l) if err != nil { return err } if len(mgArgs.Components) != 0 { filteredManifests := name.ManifestMap{} for _, cArg := range mgArgs.Components { componentName := name.ComponentName(cArg) if cManifests, ok := manifests[componentName]; ok { filteredManifests[componentName] = cManifests } else {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 8.5K bytes - Viewed (0) -
cni/test/install_cni.go
t.Helper() t.Logf("Pre-populating working dirs") for i, f := range cniDirOrderedFiles { destFilenm := fmt.Sprintf("0%d-%s", i, f) t.Logf("Copying %v into temp config dir %v/%s", f, tempCNIConfDir, destFilenm) cp(wd+cniConfSubDir+f, tempCNIConfDir+"/"+destFilenm, t) } for _, f := range ls(wd+k8sSvcAcctSubDir, t) { t.Logf("Copying %v into temp k8s serviceaccount dir %v", f, tempK8sSvcAcctDir)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 12.5K bytes - Viewed (0) -
cni/pkg/log/uds.go
err := json.Unmarshal(body, &cniLogs) if err != nil { log.Errorf("Failed to unmarshal CNI plugin logs: %v", err) return } messages := make([]cniLog, 0, len(cniLogs)) for _, l := range cniLogs { var msg cniLog if err := json.Unmarshal([]byte(l), &msg); err != nil { log.Debugf("Failed to unmarshal CNI plugin log entry: %v", err) continue } msg.Msg = strings.TrimSpace(msg.Msg)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 01:05:12 GMT 2023 - 3.3K 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) -
istioctl/pkg/install/k8sversion/version_test.go
isValid: false, }, { version: versionInvalid2, errMsg: fmt.Errorf("could not parse Malformed version: %v", versionInvalid2.GitVersion), isValid: false, }, } for i, c := range cases { t.Run(fmt.Sprintf("case %d %s", i, c.version), func(t *testing.T) { got, err := extractKubernetesVersion(c.version) if c.errMsg != err && c.isValid { t.Fatalf("\nwanted: %v \nbut found: %v", c.errMsg, err)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 19 02:46:48 GMT 2024 - 6.3K bytes - Viewed (0)