- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 52 for Se (0.02 sec)
-
pilot/pkg/serviceregistry/serviceentry/util_test.go
} currSes := map[types.NamespacedName]*config.Config{ {Namespace: "default", Name: "se-2"}: {}, {Namespace: "default", Name: "se-4"}: {}, {Namespace: "default", Name: "se-5"}: {}, } expectedUnselected := map[types.NamespacedName]*config.Config{ {Namespace: "default", Name: "se-1"}: {}, {Namespace: "default", Name: "se-3"}: {}, } unSelected := difference(oldSes, currSes)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 17 22:32:10 UTC 2023 - 3.5K bytes - Viewed (0) -
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/serviceentry/util.go
for key := range old { if _, ok := curr[key]; !ok { out = append(out, key) } } return out } func isDNSTypeServiceEntry(se *networking.ServiceEntry) bool { if se == nil { return false } return se.Resolution == networking.ServiceEntry_DNS || se.Resolution == networking.ServiceEntry_DNS_ROUND_ROBIN } // count the number of elements in the map value. The value is []any type.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 1.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/kube/controller/serviceexportcache.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 28 16:41:38 UTC 2024 - 7.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/ambient/services_test.go
) func TestServiceEntryServices(t *testing.T) { cases := []struct { name string inputs []any se *networkingclient.ServiceEntry result []*workloadapi.Service }{ { name: "DNS service entry with address", inputs: []any{}, se: &networkingclient.ServiceEntry{ ObjectMeta: metav1.ObjectMeta{ Name: "name", Namespace: "ns", },
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 05 12:29:55 UTC 2024 - 2.9K bytes - Viewed (0) -
tests/integration/security/remote_jwks/remote_jwks_test.go
timeout string customizeCall func(t framework.TestContext, from echo.Instance, opts *echo.CallOptions) }{ { name: "remote-jwks-without-service-entry", policyFile: "./testdata/requestauthn-no-se.yaml.tmpl", customizeCall: func(t framework.TestContext, from echo.Instance, opts *echo.CallOptions) { opts.HTTP.Path = "/valid-token-forward-remote-jwks"
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Apr 08 22:02:59 UTC 2024 - 4.1K bytes - Viewed (0) -
pkg/config/analysis/analyzers/serviceentry/protocoladdresses.go
}) } func (serviceEntry *ProtocolAddressesAnalyzer) analyzeProtocolAddresses(r *resource.Instance, ctx analysis.Context, metaDNSAutoAllocated bool) { se := r.Message.(*v1alpha3.ServiceEntry) if se.Addresses == nil && !metaDNSAutoAllocated { for index, port := range se.Ports { if port.Protocol == "" || port.Protocol == "TCP" { message := msg.NewServiceEntryAddressesRequired(r)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 01 01:34:15 UTC 2023 - 2.5K 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)