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 GetPassword(ctx context.Context, kube client.Client, r *v1beta1.RDSInstance) (newPwd string, changed bool, err error)
• func IsErrorAlreadyExists(err error) bool
• func IsErrorNotFound(err error) bool
• func IsUpToDate(ctx context.Context, kube client.Client, r *v1beta1.RDSInstance, ...) (bool, error)
• func LateInitialize(in *v1beta1.RDSInstanceParameters, db *rds.DBInstance)
• type Client
  • func NewClient(cfg *aws.Config) Client

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 v1beta1.RDSInstance.

func GetPassword

func GetPassword(ctx context.Context, kube client.Client, r *v1beta1.RDSInstance) (newPwd string, changed bool, err error)

GetPassword fetches the referenced input password for an RDSInstance CRD and determines whether it has changed or not

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(ctx context.Context, kube client.Client, r *v1beta1.RDSInstance, 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 *v1beta1.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
	AddTagsToResourceRequest(*rds.AddTagsToResourceInput) rds.AddTagsToResourceRequest
}

Client defines RDS RDSClient operations

func NewClient

func NewClient(cfg *aws.Config) Client

NewClient creates new RDS RDSClient with provided AWS Configurations/Credentials