- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for _process (0.17 sec)
-
cni/pkg/repair/netns.go
best := "" // We will iterate over all processes. Our goal is to find a process with the same network ID as we found above. // There should be 1 or 2 processes that match: the pause container should always be there, and the istio-validation *might*. // We want the pause container, as the istio-validation one may exit before we are done. // We do this by detecting the longest running process. We could look at `cmdline`, but is likely more reliable to weird platforms.
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed Dec 20 22:14:13 GMT 2023 - 4.8K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
err := rootCmd.Execute() return out.String(), err } // cleanTestCluster resets the test cluster. func cleanTestCluster() error { // Needed in case we are running a test through this path that doesn't start a new process. cache.FlushObjectCaches() if !kubeBuilderInstalled() { return nil } return recreateTestEnv() } // getAllIstioObjects lists all Istio GVK resources from the testClient.
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/net.go
if err := s.rescanPod(pod); err != nil { log.Errorf("error scanning proc: error was %s", err) return nil, err } // try again. we can still get here if the pod is in the process of being created. // in this case the CNI will be invoked soon and provide us with the netns. openNetns = s.currentPodSnapshot.Get(string(pod.UID)) if openNetns == nil {
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
"--set-xmark", inpodTproxyMark) // Handle healthcheck probes from the host node. In the host netns, before the packet enters the pod, we SNAT // the healthcheck packet to a fixed IP if the packet is coming from a node-local process with a socket. // // We do this so we can exempt this traffic from ztunnel capture/proxy - otherwise both kube-proxy (legit)
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/dashboard/dashboard.go
openBrowser(fmt.Sprintf(urlFormat, fw.Address()), writer, browser) // Wait for stop fw.WaitForStop() return nil } return fmt.Errorf("failure running port forward process: %v", err) } func ClosePortForwarderOnInterrupt(fw kube.PortForwarder) { go func() { signals := make(chan os.Signal, 1) signal.Notify(signals, os.Interrupt) defer signal.Stop(signals) <-signals
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Apr 15 01:29:35 GMT 2024 - 20.5K bytes - Viewed (0) -
operator/cmd/mesh/install.go
Namespace: ns, DryRun: rootArgs.DryRun, } if processed, err := helmreconciler.ProcessDefaultWebhook(kubeClient, iop, exists, opts); err != nil { return fmt.Errorf("failed to process default webhook: %v", err) } else if processed { p.Println("Made this installation the default for cluster-wide operations.") } if iArgs.Verify { if rootArgs.DryRun {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Thu May 02 14:30:43 GMT 2024 - 15.5K bytes - Viewed (1) -
istioctl/pkg/writer/compare/sds/util.go
} // NewSecretItemBuilder returns a new builder to create a secret item func NewSecretItemBuilder() SecretItemBuilder { return &secretItemBuilder{} } // SecretItemBuilder wraps the process of setting fields for the SecretItem // and builds the Metadata fields from the cert contents behind the scenes type SecretItemBuilder interface { Name(string) SecretItemBuilder Data(string) SecretItemBuilder
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Jun 06 15:14:48 GMT 2023 - 6.6K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
log.Errorf("Skipping pod, already repaired with an unexpected UID %v vs %v", uid, pod.UID) } return nil } log.Infof("Repairing pod...") // Fetch the pod's network namespace. This must run in the host process due to how the procfs /ns/net works. // This will get a network namespace ID. This ID is scoped to the network namespace we running in.
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) -
istioctl/pkg/tag/generate_test.go
istioNamespace: "istio-system", webhook: revisionCanonicalWebhookRemote, whURL: remoteValidationURL, whSVC: "", whCA: "ca", }, { name: "webhook-process-failure-policy", istioNamespace: "istio-system", webhook: revisionCanonicalWebhook, whURL: "", whSVC: "istiod-revision", whCA: "ca", userManaged: true,
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) -
istioctl/pkg/metrics/metrics.go
if err != nil { return fmt.Errorf("could not build port forwarder for prometheus: %v", err) } if err = fw.Start(); err != nil { return fmt.Errorf("failure running port forward process: %v", err) } // Close the forwarder either when we exit or when an this processes is interrupted. defer fw.Close() dashboard.ClosePortForwarderOnInterrupt(fw)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 8.4K bytes - Viewed (0)