- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 27 for NodeIPs (0.2 sec)
-
pkg/proxy/nftables/helpers_test.go
markMasq bool } // newNFTablesTracer creates an nftablesTracer. nodeIPs are the IP to treat as local node // IPs (for determining whether rules with "fib saddr type local" or "fib daddr type // local" match). func newNFTablesTracer(t *testing.T, nft *knftables.Fake, nodeIPs []string) *nftablesTracer { return &nftablesTracer{ nft: nft, nodeIPs: sets.New(nodeIPs...), t: t, } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 09:57:47 UTC 2024 - 48.5K bytes - Viewed (0) -
pkg/envoy/proxy_test.go
proxyConfig.Concurrency = &wrapperspb.Int32Value{Value: 8} cfg := ProxyConfig{ LogLevel: "trace", ComponentLogLevel: "misc:error", NodeIPs: []string{"10.75.2.9", "192.168.11.18"}, BinaryPath: proxyConfig.BinaryPath, ConfigPath: proxyConfig.ConfigPath, ConfigCleanup: true, AdminPort: proxyConfig.ProxyAdminPort,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 09 11:45:51 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier.go
// List of node IP addresses to be used as IPVS services if nodePort is set. This // can be reused for all nodePort services. var nodeIPs []net.IP if hasNodePort { if proxier.nodePortAddresses.MatchAll() { for _, ipStr := range nodeAddressSet.UnsortedList() { nodeIPs = append(nodeIPs, netutils.ParseIPSloppy(ipStr)) } } else { allNodeIPs, err := proxier.nodePortAddresses.GetNodeIPs(proxier.networkInterfacer)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 77.7K bytes - Viewed (0) -
pkg/proxy/nftables/proxier.go
localDetectors[v1.IPv4Protocol], hostname, nodeIPs[v1.IPv4Protocol], recorder, healthzServer, nodePortAddresses, initOnly) if err != nil { return nil, fmt.Errorf("unable to create ipv4 proxier: %v", err) } ipv6Proxier, err := NewProxier(ctx, v1.IPv6Protocol, syncPeriod, minSyncPeriod, masqueradeAll, masqueradeBit, localDetectors[v1.IPv6Protocol], hostname, nodeIPs[v1.IPv6Protocol],
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 55.5K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods_test.go
testKubelet := newTestKubelet(t, false /* controllerAttachDetachEnabled */) defer testKubelet.Cleanup() kl := testKubelet.kubelet for _, ip := range tc.nodeIPs { kl.nodeIPs = append(kl.nodeIPs, netutils.ParseIPSloppy(ip)) } kl.nodeLister = testNodeLister{nodes: []*v1.Node{ { ObjectMeta: metav1.ObjectMeta{Name: string(kl.nodeName)}, Status: v1.NodeStatus{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 00:05:23 UTC 2024 - 198.8K bytes - Viewed (0) -
pkg/proxy/ipvs/proxier_test.go
} func NewFakeProxier(ctx context.Context, ipt utiliptables.Interface, ipvs utilipvs.Interface, ipset utilipset.Interface, nodeIPs []string, excludeCIDRs []*net.IPNet, ipFamily v1.IPFamily) *Proxier { netlinkHandle := netlinktest.NewFakeNetlinkHandle(ipFamily == v1.IPv6Protocol) netlinkHandle.SetLocalAddresses("eth0", nodeIPs...) // initialize ipsetList with all sets we needed ipsetList := make(map[string]*IPSet)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 01:31:57 UTC 2024 - 186.8K bytes - Viewed (0) -
pkg/proxy/winkernel/proxier.go
hostname, nodeIPs[v1.IPv4Protocol], recorder, healthzServer, healthzBindAddress, config) if err != nil { return nil, fmt.Errorf("unable to create ipv4 proxier: %v, hostname: %s, nodeIP:%v", err, hostname, nodeIPs[v1.IPv4Protocol]) } ipv6Proxier, err := NewProxier(v1.IPv6Protocol, syncPeriod, minSyncPeriod, hostname, nodeIPs[v1.IPv6Protocol], recorder, healthzServer,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 13:25:06 UTC 2024 - 59K bytes - Viewed (0) -
pkg/bootstrap/config.go
for _, val := range values { ret = append(ret, strings.Replace(pattern, varName, val, -1)) } } return ret } func getStatsOptions(meta *model.BootstrapNodeMetadata) []option.Instance { nodeIPs := meta.InstanceIPs config := meta.ProxyConfig tagAnno := meta.Annotations[annotation.SidecarExtraStatTags.Name] prefixAnno := meta.Annotations[annotation.SidecarStatsInclusionPrefixes.Name]
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 14 17:02:38 UTC 2024 - 27.6K bytes - Viewed (0) -
pilot/cmd/pilot-agent/app/cmd.go
} envoyOptions := envoy.ProxyConfig{ LogLevel: proxyArgs.ProxyLogLevel, ComponentLogLevel: proxyArgs.ProxyComponentLogLevel, LogAsJSON: loggingOptions.JSONEncoding, NodeIPs: proxyArgs.IPAddresses, Sidecar: proxyArgs.Type == model.SidecarProxy, OutlierLogPath: proxyArgs.OutlierLogPath, } agentOptions := options.NewAgentOptions(&proxyArgs, proxyConfig, sds)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 22:12:28 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/proxy/iptables/proxier.go
destinations, "-j", string(kubeNodePortsChain)) } else { nodeIPs, err := proxier.nodePortAddresses.GetNodeIPs(proxier.networkInterfacer) if err != nil { proxier.logger.Error(err, "Failed to get node ip address matching nodeport cidrs, services with nodeport may not work as intended", "CIDRs", proxier.nodePortAddresses) } for _, ip := range nodeIPs { if ip.IsLoopback() { if isIPv6 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 14:39:54 UTC 2024 - 65.1K bytes - Viewed (0)