Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 52 for Se (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. pilot/pkg/serviceregistry/kube/controller/serviceexportcache.go

    	se := controllers.Extract[*unstructured.Unstructured](obj)
    	if se == nil {
    		return nil
    	}
    
    	switch event {
    	case model.EventAdd, model.EventDelete:
    		ec.updateXDS(se)
    	default:
    		// Don't care about updates.
    	}
    	return nil
    }
    
    func (ec *serviceExportCacheImpl) updateXDS(se metav1.Object) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 28 16:41:38 UTC 2024
    - 7.5K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top