Versions in this module Expand all Collapse all v1 v1.1.4 Jul 20, 2026 v1.1.3 Jul 20, 2026 v1.1.2 Jul 20, 2026 v1.1.1 Jul 20, 2026 v1.1.0 Jul 19, 2026 Changes in this version + var ErrClusterAlreadyExists = awserr.New("DBClusterAlreadyExistsFault", awserr.ErrAlreadyExists) + var ErrClusterNotFound = awserr.New("DBClusterNotFoundFault", awserr.ErrNotFound) + var ErrClusterParameterGroupAlreadyExists = awserr.New("DBParameterGroupAlreadyExists", awserr.ErrAlreadyExists) + var ErrClusterParameterGroupNotFound = awserr.New("DBParameterGroupNotFound", awserr.ErrNotFound) + var ErrClusterSnapshotAlreadyExists = awserr.New("DBClusterSnapshotAlreadyExistsFault", awserr.ErrAlreadyExists) + var ErrClusterSnapshotNotFound = awserr.New("DBClusterSnapshotNotFoundFault", awserr.ErrNotFound) + var ErrEventSubscriptionAlreadyExists = awserr.New("SubscriptionAlreadyExist", awserr.ErrAlreadyExists) + var ErrEventSubscriptionNotFound = awserr.New("SubscriptionNotFound", awserr.ErrNotFound) + var ErrGlobalClusterAlreadyExists = awserr.New("GlobalClusterAlreadyExistsFault", awserr.ErrAlreadyExists) + var ErrGlobalClusterNotFound = awserr.New("GlobalClusterNotFoundFault", awserr.ErrNotFound) + var ErrInstanceAlreadyExists = awserr.New("DBInstanceAlreadyExists", awserr.ErrAlreadyExists) + var ErrInstanceNotFound = awserr.New("DBInstanceNotFound", awserr.ErrNotFound) + var ErrInvalidClusterState = awserr.New("InvalidDBClusterStateFault", awserr.ErrInvalidParameter) + var ErrInvalidParameter = awserr.New("InvalidParameterValue", awserr.ErrInvalidParameter) + var ErrNilAppContext = errors.New("AppContext is required") + var ErrParameterGroupInUse = awserr.New("InvalidDBParameterGroupState", awserr.ErrInvalidParameter) + var ErrSubnetGroupAlreadyExists = awserr.New("DBSubnetGroupAlreadyExists", awserr.ErrAlreadyExists) + var ErrSubnetGroupInUse = awserr.New("InvalidDBSubnetGroupStateFault", awserr.ErrInvalidParameter) + var ErrSubnetGroupNotFound = awserr.New("DBSubnetGroupNotFoundFault", awserr.ErrNotFound) + var ErrUnknownAction = awserr.New("InvalidAction", awserr.ErrInvalidParameter) + type Certificate struct + CertificateIdentifier string + CertificateType string + Thumbprint string + ValidFrom string + ValidTill string + type CreateDBClusterOptions struct + EnabledCloudwatchLogsExports []string + IAMDatabaseAuthenticationEnabled bool + KmsKeyID string + VpcSecurityGroupIDs []string + type CreateDBInstanceOptions struct + CACertificateIdentifier string + CopyTagsToSnapshot bool + type DBCluster struct + AvailabilityZones []string + BackupRetentionPeriod int + ClusterCreateTime string + DBClusterArn string + DBClusterIdentifier string + DBClusterParameterGroupName string + DBSubnetGroupName string + DatabaseName string + DeletionProtection bool + EnabledCloudwatchLogsExports []string + Endpoint string + Engine string + EngineVersion string + HostedZoneID string + IAMDatabaseAuthenticationEnabled bool + KmsKeyID string + MasterUsername string + MultiAZ bool + Port int + PreferredBackupWindow string + PreferredMaintenanceWindow string + ReadReplicaIdentifiers []string + ReaderEndpoint string + ReplicationSourceIdentifier string + Status string + StorageEncrypted bool + Tags map[string]string + VpcSecurityGroupIDs []string + type DBClusterMemberEntry struct + DBInstanceIdentifier string + IsClusterWriter bool + PromotionTier int + type DBClusterParameter struct + ApplyType string + DataType string + Description string + IsModifiable bool + ParameterName string + ParameterValue string + Source string + type DBClusterParameterGroup struct + DBClusterParameterGroupArn string + DBClusterParameterGroupName string + DBParameterGroupFamily string + Description string + Parameters map[string]string + Tags map[string]string + type DBClusterSnapshot struct + DBClusterArn string + DBClusterIdentifier string + DBClusterSnapshotIdentifier string + Engine string + EngineVersion string + PercentProgress int + SnapshotCreateTime string + SnapshotType string + Status string + StorageEncrypted bool + Tags map[string]string + type DBClusterSnapshotAttribute struct + AttributeName string + AttributeValues []string + type DBClusterSnapshotAttributesResult struct + Attributes []DBClusterSnapshotAttribute + DBClusterSnapshotIdentifier string + type DBEngineVersion struct + DBEngineDescription string + Engine string + EngineVersion string + type DBInstance struct + AutoMinorVersionUpgrade bool + AvailabilityZone string + CACertificateIdentifier string + CopyTagsToSnapshot bool + DBClusterIdentifier string + DBInstanceArn string + DBInstanceClass string + DBInstanceIdentifier string + DBInstanceStatus string + DBSubnetGroupName string + EnabledCloudwatchLogsExports []string + Endpoint string + Engine string + EngineVersion string + Port int + PreferredMaintenanceWindow string + PromotionTier int + PubliclyAccessible bool + StorageEncrypted bool + Tags map[string]string + type DBSubnetGroup struct + DBSubnetGroupArn string + DBSubnetGroupDescription string + DBSubnetGroupName string + Status string + SubnetIDs []string + Tags map[string]string + VpcID string + type DeleteDBClusterOptions struct + FinalDBClusterSnapshotIdentifier string + SkipFinalSnapshot bool + type EventCategoryMap struct + EventCategories []string + SourceType string + type EventSubscription struct + EventCategories []string + SnsTopicARN string + SourceIDs []string + SourceType string + Status string + SubscriptionName string + type GlobalCluster struct + DeletionProtection bool + Engine string + EngineVersion string + GlobalClusterArn string + GlobalClusterIdentifier string + SourceDBClusterID string + Status string + StorageEncrypted bool + type Handler struct + Backend *InMemoryBackend + func NewHandler(backend *InMemoryBackend) *Handler + func (h *Handler) ChaosOperations() []string + func (h *Handler) ChaosRegions() []string + func (h *Handler) ChaosServiceName() string + func (h *Handler) ExtractOperation(c *echo.Context) string + func (h *Handler) ExtractResource(c *echo.Context) string + func (h *Handler) GetSupportedOperations() []string + func (h *Handler) Handler() echo.HandlerFunc + func (h *Handler) MatchPriority() int + func (h *Handler) Name() string + func (h *Handler) Reset() + func (h *Handler) Restore(ctx context.Context, data []byte) error + func (h *Handler) RouteMatcher() service.Matcher + func (h *Handler) Snapshot(ctx context.Context) []byte + type InMemoryBackend struct + func NewInMemoryBackend(accountID, region string) *InMemoryBackend + func (b *InMemoryBackend) AddDBClusterInternal(cluster *DBCluster) + func (b *InMemoryBackend) AddDBClusterParameterGroupInternal(pg *DBClusterParameterGroup) + func (b *InMemoryBackend) AddDBClusterSnapshotInternal(snap *DBClusterSnapshot) + func (b *InMemoryBackend) AddDBInstanceInternal(inst *DBInstance) + func (b *InMemoryBackend) AddDBSubnetGroupInternal(sg *DBSubnetGroup) + func (b *InMemoryBackend) AddEventSubscriptionInternal(sub *EventSubscription) + func (b *InMemoryBackend) AddGlobalClusterInternal(gc *GlobalCluster) + func (b *InMemoryBackend) AddSourceIdentifierToSubscription(ctx context.Context, subscriptionName, sourceID string) (*EventSubscription, error) + func (b *InMemoryBackend) AddTagsToResource(ctx context.Context, arnStr string, tags []Tag) error + func (b *InMemoryBackend) ApplyPendingMaintenanceAction(_ context.Context, resourceARN, action, optInType string) error + func (b *InMemoryBackend) CopyDBClusterParameterGroup(ctx context.Context, sourceGroupName, targetName, targetDescription string) (*DBClusterParameterGroup, error) + func (b *InMemoryBackend) CopyDBClusterSnapshot(ctx context.Context, sourceSnapshotID, targetSnapshotID string) (*DBClusterSnapshot, error) + func (b *InMemoryBackend) CreateDBCluster(ctx context.Context, ...) (*DBCluster, error) + func (b *InMemoryBackend) CreateDBClusterParameterGroup(ctx context.Context, name, family, description string, tags map[string]string) (*DBClusterParameterGroup, error) + func (b *InMemoryBackend) CreateDBClusterSnapshot(ctx context.Context, snapshotID, clusterID string, tags map[string]string) (*DBClusterSnapshot, error) + func (b *InMemoryBackend) CreateDBInstance(ctx context.Context, id, clusterID, instanceClass, engine string, ...) (*DBInstance, error) + func (b *InMemoryBackend) CreateDBSubnetGroup(ctx context.Context, name, description, vpcID string, subnetIDs []string, ...) (*DBSubnetGroup, error) + func (b *InMemoryBackend) CreateEventSubscription(ctx context.Context, name, snsTopicARN, sourceType string, ...) (*EventSubscription, error) + func (b *InMemoryBackend) CreateGlobalCluster(_ context.Context, id, sourceDBClusterID, engine, engineVersion string) (*GlobalCluster, error) + func (b *InMemoryBackend) DeleteDBCluster(ctx context.Context, id string, opts *DeleteDBClusterOptions) (*DBCluster, error) + func (b *InMemoryBackend) DeleteDBClusterParameterGroup(ctx context.Context, name string) error + func (b *InMemoryBackend) DeleteDBClusterSnapshot(ctx context.Context, snapshotID string) (*DBClusterSnapshot, error) + func (b *InMemoryBackend) DeleteDBInstance(ctx context.Context, id string) (*DBInstance, error) + func (b *InMemoryBackend) DeleteDBSubnetGroup(ctx context.Context, name string) error + func (b *InMemoryBackend) DeleteEventSubscription(ctx context.Context, name string) (*EventSubscription, error) + func (b *InMemoryBackend) DeleteGlobalCluster(_ context.Context, id string) (*GlobalCluster, error) + func (b *InMemoryBackend) DescribeCertificates(_ context.Context, certificateID string) []Certificate + func (b *InMemoryBackend) DescribeDBClusterParameterGroups(ctx context.Context, name string) ([]DBClusterParameterGroup, error) + func (b *InMemoryBackend) DescribeDBClusterParameters(ctx context.Context, groupName string) ([]DBClusterParameter, error) + func (b *InMemoryBackend) DescribeDBClusterSnapshotAttributes(ctx context.Context, snapshotID string) (*DBClusterSnapshotAttributesResult, error) + func (b *InMemoryBackend) DescribeDBClusterSnapshots(ctx context.Context, snapshotID, clusterID, snapshotType string) ([]DBClusterSnapshot, error) + func (b *InMemoryBackend) DescribeDBClusters(ctx context.Context, id string) ([]DBCluster, error) + func (b *InMemoryBackend) DescribeDBEngineVersions(_ context.Context, engine, engineVersion string) []DBEngineVersion + func (b *InMemoryBackend) DescribeDBInstances(ctx context.Context, id, clusterID string) ([]DBInstance, error) + func (b *InMemoryBackend) DescribeDBSubnetGroups(ctx context.Context, name string) ([]DBSubnetGroup, error) + func (b *InMemoryBackend) DescribeEngineDefaultClusterParameters(_ context.Context, _ string) []DBClusterParameter + func (b *InMemoryBackend) DescribeEventCategories(_ context.Context, sourceType string) []EventCategoryMap + func (b *InMemoryBackend) DescribeEventSubscriptions(ctx context.Context, name string) []EventSubscription + func (b *InMemoryBackend) DescribeGlobalClusters(_ context.Context, id string) []GlobalCluster + func (b *InMemoryBackend) DescribePendingMaintenanceActions(_ context.Context, _ string) []ResourcePendingMaintenanceActions + func (b *InMemoryBackend) FailoverDBCluster(ctx context.Context, id string) (*DBCluster, error) + func (b *InMemoryBackend) FailoverGlobalCluster(_ context.Context, id, _ string) (*GlobalCluster, error) + func (b *InMemoryBackend) GetClusterMembers(ctx context.Context, clusterID string) []DBClusterMemberEntry + func (b *InMemoryBackend) ListTagsForResource(ctx context.Context, arnStr string) []Tag + func (b *InMemoryBackend) ModifyDBCluster(ctx context.Context, id, paramGroupName string, deletionProtection *bool, ...) (*DBCluster, error) + func (b *InMemoryBackend) ModifyDBClusterParameterGroup(ctx context.Context, name string, parameters map[string]string) (*DBClusterParameterGroup, error) + func (b *InMemoryBackend) ModifyDBClusterSnapshotAttribute(ctx context.Context, snapshotID, attributeName string, ...) (*DBClusterSnapshotAttributesResult, error) + func (b *InMemoryBackend) ModifyDBInstance(ctx context.Context, id, instanceClass string, autoMinorVersionUpgrade *bool, ...) (*DBInstance, error) + func (b *InMemoryBackend) ModifyDBSubnetGroup(ctx context.Context, name, description string, subnetIDs []string) (*DBSubnetGroup, error) + func (b *InMemoryBackend) ModifyEventSubscription(ctx context.Context, name, snsTopicARN, sourceType string, ...) (*EventSubscription, error) + func (b *InMemoryBackend) ModifyGlobalCluster(_ context.Context, id, newID string, deletionProtection *bool) (*GlobalCluster, error) + func (b *InMemoryBackend) RebootDBInstance(ctx context.Context, id string) (*DBInstance, error) + func (b *InMemoryBackend) Region() string + func (b *InMemoryBackend) RemoveFromGlobalCluster(_ context.Context, globalClusterID, _ string) (*GlobalCluster, error) + func (b *InMemoryBackend) RemoveSourceIdentifierFromSubscription(ctx context.Context, subscriptionName, sourceID string) (*EventSubscription, error) + func (b *InMemoryBackend) RemoveTagsFromResource(ctx context.Context, arnStr string, keys []string) + func (b *InMemoryBackend) Reset() + func (b *InMemoryBackend) ResetDBClusterParameterGroup(ctx context.Context, name string) (*DBClusterParameterGroup, error) + func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error + func (b *InMemoryBackend) RestoreDBClusterFromSnapshot(ctx context.Context, snapshotID, clusterID, engine string) (*DBCluster, error) + func (b *InMemoryBackend) RestoreDBClusterToPointInTime(ctx context.Context, sourceClusterID, targetClusterID string) (*DBCluster, error) + func (b *InMemoryBackend) Snapshot(ctx context.Context) []byte + func (b *InMemoryBackend) StartDBCluster(ctx context.Context, id string) (*DBCluster, error) + func (b *InMemoryBackend) StopDBCluster(ctx context.Context, id string) (*DBCluster, error) + func (b *InMemoryBackend) SwitchoverGlobalCluster(_ context.Context, id, _ string) (*GlobalCluster, error) + type ModifyDBClusterOptions struct + DisableLogsTypes []string + EnableLogsTypes []string + EngineVersion string + MasterUserPassword string + NewDBClusterIdentifier string + Port int + VpcSecurityGroupIDs []string + type ModifyDBInstanceOptions struct + CACertificateIdentifier string + CopyTagsToSnapshot *bool + PromotionTier *int + type PendingMaintenanceAction struct + Action string + OptInStatus string + type Provider struct + func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error) + func (p *Provider) Name() string + type ResourcePendingMaintenanceActions struct + Actions []PendingMaintenanceAction + ResourceIdentifier string + type Tag struct + Key string + Value string