Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 66 for serviceentry (0.35 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top