Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 50 for Se (0.03 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. pilot/pkg/networking/apigen/apigen_test.go

    		if err != nil {
    			t.Fatal("Failed to receive lds", err)
    		}
    
    		ses := adscConn.Store.List(gvk.ServiceEntry, "")
    		for _, se := range ses {
    			t.Log(se)
    		}
    		sec := adscConn.Store.List(gvk.EnvoyFilter, "")
    		for _, se := range sec {
    			t.Log(se)
    		}
    	})
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 12 18:20:36 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/serviceentry/controller_test.go

    		// same as selector but with an additional host
    		selector1 := func() *config.Config {
    			c := httpStaticOverlay.DeepCopy()
    			se := c.Spec.(*networking.ServiceEntry)
    			se.Hosts = append(se.Hosts, "selector1.com")
    			se.Endpoints = nil
    			se.WorkloadSelector = &networking.WorkloadSelector{
    				Labels: map[string]string{"app": "wle"},
    			}
    			return &c
    		}()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 92.9K bytes
    - Viewed (0)
Back to top