- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for agentzh (0.2 sec)
-
istioctl/pkg/proxystatus/proxystatus.go
statusCmd.PersistentFlags().BoolVar(&multiXdsOpts.XdsViaAgents, "xds-via-agents", false, "Access Istiod via the tap service of each agent") statusCmd.PersistentFlags().IntVar(&multiXdsOpts.XdsViaAgentsLimit, "xds-via-agents-limit", 100, "Maximum number of pods being visited by istioctl when `xds-via-agent` flag is true."+ "To iterate all the agent pods without limit, set to 0") return statusCmd
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Sat Apr 13 05:23:38 GMT 2024 - 6.2K bytes - Viewed (0) -
istioctl/pkg/multixds/gather.go
" which can be set by `--xds-via-agents-limit` flag.\n", options.XdsViaAgentsLimit) break GetProxyLoop } namespacedName := pod.Name + "." + pod.Namespace if visited[namespacedName] { // If we already have information about the pod, skip it. continue } resp, err := queryToOnePod(&pod) if err != nil {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Mar 08 08:38:19 GMT 2024 - 13.6K bytes - Viewed (0) -
cni/pkg/nodeagent/informers.go
"istio.io/istio/pkg/monitoring" ) var ( eventTypeTag = monitoring.CreateLabel("type") EventTotals = monitoring.NewSum( "nodeagent_reconcile_events_total", "The total number of node agent reconcile events.", ) ) type K8sHandlers interface { GetPodIfAmbient(podName, podNamespace string) (*corev1.Pod, error) GetAmbientPods() []*corev1.Pod Start() } type InformerHandlers struct {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 9.6K bytes - Viewed (0) -
cni/pkg/plugin/plugin.go
cniClient := newCNIClient(conf.CNIEventAddress, constants.CNIAddEventPath) if err = PushCNIEvent(cniClient, args, prevResIps, podName, podNamespace); err != nil { log.Errorf("istio-cni cmdAdd failed to signal node Istio CNI agent: %s", err) return err } return nil } log.Debugf("istio-cni ambient cmdAdd podName: %s - not ambient enabled, ignoring", podName) } // End ambient plugin logic pi := &PodInfo{}
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) -
cni/pkg/cmd/root.go
if cfg.InstallConfig.AmbientEnabled { // Start ambient controller // node agent will spawn a goroutine and watch the K8S API for events, // as well as listen for messages from the CNI binary. log.Info("Starting ambient node agent with inpod redirect mode") ambientAgent, err := nodeagent.NewServer(ctx, watchServerReady, cfg.InstallConfig.CNIEventAddress, nodeagent.AmbientArgs{
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Tue Apr 30 22:24:38 GMT 2024 - 12.5K bytes - Viewed (0) -
istioctl/pkg/workload/workload.go
"istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/pkg/serviceregistry/kube/controller" "istio.io/istio/pkg/config/constants" "istio.io/istio/pkg/config/schema/gvk" "istio.io/istio/pkg/config/validation/agent" "istio.io/istio/pkg/kube" "istio.io/istio/pkg/kube/labels" "istio.io/istio/pkg/log" netutil "istio.io/istio/pkg/util/net" "istio.io/istio/pkg/util/protomarshal" "istio.io/istio/pkg/util/shellescape" )
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) -
cni/pkg/nodeagent/podcgroupns.go
// descendants of a kubepods directory, however, as of Kubernetes 1.21, cgroups // namespaces are in use and therefore we can no longer discern if that is the // case from within SPIRE agent container (since the container itself is // namespaced). As such, the regex has been relaxed to simply find the pod UID // followed by the container ID with allowances for arbitrary punctuation, and
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri Apr 12 21:47:31 GMT 2024 - 11K bytes - Viewed (0)