- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 66 for serviceentry (0.35 sec)
-
pilot/pkg/serviceregistry/serviceentry/conversion.go
serviceEntry := cfg.Spec.(*networking.ServiceEntry) if serviceEntry == nil { return nil } if services == nil { services = convertServices(cfg) } endpointsNum := len(serviceEntry.Endpoints) hostnameToServiceInstance := false if len(serviceEntry.Endpoints) == 0 && serviceEntry.WorkloadSelector == nil && isDNSTypeServiceEntry(serviceEntry) { hostnameToServiceInstance = true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 16.9K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/conversion_test.go
makeInstance(httpStatic, "2.2.2.2", 18080, httpStatic.Spec.(*networking.ServiceEntry).Ports[1], nil, MTLS), makeInstance(httpStatic, "3.3.3.3", 1080, httpStatic.Spec.(*networking.ServiceEntry).Ports[0], nil, MTLS), makeInstance(httpStatic, "3.3.3.3", 8080, httpStatic.Spec.(*networking.ServiceEntry).Ports[1], nil, MTLS),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 39K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
// from a ServiceEntry selector, the parent is the ServiceEntry // This is used to distinguish between 1 config (Pod/SE) selected by 2 different parents (ServiceEntry). type configKeyWithParent struct { configKey parent types.NamespacedName } // configKey unique identifies a config object managed by this registry (ServiceEntry and WorkloadEntry) type configKey struct { kind configType
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
pkg/config/schema/collections/collections.agent.gen.go
}.MustBuild() ServiceEntry = resource.Builder{ Identifier: "ServiceEntry", Group: "networking.istio.io", Kind: "ServiceEntry", Plural: "serviceentries", Version: "v1alpha3", VersionAliases: []string{ "v1beta1", "v1", }, Proto: "istio.networking.v1alpha3.ServiceEntry", StatusProto: "istio.meta.v1alpha1.IstioStatus",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Apr 25 14:44:17 UTC 2024 - 12.9K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/client_test.go
selectedLabels := labels[i%len(labels)] obj := &clientnetworkingv1alpha3.ServiceEntry{ ObjectMeta: metav1.ObjectMeta{ Name: fmt.Sprintf("test-service-entry-%d", i), Namespace: "test", Labels: selectedLabels, }, Spec: v1alpha3.ServiceEntry{}, } clienttest.NewWriter[*clientnetworkingv1alpha3.ServiceEntry](t, fake).Create(obj)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 10 02:58:52 UTC 2024 - 14.1K bytes - Viewed (0) -
pilot/pkg/xds/proxy_dependencies_test.go
model.ConfigKey{Kind: kind.ServiceEntry, Name: svcName + invalidNameSuffix, Namespace: nsName}, ), true}, {"mixture unmatched and unmatched config for sidecar", sidecar, sets.New( model.ConfigKey{Kind: kind.DestinationRule, Name: drName + invalidNameSuffix, Namespace: nsName}, model.ConfigKey{Kind: kind.ServiceEntry, Name: svcName + invalidNameSuffix, Namespace: nsName}, ), false},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 22:20:44 UTC 2024 - 13.5K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/multicluster.go
configStore := createWleConfigStore(client, m.revision, options) kubeController.workloadEntryController = serviceentry.NewWorkloadEntryController( configStore, options.XDSUpdater, m.opts.MeshWatcher, serviceentry.WithClusterID(cluster.ID), serviceentry.WithNetworkIDCb(kubeRegistry.Network))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
pilot/pkg/xds/eds.go
// This is the main method implementing EDS. // It replaces InstancesByPort in model - instead of iterating over all endpoints it uses // the hostname-keyed map. And it avoids the conversion from Endpoint to ServiceEntry to envoy // on each step: instead the conversion happens once, when an endpoint is first discovered. func (s *DiscoveryServer) EDSUpdate(shard model.ShardKey, serviceName string, namespace string,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 15:58:06 UTC 2024 - 9.9K bytes - Viewed (0) -
pilot/pkg/xds/xds_test.go
"cluster-1": {"10.0.0.1:7070", "10.1.1.1:7070", "10.0.0.2:7070"}, "cluster-2": {"10.0.0.1:7070", "10.1.1.1:7070", "10.0.0.2:7070"}, }, }, "serviceentry": { fakeOpts: xds.FakeOptions{ ConfigString: ` apiVersion: networking.istio.io/v1alpha3 kind: ServiceEntry metadata: name: external-svc-mongocluster spec: hosts: - mymongodb.somedomain addresses: - 192.192.192.192/24 # VIPs
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 27 16:59:05 UTC 2024 - 13.8K bytes - Viewed (0) -
pilot/pkg/networking/core/fake.go
if xdsUpdater == nil { xdsUpdater = model.NewEndpointIndexUpdater(env.EndpointIndex) } serviceDiscovery := aggregate.NewController(aggregate.Options{}) se := serviceentry.NewController( configController, xdsUpdater, env.Watcher, serviceentry.WithClusterID(opts.ClusterID)) // TODO allow passing in registry, for k8s, mem reigstry serviceDiscovery.AddRegistry(se)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 11.5K bytes - Viewed (0)