- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 63 for join (0.21 sec)
-
operator/cmd/mesh/profile-dump_test.go
}, } installPackagePathRegex := regexp.MustCompile(" installPackagePath: .*") for _, tt := range tests { t.Run(tt.desc, func(t *testing.T) { inPath := filepath.Join(testDataDir, "input", tt.desc+".yaml") outPath := filepath.Join(testDataDir, "output", tt.desc+".yaml") got, err := runProfileDump(inPath, tt.configPath, snapshotCharts, "") if err != nil { t.Fatal(err) }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jan 20 11:44:25 GMT 2022 - 3.7K 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/writer/compare/sds/writer.go
if len(secrets) == 0 { fmt.Fprintln(w.w, "No secret items to show.") return nil } tw := new(tabwriter.Writer).Init(w.w, 0, 5, 5, ' ', 0) fmt.Fprintln(tw, strings.Join(secretItemColumns, "\t")) for _, s := range secrets { if includeConfigType { s.Name = fmt.Sprintf("secret/%s", s.Name) } fmt.Fprintf(tw, "%s\t%s\t%s\t%t\t%s\t%s\t%s\n",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 21 14:17:23 GMT 2023 - 4.1K bytes - Viewed (0) -
cni/pkg/install/kubeconfig_test.go
k8sServicePort = "443" kubeCAFilepath = "testdata/kube-ca.crt" saToken = "service_account_token_string" ) func TestCreateValidKubeconfigFile(t *testing.T) { tmp := t.TempDir() os.WriteFile(filepath.Join(tmp, "token"), []byte(saToken), 0o644) constants.ServiceAccountPath = tmp cases := []struct { name string expectedFailure bool k8sServiceProtocol string k8sServiceHost string
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 03:52:24 GMT 2024 - 5.1K bytes - Viewed (0) -
cni/pkg/util/executil.go
return stderr.String(), err } return strings.TrimSuffix(stdout.String(), "\n"), err } func Execute(cmd string, args ...string) error { log.Debugf("Running command: %s %s", cmd, strings.Join(args, " ")) externalCommand := exec.Command(cmd, args...) stdout := &bytes.Buffer{} stderr := &bytes.Buffer{} externalCommand.Stdout = stdout externalCommand.Stderr = stderr err := externalCommand.Run()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Jan 26 20:34:28 GMT 2024 - 1.8K bytes - Viewed (0) -
operator/cmd/mesh/operator_test.go
) var ( extendedClient kube.CLIClient kubeClient client.Client ) // TODO: rewrite this with running the actual top level command. func TestOperatorDump(t *testing.T) { goldenFilepath := filepath.Join(env.IstioSrc, "operator/cmd/mesh/testdata/operator/output/operator-dump.yaml") odArgs := &operatorDumpArgs{ common: operatorCommonArgs{ hub: "foo.io/istio", tag: "1.2.3",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Aug 29 14:15:33 GMT 2023 - 6.4K bytes - Viewed (0) -
istioctl/pkg/checkinject/checkinject.go
} if isDeactivated { return "The injection webhook is deactivated, and will never match labels." } return fmt.Sprintf("No matching namespace labels (%s) "+ "or pod labels (%s)", strings.Join(nsMatchedLabels, ", "), strings.Join(podMatchedLabels, ", ")) } return noMatchingReason(whs), false } func extractMatchedSelectorInfo(ls *metav1.LabelSelector, objLabels map[string]string) (matched bool, injLabel string) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 9.3K bytes - Viewed (0) -
cni/pkg/log/uds_test.go
"istio.io/istio/cni/pkg/constants" "istio.io/istio/pkg/log" "istio.io/istio/pkg/test/util/assert" ) func TestUDSLog(t *testing.T) { // Start UDS log server udsSockDir := t.TempDir() udsSock := filepath.Join(udsSockDir, "cni.sock") logger := NewUDSLogger() pluginLog.SetOutputLevel(log.DebugLevel) // this will be configured by global.logging.level stop := make(chan struct{}) defer close(stop)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Mar 16 00:20:01 GMT 2024 - 2.5K bytes - Viewed (0)