- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 21 for Se (0.05 sec)
-
pilot/pkg/serviceregistry/kube/controller/ambient/workloads.go
} w.WorkloadName, w.WorkloadType = se.Name, workloadapi.WorkloadType_POD // XXX(shashankram): HACK to impersonate pod w.CanonicalName, w.CanonicalRevision = kubelabels.CanonicalService(se.Labels, w.WorkloadName) setTunnelProtocol(se.Labels, se.Annotations, w) res = append(res, model.WorkloadInfo{Workload: w, Labels: se.Labels, Source: kind.WorkloadEntry, CreationTime: se.CreationTimestamp.Time}) } return res }
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/conversion.go
} if len(svc.Attributes.LabelSelectors) > 0 { se.WorkloadSelector = &networking.WorkloadSelector{Labels: svc.Attributes.LabelSelectors} } // Based on networking.istio.io/exportTo annotation for k := range svc.Attributes.ExportTo { // k is Private or Public se.ExportTo = append(se.ExportTo, string(k)) } if svc.MeshExternal { se.Location = networking.ServiceEntry_MESH_EXTERNAL // 0 - default } else {
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/kube/controller/ambient/ambientindex_serviceentry_test.go
// test code path where service entry creates a workload entry via `ServiceEntry.endpoints` // and the inlined WE has a port override s.addServiceEntry(t, "se.istio.io", []string{"240.240.23.45"}, "name1", testNS, nil, []string{"127.0.0.1"}) 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{{
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/serviceentry/controller.go
services := s.services.getServices(namespacedName) se := cfg.Spec.(*networking.ServiceEntry) if wi.DNSServiceEntryOnly && !isDNSTypeServiceEntry(se) { log.Debugf("skip selecting workload instance %v/%v for DNS service entry %v", wi.Namespace, wi.Name, se.Hosts) continue } instance := s.convertWorkloadEntryToServiceInstances(wle, services, se, &key, s.Cluster()) instancesUpdated = append(instancesUpdated, instance...)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
tests/integration/security/pass_through_filter_chain_test.go
})). // It's not trivial to force mTLS to pass-through ports. To work around this, we will // set up a SE and DR that forces it. // // Since our client will talk directly to pods via IP, we have to configure the ports // in the SE as TCP, since only TCP does will match based in IP address rather than host.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 11.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/conversion_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 39K bytes - Viewed (0) -
tests/integration/ambient/waypoint_test.go
func SetWaypoint(t framework.TestContext, svc string, waypoint string) { setWaypointInternal(t, svc, apps.Namespace.Name(), waypoint, true) } func SetWaypointServiceEntry(t framework.TestContext, se, namespace string, waypoint string) { setWaypointInternal(t, se, namespace, waypoint, false) } func setWaypointInternal(t framework.TestContext, name, ns string, waypoint string, service bool) { for _, c := range t.Clusters() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 11.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/workloads_test.go
}) } } func TestServiceEntryWorkloads(t *testing.T) { cases := []struct { name string inputs []any se *networkingclient.ServiceEntry result []*workloadapi.Workload }{ { name: "dns without endpoints", inputs: []any{}, se: &networkingclient.ServiceEntry{ ObjectMeta: metav1.ObjectMeta{ Name: "name", Namespace: "ns", },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 16:51:29 UTC 2024 - 20.3K bytes - Viewed (0) -
pilot/pkg/networking/core/fake.go
} serviceDiscovery := aggregate.NewController(aggregate.Options{}) se := serviceentry.NewController( configController, xdsUpdater, env.Watcher, serviceentry.WithClusterID(opts.ClusterID)) // TODO allow passing in registry, for k8s, mem reigstry serviceDiscovery.AddRegistry(se) msd := memregistry.NewServiceDiscovery(opts.Services...) msd.XdsUpdater = xdsUpdater
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.5K bytes - Viewed (0) -
istioctl/pkg/precheck/precheck.go
if err != nil { return err } for _, se := range ses.Items { if se.Spec.Resolution != networking.ServiceEntry_NONE { continue } changed := false for _, p := range se.Spec.Ports { if p.TargetPort != 0 && p.Number != p.TargetPort { changed = true } } if changed { res := ObjectToInstance(se) messages.Add(msg.NewUpdateIncompatibility(res,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 02:57:30 UTC 2024 - 19.3K bytes - Viewed (0)