mirror of
https://github.com/rancher/k3k.git
synced 2026-08-18 03:46:31 +00:00
Kevin McDermottandEnrico Candino
d975171920
This modifies the configuration of the created nodes via virtual-kubelet to set the node type to be worker instead of agent. Bump the Ginkgo version to the latest - allows use of `t.Context()` rather than creating contexts. Co-authored-by: Enrico Candino <enrico.candino@gmail.com>
104 lines
3.2 KiB
Go
104 lines
3.2 KiB
Go
package provider
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/go-logr/logr"
|
|
"k8s.io/apimachinery/pkg/types"
|
|
"sigs.k8s.io/controller-runtime/pkg/client"
|
|
"sigs.k8s.io/controller-runtime/pkg/manager"
|
|
|
|
corev1 "k8s.io/api/core/v1"
|
|
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
|
|
|
|
"github.com/rancher/k3k/pkg/apis/k3k.io/v1beta1"
|
|
)
|
|
|
|
func ConfigureNode(logger logr.Logger, node *corev1.Node, hostname string, servicePort int, ip string, hostMgr manager.Manager, virtualClient client.Client, virtualCluster v1beta1.Cluster, version string, mirrorHostNodes bool) error {
|
|
ctx := context.Background()
|
|
|
|
if mirrorHostNodes {
|
|
var hostNode corev1.Node
|
|
if err := hostMgr.GetAPIReader().Get(ctx, types.NamespacedName{Name: node.Name}, &hostNode); err != nil {
|
|
logger.Error(err, "error getting host node for mirroring", "node", node.Name)
|
|
return err
|
|
}
|
|
|
|
node.Spec = *hostNode.Spec.DeepCopy()
|
|
node.Status = *hostNode.Status.DeepCopy()
|
|
node.Labels = hostNode.GetLabels()
|
|
node.Annotations = hostNode.GetAnnotations()
|
|
node.Finalizers = hostNode.GetFinalizers()
|
|
node.Status.DaemonEndpoints.KubeletEndpoint.Port = int32(servicePort)
|
|
} else {
|
|
node.Status.Conditions = nodeConditions()
|
|
node.Status.DaemonEndpoints.KubeletEndpoint.Port = int32(servicePort)
|
|
node.Status.Addresses = []corev1.NodeAddress{
|
|
{
|
|
Type: corev1.NodeHostName,
|
|
Address: hostname,
|
|
},
|
|
{
|
|
Type: corev1.NodeInternalIP,
|
|
Address: ip,
|
|
},
|
|
}
|
|
|
|
node.Labels["node.kubernetes.io/exclude-from-external-load-balancers"] = "true"
|
|
node.Labels["kubernetes.io/os"] = "linux"
|
|
|
|
// configure versions
|
|
node.Status.NodeInfo.KubeletVersion = version
|
|
|
|
startNodeCapacityUpdater(ctx, logger, hostMgr.GetClient(), virtualClient, virtualCluster, node.Name)
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// nodeConditions returns the basic conditions which mark the node as ready
|
|
func nodeConditions() []corev1.NodeCondition {
|
|
return []corev1.NodeCondition{
|
|
{
|
|
Type: "Ready",
|
|
Status: corev1.ConditionTrue,
|
|
LastHeartbeatTime: metav1.Now(),
|
|
LastTransitionTime: metav1.Now(),
|
|
Reason: "KubeletReady",
|
|
Message: "kubelet is ready.",
|
|
},
|
|
{
|
|
Type: "OutOfDisk",
|
|
Status: corev1.ConditionFalse,
|
|
LastHeartbeatTime: metav1.Now(),
|
|
LastTransitionTime: metav1.Now(),
|
|
Reason: "KubeletHasSufficientDisk",
|
|
Message: "kubelet has sufficient disk space available",
|
|
},
|
|
{
|
|
Type: "MemoryPressure",
|
|
Status: corev1.ConditionFalse,
|
|
LastHeartbeatTime: metav1.Now(),
|
|
LastTransitionTime: metav1.Now(),
|
|
Reason: "KubeletHasSufficientMemory",
|
|
Message: "kubelet has sufficient memory available",
|
|
},
|
|
{
|
|
Type: "DiskPressure",
|
|
Status: corev1.ConditionFalse,
|
|
LastHeartbeatTime: metav1.Now(),
|
|
LastTransitionTime: metav1.Now(),
|
|
Reason: "KubeletHasNoDiskPressure",
|
|
Message: "kubelet has no disk pressure",
|
|
},
|
|
{
|
|
Type: "NetworkUnavailable",
|
|
Status: corev1.ConditionFalse,
|
|
LastHeartbeatTime: metav1.Now(),
|
|
LastTransitionTime: metav1.Now(),
|
|
Reason: "RouteCreated",
|
|
Message: "RouteController created a route",
|
|
},
|
|
}
|
|
}
|