- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for funding (0.19 sec)
-
cni/pkg/nodeagent/net.go
s.ztunnelServer.Close() } func (s *NetServer) rescanPod(pod *corev1.Pod) error { // this can happen if the pod was dynamically added to the mesh after it was created. // in that case, try finding the netns using procfs. filter := map[types.UID]*corev1.Pod{ pod.UID: pod, } return s.scanProcForPodsAndCache(filter) } func (s *NetServer) getOrOpenNetns(pod *corev1.Pod, netNs string) (Netns, error) {
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) -
istioctl/pkg/xds/client.go
GrpcOpts: grpcOpts, }, }, nil) if err != nil { return nil, fmt.Errorf("could not dial: %w", err) } err = adscConn.Run() if err != nil { return nil, fmt.Errorf("ADSC: failed running %v", err) } err = adscConn.Send(dr) if err != nil { return nil, err } response, err := adscConn.WaitVersion(opts.Timeout, dr.TypeUrl, "") return response, err }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Dec 19 22:42:42 GMT 2023 - 3.7K bytes - Viewed (0) -
cni/pkg/iptables/iptables.go
// committing to using the same binary/variant (legacy or nft) // within all pods as we do on the host. // // This should be fine, as the host binaries are all we have to work with here anyway, // as we are running within a privileged container - and we don't want to take the time to // redetect for each pod anyway. // // Extreme corner case: // If for some reason your host had both binaries, and you were injecting out-of-band
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)
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
if err != nil { return fmt.Errorf("failed to get profile, namespace or enabled components: %v", err) } // Ignore the err because we don't want to show // "no running Istio pods in istio-system" for the first time _ = detectIstioVersionDiff(p, tag, ns, kubeClient, iop) exists := revtag.PreviousInstallExists(context.Background(), kubeClient.Kube())
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/proxyconfig/proxyconfig.go
fmt.Sprintf("Comma-separated minimum per-logger level of messages to output, in the form of"+ " [<logger>:]<level>,[<logger>:]<level>,... or <level> to change all active loggers, "+ "where logger components can be listed by running \"istioctl proxy-config log <pod-name[.namespace]>\""+ "or referred from https://github.com/envoyproxy/envoy/blob/main/source/common/common/logger.h, and level can be one of %s", levelListString)) return logCmd }
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 16 03:28:36 GMT 2024 - 48K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics.go
cmd := &cobra.Command{ Use: "metrics <workload name>...", Short: "Prints the metrics for the specified workload(s) when running in Kubernetes.", Long: ` Prints the metrics for the specified service(s) when running in Kubernetes. This command finds a Prometheus pod running in the specified istio system namespace. It then executes a series of queries per requested workload to
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) -
cni/pkg/plugin/plugin.go
log.Debugf("istio-cni CmdAdd previous result: %+v", loggedPrevResult) // Determine if running under k8s by checking the CNI args k8sArgs := K8sArgs{} if err := types.LoadArgs(args.Args, &k8sArgs); err != nil { return err } // Check if the workload is running under Kubernetes. podNamespace := string(k8sArgs.K8S_POD_NAMESPACE) podName := string(k8sArgs.K8S_POD_NAME)
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Wed May 08 15:58:51 GMT 2024 - 10.5K bytes - Viewed (0) -
operator/cmd/mesh/shared.go
func applyManifest(kubeClient kube.Client, client client.Client, manifestStr string, componentName name.ComponentName, opts *applyOptions, iop *v1alpha1.IstioOperator, l clog.Logger, ) error { // Needed in case we are running a test through this path that doesn't start a new process. cache.FlushObjectCaches() reconciler, err := helmreconciler.NewHelmReconciler(client, kubeClient, iop, &helmreconciler.Options{DryRun: opts.DryRun, Log: l})
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 29 02:29:02 GMT 2024 - 5.1K bytes - Viewed (0) -
istioctl/pkg/analyze/analyze.go
sa.AddRunningKubeSourceWithRevision(k, revisionSpecified, c.remote) } } // If we explicitly specify mesh config, use it. // This takes precedence over default mesh config or mesh config from a running Kube instance. if meshCfgFile != "" { _ = sa.AddFileKubeMeshConfig(meshCfgFile) } // If we're not using kube (files only), add defaults for some resources we expect to be provided by Istio
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 02 08:32:06 GMT 2024 - 17K bytes - Viewed (0)