-
Notifications
You must be signed in to change notification settings - Fork 28
/
Copy pathibm-pi-dr-location.go
59 lines (53 loc) · 2.45 KB
/
ibm-pi-dr-location.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
package instance
import (
"context"
"fmt"
"github.com/IBM-Cloud/power-go-client/errors"
"github.com/IBM-Cloud/power-go-client/helpers"
"github.com/IBM-Cloud/power-go-client/ibmpisession"
"github.com/IBM-Cloud/power-go-client/power/client/p_cloud_disaster_recovery"
"github.com/IBM-Cloud/power-go-client/power/models"
)
// IBMPIDisasterRecoveryLocationClient
type IBMPIDisasterRecoveryLocationClient struct {
IBMPIClient
}
// NewIBMPIDisasterRecoveryLocationClient
func NewIBMPIDisasterRecoveryLocationClient(ctx context.Context, sess *ibmpisession.IBMPISession, cloudInstanceID string) *IBMPIDisasterRecoveryLocationClient {
return &IBMPIDisasterRecoveryLocationClient{
*NewIBMPIClient(ctx, sess, cloudInstanceID),
}
}
// Get the disaster recovery site details for the current location
func (f *IBMPIDisasterRecoveryLocationClient) Get() (*models.DisasterRecoveryLocation, error) {
if f.session.IsOnPrem() {
return nil, fmt.Errorf("operation not supported in satellite location, check documentation")
}
params := p_cloud_disaster_recovery.NewPcloudLocationsDisasterrecoveryGetParams().
WithContext(f.ctx).WithTimeout(helpers.PIGetTimeOut).
WithCloudInstanceID(f.cloudInstanceID)
resp, err := f.session.Power.PCloudDisasterRecovery.PcloudLocationsDisasterrecoveryGet(params, f.session.AuthInfo(f.cloudInstanceID))
if err != nil {
return nil, fmt.Errorf(errors.GetDisasterRecoveryLocationOperationFailed, f.cloudInstanceID, err)
}
if resp == nil || resp.Payload == nil {
return nil, fmt.Errorf("failed to perform the Get Disaster Recovery Location for the cloud instance %s", f.cloudInstanceID)
}
return resp.Payload, nil
}
// Get all disaster recovery locations supported by Power Virtual Server
func (f *IBMPIDisasterRecoveryLocationClient) GetAll() (*models.DisasterRecoveryLocations, error) {
if f.session.IsOnPrem() {
return nil, fmt.Errorf("operation not supported in satellite location, check documentation")
}
params := p_cloud_disaster_recovery.NewPcloudLocationsDisasterrecoveryGetallParams().
WithContext(f.ctx).WithTimeout(helpers.PIGetTimeOut)
resp, err := f.session.Power.PCloudDisasterRecovery.PcloudLocationsDisasterrecoveryGetall(params, f.session.AuthInfo(f.cloudInstanceID))
if err != nil {
return nil, fmt.Errorf(errors.GetAllDisasterRecoveryLocationOperationFailed, err)
}
if resp == nil || resp.Payload == nil {
return nil, fmt.Errorf("failed to Get All Disaster Recovery Location of Power Virtual Server")
}
return resp.Payload, nil
}