Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 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/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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. pilot/pkg/networking/core/serviceentry_simulation_test.go

    // limitations under the License.
    package core_test
    
    import (
    	"fmt"
    	"testing"
    
    	"istio.io/istio/pilot/pkg/model"
    	"istio.io/istio/pilot/pkg/simulation"
    	"istio.io/istio/pilot/test/xds"
    )
    
    const se = `
    apiVersion: networking.istio.io/v1alpha3
    kind: ServiceEntry
    metadata:
      name: se1
    spec:
      hosts:
      - blah.somedomain
      addresses:
      - %s
      ports:
      - number: 9999
        name: TCP-9999
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 02 21:06:06 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  9. pkg/config/analysis/analyzers/util/service_lookup.go

    		s := r.Message.(*corev1.ServiceSpec)
    		var se *v1alpha3.ServiceEntry
    		var ports []*v1alpha3.ServicePort
    		for _, p := range s.Ports {
    			ports = append(ports, &v1alpha3.ServicePort{
    				Number:   uint32(p.Port),
    				Name:     p.Name,
    				Protocol: string(p.Protocol),
    			})
    		}
    		host := ConvertHostToFQDN(r.Metadata.FullName.Namespace, r.Metadata.FullName.Name.String())
    		se = &v1alpha3.ServiceEntry{
    			Hosts: []string{host},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Aug 21 21:37:53 UTC 2023
    - 5K bytes
    - Viewed (0)
  10. pkg/kube/krt/join_test.go

    	})
    
    	se := &istioclient.ServiceEntry{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "svc-entry",
    			Namespace: "namespace",
    		},
    		Spec: istio.ServiceEntry{WorkloadSelector: &istio.WorkloadSelector{Labels: map[string]string{"app": "foo"}}},
    	}
    	sec.Create(se)
    	assert.EventuallyEqual(t, fetch, []SimpleEndpoint{
    		{pod.Name, se.Name, pod.Namespace, pod.Status.PodIP},
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 09 19:55:53 UTC 2024
    - 6.1K bytes
    - Viewed (0)
Back to top