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
|
package throttle
import (
"errors"
"github.com/rackspace/gophercloud"
)
// CreateOptsBuilder is the interface options structs have to satisfy in order
// to be used in the main Create operation in this package.
type CreateOptsBuilder interface {
ToCTCreateMap() (map[string]interface{}, error)
}
// CreateOpts is the common options struct used in this package's Create
// operation.
type CreateOpts struct {
// Required - the maximum amount of connections per IP address to allow per LB.
MaxConnections int
// Deprecated as of v1.22.
MaxConnectionRate int
// Deprecated as of v1.22.
MinConnections int
// Deprecated as of v1.22.
RateInterval int
}
// ToCTCreateMap casts a CreateOpts struct to a map.
func (opts CreateOpts) ToCTCreateMap() (map[string]interface{}, error) {
ct := make(map[string]interface{})
if opts.MaxConnections < 0 || opts.MaxConnections > 100000 {
return ct, errors.New("MaxConnections must be an int between 0 and 100000")
}
ct["maxConnections"] = opts.MaxConnections
ct["maxConnectionRate"] = opts.MaxConnectionRate
ct["minConnections"] = opts.MinConnections
ct["rateInterval"] = opts.RateInterval
return map[string]interface{}{"connectionThrottle": ct}, nil
}
// Create is the operation responsible for creating or updating the connection
// throttling configuration for a load balancer.
func Create(c *gophercloud.ServiceClient, lbID int, opts CreateOptsBuilder) CreateResult {
var res CreateResult
reqBody, err := opts.ToCTCreateMap()
if err != nil {
res.Err = err
return res
}
_, res.Err = c.Put(rootURL(c, lbID), reqBody, &res.Body, nil)
return res
}
// Get is the operation responsible for showing the details of the connection
// throttling configuration for a load balancer.
func Get(c *gophercloud.ServiceClient, lbID int) GetResult {
var res GetResult
_, res.Err = c.Get(rootURL(c, lbID), &res.Body, nil)
return res
}
// Delete is the operation responsible for deleting the connection throttling
// configuration for a load balancer.
func Delete(c *gophercloud.ServiceClient, lbID int) DeleteResult {
var res DeleteResult
_, res.Err = c.Delete(rootURL(c, lbID), nil)
return res
}
|
