30 lines
529 B
Go
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
|
|
}
|