1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
|
//go:build acceptance || compute || services
// +build acceptance compute services
package v2
import (
"testing"
"github.com/gophercloud/gophercloud/acceptance/clients"
"github.com/gophercloud/gophercloud/acceptance/tools"
"github.com/gophercloud/gophercloud/openstack/compute/v2/extensions/services"
th "github.com/gophercloud/gophercloud/testhelper"
)
func TestServicesList(t *testing.T) {
clients.RequireAdmin(t)
client, err := clients.NewComputeV2Client()
th.AssertNoErr(t, err)
allPages, err := services.List(client, nil).AllPages()
th.AssertNoErr(t, err)
allServices, err := services.ExtractServices(allPages)
th.AssertNoErr(t, err)
var found bool
for _, service := range allServices {
tools.PrintResource(t, service)
if service.Binary == "nova-scheduler" {
found = true
}
}
th.AssertEquals(t, found, true)
}
func TestServicesListWithOpts(t *testing.T) {
clients.RequireAdmin(t)
client, err := clients.NewComputeV2Client()
th.AssertNoErr(t, err)
opts := services.ListOpts{
Binary: "nova-scheduler",
}
allPages, err := services.List(client, opts).AllPages()
th.AssertNoErr(t, err)
allServices, err := services.ExtractServices(allPages)
th.AssertNoErr(t, err)
var found bool
for _, service := range allServices {
tools.PrintResource(t, service)
th.AssertEquals(t, service.Binary, "nova-scheduler")
if service.Binary == "nova-scheduler" {
found = true
}
}
th.AssertEquals(t, found, true)
}
func TestServicesUpdate(t *testing.T) {
clients.RequireAdmin(t)
client, err := clients.NewComputeV2Client()
th.AssertNoErr(t, err)
listOpts := services.ListOpts{
Binary: "nova-compute",
}
client.Microversion = "2.53"
allPages, err := services.List(client, listOpts).AllPages()
th.AssertNoErr(t, err)
allServices, err := services.ExtractServices(allPages)
th.AssertNoErr(t, err)
// disable all services
for _, service := range allServices {
opts := services.UpdateOpts{
Status: services.ServiceDisabled,
}
updated, err := services.Update(client, service.ID, opts).Extract()
th.AssertNoErr(t, err)
th.AssertEquals(t, updated.ID, service.ID)
}
// verify all services are disabled
allPages, err = services.List(client, listOpts).AllPages()
th.AssertNoErr(t, err)
allServices, err = services.ExtractServices(allPages)
th.AssertNoErr(t, err)
for _, service := range allServices {
th.AssertEquals(t, service.Status, "disabled")
}
// reenable all services
allPages, err = services.List(client, listOpts).AllPages()
th.AssertNoErr(t, err)
allServices, err = services.ExtractServices(allPages)
th.AssertNoErr(t, err)
for _, service := range allServices {
opts := services.UpdateOpts{
Status: services.ServiceEnabled,
}
updated, err := services.Update(client, service.ID, opts).Extract()
th.AssertNoErr(t, err)
th.AssertEquals(t, updated.ID, service.ID)
}
}
|
