fuse-device-plugin/src/fuse.go
Stefan Reimer dc23e0323a
All checks were successful
ZeroDownTime/fuse-device-plugin/pipeline/tag This commit looks good
ZeroDownTime/fuse-device-plugin/pipeline/head This commit looks good
Use updated GO dependencies and fixes from https://github.com/cox96de/fuse-device-plugin.git
2023-09-27 17:56:58 +00:00

30 lines
529 B
Go

package main
import (
"fmt"
"os"
pluginapi "k8s.io/kubelet/pkg/apis/deviceplugin/v1beta1"
)
func getDevices(number int) []*pluginapi.Device {
hostname, _ := os.Hostname()
var devs []*pluginapi.Device
for i := 0; i < number; i++ {
devs = append(devs, &pluginapi.Device{
ID: fmt.Sprintf("fuse-%s-%d", hostname, i),
Health: pluginapi.Healthy,
})
}
return devs
}
func deviceExists(devs []*pluginapi.Device, id string) bool {
for _, d := range devs {
if d.ID == id {
return true
}
}
return false
}