- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 38 for join (0.13 sec)
-
cni/pkg/install/install_test.go
// Create existing config file if specified in test case cniConfigFilePath := filepath.Join(cniNetDir, c.configFilename) if err := file.AtomicCopy(filepath.Join("testdata", c.existingConfigFilename), cniNetDir, c.configFilename); err != nil { t.Fatal(err) } // Create existing binary files if err := os.WriteFile(filepath.Join(cniBinDir, "istio-cni"), []byte{1, 2, 3}, 0o755); err != nil { t.Fatal(err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 11.1K bytes - Viewed (0) -
istioctl/pkg/workload/workload_test.go
"ingressIP": "fd00:10:96::2", }, } for _, dir := range files { if !dir.IsDir() { continue } testdir := path.Join("testdata/vmconfig", dir.Name()) t.Cleanup(func() { for k := range generated { os.Remove(path.Join(testdir, k)) } }) t.Run(dir.Name(), func(t *testing.T) { createClientFunc := func(client kube.CLIClient) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Mar 27 16:59:05 GMT 2024 - 14.6K bytes - Viewed (0) -
istioctl/pkg/writer/envoy/configdump/listener.go
if includeConfigType { name := fmt.Sprintf("listener/%s", l.Name) fmt.Fprintf(w, "%v\t%v\t%v\t%v\t%v\n", name, strings.Join(addresses, ","), port, match.match, match.destination) } else { fmt.Fprintf(w, "%v\t%v\t%v\t%v\n", strings.Join(addresses, ","), port, match.match, match.destination) } } } else { listenerType := retrieveListenerType(l) if includeConfigType {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Nov 29 12:37:14 GMT 2023 - 18.1K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
out[cmd] = objs } return out, nil } // fakeApplyManifest runs istioctl install. func fakeApplyManifest(inFile, flags string, chartSource chartSourceType) (*ObjectSet, error) { inPath := filepath.Join(testDataDir, "input", inFile+".yaml") manifest, err := runManifestCommand("install", []string{inPath}, flags, chartSource, nil) if err != nil { return nil, fmt.Errorf("error %s: %s", err, manifest) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Feb 20 22:39:28 GMT 2024 - 11.7K bytes - Viewed (1) -
istioctl/pkg/describe/describe_test.go
t.Fatalf("Unexpected output for 'istioctl %s'\n got: %q\nwant: %q", strings.Join(c.args, " "), output, c.expectedOutput) } if c.expectedString != "" && !strings.Contains(output, c.expectedString) { t.Fatalf("Output didn't match for 'istioctl %s'\n got %v\nwant: %v", strings.Join(c.args, " "), output, c.expectedString) } if c.wantException { if fErr == nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Mar 28 09:54:01 GMT 2024 - 30.4K bytes - Viewed (0) -
istioctl/pkg/tag/generate_test.go
} webhookConfig, err = fixWhConfig(fakeClient, webhookConfig) if err != nil { t.Fatalf("webhook fixing failed with error: %v", err) } opts := &GenerateOptions{ ManifestsPath: filepath.Join(env.IstioSrc, "manifests"), } if tc.userManaged { opts.UserManaged = true } webhookYAML, err := generateValidatingWebhook(webhookConfig, opts) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jan 16 17:43:49 GMT 2024 - 12.1K bytes - Viewed (0) -
cni/pkg/install/cniconfig.go
cniConfigStr = strings.ReplaceAll(cniConfigStr, "__KUBECONFIG_FILENAME__", vars.kubeconfigFilename) cniConfigStr = strings.ReplaceAll(cniConfigStr, "__KUBECONFIG_FILEPATH__", filepath.Join(vars.cniNetDir, vars.kubeconfigFilename)) cniConfigStr = strings.ReplaceAll(cniConfigStr, "__KUBERNETES_SERVICE_HOST__", vars.k8sServiceHost)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 10.4K bytes - Viewed (0) -
cni/pkg/nodeagent/net.go
if err := s.buildZtunnelSnapshot(podsByUID); err != nil { log.Warnf("failed to construct initial ztunnel snapshot: %v", err) consErr = append(consErr, err) } return errors.Join(consErr...) } func (s *NetServer) buildZtunnelSnapshot(ambientPodUIDs map[types.UID]*corev1.Pod) error { // first add all the pods as empty: for uid := range ambientPodUIDs {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.2K bytes - Viewed (1) -
cni/pkg/iptables/iptables.go
} } return errors.Join(execErrs...) } func (cfg *IptablesConfigurator) executeIptablesCommands(iptVer *dep.IptablesVersion, args [][]string) error { var iptErrs []error for _, argSet := range args { iptErrs = append(iptErrs, cfg.ext.Run(iptablesconstants.IPTables, iptVer, nil, argSet...)) } return errors.Join(iptErrs...) }
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/repair/repaircontroller.go
fieldSelectors = append(fieldSelectors, fmt.Sprintf("spec.nodeName=%v", cfg.NodeName)) c.pods = kclient.NewFiltered[*corev1.Pod](client, kclient.Filter{ LabelSelector: cfg.LabelSelectors, FieldSelector: strings.Join(fieldSelectors, ","), }) c.queue = controllers.NewQueue("repair pods", controllers.WithReconciler(c.Reconcile), controllers.WithMaxAttempts(5)) c.pods.AddEventHandler(controllers.ObjectHandler(c.queue.AddObject))
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Feb 10 00:31:55 GMT 2024 - 10.4K bytes - Viewed (0)