Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly
Appearance settings

Commit 9c1d6af

Browse filesBrowse files
kayruskayrus
committed
[networking]: add BGP VPNs support
1 parent 0dae567 commit 9c1d6af
Copy full SHA for 9c1d6af

File tree

Expand file treeCollapse file tree

11 files changed

+2431
-0
lines changed
Filter options
Expand file treeCollapse file tree

11 files changed

+2431
-0
lines changed

‎.github/workflows/functional-networking.yaml

Copy file name to clipboardExpand all lines: .github/workflows/functional-networking.yaml
+1Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -47,6 +47,7 @@ jobs:
4747
conf_overrides: |
4848
enable_plugin neutron-dynamic-routing https://github.com/openstack/neutron-dynamic-routing ${{ matrix.openstack_version }}
4949
enable_plugin neutron-vpnaas https://github.com/openstack/neutron-vpnaas ${{ matrix.openstack_version }}
50+
enable_plugin networking-bgpvpn https://github.com/openstack/networking-bgpvpn.git ${{ matrix.openstack_version }}
5051
Q_ML2_PLUGIN_EXT_DRIVERS=qos,port_security,dns_domain_keywords
5152
5253
[[post-config|\$NEUTRON_CONF]]

‎internal/acceptance/openstack/networking/v2/extensions/bgpvpns/bgpvpns.go

Copy file name to clipboard
+28Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,28 @@
1+
package bgpvpns
2+
3+
import (
4+
"context"
5+
"testing"
6+
7+
"github.com/gophercloud/gophercloud/v2"
8+
"github.com/gophercloud/gophercloud/v2/internal/acceptance/tools"
9+
"github.com/gophercloud/gophercloud/v2/openstack/networking/v2/extensions/bgpvpns"
10+
th "github.com/gophercloud/gophercloud/v2/testhelper"
11+
)
12+
13+
func CreateBGPVPN(t *testing.T, client *gophercloud.ServiceClient) (*bgpvpns.BGPVPN, error) {
14+
opts := bgpvpns.CreateOpts{
15+
Name: tools.RandomString("TESTACC-BGPVPN-", 10),
16+
}
17+
18+
t.Logf("Attempting to create BGP VPN: %s", opts.Name)
19+
bgpVpn, err := bgpvpns.Create(context.TODO(), client, opts).Extract()
20+
if err != nil {
21+
return bgpVpn, err
22+
}
23+
24+
th.AssertEquals(t, bgpVpn.Name, opts.Name)
25+
t.Logf("Successfully created BGP VPN")
26+
tools.PrintResource(t, bgpVpn)
27+
return bgpVpn, err
28+
}

‎internal/acceptance/openstack/networking/v2/extensions/bgpvpns/bgpvpns_test.go

Copy file name to clipboard
+247Lines changed: 247 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,247 @@
1+
//go:build acceptance || networking || bgp || bgpvpns
2+
3+
package bgpvpns
4+
5+
import (
6+
"context"
7+
"testing"
8+
9+
"github.com/gophercloud/gophercloud/v2/internal/acceptance/clients"
10+
networking "github.com/gophercloud/gophercloud/v2/internal/acceptance/openstack/networking/v2"
11+
"github.com/gophercloud/gophercloud/v2/internal/acceptance/openstack/networking/v2/extensions/layer3"
12+
"github.com/gophercloud/gophercloud/v2/internal/acceptance/tools"
13+
"github.com/gophercloud/gophercloud/v2/openstack/networking/v2/extensions/bgpvpns"
14+
th "github.com/gophercloud/gophercloud/v2/testhelper"
15+
)
16+
17+
func TestBGPVPNCRUD(t *testing.T) {
18+
clients.RequireAdmin(t)
19+
20+
client, err := clients.NewNetworkV2Client()
21+
th.AssertNoErr(t, err)
22+
23+
// Create a BGP VPN
24+
bgpVpnCreated, err := CreateBGPVPN(t, client)
25+
th.AssertNoErr(t, err)
26+
27+
// Get a BGP VPN
28+
bgpVpnGot, err := bgpvpns.Get(context.TODO(), client, bgpVpnCreated.ID).Extract()
29+
th.AssertNoErr(t, err)
30+
th.AssertEquals(t, bgpVpnCreated.ID, bgpVpnGot.ID)
31+
th.AssertEquals(t, bgpVpnCreated.Name, bgpVpnGot.Name)
32+
33+
// Update a BGP VPN
34+
newBGPVPNName := tools.RandomString("TESTACC-BGPVPN-", 10)
35+
updateBGPOpts := bgpvpns.UpdateOpts{
36+
Name: &newBGPVPNName,
37+
}
38+
bgpVpnUpdated, err := bgpvpns.Update(context.TODO(), client, bgpVpnGot.ID, updateBGPOpts).Extract()
39+
th.AssertNoErr(t, err)
40+
th.AssertEquals(t, bgpVpnUpdated.Name, newBGPVPNName)
41+
t.Logf("Update BGP VPN, renamed from %s to %s", bgpVpnGot.Name, bgpVpnUpdated.Name)
42+
43+
// List all BGP VPNs
44+
allPages, err := bgpvpns.List(client, bgpvpns.ListOpts{}).AllPages(context.TODO())
45+
th.AssertNoErr(t, err)
46+
allVPNs, err := bgpvpns.ExtractBGPVPNs(allPages)
47+
th.AssertNoErr(t, err)
48+
49+
t.Logf("Retrieved BGP VPNs")
50+
tools.PrintResource(t, allVPNs)
51+
th.AssertIntGreaterOrEqual(t, len(allVPNs), 1)
52+
53+
// Delete a BGP VPN
54+
t.Logf("Attempting to delete BGP VPN: %s", bgpVpnUpdated.Name)
55+
err = bgpvpns.Delete(context.TODO(), client, bgpVpnUpdated.ID).ExtractErr()
56+
th.AssertNoErr(t, err)
57+
58+
_, err = bgpvpns.Get(context.TODO(), client, bgpVpnGot.ID).Extract()
59+
th.AssertErr(t, err)
60+
t.Logf("BGP VPN %s deleted", bgpVpnUpdated.Name)
61+
}
62+
63+
func TestBGPVPNNetworkAssociationCRD(t *testing.T) {
64+
clients.RequireAdmin(t)
65+
66+
client, err := clients.NewNetworkV2Client()
67+
th.AssertNoErr(t, err)
68+
69+
// Create a BGP VPN
70+
bgpVpnCreated, err := CreateBGPVPN(t, client)
71+
th.AssertNoErr(t, err)
72+
defer func() {
73+
err = bgpvpns.Delete(context.TODO(), client, bgpVpnCreated.ID).ExtractErr()
74+
th.AssertNoErr(t, err)
75+
}()
76+
77+
// Create a Network
78+
network, err := networking.CreateNetwork(t, client)
79+
th.AssertNoErr(t, err)
80+
defer networking.DeleteNetwork(t, client, network.ID)
81+
82+
// Associate a Network with a BGP VPN
83+
assocOpts := bgpvpns.CreateNetworkAssociationOpts{
84+
NetworkID: network.ID,
85+
}
86+
assoc, err := bgpvpns.CreateNetworkAssociation(context.TODO(), client, bgpVpnCreated.ID, assocOpts).Extract()
87+
th.AssertNoErr(t, err)
88+
defer func() {
89+
err = bgpvpns.DeleteNetworkAssociation(context.TODO(), client, bgpVpnCreated.ID, assoc.ID).ExtractErr()
90+
th.AssertNoErr(t, err)
91+
}()
92+
th.AssertEquals(t, assoc.NetworkID, network.ID)
93+
94+
// Get a Network Association
95+
assocGot, err := bgpvpns.GetNetworkAssociation(context.TODO(), client, bgpVpnCreated.ID, assoc.ID).Extract()
96+
th.AssertNoErr(t, err)
97+
th.AssertEquals(t, assocGot.NetworkID, network.ID)
98+
99+
// List all Network Associations
100+
allPages, err := bgpvpns.ListNetworkAssociations(client, bgpVpnCreated.ID, bgpvpns.ListNetworkAssociationsOpts{}).AllPages(context.TODO())
101+
th.AssertNoErr(t, err)
102+
allAssocs, err := bgpvpns.ExtractNetworkAssociations(allPages)
103+
th.AssertNoErr(t, err)
104+
t.Logf("Retrieved Network Associations")
105+
tools.PrintResource(t, allAssocs)
106+
th.AssertIntGreaterOrEqual(t, len(allAssocs), 1)
107+
108+
// Get BGP VPN with associations
109+
getBgpVpn, err := bgpvpns.Get(context.TODO(), client, bgpVpnCreated.ID).Extract()
110+
th.AssertNoErr(t, err)
111+
tools.PrintResource(t, getBgpVpn)
112+
}
113+
114+
func TestBGPVPNRouterAssociationCRUD(t *testing.T) {
115+
clients.RequireAdmin(t)
116+
117+
client, err := clients.NewNetworkV2Client()
118+
th.AssertNoErr(t, err)
119+
120+
// Create a BGP VPN
121+
bgpVpnCreated, err := CreateBGPVPN(t, client)
122+
th.AssertNoErr(t, err)
123+
defer func() {
124+
err = bgpvpns.Delete(context.TODO(), client, bgpVpnCreated.ID).ExtractErr()
125+
th.AssertNoErr(t, err)
126+
}()
127+
128+
// Create a Network
129+
network, err := networking.CreateNetwork(t, client)
130+
th.AssertNoErr(t, err)
131+
defer networking.DeleteNetwork(t, client, network.ID)
132+
133+
// Create a Router
134+
routerCreated, err := layer3.CreateRouter(t, client, network.ID)
135+
th.AssertNoErr(t, err)
136+
defer layer3.DeleteRouter(t, client, routerCreated.ID)
137+
138+
// Associate a Router with a BGP VPN
139+
assocOpts := bgpvpns.CreateRouterAssociationOpts{
140+
RouterID: routerCreated.ID,
141+
}
142+
assoc, err := bgpvpns.CreateRouterAssociation(context.TODO(), client, bgpVpnCreated.ID, assocOpts).Extract()
143+
th.AssertNoErr(t, err)
144+
defer func() {
145+
err = bgpvpns.DeleteRouterAssociation(context.TODO(), client, bgpVpnCreated.ID, assoc.ID).ExtractErr()
146+
th.AssertNoErr(t, err)
147+
}()
148+
th.AssertEquals(t, assoc.RouterID, routerCreated.ID)
149+
150+
// Get a Router Association
151+
assocGot, err := bgpvpns.GetRouterAssociation(context.TODO(), client, bgpVpnCreated.ID, assoc.ID).Extract()
152+
th.AssertNoErr(t, err)
153+
th.AssertEquals(t, assocGot.RouterID, routerCreated.ID)
154+
155+
// Update a Router Association
156+
assocUpdOpts := bgpvpns.UpdateRouterAssociationOpts{
157+
AdvertiseExtraRoutes: new(bool),
158+
}
159+
assocUpdate, err := bgpvpns.UpdateRouterAssociation(context.TODO(), client, bgpVpnCreated.ID, assoc.ID, assocUpdOpts).Extract()
160+
th.AssertNoErr(t, err)
161+
th.AssertEquals(t, assocUpdate.RouterID, routerCreated.ID)
162+
th.AssertEquals(t, assocUpdate.AdvertiseExtraRoutes, false)
163+
164+
// List all Router Associations
165+
allPages, err := bgpvpns.ListRouterAssociations(client, bgpVpnCreated.ID, bgpvpns.ListRouterAssociationsOpts{}).AllPages(context.TODO())
166+
th.AssertNoErr(t, err)
167+
allAssocs, err := bgpvpns.ExtractRouterAssociations(allPages)
168+
th.AssertNoErr(t, err)
169+
t.Logf("Retrieved Router Associations")
170+
tools.PrintResource(t, allAssocs)
171+
th.AssertIntGreaterOrEqual(t, len(allAssocs), 1)
172+
173+
// Get BGP VPN with associations
174+
getBgpVpn, err := bgpvpns.Get(context.TODO(), client, bgpVpnCreated.ID).Extract()
175+
th.AssertNoErr(t, err)
176+
tools.PrintResource(t, getBgpVpn)
177+
}
178+
179+
func TestBGPVPNPortAssociationCRUD(t *testing.T) {
180+
clients.RequireAdmin(t)
181+
182+
client, err := clients.NewNetworkV2Client()
183+
th.AssertNoErr(t, err)
184+
185+
// Create a BGP VPN
186+
bgpVpnCreated, err := CreateBGPVPN(t, client)
187+
th.AssertNoErr(t, err)
188+
defer func() {
189+
err = bgpvpns.Delete(context.TODO(), client, bgpVpnCreated.ID).ExtractErr()
190+
th.AssertNoErr(t, err)
191+
}()
192+
193+
// Create a Network
194+
network, err := networking.CreateNetwork(t, client)
195+
th.AssertNoErr(t, err)
196+
defer networking.DeleteNetwork(t, client, network.ID)
197+
198+
// Create Subnet
199+
subnet, err := networking.CreateSubnet(t, client, network.ID)
200+
th.AssertNoErr(t, err)
201+
defer networking.DeleteSubnet(t, client, subnet.ID)
202+
203+
// Create port
204+
port, err := networking.CreatePort(t, client, network.ID, subnet.ID)
205+
th.AssertNoErr(t, err)
206+
defer networking.DeletePort(t, client, port.ID)
207+
208+
// Associate a Port with a BGP VPN
209+
assocOpts := bgpvpns.CreatePortAssociationOpts{
210+
PortID: port.ID,
211+
}
212+
assoc, err := bgpvpns.CreatePortAssociation(context.TODO(), client, bgpVpnCreated.ID, assocOpts).Extract()
213+
th.AssertNoErr(t, err)
214+
defer func() {
215+
err = bgpvpns.DeletePortAssociation(context.TODO(), client, bgpVpnCreated.ID, assoc.ID).ExtractErr()
216+
th.AssertNoErr(t, err)
217+
}()
218+
th.AssertEquals(t, assoc.PortID, port.ID)
219+
220+
// Get a Port Association
221+
assocGot, err := bgpvpns.GetPortAssociation(context.TODO(), client, bgpVpnCreated.ID, assoc.ID).Extract()
222+
th.AssertNoErr(t, err)
223+
th.AssertEquals(t, assocGot.PortID, port.ID)
224+
225+
// Update a Port Association
226+
assocUpdOpts := bgpvpns.UpdatePortAssociationOpts{
227+
AdvertiseFixedIPs: new(bool),
228+
}
229+
assocUpdate, err := bgpvpns.UpdatePortAssociation(context.TODO(), client, bgpVpnCreated.ID, assoc.ID, assocUpdOpts).Extract()
230+
th.AssertNoErr(t, err)
231+
th.AssertEquals(t, assocUpdate.PortID, port.ID)
232+
th.AssertEquals(t, assocUpdate.AdvertiseFixedIPs, false)
233+
234+
// List all Port Associations
235+
allPages, err := bgpvpns.ListPortAssociations(client, bgpVpnCreated.ID, bgpvpns.ListPortAssociationsOpts{}).AllPages(context.TODO())
236+
th.AssertNoErr(t, err)
237+
allAssocs, err := bgpvpns.ExtractPortAssociations(allPages)
238+
th.AssertNoErr(t, err)
239+
t.Logf("Retrieved Port Associations")
240+
tools.PrintResource(t, allAssocs)
241+
th.AssertIntGreaterOrEqual(t, len(allAssocs), 1)
242+
243+
// Get BGP VPN with associations
244+
getBgpVpn, err := bgpvpns.Get(context.TODO(), client, bgpVpnCreated.ID).Extract()
245+
th.AssertNoErr(t, err)
246+
tools.PrintResource(t, getBgpVpn)
247+
}

‎internal/acceptance/openstack/networking/v2/extensions/bgpvpns/doc.go

Copy file name to clipboard
+2Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,2 @@
1+
// BGP VPN acceptance tests
2+
package bgpvpns

‎openstack/networking/v2/extensions/bgpvpns/doc.go

Copy file name to clipboard
+66Lines changed: 66 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,66 @@
1+
package bgpvpns
2+
3+
/*
4+
Package bgpvpns contains the functionality for working with Neutron BGP VPNs.
5+
6+
1. List BGP VPNs, a.k.a. GET /bgpvpn/bgpvpns
7+
8+
Example:
9+
10+
pages, err := bgpvpns.List(client).AllPages(context.TODO())
11+
if err != nil {
12+
log.Panic(err)
13+
}
14+
allVPNs, err := bgpvpns.ExtractBGPVPNs(pages)
15+
if err != nil {
16+
log.Panic(err)
17+
}
18+
19+
for _, bgpvpn := range allVPNs {
20+
log.Printf("%+v", bgpvpn)
21+
}
22+
23+
2. Get BGP VPN, a.k.a. GET /bgpvpn/bgpvpns/{id}
24+
25+
Example:
26+
p, err := bgpvpns.Get(context.TODO(), client, id).Extract()
27+
if err != nil {
28+
log.Panic(err)
29+
}
30+
log.Printf("%+v", *p)
31+
32+
3. Create BGP VPN, a.k.a. POST /bgpvpn/bgpvpns
33+
34+
Example:
35+
opts := bgpvpns.CreateOpts{
36+
name: "gophercloud-testing-bgpvpn".
37+
}
38+
r, err := bgpvpns.Create(context.TODO(), client, opts).Extract()
39+
if err != nil {
40+
log.Panic(err)
41+
}
42+
log.Printf("%+v", *r)
43+
44+
4. Delete BGP VPN, a.k.a. DELETE /bgpvpn/bgpvpns/{id}
45+
46+
Example:
47+
err := bgpvpns.Delete(context.TODO(), client, bgpVpnID).ExtractErr()
48+
if err != nil {
49+
log.Panic(err)
50+
}
51+
log.Printf("BGP VPN deleted")
52+
53+
54+
5. Update BGP VPN, a.k.a. PUT /bgpvpn/bgpvpns/{id}
55+
56+
Example:
57+
nameUpdated := "bgpvpn-name-updated"
58+
opts := bgpvpns.UpdateOpts{
59+
name: &nameUpdated,
60+
}
61+
p, err := bgpvpns.Update(context.TODO(), client, id, opts).Extract()
62+
if err != nil {
63+
log.Panic(err)
64+
}
65+
log.Printf("%+v", p)
66+
*/

0 commit comments

Comments
0 (0)
Morty Proxy This is a proxified and sanitized view of the page, visit original site.