- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 111 for serviceentry (2.52 sec)
-
pkg/config/schema/kubetypes/resources.gen.go
return gvk.Service, true case *k8sioapicorev1.ServiceAccount: return gvk.ServiceAccount, true case *istioioapinetworkingv1alpha3.ServiceEntry: return gvk.ServiceEntry, true case *apiistioioapinetworkingv1alpha3.ServiceEntry: return gvk.ServiceEntry, true case *istioioapinetworkingv1alpha3.Sidecar: return gvk.Sidecar, true case *apiistioioapinetworkingv1alpha3.Sidecar: return gvk.Sidecar, true
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 16:38:40 UTC 2024 - 6.2K bytes - Viewed (0) -
pilot/pkg/bootstrap/servicecontroller.go
func (s *Server) initServiceControllers(args *PilotArgs) error { serviceControllers := s.ServiceController() s.serviceEntryController = serviceentry.NewController( s.configController, s.XDSServer, s.environment.Watcher, serviceentry.WithClusterID(s.clusterID), ) serviceControllers.AddRegistry(s.serviceEntryController) registered := sets.New[provider.ID]()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 3.2K 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) -
pilot/pkg/xds/proxy_dependencies.go
return true } else if proxy.PrevSidecarScope != nil && proxy.PrevSidecarScope.DependsOnConfig(config, push.Mesh.RootNamespace) { return true } case model.Router: if config.Kind == kind.ServiceEntry { // If config is ServiceEntry, name of the config is service's FQDN if features.FilterGatewayClusterConfig && !push.ServiceAttachedToGateway(config.Name, proxy) { return false } hostname := host.Name(config.Name)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 15:58:06 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/config/schema/gvk/resources.gen.go
ServiceEntry = config.GroupVersionKind{Group: "networking.istio.io", Version: "v1alpha3", Kind: "ServiceEntry"} ServiceEntry_v1beta1 = config.GroupVersionKind{Group: "networking.istio.io", Version: "v1beta1", Kind: "ServiceEntry"} ServiceEntry_v1 = config.GroupVersionKind{Group: "networking.istio.io", Version: "v1", Kind: "ServiceEntry"}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 17:37:32 UTC 2024 - 15.6K bytes - Viewed (0) -
pkg/config/validation/validation_test.go
} } } func TestValidateServiceEntries(t *testing.T) { cases := []struct { name string in *networking.ServiceEntry valid bool warning bool }{ { name: "discovery type DNS", in: &networking.ServiceEntry{ Hosts: []string{"*.google.com"}, Ports: []*networking.ServicePort{ {Number: 80, Protocol: "http", Name: "http-valid1"},
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 03:11:45 UTC 2024 - 196K bytes - Viewed (0) -
pkg/kube/krt/join_test.go
services := krt.NewInformer[*corev1.Service](c) serviceEntries := krt.NewInformer[*istioclient.ServiceEntry](c) c.RunAndWait(test.NewStop(t)) pc := clienttest.Wrap(t, kclient.New[*corev1.Pod](c)) sc := clienttest.Wrap(t, kclient.New[*corev1.Service](c)) sec := clienttest.Wrap(t, kclient.New[*istioclient.ServiceEntry](c)) SimplePods := SimplePodCollection(pods) ExtraSimplePods := krt.NewStatic(&SimplePod{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 09 19:55:53 UTC 2024 - 6.1K bytes - Viewed (0) -
pilot/pkg/serviceregistry/util/workloadinstances/index_test.go
"istio.io/istio/pkg/test/util/assert" ) var GlobalTime = time.Now() // ServiceEntry with a selector var selector = &config.Config{ Meta: config.Meta{ GroupVersionKind: gvk.ServiceEntry, Name: "selector", Namespace: "selector", CreationTimestamp: GlobalTime, }, Spec: &networking.ServiceEntry{ Hosts: []string{"selector.com"}, Ports: []*networking.ServicePort{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 5K bytes - Viewed (0)