Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for DiscoverIPMode (0.18 sec)

  1. pilot/pkg/xds/bench_test.go

    		ConfigNamespace:  "default",
    		VerifiedIdentity: &spiffe.Identity{Namespace: "default"},
    	}
    	proxy.IstioVersion = model.ParseIstioVersion(proxy.Metadata.IstioVersion)
    	// need to call DiscoverIPMode to check the ipMode of the proxy
    	proxy.DiscoverIPMode()
    
    	configs, k8sConfig := getConfigsWithCache(t, config)
    	m := mesh.DefaultMeshConfig()
    	m.ExtensionProviders = append(m.ExtensionProviders, &meshconfig.MeshConfig_ExtensionProvider{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Apr 22 18:13:40 UTC 2024
    - 19.7K bytes
    - Viewed (0)
  2. pilot/pkg/networking/core/listener_test.go

    		IPAddresses: []string{"1.1.1.1"},
    		ID:          "v0.default",
    		DNSDomain:   "default.example.org",
    		Metadata: &model.NodeMetadata{
    			Namespace: "not-default",
    		},
    		ConfigNamespace: "not-default",
    	}
    	pr.DiscoverIPMode()
    	return pr
    }
    
    func getIPv6Proxy() *model.Proxy {
    	pr := &model.Proxy{
    		Type:        model.SidecarProxy,
    		IPAddresses: []string{"2001:1::1"},
    		Metadata: &model.NodeMetadata{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 01:56:28 UTC 2024
    - 93.6K bytes
    - Viewed (0)
  3. pilot/pkg/model/context.go

    	} else {
    		// If could not find pod labels, fallback to use the node metadata labels.
    		node.Labels = node.Metadata.Labels
    	}
    }
    
    // DiscoverIPMode discovers the IP Versions supported by Proxy based on its IP addresses.
    func (node *Proxy) DiscoverIPMode() {
    	node.ipMode = pm.DiscoverIPMode(node.IPAddresses)
    	node.GlobalUnicastIP = networkutil.GlobalUnicastIP(node.IPAddresses)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 33.6K bytes
    - Viewed (0)
  4. pilot/pkg/networking/core/fake.go

    		p.IPAddresses = []string{"1.1.1.1"}
    	}
    
    	// Initialize data structures
    	pc := f.PushContext()
    	p.SetSidecarScope(pc)
    	p.SetServiceTargets(f.env.ServiceDiscovery)
    	p.SetGatewaysForProxy(pc)
    	p.DiscoverIPMode()
    	return p
    }
    
    func (f *ConfigGenTest) Listeners(p *model.Proxy) []*listener.Listener {
    	return f.ConfigGen.BuildListeners(p, f.PushContext())
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  5. pilot/pkg/model/context_test.go

    			expect: "fc00:f853:ccd:e793::1",
    		},
    	}
    	for _, tt := range cases {
    		t.Run(tt.name, func(t *testing.T) {
    			var node model.Proxy
    			node.IPAddresses = tt.in
    			node.DiscoverIPMode()
    			if got := node.GlobalUnicastIP; got != tt.expect {
    				t.Errorf("GlobalUnicastIP = %v, want %v", got, tt.expect)
    			}
    		})
    	}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Apr 05 23:51:52 UTC 2024
    - 11.2K bytes
    - Viewed (0)
  6. pilot/cmd/pilot-agent/app/cmd.go

    	})
    
    	proxyArgs.IPAddresses = append(proxyArgs.IPAddresses, proxyAddrs...)
    	log.Debugf("proxy IPAddresses: %v", proxyArgs.IPAddresses)
    
    	// After IP addresses are set, let us discover IPMode.
    	proxyArgs.DiscoverIPMode()
    
    	// Extract pod variables.
    	proxyArgs.ID = proxyArgs.PodName + "." + proxyArgs.PodNamespace
    
    	// If not set, set a default based on platform - podNamespace.svc.cluster.local for
    	// K8S
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 16 22:12:28 UTC 2024
    - 11.9K bytes
    - Viewed (0)
  7. pkg/istio-agent/agent.go

    type Proxy struct {
    	ID          string
    	IPAddresses []string
    	Type        model.NodeType
    	ipMode      model.IPMode
    	DNSDomain   string
    }
    
    func (node *Proxy) DiscoverIPMode() {
    	node.ipMode = model.DiscoverIPMode(node.IPAddresses)
    }
    
    // IsIPv6 returns true if proxy only supports IPv6 addresses.
    func (node *Proxy) IsIPv6() bool {
    	return node.ipMode == model.IPv6
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Jun 05 10:02:56 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  8. pkg/model/proxy.go

    	}
    }
    
    // IPMode represents the IP mode of proxy.
    type IPMode int
    
    // IPMode constants starting with index 1.
    const (
    	IPv4 IPMode = iota + 1
    	IPv6
    	Dual
    )
    
    func DiscoverIPMode(addrs []string) IPMode {
    	if networkutil.AllIPv4(addrs) {
    		return IPv4
    	} else if networkutil.AllIPv6(addrs) {
    		return IPv6
    	}
    	return Dual
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 25 17:18:17 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  9. pilot/pkg/xds/ads.go

    	if err := s.WorkloadEntryController.OnConnect(con); err != nil {
    		return err
    	}
    	s.computeProxyState(proxy, nil)
    	// Discover supported IP Versions of proxy so that appropriate config can be delivered.
    	proxy.DiscoverIPMode()
    
    	proxy.WatchedResources = map[string]*model.WatchedResource{}
    	// Based on node metadata and version, we can associate a different generator.
    	if proxy.Metadata.Generator != "" {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 23.4K bytes
    - Viewed (0)
Back to top