rds

Documentation

Index

• func CreatePatch(in *rdstypes.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 rdstypes.DBInstance) v1beta1.RDSInstanceObservation
• func GenerateRestoreDBInstanceFromS3Input(name, password string, p *v1beta1.RDSInstanceParameters) *rds.RestoreDBInstanceFromS3Input
• func GenerateRestoreDBInstanceFromSnapshotInput(name string, p *v1beta1.RDSInstanceParameters) *rds.RestoreDBInstanceFromDBSnapshotInput
• func GenerateRestoreDBInstanceToPointInTimeInput(name string, p *v1beta1.RDSInstanceParameters) *rds.RestoreDBInstanceToPointInTimeInput
• func GetConnectionDetails(in v1beta1.RDSInstance) managed.ConnectionDetails
• func GetPassword(ctx context.Context, kube client.Client, in *xpv1.SecretKeySelector, ...) (newPwd string, changed bool, err error)
• func IsErrorNotFound(err error) bool
• func IsUpToDate(ctx context.Context, kube client.Client, r *v1beta1.RDSInstance, ...) (bool, error)
• func LateInitialize(in *v1beta1.RDSInstanceParameters, db *rdstypes.DBInstance)
• type Client
  • func NewClient(cfg *aws.Config) Client

Functions

func CreatePatch

func CreatePatch(in *rdstypes.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 rdstypes.DBInstance) v1beta1.RDSInstanceObservation

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

func GenerateRestoreDBInstanceFromS3Input

func GenerateRestoreDBInstanceFromS3Input(name, password string, p *v1beta1.RDSInstanceParameters) *rds.RestoreDBInstanceFromS3Input

GenerateRestoreDBInstanceFromS3Input from RDSInstanceSpec

func GenerateRestoreDBInstanceFromSnapshotInput

func GenerateRestoreDBInstanceFromSnapshotInput(name string, p *v1beta1.RDSInstanceParameters) *rds.RestoreDBInstanceFromDBSnapshotInput

GenerateRestoreDBInstanceFromSnapshotInput from RDSInstanceSpec

func GenerateRestoreDBInstanceToPointInTimeInput

func GenerateRestoreDBInstanceToPointInTimeInput(name string, p *v1beta1.RDSInstanceParameters) *rds.RestoreDBInstanceToPointInTimeInput

GenerateRestoreDBInstanceToPointInTimeInput from RDSInstanceSpec

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, in *xpv1.SecretKeySelector, out *xpv1.SecretReference) (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 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 rdstypes.DBInstance) (bool, error)

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

func LateInitialize

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

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

Types

type Client

type Client interface {
	CreateDBInstance(context.Context, *rds.CreateDBInstanceInput, ...func(*rds.Options)) (*rds.CreateDBInstanceOutput, error)
	RestoreDBInstanceFromS3(context.Context, *rds.RestoreDBInstanceFromS3Input, ...func(*rds.Options)) (*rds.RestoreDBInstanceFromS3Output, error)
	RestoreDBInstanceFromDBSnapshot(context.Context, *rds.RestoreDBInstanceFromDBSnapshotInput, ...func(*rds.Options)) (*rds.RestoreDBInstanceFromDBSnapshotOutput, error)
	RestoreDBInstanceToPointInTime(context.Context, *rds.RestoreDBInstanceToPointInTimeInput, ...func(*rds.Options)) (*rds.RestoreDBInstanceToPointInTimeOutput, error)
	DescribeDBInstances(context.Context, *rds.DescribeDBInstancesInput, ...func(*rds.Options)) (*rds.DescribeDBInstancesOutput, error)
	ModifyDBInstance(context.Context, *rds.ModifyDBInstanceInput, ...func(*rds.Options)) (*rds.ModifyDBInstanceOutput, error)
	DeleteDBInstance(context.Context, *rds.DeleteDBInstanceInput, ...func(*rds.Options)) (*rds.DeleteDBInstanceOutput, error)
	AddTagsToResource(context.Context, *rds.AddTagsToResourceInput, ...func(*rds.Options)) (*rds.AddTagsToResourceOutput, error)
}

Client defines RDS RDSClient operations

func NewClient

func NewClient(cfg *aws.Config) Client

NewClient creates new RDS RDSClient with provided AWS Configurations/Credentials