- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 13 for re (0.14 sec)
-
operator/cmd/mesh/profile-dump.go
// Convert the generated YAML to pretty JSON. func yamlToPrettyJSON(yml string) (string, error) { // YAML objects are not completely compatible with JSON // objects. Let yaml.YAMLToJSON handle the edge cases and // we'll re-encode the result to pretty JSON. uglyJSON, err := yaml.YAMLToJSON([]byte(yml)) if err != nil { return "", err } var decoded any if uglyJSON[0] == '[' { decoded = make([]any, 0) } else {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 15 01:18:49 GMT 2024 - 7.1K bytes - Viewed (0) -
istioctl/cmd/sysexits.go
"istio.io/istio/istioctl/pkg/util" ) // Values should try to use sendmail-style values as in <sysexits.h> // See e.g. https://man.openbsd.org/sysexits.3 // or `less /usr/includes/sysexits.h` if you're on Linux // // Picking the right range is tricky--there are a lot of reserved ones (see // https://www.tldp.org/LDP/abs/html/exitcodes.html#EXITCODESREF) and then some // used by convention (see sysexits). //
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Jun 15 15:02:17 GMT 2023 - 1.9K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
helmreconciler.TestMode = true // Add install and controller to the list of commands to run tests against. testedManifestCmds = append(testedManifestCmds, cmdApply, cmdController) } } // recreateTestEnv (re)creates a kubebuilder fake API server environment. This is required for testing of the // controller runtime, which is used in the operator. func recreateTestEnv() error {
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) -
cni/pkg/nodeagent/informers_test.go
NodeName: NodeName, }, Status: corev1.PodStatus{ PodIP: "11.1.1.12", }, } ns := &corev1.Namespace{ ObjectMeta: metav1.ObjectMeta{Name: "test"}, // TODO: once we if the add pod bug, re-enable this and remove the patch below // Labels: map[string]string{constants.DataplaneModeLabel: constants.DataplaneModeAmbient}, } client := kube.NewFakeClient(ns, pod)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 15.8K bytes - Viewed (0) -
istioctl/pkg/authz/listener.go
"istio.io/istio/pkg/wellknown" ) const ( anonymousName = "_anonymous_match_nothing_" ) // Matches the policy name in RBAC filter config with format like ns[default]-policy[some-policy]-rule[1]. var re = regexp.MustCompile(`ns\[(.+)\]-policy\[(.+)\]-rule\[(.+)\]`) type filterChain struct { rbacHTTP []*rbachttp.RBAC rbacTCP []*rbactcp.RBAC } type parsedListener struct { filterChains []*filterChain }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Sep 11 15:29:30 GMT 2023 - 6K bytes - Viewed (0) -
istioctl/pkg/kubeinject/kubeinject.go
if err != nil { return nil, fmt.Errorf("could not read valid configmap %q from namespace %q: %v - "+ "Use --meshConfigFile or re-run "+command+" with `-i <istioSystemNamespace> and ensure valid MeshConfig exists", meshConfigMapName, ctx.IstioNamespace(), err) } // values in the data are strings, while proto might use a
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 21.6K bytes - Viewed (0) -
cni/pkg/install/install.go
// we would get infinite looping of events // // Additionally, fsnotify will lose existing watches on atomic copies (due to overwrite/rename), // so we have to re-watch after re-copy to make sure we always have fresh watches. watcher, err := util.CreateFileWatcher(targets...) if err != nil { return err } defer func() { setNotReady(in.isReady) watcher.Close() }()
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu Feb 08 18:52:24 GMT 2024 - 10.8K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze.go
} suppressions = append(suppressions, local.AnalysisSuppression{ Code: parts[0], ResourceName: parts[1], }) } sa.SetSuppressions(suppressions) // If we're using kube, use that as a base source. if useKube { clients, err := getClients(ctx) if err != nil { return err } for _, c := range clients { k := kube.EnableCrdWatcher(c.client)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 17K bytes - Viewed (0) -
istioctl/pkg/describe/describe.go
return "", "", err } // Starting with recent 1.5.0 builds, the path will include .istio.io. Handle both. // nolint: gosimple re := regexp.MustCompile("/apis/networking(\\.istio\\.io)?/v1alpha3/namespaces/(?P<namespace>[^/]+)/virtual-service/(?P<name>[^/]+)") ss := re.FindStringSubmatch(path) if ss == nil { return "", "", fmt.Errorf("not a VS path: %s", path) } return ss[3], ss[2], nil }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 50.4K bytes - Viewed (0) -
cni/pkg/install/kubeconfig.go
} // checkExistingKubeConfigFile returns an error if no kubeconfig exists at the configured path, // or if a kubeconfig exists there, but differs from the current config. // In any case, an error indicates the file must be (re)written, and no error means no action need be taken func checkExistingKubeConfigFile(cfg *config.InstallConfig, expectedKC kubeconfig) error { kubeconfigFilepath := filepath.Join(cfg.MountedCNINetDir, cfg.KubeconfigFilename)
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)