Skip to content

Commit a0c7310

Browse files
committed
adding machine.go
1 parent 4c8cdf6 commit a0c7310

File tree

1 file changed

+32
-0
lines changed

1 file changed

+32
-0
lines changed

Diff for: support/machine.go

+32
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
package support
2+
3+
import (
4+
"github.com/onsi/gomega"
5+
6+
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
7+
8+
machinev1beta1 "github.com/openshift/api/machine/v1beta1"
9+
)
10+
11+
func GetMachineSets(t Test) ([]machinev1beta1.MachineSet, error) {
12+
ms, err := t.Client().Machine().MachineV1beta1().MachineSets("openshift-machine-api").List(t.Ctx(), metav1.ListOptions{})
13+
t.Expect(err).NotTo(gomega.HaveOccurred())
14+
return ms.Items, err
15+
}
16+
17+
func Machines(t Test, machineSetName string) func(g gomega.Gomega) []machinev1beta1.Machine {
18+
return func(g gomega.Gomega) []machinev1beta1.Machine {
19+
machine, err := t.Client().Machine().MachineV1beta1().Machines("openshift-machine-api").List(t.Ctx(), metav1.ListOptions{LabelSelector: "machine.openshift.io/cluster-api-machineset=" + machineSetName})
20+
g.Expect(err).NotTo(gomega.HaveOccurred())
21+
return machine.Items
22+
}
23+
}
24+
25+
func GetMachines(t Test, machineSetName string) []machinev1beta1.Machine {
26+
t.T().Helper()
27+
return Machines(t, machineSetName)(t)
28+
}
29+
30+
func MachineSetId(machineSet machinev1beta1.MachineSet) string {
31+
return machineSet.Name
32+
}

0 commit comments

Comments
 (0)