- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 239 for join (0.14 sec)
-
docs/debugging/reorder-disks/main.go
return nil, err } exp := argP.Expand() if node == "" { for index, e := range exp { result = append(result, localDisk{index: index, path: strings.Join(e, "")}) } } else { for index, e := range exp { u, err := url.Parse(strings.Join(e, "")) if err != nil { return nil, err } if strings.Contains(u.Host, node) { result = append(result, localDisk{index: index, path: u.Path}) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.4K bytes - Viewed (0) -
istioctl/pkg/multicluster/remote_secret_test.go
name: "missing service account", opts: RemoteSecretOptions{ ServiceAccountName: testServiceAccountName, KubeOptions: KubeOptions{ Namespace: testNamespace, }, ManifestsPath: filepath.Join(env.IstioSrc, "manifests"), }, wantErrStr: fmt.Sprintf("serviceaccounts %q not found", testServiceAccountName), }, } legacyCases := append([]tc{ { name: "wrong number of secrets",
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Oct 31 14:48:28 GMT 2023 - 20.6K 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/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/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) -
istioctl/pkg/workload/workload.go
} if err = os.WriteFile(filepath.Join(dir, "root-cert.pem"), []byte(rootCert.Data[constants.CACertNamespaceConfigMapDataName]), filePerms); err != nil { return err } serviceAccount := wg.Spec.Template.ServiceAccount tokenPath := filepath.Join(dir, "istio-token") token := &authenticationv1.TokenRequest{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Apr 17 20:06:41 GMT 2024 - 25.5K bytes - Viewed (0) -
cmd/handler-utils.go
} else { m[supportedHeader] = strings.Join(value, ",") } } } for key := range v { for _, prefix := range userMetadataKeyPrefixes { if !stringsHasPrefixFold(key, prefix) { continue } value, ok := nv[http.CanonicalHeaderKey(key)] if ok { m[key] = strings.Join(value, ",") break } } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 15.5K bytes - Viewed (3) -
internal/s3select/sql/jsonpath_test.go
result = append(result, parsedVal.Value) } if err := dec.Err(); err != nil { return nil, err } return result, nil } func TestJsonpathEval(t *testing.T) { f, err := os.Open(filepath.Join("jsondata", "books.json")) if err != nil { t.Fatal(err) } b, err := io.ReadAll(f) if err != nil { t.Fatal(err) } p := participle.MustBuild( &JSONPath{}, participle.Lexer(sqlLexer),
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 19 18:05:16 GMT 2022 - 2.8K bytes - Viewed (0) -
istioctl/pkg/util/formatting/formatter.go
} } func printLog(ms diag.Messages, colorize bool) string { logOutput := make([]string, 0, len(ms)) for _, m := range ms { logOutput = append(logOutput, render(m, colorize)) } return strings.Join(logOutput, "\n") } func printJSON(ms diag.Messages) (string, error) { jsonOutput, err := json.MarshalIndent(ms, "", "\t") return string(jsonOutput), err } func printYAML(ms diag.Messages) (string, error) {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jul 11 02:41:45 GMT 2023 - 3.1K bytes - Viewed (0) -
cni/pkg/install/kubeconfig.go
return err } if err := checkExistingKubeConfigFile(cfg, kc); err != nil { installLog.Info("kubeconfig either does not exist or is out of date, writing a new one") kubeconfigFilepath := filepath.Join(cfg.MountedCNINetDir, cfg.KubeconfigFilename) if err := file.AtomicWrite(kubeconfigFilepath, []byte(kc.Full), os.FileMode(cfg.KubeconfigMode)); err != nil { return err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Aug 11 01:19:03 GMT 2023 - 4.9K bytes - Viewed (0)