Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 52 for Se (0.09 sec)

  1. tests/integration/pilot/workloadentry_test.go

    			}
    			cfg.ApplyOrFail(t)
    
    			// create a unique SE per cluster
    			for _, c := range t.Clusters().Configs() {
    				t.ConfigKube(c).YAML(apps.Namespace.Name(), fmt.Sprintf(seTmpl, c.Name())).ApplyOrFail(t)
    			}
    
    			weTmpl := `
    apiVersion: networking.istio.io/v1alpha3
    kind: WorkloadEntry
    metadata:
      name: se-cross-network-{{.testName}}
      labels:
        app: b
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  2. pilot/pkg/serviceregistry/kube/controller/ambient/helpers.go

    }
    
    // name format: <cluster>/<group>/<kind>/<namespace>/<name></section-name>
    // section name should be the WE address, which needs to be stable across SE updates (it is assumed WE addresses are unique)
    func (a *index) generateServiceEntryUID(svcEntryNamespace, svcEntryName, addr string) string {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Mar 22 20:35:23 UTC 2024
    - 7.2K bytes
    - Viewed (0)
  3. pilot/pkg/model/gateway.go

    		portNumber, _, _ := ParseGatewayRDSRouteName(r)
    		if _, f := pm[portNumber]; !f {
    			pm[portNumber] = sets.New[int]()
    		}
    		for _, se := range s {
    			if se.Port == nil {
    				continue
    			}
    			pm[portNumber].Insert(int(se.Port.Number))
    		}
    	}
    	return pm
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 26K bytes
    - Viewed (0)
  4. tests/integration/pilot/mcs/autoexport/autoexport_test.go

    	framework.
    		NewSuite(m).
    		Label(label.CustomSetup).
    		RequireMultiPrimary().
    		RequireMinVersion(17).
    		Setup(common.InstallMCSCRDs).
    		Setup(istio.Setup(&i, enableMCSAutoExport)).
    		Setup(common.DeployEchosFunc("se", &echos)).
    		Run()
    }
    
    func TestAutoExport(t *testing.T) {
    	framework.NewTest(t).
    		Run(func(ctx framework.TestContext) {
    			serviceExportGVR := common.KubeSettings(ctx).ServiceExportGVR()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  5. tests/integration/security/egress_sidecar_tls_origination_test.go

    ) {
    	args := map[string]any{
    		"to":               to,
    		"Mode":             destinationRuleMode,
    		"CredentialName":   credentialName,
    		"WorkloadSelector": workloadSelector,
    	}
    	se := `
    apiVersion: networking.istio.io/v1alpha3
    kind: ServiceEntry
    metadata:
      name: originate-mtls-for-nginx
    spec:
      hosts:
      - "{{ .to.Config.ClusterLocalFQDN }}"
      ports:
      - number: 80
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  6. pilot/pkg/serviceregistry/kube/controller/ambient/ambientindex_test.go

    	epAddresses []string,
    ) {
    	t.Helper()
    
    	se := &apiv1alpha3.ServiceEntry{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      name,
    			Namespace: ns,
    			Labels:    labels,
    		},
    		Spec:   *generateServiceEntry(hostStr, addresses, labels, epAddresses),
    		Status: v1alpha1.IstioStatus{},
    	}
    	s.se.CreateOrUpdate(se)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 01:04:50 UTC 2024
    - 70.2K bytes
    - Viewed (0)
  7. pilot/pkg/xds/nds_test.go

    					},
    				},
    			},
    		},
    	}
    	for _, tt := range cases {
    		t.Run(tt.name, func(t *testing.T) {
    			s := xds.NewFakeDiscoveryServer(t, xds.FakeOptions{
    				ConfigString: mustReadFile(t, "./testdata/nds-se.yaml"),
    			})
    
    			ads := s.ConnectADS().WithType(v3.NameTableType)
    			res := ads.RequestResponseAck(t, &discovery.DiscoveryRequest{
    				Node: &core.Node{
    					Id:       ads.ID,
    					Metadata: tt.meta.ToStruct(),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Mar 27 16:59:05 UTC 2024
    - 4.6K bytes
    - Viewed (0)
  8. pilot/pkg/serviceregistry/kube/controller/controller.go

    	// Add the ServiceExport info.
    	for _, se := range c.exports.ExportedServices() {
    		mcsService := outMap[se.namespacedName]
    		mcsService.Cluster = c.Cluster()
    		mcsService.Name = se.namespacedName.Name
    		mcsService.Namespace = se.namespacedName.Namespace
    		mcsService.Exported = true
    		mcsService.Discoverability = se.discoverability
    		outMap[se.namespacedName] = mcsService
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 41.2K bytes
    - Viewed (0)
  9. pilot/pkg/serviceregistry/serviceentry/store_test.go

    	store.updateServiceEntryInstances(key, expectedSeInstances)
    
    	gotSeInstances := store.getServiceEntryInstances(key)
    	if !reflect.DeepEqual(gotSeInstances, expectedSeInstances) {
    		t.Errorf("got unexpected se instances : %v", gotSeInstances)
    	}
    
    	// 5. test deleteServiceEntryInstances
    	store.deleteServiceEntryInstances(key, cKey)
    	gotSeInstances = store.getServiceEntryInstances(key)
    	if len(gotSeInstances) != 0 {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 29 15:31:09 UTC 2024
    - 8.1K bytes
    - Viewed (0)
  10. tests/integration/telemetry/api/stats_test.go

    			t.ConfigIstio().File(apps.Namespace.Name(), filepath.Join(base, "istio-mtls-gateway.yaml")).ApplyOrFail(t)
    			t.ConfigIstio().File(apps.Namespace.Name(), filepath.Join(base, "istio-mtls-vs.yaml")).ApplyOrFail(t)
    
    			// The main SE is available only to app namespace, make one the egress can access.
    			t.ConfigIstio().Eval(ist.Settings().SystemNamespace, map[string]any{
    				"Namespace": apps.External.Namespace.Name(),
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 08 22:02:59 UTC 2024
    - 17.3K bytes
    - Viewed (0)
Back to top