treewide: bump k8s to v0.34.1
Change-Id: Ie3b1296ac4788aa27aaa2985c72da6c56ea3d281
Reviewed-on: https://review.monogon.dev/c/monogon/+/4626
Reviewed-by: Lorenz Brun <lorenz@monogon.tech>
Tested-by: Jenkins CI
diff --git a/metropolis/node/kubernetes/csi.go b/metropolis/node/kubernetes/csi.go
index be9e3f5..92c700e 100644
--- a/metropolis/node/kubernetes/csi.go
+++ b/metropolis/node/kubernetes/csi.go
@@ -266,6 +266,8 @@
// in Kubelet which requires it to remove and recreate its gRPC socket for
// every new registration attempt.
type pluginRegistrationServer struct {
+ pluginregistration.UnimplementedRegistrationServer
+
// regErr has a buffer of 1, so that at least one error can always be
// sent into it in a non-blocking way. There is a race if
// NotifyRegistrationStatus is called twice with an error as the buffered
diff --git a/metropolis/node/kubernetes/hyperkube/main.go b/metropolis/node/kubernetes/hyperkube/main.go
index 5c76acf..3807d0f 100644
--- a/metropolis/node/kubernetes/hyperkube/main.go
+++ b/metropolis/node/kubernetes/hyperkube/main.go
@@ -15,6 +15,7 @@
package main
import (
+ "context"
"fmt"
"os"
@@ -33,7 +34,7 @@
"kube-apiserver": kubeapiserver.NewAPIServerCommand,
"kube-controller-manager": kubecontrollermanager.NewControllerManagerCommand,
"kube-scheduler": func() *cobra.Command { return kubescheduler.NewSchedulerCommand() },
- "kubelet": kubelet.NewKubeletCommand,
+ "kubelet": func() *cobra.Command { return kubelet.NewKubeletCommand(context.Background()) },
}
func main() {
diff --git a/metropolis/node/kubernetes/plugins/kvmdevice/kvmdevice.go b/metropolis/node/kubernetes/plugins/kvmdevice/kvmdevice.go
index b75831a..15f1d9e 100644
--- a/metropolis/node/kubernetes/plugins/kvmdevice/kvmdevice.go
+++ b/metropolis/node/kubernetes/plugins/kvmdevice/kvmdevice.go
@@ -35,7 +35,8 @@
var Name corev1.ResourceName = "devices.monogon.dev/kvm"
type Plugin struct {
- *deviceplugin.UnimplementedDevicePluginServer
+ deviceplugin.UnimplementedDevicePluginServer
+ pluginregistration.UnimplementedRegistrationServer
KubeletDirectory *localstorage.DataKubernetesKubeletDirectory
logger logging.Leveled
@@ -86,7 +87,7 @@
for _, req := range req.ContainerRequests {
var devices []*deviceplugin.DeviceSpec
- for range req.DevicesIDs {
+ for range req.DevicesIds {
dev := new(deviceplugin.DeviceSpec)
dev.HostPath = "/dev/kvm"
dev.ContainerPath = "/dev/kvm"