- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 941 for ipaddresses (0.25 sec)
-
pilot/pkg/networking/core/listener_address.go
package core import ( "istio.io/istio/pilot/pkg/features" "istio.io/istio/pilot/pkg/model" ) const ( // WildcardAddress binds to all IP addresses WildcardAddress = "0.0.0.0" // WildcardIPv6Address binds to all IPv6 addresses WildcardIPv6Address = "::" // LocalhostAddress for local binding LocalhostAddress = "127.0.0.1" // LocalhostIPv6Address for local binding
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 3.3K bytes - Viewed (0) -
pilot/pkg/xds/vm_test.go
Labels: map[string]string{ "merge": "wg", "wg": "1", }, }, }, Status: nil, }) proxy := &model.Proxy{ Labels: map[string]string{"merge": "me"}, IPAddresses: []string{"1.1.1.1"}, Metadata: &model.NodeMetadata{ AutoRegisterGroup: "wg", Namespace: "namespace", Network: "network1", Labels: map[string]string{"merge": "meta", "meta": "2"},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 12 18:20:36 UTC 2024 - 2.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller_test.go
"cluster-2": []string{"10.2.0.0"}, }, } for _, svc := range services { if !reflect.DeepEqual(svc.ClusterVIPs.Addresses, ClusterVIPs[svc.Hostname]) { t.Fatalf("Service %s ClusterVIPs actual %v, expected %v", svc.Hostname, svc.ClusterVIPs.Addresses, ClusterVIPs[svc.Hostname]) } } registry2.RemoveService(mock.HelloService.Hostname) // List Services from aggregate controller
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0) -
pkg/registry/networking/ipaddress/strategy.go
_, _ = newIPAddress, oldIPAddress } // Validate validates a new IPAddress. func (ipAddressStrategy) Validate(ctx context.Context, obj runtime.Object) field.ErrorList { ipAddress := obj.(*networking.IPAddress) err := validation.ValidateIPAddress(ipAddress) return err } // Canonicalize normalizes the object after validation. func (ipAddressStrategy) Canonicalize(obj runtime.Object) { }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 22:58:11 UTC 2023 - 3.6K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/ipallocator.go
return *a.cidr } // for testing func (a *Allocator) Has(ip net.IP) bool { // convert IP to name name := ip.String() ipAddress, err := a.client.IPAddresses().Get(context.Background(), name, metav1.GetOptions{}) if err != nil || len(ipAddress.Name) == 0 { return false } return true } func (a *Allocator) IPFamily() api.IPFamily { return a.family }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:04 UTC 2023 - 17K bytes - Viewed (0) -
pilot/pkg/serviceregistry/memory/discovery.go
sd.mutex.Lock() defer sd.mutex.Unlock() if len(requests) == 0 { return maps.Values(sd.addresses), nil } var infos []model.AddressInfo removed := sets.String{} for req := range requests { if _, found := sd.addresses[req]; !found { removed.Insert(req) } else { infos = append(infos, sd.addresses[req]) } } return infos, removed }
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/mock/discovery_mock.go
HelloInstanceV0 = MakeIP(HelloService, 0) // HelloProxyV0 is a mock proxy v0 of HelloService HelloProxyV0 = model.Proxy{ Type: model.SidecarProxy, IPAddresses: []string{HelloInstanceV0}, ID: "v0.default", DNSDomain: "default.svc.cluster.local", IstioVersion: model.MaxIstioVersion, Metadata: &model.NodeMetadata{}, }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 23 02:37:56 UTC 2022 - 2.7K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/cidrallocator_test.go
return false, ip, err })) client.PrependReactor("delete", "ipaddresses", k8stesting.ReactionFunc(func(action k8stesting.Action) (bool, runtime.Object, error) { name := action.(k8stesting.DeleteAction).GetName() obj, exists, err := ipStore.GetByKey(name) ip := &networkingv1alpha1.IPAddress{} if exists && err == nil { ip = obj.(*networkingv1alpha1.IPAddress) err = ipStore.Delete(ip) } return false, ip, err }))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 13.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/workloadinstances/util.go
// GetInstanceForProxy returns a workload instance that // corresponds to a given proxy, if any. func GetInstanceForProxy(index Index, proxy *model.Proxy, proxyIP string) *model.WorkloadInstance { if !slices.Contains(proxy.IPAddresses, proxyIP) { return nil } instances := index.GetByIP(proxyIP) // list is ordered by namespace/name if len(instances) == 0 { return nil } if len(instances) == 1 { // dominant use case
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 24 17:36:41 UTC 2023 - 2.8K bytes - Viewed (0) -
pkg/registry/networking/rest/storage_settings.go
storage := map[string]rest.Storage{} // ipaddress if resource := "ipaddresses"; apiResourceConfigSource.ResourceEnabled(networkingapiv1alpha1.SchemeGroupVersion.WithResource(resource)) { ipAddressStorage, err := ipaddressstore.NewREST(restOptionsGetter) if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:04 UTC 2023 - 4.7K bytes - Viewed (0)