Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 111 for serviceentry (2.52 sec)

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