Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for IsZTunnel (0.26 sec)

  1. istioctl/pkg/util/ambient/util.go

    	isZtunnel := strings.HasPrefix(podName, "ztunnel")
    	if client == nil {
    		return isZtunnel
    	}
    	pod, err := client.Kube().CoreV1().Pods(podNamespace).Get(context.Background(), podName, metav1.GetOptions{})
    	if err != nil {
    		return isZtunnel
    	}
    	if v, ok := pod.Labels["app"]; ok {
    		return v == "ztunnel"
    	}
    	return isZtunnel
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 02 21:29:40 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  2. pilot/pkg/xds/statusgen.go

    		if isProxy(con) || isZtunnel(con) {
    			xdsConfigs := make([]*status.ClientConfig_GenericXdsConfig, 0)
    			for _, stype := range stypes {
    				pxc := &status.ClientConfig_GenericXdsConfig{}
    				if watchedResource, ok := con.proxy.WatchedResources[stype]; ok {
    					pxc.ConfigStatus = debugSyncStatus(watchedResource)
    				} else if isZtunnel(con) {
    					pxc.ConfigStatus = status.ConfigStatus_UNKNOWN
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jan 10 23:30:28 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  3. security/pkg/server/ca/node_auth_test.go

    			}
    		})
    	}
    }
    
    func toPod(p pod, isZtunnel bool) *v1.Pod {
    	po := &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      p.name,
    			Namespace: p.namespace,
    			UID:       types.UID(p.uid),
    		},
    		Spec: v1.PodSpec{
    			ServiceAccountName: p.account,
    			NodeName:           p.node,
    		},
    	}
    	if isZtunnel {
    		po.Labels = map[string]string{
    			"app": "ztunnel",
    		}
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 10.5K bytes
    - Viewed (0)
  4. pilot/pkg/xds/proxy_dependencies.go

    func ConfigAffectsProxy(req *model.PushRequest, proxy *model.Proxy) bool {
    	// Empty changes means "all" to get a backward compatibility.
    	if len(req.ConfigsUpdated) == 0 {
    		return true
    	}
    	if proxy.IsWaypointProxy() || proxy.IsZTunnel() {
    		// Optimizations do not apply since scoping uses different mechanism
    		// TODO: implement ambient aware scoping
    		return true
    	}
    
    	for config := range req.ConfigsUpdated {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 15:58:06 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  5. pilot/pkg/model/context.go

    	return node.Type == Waypoint
    }
    
    // IsZTunnel returns true if the proxy is acting as a ztunnel in an ambient mesh.
    func (node *Proxy) IsZTunnel() bool {
    	return node.Type == Ztunnel
    }
    
    // IsAmbient returns true if the proxy is acting as either a ztunnel or a waypoint proxy in an ambient mesh.
    func (node *Proxy) IsAmbient() bool {
    	return node.IsWaypointProxy() || node.IsZTunnel()
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 33.6K bytes
    - Viewed (0)
  6. pilot/pkg/xds/ads.go

    	proxy.LastPushContext = s.globalPushContext()
    	// First request so initialize connection id and start tracking it.
    	con.SetID(connectionID(proxy.ID))
    	con.node = node
    	con.proxy = proxy
    	if proxy.IsZTunnel() && !features.EnableAmbient {
    		return fmt.Errorf("ztunnel requires PILOT_ENABLE_AMBIENT=true")
    	}
    
    	// Authorize xds clients
    	if err := s.authorize(con, identities); err != nil {
    		return err
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  7. pilot/pkg/xds/debug.go

    			for _, rr := range resource {
    				configDump.Configs = append(configDump.Configs, rr.Resource)
    			}
    		}
    		writeJSON(w, configDump, req)
    		return
    	}
    
    	if con.proxy.IsZTunnel() {
    		resources := s.getConfigDumpByResourceType(con, nil, []string{v3.AddressType})
    		configDump := &admin.ConfigDump{}
    		for _, resource := range resources {
    			for _, rr := range resource {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 39.5K bytes
    - Viewed (0)
Back to top