mirror of
https://github.com/optim-enterprises-bv/kubernetes.git
synced 2025-10-31 02:08:13 +00:00
d6c575532a
KubeProxy operates with a single health server and two proxies, one for each IP family. The use of the term 'proxier' in the types and functions within pkg/proxy/healthcheck can be misleading, as it may suggest the existence of two health servers, one for each IP family. Signed-off-by: Daman Arora <aroradaman@gmail.com>
112 lines
3.5 KiB
Go
112 lines
3.5 KiB
Go
/*
|
|
Copyright 2022 The Kubernetes Authors.
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
package proxy
|
|
|
|
import (
|
|
"context"
|
|
"reflect"
|
|
"sync"
|
|
|
|
v1 "k8s.io/api/core/v1"
|
|
"k8s.io/klog/v2"
|
|
"k8s.io/kubernetes/pkg/proxy/config"
|
|
"k8s.io/kubernetes/pkg/proxy/healthcheck"
|
|
)
|
|
|
|
// NodePodCIDRHandler handles the life cycle of kube-proxy based on the node PodCIDR assigned
|
|
// Implements the config.NodeHandler interface
|
|
// https://issues.k8s.io/111321
|
|
type NodePodCIDRHandler struct {
|
|
mu sync.Mutex
|
|
podCIDRs []string
|
|
logger klog.Logger
|
|
}
|
|
|
|
func NewNodePodCIDRHandler(ctx context.Context, podCIDRs []string) *NodePodCIDRHandler {
|
|
return &NodePodCIDRHandler{
|
|
podCIDRs: podCIDRs,
|
|
logger: klog.FromContext(ctx),
|
|
}
|
|
}
|
|
|
|
var _ config.NodeHandler = &NodePodCIDRHandler{}
|
|
|
|
// OnNodeAdd is a handler for Node creates.
|
|
func (n *NodePodCIDRHandler) OnNodeAdd(node *v1.Node) {
|
|
n.mu.Lock()
|
|
defer n.mu.Unlock()
|
|
|
|
podCIDRs := node.Spec.PodCIDRs
|
|
// initialize podCIDRs
|
|
if len(n.podCIDRs) == 0 && len(podCIDRs) > 0 {
|
|
n.logger.Info("Setting current PodCIDRs", "podCIDRs", podCIDRs)
|
|
n.podCIDRs = podCIDRs
|
|
return
|
|
}
|
|
if !reflect.DeepEqual(n.podCIDRs, podCIDRs) {
|
|
n.logger.Error(nil, "Using NodeCIDR LocalDetector mode, current PodCIDRs are different than previous PodCIDRs, restarting",
|
|
"node", klog.KObj(node), "newPodCIDRs", podCIDRs, "oldPodCIDRs", n.podCIDRs)
|
|
klog.FlushAndExit(klog.ExitFlushTimeout, 1)
|
|
}
|
|
}
|
|
|
|
// OnNodeUpdate is a handler for Node updates.
|
|
func (n *NodePodCIDRHandler) OnNodeUpdate(_, node *v1.Node) {
|
|
n.mu.Lock()
|
|
defer n.mu.Unlock()
|
|
podCIDRs := node.Spec.PodCIDRs
|
|
// initialize podCIDRs
|
|
if len(n.podCIDRs) == 0 && len(podCIDRs) > 0 {
|
|
n.logger.Info("Setting current PodCIDRs", "podCIDRs", podCIDRs)
|
|
n.podCIDRs = podCIDRs
|
|
return
|
|
}
|
|
if !reflect.DeepEqual(n.podCIDRs, podCIDRs) {
|
|
n.logger.Error(nil, "Using NodeCIDR LocalDetector mode, current PodCIDRs are different than previous PodCIDRs, restarting",
|
|
"node", klog.KObj(node), "newPodCIDRs", podCIDRs, "oldPODCIDRs", n.podCIDRs)
|
|
klog.FlushAndExit(klog.ExitFlushTimeout, 1)
|
|
}
|
|
}
|
|
|
|
// OnNodeDelete is a handler for Node deletes.
|
|
func (n *NodePodCIDRHandler) OnNodeDelete(node *v1.Node) {
|
|
n.logger.Error(nil, "Current Node is being deleted", "node", klog.KObj(node))
|
|
}
|
|
|
|
// OnNodeSynced is a handler for Node syncs.
|
|
func (n *NodePodCIDRHandler) OnNodeSynced() {}
|
|
|
|
// NodeEligibleHandler handles the life cycle of the Node's eligibility, as
|
|
// determined by the health server for directing load balancer traffic.
|
|
type NodeEligibleHandler struct {
|
|
HealthServer *healthcheck.ProxyHealthServer
|
|
}
|
|
|
|
var _ config.NodeHandler = &NodeEligibleHandler{}
|
|
|
|
// OnNodeAdd is a handler for Node creates.
|
|
func (n *NodeEligibleHandler) OnNodeAdd(node *v1.Node) { n.HealthServer.SyncNode(node) }
|
|
|
|
// OnNodeUpdate is a handler for Node updates.
|
|
func (n *NodeEligibleHandler) OnNodeUpdate(_, node *v1.Node) { n.HealthServer.SyncNode(node) }
|
|
|
|
// OnNodeDelete is a handler for Node deletes.
|
|
func (n *NodeEligibleHandler) OnNodeDelete(node *v1.Node) { n.HealthServer.SyncNode(node) }
|
|
|
|
// OnNodeSynced is a handler for Node syncs.
|
|
func (n *NodeEligibleHandler) OnNodeSynced() {}
|