...
1 package status
2
3 import (
4 "edge-infra.dev/pkg/edge/api/graph/model"
5 "edge-infra.dev/pkg/edge/api/services/kinform"
6 kinformmodel "edge-infra.dev/pkg/f8n/kinform/model"
7 )
8
9
10
11 func StatusesFromWatchedFields(watchedVMList []*kinformmodel.WatchedField) ([]*model.VirtualMachineStatus, error) {
12 statusList := []*model.VirtualMachineStatus{}
13 for _, watchedVM := range watchedVMList {
14 status := &model.VirtualMachineStatus{
15 Name: watchedVM.Name,
16 ClusterEdgeID: watchedVM.Cluster.String(),
17 Namespace: watchedVM.Namespace,
18 }
19 conditions, err := kinform.ObjStatusConditionsFromFieldValues(watchedVM.Fields)
20 if err != nil {
21 return nil, err
22 }
23 status.Conditions = conditions
24 statusList = append(statusList, status)
25 }
26 return statusList, nil
27 }
28
View as plain text