- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for ExtractWorkloadsFromAddresses (0.27 sec)
-
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go
// Since it is a part of VIP1 which we are subscribe to, add it to the subscriptions for addr := range allAddresses { for _, wl := range model.ExtractWorkloadsFromAddresses(a.Lookup(addr)) { // We may have gotten an update for Pod, but are subscribed to a Service. // We need to force a subscription on the Pod as well for namespacedHostname := range wl.Services {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 19 17:19:41 UTC 2024 - 15.8K bytes - Viewed (0) -
pilot/pkg/model/service.go
} func NewSelector(l map[string]string) LabelSelector { return LabelSelector{l} } func (l LabelSelector) GetLabelSelector() map[string]string { return l.Labels } func ExtractWorkloadsFromAddresses(addrs []AddressInfo) []WorkloadInfo { return slices.MapFilter(addrs, func(a AddressInfo) *WorkloadInfo { switch addr := a.Type.(type) { case *workloadapi.Address_Workload:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 46.3K bytes - Viewed (0) -
pilot/pkg/model/push_context.go
// We should get 0 or 1 workloads, so just return the first. infos, _ := ps.ambientIndex.AddressInformation(sets.New(n.String() + "/" + ip)) for _, wl := range ExtractWorkloadsFromAddresses(infos) { if wl.TunnelProtocol == workloadapi.TunnelProtocol_HBONE { return true } } return false }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 09:02:11 UTC 2024 - 91.8K bytes - Viewed (0)