- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 525 for nodeIPs (0.12 sec)
-
cmd/kube-proxy/app/server_linux.go
options.FieldSelector = fieldSelector return client.CoreV1().Nodes().List(ctx, options) }, WatchFunc: func(options metav1.ListOptions) (i watch.Interface, e error) { options.FieldSelector = fieldSelector return client.CoreV1().Nodes().Watch(ctx, options) }, } condition := func(event watch.Event) (bool, error) { // don't process delete events
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 08 13:48:54 UTC 2024 - 18.1K bytes - Viewed (0) -
cmd/kube-proxy/app/server.go
backoff := wait.Backoff{ Steps: 6, Duration: 1 * time.Second, Factor: 2.0, Jitter: 0.2, } err := wait.ExponentialBackoff(backoff, func() (bool, error) { node, err := client.CoreV1().Nodes().Get(ctx, name, metav1.GetOptions{}) if err != nil { logger.Error(err, "Failed to retrieve node info") return false, nil } nodeIPs, err = utilnode.GetNodeHostIPs(node)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 26 13:27:41 UTC 2024 - 46.8K bytes - Viewed (0) -
pkg/kubelet/nodestatus/setters.go
) Setter { var nodeIP, secondaryNodeIP net.IP if len(nodeIPs) > 0 { nodeIP = nodeIPs[0] } preferIPv4 := nodeIP == nil || nodeIP.To4() != nil isPreferredIPFamily := func(ip net.IP) bool { return (ip.To4() != nil) == preferIPv4 } nodeIPSpecified := nodeIP != nil && !nodeIP.IsUnspecified() if len(nodeIPs) > 1 { secondaryNodeIP = nodeIPs[1] }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 12:12:04 UTC 2024 - 30.5K bytes - Viewed (0) -
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/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) -
cmd/kube-proxy/app/server_linux_test.go
// start with the new node client := clientsetfake.NewSimpleClientset() client.AddReactor("list", "nodes", func(action clientgotesting.Action) (handled bool, ret runtime.Object, err error) { obj := &v1.NodeList{} return true, obj, nil }) fakeWatch := watch.NewFake() client.PrependWatchReactor("nodes", clientgotesting.DefaultWatchReactor(fakeWatch, nil)) go func() { fakeWatch.Add(node)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 28 15:51:23 UTC 2024 - 21.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_node_status.go
_, err := kl.kubeClient.CoreV1().Nodes().Create(context.TODO(), node, metav1.CreateOptions{}) if err == nil { kl.nodeStartupLatencyTracker.RecordRegisteredNewNode() return true } if !apierrors.IsAlreadyExists(err) { klog.ErrorS(err, "Unable to register node with API server", "node", klog.KObj(node)) return false }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 31.1K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/node_authorizer_test.go
nodes := make([]*corev1.Node, 0, opts.nodes) pods := make([]*corev1.Pod, 0, opts.nodes*opts.podsPerNode) pvs := make([]*corev1.PersistentVolume, 0, (opts.nodes*opts.podsPerNode*opts.uniquePVCsPerPod)+(opts.sharedPVCsPerPod*opts.namespaces)) attachments := make([]*storagev1.VolumeAttachment, 0, opts.nodes*opts.attachmentsPerNode)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 40.5K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_extender.go
func ErrorPrioritizerExtender(pod *v1.Pod, nodes []*framework.NodeInfo) (*framework.NodeScoreList, error) { return &framework.NodeScoreList{}, fmt.Errorf("some error") } // Node1PrioritizerExtender implements PriorityFunc function to give score 10 // if the given node's name is "node1"; otherwise score 1. func Node1PrioritizerExtender(pod *v1.Pod, nodes []*framework.NodeInfo) (*framework.NodeScoreList, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.9K bytes - Viewed (0)