Register initializes and registers our aws iam rds wrapped database driver.
(ctx context.Context, parentName string)
| 28 | |
| 29 | // Register initializes and registers our aws iam rds wrapped database driver. |
| 30 | func Register(ctx context.Context, parentName string) (string, error) { |
| 31 | cfg, err := config.LoadDefaultConfig(ctx) |
| 32 | if err != nil { |
| 33 | return "", err |
| 34 | } |
| 35 | |
| 36 | db, err := sql.Open(parentName, "") |
| 37 | if err != nil { |
| 38 | return "", err |
| 39 | } |
| 40 | |
| 41 | // create a new aws iam rds driver |
| 42 | d := newDriver(db.Driver(), cfg) |
| 43 | name := fmt.Sprintf("%s-awsiamrds", parentName) |
| 44 | sql.Register(fmt.Sprintf("%s-awsiamrds", parentName), d) |
| 45 | |
| 46 | return name, nil |
| 47 | } |
| 48 | |
| 49 | // newDriver will create a new *AwsIamRdsDriver using the environment aws session. |
| 50 | func newDriver(parentDriver driver.Driver, cfg aws.Config) *awsIamRdsDriver { |