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
|
package rds
import (
"encoding/xml"
"github.com/goamz/goamz/aws"
"log"
"net/http/httputil"
"strconv"
)
const debug = false
const (
ServiceName = "rds"
ApiVersion = "2013-09-09"
)
// The RDS type encapsulates operations within a specific EC2 region.
type RDS struct {
Service aws.AWSService
}
// New creates a new RDS Client.
func New(auth aws.Auth, region aws.Region) (*RDS, error) {
service, err := aws.NewService(auth, region.RDSEndpoint)
if err != nil {
return nil, err
}
return &RDS{
Service: service,
}, nil
}
// ----------------------------------------------------------------------------
// Request dispatching logic.
// query dispatches a request to the RDS API signed with a version 2 signature
func (rds *RDS) query(method, path string, params map[string]string, resp interface{}) error {
// Add basic RDS param
params["Version"] = ApiVersion
r, err := rds.Service.Query(method, path, params)
if err != nil {
return err
}
defer r.Body.Close()
if debug {
dump, _ := httputil.DumpResponse(r, true)
log.Printf("response:\n")
log.Printf("%v\n}\n", string(dump))
}
if r.StatusCode != 200 {
return rds.Service.BuildError(r)
}
err = xml.NewDecoder(r.Body).Decode(resp)
return err
}
// ----------------------------------------------------------------------------
// API methods and corresponding response types.
// Response to a DescribeDBInstances request
//
// See http://goo.gl/KSPlAl for more details.
type DescribeDBInstancesResponse struct {
DBInstances []DBInstance `xml:"DescribeDBInstancesResult>DBInstances>DBInstance"` // The list of database instances
Marker string `xml:"DescribeDBInstancesResult>Marker"` // An optional pagination token provided by a previous request
RequestId string `xml:"ResponseMetadata>RequestId"`
}
// DescribeDBInstances - Returns a description of each Database Instance
// Supports pagination by using the "Marker" parameter, and "maxRecords" for subsequent calls
// Unfortunately RDS does not currently support filtering
//
// See http://goo.gl/lzZMyz for more details.
func (rds *RDS) DescribeDBInstances(id string, maxRecords int, marker string) (*DescribeDBInstancesResponse, error) {
params := aws.MakeParams("DescribeDBInstances")
if id != "" {
params["DBInstanceIdentifier"] = id
}
if maxRecords != 0 {
params["MaxRecords"] = strconv.Itoa(maxRecords)
}
if marker != "" {
params["Marker"] = marker
}
resp := &DescribeDBInstancesResponse{}
err := rds.query("POST", "/", params, resp)
return resp, err
}
|
