rds

Documentation

Index

• func CreatePatch(in *rds.DBInstance, target *v1beta1.RDSInstanceParameters) (*v1beta1.RDSInstanceParameters, error)
• func GenerateCreateDBInstanceInput(name, password string, p *v1beta1.RDSInstanceParameters) *rds.CreateDBInstanceInput
• func GenerateModifyDBInstanceInput(name string, p *v1beta1.RDSInstanceParameters) *rds.ModifyDBInstanceInput
• func GenerateObservation(db rds.DBInstance) v1beta1.RDSInstanceObservation
• func GetConnectionDetails(in v1beta1.RDSInstance) managed.ConnectionDetails
• func IsDBSubnetGroupNotFoundErr(err error) bool
• func IsErrorAlreadyExists(err error) bool
• func IsErrorNotFound(err error) bool
• func IsUpToDate(p v1beta1.RDSInstanceParameters, db rds.DBInstance) (bool, error)
• func LateInitialize(in *v1beta1.RDSInstanceParameters, db *rds.DBInstance)
• type Client
  • func NewClient(ctx context.Context, credentials []byte, region string, ...) (Client, error)
• type DBSubnetGroupClient
  • func NewDBSubnetGroupClient(cfg *aws.Config) (DBSubnetGroupClient, error)

Functions

func CreatePatch

func CreatePatch(in *rds.DBInstance, target *v1beta1.RDSInstanceParameters) (*v1beta1.RDSInstanceParameters, error)

CreatePatch creates a *v1beta1.RDSInstanceParameters that has only the changed values between the target *v1beta1.RDSInstanceParameters and the current *rds.DBInstance

func GenerateCreateDBInstanceInput

func GenerateCreateDBInstanceInput(name, password string, p *v1beta1.RDSInstanceParameters) *rds.CreateDBInstanceInput

GenerateCreateDBInstanceInput from RDSInstanceSpec

func GenerateModifyDBInstanceInput

func GenerateModifyDBInstanceInput(name string, p *v1beta1.RDSInstanceParameters) *rds.ModifyDBInstanceInput

GenerateModifyDBInstanceInput from RDSInstanceSpec

func GenerateObservation

func GenerateObservation(db rds.DBInstance) v1beta1.RDSInstanceObservation

GenerateObservation is used to produce v1alpha3.RDSInstanceObservation from rds.DBInstance.

func GetConnectionDetails

func GetConnectionDetails(in v1beta1.RDSInstance) managed.ConnectionDetails

GetConnectionDetails extracts managed.ConnectionDetails out of v1alpha3.RDSInstance.

func IsDBSubnetGroupNotFoundErr

func IsDBSubnetGroupNotFoundErr(err error) bool

IsDBSubnetGroupNotFoundErr returns true if the error is because the item doesn't exist

func IsErrorAlreadyExists

func IsErrorAlreadyExists(err error) bool

IsErrorAlreadyExists returns true if the supplied error indicates an instance already exists.

func IsErrorNotFound

func IsErrorNotFound(err error) bool

IsErrorNotFound helper function to test for ErrCodeDBInstanceNotFoundFault error

func IsUpToDate

func IsUpToDate(p v1beta1.RDSInstanceParameters, db rds.DBInstance) (bool, error)

IsUpToDate checks whether there is a change in any of the modifiable fields.

func LateInitialize

func LateInitialize(in *v1beta1.RDSInstanceParameters, db *rds.DBInstance)

LateInitialize fills the empty fields in *v1alpha3.RDSInstanceParameters with the values seen in rds.DBInstance.

Types

type Client

type Client interface {
	CreateDBInstanceRequest(*rds.CreateDBInstanceInput) rds.CreateDBInstanceRequest
	DescribeDBInstancesRequest(*rds.DescribeDBInstancesInput) rds.DescribeDBInstancesRequest
	ModifyDBInstanceRequest(*rds.ModifyDBInstanceInput) rds.ModifyDBInstanceRequest
	DeleteDBInstanceRequest(*rds.DeleteDBInstanceInput) rds.DeleteDBInstanceRequest
}

Client defines RDS RDSClient operations

func NewClient

func NewClient(ctx context.Context, credentials []byte, region string, auth awsclients.AuthMethod) (Client, error)

NewClient creates new RDS RDSClient with provided AWS Configurations/Credentials

type DBSubnetGroupClient

type DBSubnetGroupClient interface {
	CreateDBSubnetGroupRequest(input *rds.CreateDBSubnetGroupInput) rds.CreateDBSubnetGroupRequest
	DeleteDBSubnetGroupRequest(input *rds.DeleteDBSubnetGroupInput) rds.DeleteDBSubnetGroupRequest
	DescribeDBSubnetGroupsRequest(input *rds.DescribeDBSubnetGroupsInput) rds.DescribeDBSubnetGroupsRequest
}

DBSubnetGroupClient is the external client used for DBSubnetGroup Custom Resource

func NewDBSubnetGroupClient

func NewDBSubnetGroupClient(cfg *aws.Config) (DBSubnetGroupClient, error)

NewDBSubnetGroupClient returns a new client using AWS credentials as JSON encoded data.