- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 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/util/workloadinstances/index_test.go
ServiceAccount: spiffe.MustGenSpiffeURIForTrustDomain("cluster.local", selector.Name, "default"), TLSMode: model.IstioMutualTLSModeLabel, }, } wi3 := &model.WorkloadInstance{ Name: "another-name", Namespace: "dns-selector", Endpoint: &model.IstioEndpoint{ Address: "2.2.2.2", Labels: map[string]string{"app": "dns-wle"},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 5K 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/controller_test.go
wle := createWorkloadEntry("wl", selector.Name, &networking.WorkloadEntry{ Address: "2.2.2.2", Labels: map[string]string{"app": "wle"}, ServiceAccount: "default", }) wle2 := createWorkloadEntry("wl2", selector.Name, &networking.WorkloadEntry{ Address: "3.3.3.3", Labels: map[string]string{"app": "wle"}, ServiceAccount: "default", })
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 92.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/serviceregistry/serviceentry/util.go
) func getWorkloadServiceEntries(ses []config.Config, wle *networking.WorkloadEntry) map[types.NamespacedName]*config.Config { out := make(map[types.NamespacedName]*config.Config) for i, cfg := range ses { se := cfg.Spec.(*networking.ServiceEntry) if se.WorkloadSelector != nil && labels.Instance(se.WorkloadSelector.Labels).Match(wle.Labels) { out[cfg.NamespacedName()] = &ses[i] } } return out }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 1.9K 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/autoregistration/internal/health/controller.go
"istio.io/istio/pilot/pkg/model" "istio.io/istio/pilot/pkg/model/status" "istio.io/istio/pkg/kube/controllers" istiolog "istio.io/istio/pkg/log" ) var log = istiolog.RegisterScope("wle", "wle controller debugging") type HealthEvent struct { // whether or not the agent thought the target is healthy Healthy bool `json:"healthy,omitempty"` // error message propagated
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Sep 19 20:41:55 UTC 2023 - 3.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)