- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for wle (0.02 sec)
-
pilot/pkg/autoregistration/controller.go
return } log.Infof("cleaned up health-checked WorkloadEntry %s/%s periodic:%v", wle.Namespace, wle.Name, periodic) } // IsControllerOf implements state.StoreCallbacks. func (c *Controller) IsControllerOf(wle *config.Config) bool { if wle == nil { return false } return wle.Annotations[annotation.IoIstioWorkloadController.Name] == c.instanceID }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go
network := a.Network(wle.Spec.Address, wle.Labels).String() if wle.Spec.Network != "" { network = wle.Spec.Network } // enforce traversing waypoints policies = append(policies, implicitWaypointPolicies(ctx, Waypoints, waypoint, services)...) w := &workloadapi.Workload{ Uid: a.generateWorkloadEntryUID(wle.Namespace, wle.Name), Name: wle.Name,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/conversion.go
} networkID := s.workloadEntryNetwork(wle) locality := wle.Locality if locality == "" && len(wle.Labels[model.LocalityLabel]) > 0 { locality = model.GetLocalityLabel(wle.Labels[model.LocalityLabel]) } labels := labelutil.AugmentLabels(wle.Labels, clusterID, locality, "", networkID) return &model.ServiceInstance{ Endpoint: &model.IstioEndpoint{ Address: addr,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/conversion_test.go
sortServiceInstances(instances) sortServiceInstances(tt.out) if tt.wle.Locality != "" || tt.clusterID != "" || tt.wle.Network != "" { for _, serviceInstance := range tt.out { serviceInstance.Endpoint.Locality = model.Locality{ Label: tt.wle.Locality, ClusterID: tt.clusterID,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 39K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller_test.go
} } func fakeProxySuitableForHealthChecks(wle config.Config) *model.Proxy { wleSpec := wle.Spec.(*v1alpha3.WorkloadEntry) return &model.Proxy{ ID: wle.Name + "." + wle.Namespace, IPAddresses: []string{wleSpec.Address}, VerifiedIdentity: &spiffe.Identity{Namespace: wle.Namespace, ServiceAccount: "my-sa"}, Metadata: &model.NodeMetadata{ Namespace: wle.Namespace, Network: network.ID(wleSpec.Network),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 31.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
return s } // ConvertWorkloadEntry convert wle from Config.Spec and populate the metadata labels into it. func ConvertWorkloadEntry(cfg config.Config) *networking.WorkloadEntry { wle := cfg.Spec.(*networking.WorkloadEntry) if wle == nil { return nil } // we will merge labels from metadata with spec, with precedence to the metadata labels := maps.MergeCopy(wle.Labels, cfg.Labels) // shallow copy
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/deployment.go
return } // Deploy the workload entry to the primary cluster. We will read WorkloadEntry across clusters. wle := d.workloadEntryYAML(w) if err := d.ctx.ConfigKube(d.cfg.Cluster.Primary()). YAML(d.cfg.Namespace.Name(), wle). Apply(apply.NoCleanup); err != nil { log.Warnf("failed deploying echo WLE for %s/%s to primary cluster: %v", d.cfg.Namespace.Name(), d.cfg.Service, err) } }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 12:26:52 UTC 2024 - 24.1K bytes - Viewed (0)