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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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 ¶ added in v0.46.0
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 ¶
IsErrorNotFound helper function to test for ErrCodeDBInstanceNotFoundFault error
func IsStorageTypeGP3BelowAllocatedStorageThreshold ¶ added in v0.48.0
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
Source Files
Directories