rds

Documentation

Index

• func CreatePatch(in *rdstypes.DBInstance, spec *v1beta1.RDSInstanceParameters) (*v1beta1.RDSInstanceParameters, error)
• func DiffTags(spec []v1beta1.Tag, current []rdstypes.Tag) (addTags []rdstypes.Tag, removeTags []string)
• func GenerateCreateRDSInstanceInput(name, password string, p *v1beta1.RDSInstanceParameters) *rds.CreateDBInstanceInput
• func GenerateModifyDBInstanceInput(name string, p *v1beta1.RDSInstanceParameters, db *rdstypes.DBInstance) *rds.ModifyDBInstanceInput
• func GenerateObservation(db rdstypes.DBInstance) v1beta1.RDSInstanceObservation
• func GenerateRestoreRDSInstanceFromS3Input(name, password string, p *v1beta1.RDSInstanceParameters) *rds.RestoreDBInstanceFromS3Input
• func GenerateRestoreRDSInstanceFromSnapshotInput(name string, p *v1beta1.RDSInstanceParameters) *rds.RestoreDBInstanceFromDBSnapshotInput
• func GenerateRestoreRDSInstanceToPointInTimeInput(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 IsStorageTypeGP3BelowAllocatedStorageThreshold(p *v1beta1.RDSInstanceParameters) bool
• func IsUpToDate(ctx context.Context, kube client.Client, r *v1beta1.RDSInstance, ...) (bool, string, []rdstypes.Tag, []string, 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, spec *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 DiffTags

func DiffTags(spec []v1beta1.Tag, current []rdstypes.Tag) (addTags []rdstypes.Tag, removeTags []string)

DiffTags between spec and current

func GenerateCreateRDSInstanceInput

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

GenerateCreateRDSInstanceInput from RDSInstanceSpec

func GenerateModifyDBInstanceInput

func GenerateModifyDBInstanceInput(name string, p *v1beta1.RDSInstanceParameters, db *rdstypes.DBInstance) *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 GenerateRestoreRDSInstanceFromS3Input

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

GenerateRestoreRDSInstanceFromS3Input from RDSInstanceSpec

func GenerateRestoreRDSInstanceFromSnapshotInput

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

GenerateRestoreRDSInstanceFromSnapshotInput from RDSInstanceSpec

func GenerateRestoreRDSInstanceToPointInTimeInput

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

GenerateRestoreRDSInstanceToPointInTimeInput 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 IsStorageTypeGP3BelowAllocatedStorageThreshold

func IsStorageTypeGP3BelowAllocatedStorageThreshold(p *v1beta1.RDSInstanceParameters) bool

IsStorageTypeGP3BelowAllocatedStorageThreshold returns true if storageType is gp3 and allocatedStorage is below engine specific threshold See also https://docs.aws.amazon.com/AmazonRDS/latest/UserGuide/CHAP_Storage.html#gp3-storage.

func IsUpToDate

func IsUpToDate(ctx context.Context, kube client.Client, r *v1beta1.RDSInstance, db rdstypes.DBInstance) (bool, string, []rdstypes.Tag, []string, 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)
	RemoveTagsFromResource(context.Context, *rds.RemoveTagsFromResourceInput, ...func(*rds.Options)) (*rds.RemoveTagsFromResourceOutput, error)
}

Client defines RDS RDSClient operations

func NewClient

func NewClient(cfg *aws.Config) Client

NewClient creates new RDS RDSClient with provided AWS Configurations/Credentials