- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for AddressInfo (0.25 sec)
-
pilot/pkg/serviceregistry/memory/discovery.go
} func workloadToAddressInfo(w *workloadapi.Workload) model.AddressInfo { return model.AddressInfo{ Address: &workloadapi.Address{ Type: &workloadapi.Address_Workload{ Workload: w, }, }, } } func serviceToAddressInfo(s *workloadapi.Service) model.AddressInfo { return model.AddressInfo{ Address: &workloadapi.Address{ Type: &workloadapi.Address_Service{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 23:10:01 UTC 2024 - 12.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/helpers.go
func workloadToAddressInfo(w *workloadapi.Workload) model.AddressInfo { return model.AddressInfo{ Address: &workloadapi.Address{ Type: &workloadapi.Address_Workload{ Workload: w, }, }, } } func modelWorkloadToAddressInfo(w model.WorkloadInfo) model.AddressInfo { return workloadToAddressInfo(w.Workload) } func serviceToAddressInfo(s *workloadapi.Service) model.AddressInfo { return model.AddressInfo{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 22 20:35:23 UTC 2024 - 7.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_serviceentry_test.go
s.assertEvent(t, s.seIPXdsName("name1", "127.0.0.1"), "ns1/se.istio.io") s.assertWorkloads(t, "", workloadapi.WorkloadStatus_HEALTHY, "name1") assert.Equal(t, s.lookup(s.addrXdsName("127.0.0.1")), []model.AddressInfo{{ Address: &workloadapi.Address{ Type: &workloadapi.Address_Workload{ Workload: &workloadapi.Workload{ Uid: s.seIPXdsName("name1", "127.0.0.1"), Name: "name1",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 03:01:04 UTC 2024 - 12.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex.go
"istio.io/istio/pkg/network" "istio.io/istio/pkg/slices" "istio.io/istio/pkg/util/sets" "istio.io/istio/pkg/workloadapi" ) type Index interface { Lookup(key string) []model.AddressInfo All() []model.AddressInfo WorkloadsForWaypoint(key model.WaypointKey) []model.WorkloadInfo ServicesForWaypoint(key model.WaypointKey) []model.ServiceInfo SyncAll() HasSynced() bool model.AmbientIndexes }
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
return nil } func (u NoopAmbientIndexes) WorkloadsForWaypoint(WaypointKey) []WorkloadInfo { return nil } var _ AmbientIndexes = NoopAmbientIndexes{} type AddressInfo struct { *workloadapi.Address } func (i AddressInfo) Aliases() []string { switch addr := i.Type.(type) { case *workloadapi.Address_Workload: aliases := make([]string, 0, len(addr.Workload.Addresses)) network := addr.Workload.Network
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/serviceregistry/aggregate/controller.go
} for _, p := range c.GetRegistries() { res = append(res, p.Policies(requested)...) } return res } func (c *Controller) AddressInformation(addresses sets.String) ([]model.AddressInfo, sets.String) { i := []model.AddressInfo{} if !features.EnableAmbient { return i, nil } removed := sets.String{} for _, p := range c.GetRegistries() { wis, r := p.AddressInformation(addresses) i = append(i, wis...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0) -
pkg/controller/endpointslicemirroring/reconciler_test.go
t.Helper() type addressInfo struct { ready bool epAddress corev1.EndpointAddress } // This approach assumes that each IP is unique within an EndpointSubset. expectedEndpoints := map[string]addressInfo{} for _, address := range epSubset.Addresses { at := getAddressType(address.IP)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 06:51:56 UTC 2024 - 42.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go
s.assertAddresses(t, s.addrXdsName("127.0.0.2"), "pod2") for _, key := range []string{s.podXdsName("pod3"), s.addrXdsName("127.0.0.3")} { assert.Equal(t, s.lookup(key), []model.AddressInfo{ { Address: &workloadapi.Address{ Type: &workloadapi.Address_Workload{ Workload: &workloadapi.Workload{ Name: "pod3", Namespace: testNS,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 70.2K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_workloadentry_test.go
s.assertWorkloads(t, s.addrXdsName("127.0.0.2"), workloadapi.WorkloadStatus_HEALTHY, "name2") assert.Equal(t, s.lookup(s.addrXdsName("127.0.0.3")), []model.AddressInfo{{ Address: &workloadapi.Address{ Type: &workloadapi.Address_Workload{ Workload: &workloadapi.Workload{ Uid: s.wleXdsName("name3"), Name: "name3",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 08 01:04:50 UTC 2024 - 15.6K bytes - Viewed (0)