- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 22 for Se (0.02 sec)
-
pkg/dns/server/name_table.go
} out.Table[hostName.String()] = nameInfo } else if provider.ID(ni.Registry) != provider.Kubernetes { // 2 possible cases: // 1. If the SE has multiple addresses(vips) specified, merge the ips // 2. If the previous SE is a decorator of the k8s service, give precedence to the k8s service if svc.Attributes.ServiceRegistry == provider.Kubernetes { ni.Ips = addressList
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 07:19:38 UTC 2024 - 6.3K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/workloadinstances/index_test.go
// GetByIP should return nil verifyGetByIP("1.1.1.1", nil) } func TestIndex_FindAll(t *testing.T) { // Setup a couple of workload instances for test. These will be selected by the `selector` SE wi1 := &model.WorkloadInstance{ Name: selector.Name, Namespace: selector.Namespace, Endpoint: &model.IstioEndpoint{ Address: "2.2.2.2", Labels: map[string]string{"app": "wle"}, // should match
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 5K bytes - Viewed (0) -
pilot/pkg/xds/cds_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 01 02:06:39 UTC 2024 - 9.2K bytes - Viewed (0) -
tests/integration/pilot/multiplecontrolplanes/main_test.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 16:52:52 UTC 2024 - 9.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/store.go
"k8s.io/apimachinery/pkg/types" "istio.io/istio/pilot/pkg/model" "istio.io/istio/pkg/util/sets" ) type hostPort struct { host instancesKey port int } // stores all the service instances from SE, WLE and pods type serviceInstancesStore struct { ip2instance map[string][]*model.ServiceInstance // service instances by hostname -> config instances map[instancesKey]map[configKeyWithParent][]*model.ServiceInstance
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/serviceexportcache_test.go
} } func newServiceExport() *unstructured.Unstructured { se := &mcsapi.ServiceExport{ TypeMeta: metav1.TypeMeta{ Kind: "ServiceExport", APIVersion: mcs.MCSSchemeGroupVersion.String(), }, ObjectMeta: metav1.ObjectMeta{ Name: serviceExportName, Namespace: serviceExportNamespace, }, } return toUnstructured(se) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 18:50:38 UTC 2023 - 9.1K bytes - Viewed (0) -
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) -
pilot/pkg/serviceregistry/kube/controller/ambient/helpers.go
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 22 20:35:23 UTC 2024 - 7.2K bytes - Viewed (0) -
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) -
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)