- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for IsZTunnel (0.26 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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)