- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 137 for vips (0.15 sec)
-
pilot/pkg/serviceregistry/kube/controller/serviceimportcache.go
} sort.Strings(ips) return ips } // genMCSService generates an MCS service based on the given real k8s service. The list of vips must be non-empty. func (ic *serviceImportCacheImpl) genMCSService(realService *model.Service, mcsHost host.Name, vips []string) *model.Service { mcsService := realService.DeepCopy() mcsService.Hostname = mcsHost mcsService.DefaultAddress = vips[0] mcsService.ClusterVIPs.Addresses = map[cluster.ID][]string{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 10.2K bytes - Viewed (0) -
istioctl/pkg/writer/ztunnel/configdump/testdata/dump.json
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 03:28:36 UTC 2024 - 33.1K bytes - Viewed (0) -
pilot/pkg/model/service_test.go
"cluster-1": {"c1-vip1,c1-vip2"}, "cluster-2": {"c2-vip1,c2-vip2"}, }, }, }, other: &Service{ ClusterVIPs: AddressMap{ Addresses: map[cluster.ID][]string{ "cluster-1": {"c1-vip1,c1-vip2"}, "cluster-2": {"c2-vip1,c2-vip2"}, }, }, }, shouldEq: true, name: "matching cluster VIPs", }, { first: &Service{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 20:38:02 UTC 2024 - 13.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_serviceentry_test.go
CanonicalName: "a", CanonicalRevision: "latest", ServiceAccount: "sa1", WorkloadType: workloadapi.WorkloadType_POD, WorkloadName: "pod1", Services: nil, // vips for pod1 should be gone now }, }, }, }}) assert.Equal(t, s.lookup(s.addrXdsName("240.240.34.56")), []model.AddressInfo{{ Address: &workloadapi.Address{ Type: &workloadapi.Address_Workload{
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/xds/workload_test.go
createPod(s, "pod2", "sa", "127.0.0.2", "node") expect(ads.ExpectResponse(), "Kubernetes//Pod/default/pod2") // TODO: implement pod update; this actually cannot really be done without waypoints or VIPs deletePod(s, "pod") expectRemoved(ads.ExpectResponse(), "Kubernetes//Pod/default/pod") // Create pod we are not subscribed to; due to same-node optimization this will push
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 18 19:09:43 UTC 2024 - 15.9K bytes - Viewed (0) -
pilot/pkg/xds/xds_test.go
ConfigString: ` apiVersion: networking.istio.io/v1alpha3 kind: ServiceEntry metadata: name: external-svc-mongocluster spec: hosts: - mymongodb.somedomain addresses: - 192.192.192.192/24 # VIPs ports: - number: 27018 name: mongodb protocol: MONGO location: MESH_INTERNAL resolution: STATIC endpoints: - address: 2.2.2.2 - address: 3.3.3.3 `, },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 13.8K bytes - Viewed (0) -
pkg/dns/server/name_table_test.go
Ips: []string{"1.2.3.4"}, Registry: "Kubernetes", Shortname: "pod1.headless-svc", Namespace: "testns", }, "pod3.headless-svc.testns.svc.cluster.local": { Ips: []string{"19.6.7.8"}, Registry: "Kubernetes", Shortname: "pod3.headless-svc", Namespace: "testns", }, "pod4.headless-svc.testns.svc.cluster.local": {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jan 25 04:26:03 UTC 2024 - 16K bytes - Viewed (0) -
pilot/pkg/networking/core/tls.go
// 2) or if we have an empty destination VIP (i.e. which we should never get in case some platform adapter improper handlings); // 3) or if the destination is a wildcard destination VIP with the listener bound to the wildcard as well. // In the above cited cases, the listener will be bound to 0.0.0.0. So SNI match is the only way to distinguish different
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 17:09:02 UTC 2024 - 14.7K bytes - Viewed (0) -
tests/integration/pilot/mcs/discoverability/discoverability_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 17.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller.go
services[previous] = services[previous].DeepCopy() } // If it is seen second time, that means it is from a different cluster, update cluster VIPs. mergeService(services[previous], s, r) } } } } return services } // GetService retrieves a service by hostname if exists
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 13.5K bytes - Viewed (0)