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
|
package neutron_test
import (
"log"
gc "gopkg.in/check.v1"
"gopkg.in/goose.v1/client"
"gopkg.in/goose.v1/identity"
"gopkg.in/goose.v1/neutron"
"gopkg.in/goose.v1/testservices"
"gopkg.in/goose.v1/testservices/hook"
"gopkg.in/goose.v1/testservices/openstackservice"
)
func registerLocalTests() {
gc.Suite(&localLiveSuite{})
}
// localLiveSuite runs tests from LiveTests using a fake
// neutron server that runs within the test process itself.
type localLiveSuite struct {
LiveTests
openstack *openstackservice.Openstack
noMoreIPs bool // If true, addFloatingIP will return ErrNoMoreFloatingIPs
ipLimitExceeded bool // If true, addFloatingIP will return ErrIPLimitExceeded
}
func (s *localLiveSuite) SetUpSuite(c *gc.C) {
c.Logf("Using identity and neutron service test doubles")
// Set up an Openstack service.
s.cred = &identity.Credentials{
User: "fred",
Secrets: "secret",
Region: "some region",
TenantName: "tenant",
}
var logMsg []string
s.openstack, logMsg = openstackservice.New(s.cred, identity.AuthUserPass, false)
for _, msg := range logMsg {
c.Logf(msg)
}
s.openstack.UseNeutronNetworking()
s.openstack.SetupHTTP(nil)
s.LiveTests.SetUpSuite(c)
}
func (s *localLiveSuite) TearDownSuite(c *gc.C) {
s.LiveTests.TearDownSuite(c)
s.openstack.Stop()
}
func (s *localLiveSuite) setupClient(c *gc.C, logger *log.Logger) *neutron.Client {
client := client.NewClient(s.cred, identity.AuthUserPass, logger)
//client.SetVersionDiscoveryEnabled(false)
return neutron.New(client)
}
func (s *localLiveSuite) addFloatingIPHook(sc hook.ServiceControl) hook.ControlProcessor {
return func(sc hook.ServiceControl, args ...interface{}) error {
if s.noMoreIPs {
return testservices.NoMoreFloatingIPs
} else if s.ipLimitExceeded {
return testservices.IPLimitExceeded
}
return nil
}
}
|
