Git-Mirrors/constellation
1
0
Fork 0
mirror of https://github.com/edgelesssys/constellation.git synced 2025-04-20 23:36:29 -04:00
Code Issues Packages Projects Releases Wiki Activity

bootstrapper: only run disk prioritizer on control plane join

Browse Source
This commit is contained in:
Moritz Sanft 2024-05-21 17:31:48 +02:00
parent 9acb4e08b9
commit 5d7800f7fd
No known key found for this signature in database
GPG Key ID: 335D28368B1DA615
2 changed files with 10 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
bootstrapper/internal/kubernetes/BUILD.bazel
View File

@ -31,6 +31,7 @@ go_test(
srcs = ["kubernetes_test.go"],
embed = [":kubernetes"],
deps = [
"//bootstrapper/internal/etcdio",
"//bootstrapper/internal/kubernetes/k8sapi",
"//bootstrapper/internal/kubernetes/kubewaiter",
"//internal/cloud/metadata",

16
bootstrapper/internal/kubernetes/kubernetes.go
View File

@ -263,13 +263,15 @@ func (k *KubeWrapper) JoinCluster(ctx context.Context, args *kubeadm.BootstrapTo
return fmt.Errorf("joining cluster: %v; %w ", string(joinConfigYAML), err)
}
k.log.Info("Prioritizing etcd I/O")
err = k.etcdIOPrioritizer.PrioritizeIO()
if errors.Is(err, etcdio.ErrNoEtcdProcess) {
k.log.Warn("Skipping etcd I/O prioritization as etcd process is not running. " +
"This is expected if this node is a non-control-plane node.")
} else if err != nil {
return fmt.Errorf("prioritizing etcd I/O: %w", err)
// If on control plane (and thus with etcd), try to prioritize etcd I/O.
if peerRole == role.ControlPlane {
k.log.Info("Prioritizing etcd I/O")
err = k.etcdIOPrioritizer.PrioritizeIO()
if errors.Is(err, etcdio.ErrNoEtcdProcess) {
k.log.Warn("No etcd process found, skipping I/O prioritization. Is this a single-node cluster?")
} else if err != nil {
return fmt.Errorf("prioritizing etcd I/O: %w", err)
}
}
return nil