/
lxd_network_load_balancers.go
113 lines (92 loc) · 3.24 KB
/
lxd_network_load_balancers.go
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
package lxd
import (
"github.com/canonical/lxd/shared/api"
)
// GetNetworkLoadBalancerAddresses returns a list of network load balancer listen addresses.
func (r *ProtocolLXD) GetNetworkLoadBalancerAddresses(networkName string) ([]string, error) {
err := r.CheckExtension("network_load_balancer")
if err != nil {
return nil, err
}
// Fetch the raw URL values.
urls := []string{}
u := api.NewURL().Path("networks", networkName, "load-balancers")
_, err = r.queryStruct("GET", u.String(), nil, "", &urls)
if err != nil {
return nil, err
}
// Parse it.
return urlsToResourceNames(u.String(), urls...)
}
// GetNetworkLoadBalancers returns a list of Network load balancer structs.
func (r *ProtocolLXD) GetNetworkLoadBalancers(networkName string) ([]api.NetworkLoadBalancer, error) {
err := r.CheckExtension("network_load_balancer")
if err != nil {
return nil, err
}
loadBalancers := []api.NetworkLoadBalancer{}
// Fetch the raw value.
u := api.NewURL().Path("networks", networkName, "load-balancers").WithQuery("recursion", "1")
_, err = r.queryStruct("GET", u.String(), nil, "", &loadBalancers)
if err != nil {
return nil, err
}
return loadBalancers, nil
}
// GetNetworkLoadBalancer returns a Network load balancer entry for the provided network and listen address.
func (r *ProtocolLXD) GetNetworkLoadBalancer(networkName string, listenAddress string) (*api.NetworkLoadBalancer, string, error) {
err := r.CheckExtension("network_load_balancer")
if err != nil {
return nil, "", err
}
loadBalancer := api.NetworkLoadBalancer{}
// Fetch the raw value.
u := api.NewURL().Path("networks", networkName, "load-balancers", listenAddress)
etag, err := r.queryStruct("GET", u.String(), nil, "", &loadBalancer)
if err != nil {
return nil, "", err
}
return &loadBalancer, etag, nil
}
// CreateNetworkLoadBalancer defines a new network load balancer using the provided struct.
func (r *ProtocolLXD) CreateNetworkLoadBalancer(networkName string, loadBalancer api.NetworkLoadBalancersPost) error {
err := r.CheckExtension("network_load_balancer")
if err != nil {
return err
}
// Send the request.
u := api.NewURL().Path("networks", networkName, "load-balancers")
_, _, err = r.query("POST", u.String(), loadBalancer, "")
if err != nil {
return err
}
return nil
}
// UpdateNetworkLoadBalancer updates the network load balancer to match the provided struct.
func (r *ProtocolLXD) UpdateNetworkLoadBalancer(networkName string, listenAddress string, loadBalancer api.NetworkLoadBalancerPut, ETag string) error {
err := r.CheckExtension("network_load_balancer")
if err != nil {
return err
}
// Send the request.
u := api.NewURL().Path("networks", networkName, "load-balancers", listenAddress)
_, _, err = r.query("PUT", u.String(), loadBalancer, ETag)
if err != nil {
return err
}
return nil
}
// DeleteNetworkLoadBalancer deletes an existing network load balancer.
func (r *ProtocolLXD) DeleteNetworkLoadBalancer(networkName string, listenAddress string) error {
err := r.CheckExtension("network_load_balancer")
if err != nil {
return err
}
// Send the request.
u := api.NewURL().Path("networks", networkName, "load-balancers", listenAddress)
_, _, err = r.query("DELETE", u.String(), nil, "")
if err != nil {
return err
}
return nil
}