forked from ionos-enterprise/ionos-enterprise-sdk-go
-
Notifications
You must be signed in to change notification settings - Fork 0
/
datacenter.go
154 lines (139 loc) · 5.19 KB
/
datacenter.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
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
package profitbricks
import (
"context"
"net/http"
)
const (
// Resource is being provisioned
StateBusy = "BUSY"
// Resource is ready to be used
StateAvailable = "AVAILABLE"
// Resource has been de-provisioned
StateInactive = "INACTIVE"
)
// Datacenter represents Virtual Data Center
type Datacenter struct {
ID string `json:"id,omitempty"`
PBType string `json:"type,omitempty"`
Href string `json:"href,omitempty"`
Metadata *Metadata `json:"metadata,omitempty"`
Properties DatacenterProperties `json:"properties,omitempty"`
Entities DatacenterEntities `json:"entities,omitempty"`
Response string `json:"Response,omitempty"`
Headers *http.Header `json:"headers,omitempty"`
}
// Metadata represents metadata recieved from Cloud API
type Metadata struct {
CreatedDate string `json:"createdDate,omitempty"`
CreatedBy string `json:"createdBy,omitempty"`
CreatedByUserID string `json:"createdByUserId,omitempty"`
Etag string `json:"etag,omitempty"`
LastModifiedDate string `json:"lastModifiedDate,omitempty"`
LastModifiedBy string `json:"lastModifiedBy,omitempty"`
LastModifiedByUserID string `json:"lastModifiedByUserId,omitempty"`
State string `json:"state,omitempty"`
}
// DatacenterProperties represents Virtual Data Center properties
type DatacenterProperties struct {
Name string `json:"name,omitempty"`
Description string `json:"description,omitempty"`
Location string `json:"location,omitempty"`
Version int32 `json:"version,omitempty"`
}
// DatacenterEntities represents Virtual Data Center entities
type DatacenterEntities struct {
Servers *Servers `json:"servers,omitempty"`
Volumes *Volumes `json:"volumes,omitempty"`
Loadbalancers *Loadbalancers `json:"loadbalancers,omitempty"`
Lans *Lans `json:"lans,omitempty"`
}
// Datacenters is a list of Virtual Data Centers
type Datacenters struct {
ID string `json:"id,omitempty"`
PBType string `json:"type,omitempty"`
Href string `json:"href,omitempty"`
Items []Datacenter `json:"items,omitempty"`
Response string `json:"Response,omitempty"`
Headers *http.Header `json:"headers,omitempty"`
}
// ListDatacenters lists all data centers
func (c *Client) ListDatacenters() (*Datacenters, error) {
url := datacentersPath()
ret := &Datacenters{}
err := c.Get(url, ret, http.StatusOK)
return ret, err
}
// CreateDatacenter creates a data center
func (c *Client) CreateDatacenter(dc Datacenter) (*Datacenter, error) {
url := datacentersPath()
ret := &Datacenter{}
err := c.Post(url, dc, ret, http.StatusAccepted)
return ret, err
}
// CreateDatacenterAndWait creates a data center, waits for the request to finish and returns a refreshed
// result.
// Note that an error does not necessarily means that the resource has not been created.
// If err & res are not nil, a resource with res.ID exists, but an error occurred either while waiting for
// the request or when refreshing the resource.
func (c *Client) CreateDatacenterAndWait(ctx context.Context, dc Datacenter) (res *Datacenter, err error) {
res, err = c.CreateDatacenter(dc)
if err != nil {
return
}
if err = c.WaitTillProvisionedOrCanceled(ctx, res.Headers.Get("location")); err != nil {
return
}
var rdc *Datacenter
rdc, err = c.GetDatacenter(res.ID)
if err != nil {
return
}
return rdc, nil
}
// GetDatacenter gets a datacenter
func (c *Client) GetDatacenter(dcid string) (*Datacenter, error) {
url := datacenterPath(dcid)
ret := &Datacenter{}
err := c.Get(url, ret, http.StatusOK)
return ret, err
}
// UpdateDataCenter updates a data center
func (c *Client) UpdateDataCenter(dcid string, obj DatacenterProperties) (*Datacenter, error) {
url := datacenterPath(dcid)
ret := &Datacenter{}
err := c.Patch(url, obj, ret, http.StatusAccepted)
return ret, err
}
// UpdateDatacenter updates a data center, waits for the request to finish and returns a refreshed result.
// Note that an error does not necessarily means that the resource has not been updated.
// If err & res are not nil, a resource with res.ID exists, but an error occurred either while waiting for
// the request or when refreshing the resource.
func (c *Client) UpdateDatacenterAndWait(ctx context.Context, dcid string, obj DatacenterProperties) (res *Datacenter, err error) {
res, err = c.UpdateDataCenter(dcid, obj)
if err != nil {
return
}
if err = c.WaitTillProvisionedOrCanceled(ctx, res.Headers.Get("location")); err != nil {
return
}
var rdc *Datacenter
if rdc, err = c.GetDatacenter(res.ID); err != nil {
return
} else {
return rdc, nil
}
}
// DeleteDatacenter deletes a data center
func (c *Client) DeleteDatacenter(dcid string) (*http.Header, error) {
url := datacenterPath(dcid)
ret := &http.Header{}
return ret, c.Delete(url, ret, http.StatusAccepted)
}
// DeleteDatacenterAndWait deletes given datacenter and waits for the request to finish
func (c *Client) DeleteDatacenterAndWait(ctx context.Context, dcid string) error {
rsp, err := c.DeleteDatacenter(dcid)
if err != nil {
return err
}
return c.WaitTillProvisionedOrCanceled(ctx, rsp.Get("location"))
}