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 = errors.New("DBClusterAlreadyExists") + var ErrClusterEndpointAlreadyExists = errors.New("DBClusterEndpointAlreadyExists") + var ErrClusterEndpointNotFound = errors.New("DBClusterEndpointNotFound") + var ErrClusterNotFound = errors.New("DBClusterNotFound") + var ErrClusterParameterGroupAlreadyExists = errors.New("DBClusterParameterGroupAlreadyExists") + var ErrClusterParameterGroupNotFound = errors.New("DBClusterParameterGroupNotFound") + var ErrClusterSnapshotAlreadyExists = errors.New("DBClusterSnapshotAlreadyExists") + var ErrClusterSnapshotNotFound = errors.New("DBClusterSnapshotNotFound") + var ErrGlobalClusterAlreadyExists = errors.New("GlobalClusterAlreadyExists") + var ErrGlobalClusterNotFound = errors.New("GlobalClusterNotFound") + var ErrInstanceAlreadyExists = errors.New("DBInstanceAlreadyExists") + var ErrInstanceNotFound = errors.New("DBInstanceNotFound") + var ErrInvalidDBClusterSnapshotStateFault = errors.New("InvalidDBClusterSnapshotStateFault") + var ErrInvalidDBClusterStateFault = errors.New("InvalidDBClusterStateFault") + var ErrInvalidDBInstanceStateFault = errors.New("InvalidDBInstanceStateFault") + var ErrInvalidParameter = errors.New("InvalidParameterValue") + var ErrNilAppContext = errors.New("nil AppContext passed to Neptune Provider.Init") + var ErrParameterGroupAlreadyExists = errors.New("DBParameterGroupAlreadyExists") + var ErrParameterGroupNotFound = errors.New("DBParameterGroupNotFound") + var ErrSnapshotRequired = errors.New("InvalidParameterCombination") + var ErrSubnetGroupAlreadyExists = errors.New("DBSubnetGroupAlreadyExists") + var ErrSubnetGroupNotFound = errors.New("DBSubnetGroupNotFound") + var ErrSubscriptionAlreadyExists = errors.New("SubscriptionAlreadyExists") + var ErrSubscriptionNotFound = errors.New("SubscriptionNotFound") + var ErrUnknownAction = errors.New("InvalidAction") + type DBCluster struct + AllocatedStorage int + AssociatedRoles []string + AvailabilityZones []string + BackupRetentionPeriod int + ClusterCreateTime string + CopyTagsToSnapshot bool + DBClusterArn string + DBClusterIdentifier string + DBClusterMembers []DBClusterMember + DBClusterParameterGroupName string + DBClusterResourceID string + DBSubnetGroupName string + DeletionProtection bool + EnableIAMDatabaseAuthentication bool + Endpoint string + Engine string + EngineMode string + EngineVersion string + HostedZoneID string + KmsKeyID string + MasterUserManagedSecret *MasterUserManagedSecret + MasterUsername string + MultiAZ bool + Port int + PreferredBackupWindow string + PreferredMaintenanceWindow string + ReaderEndpoint string + ServerlessV2ScalingConfig *ServerlessV2ScalingConfiguration + Status string + StorageEncrypted bool + StorageType string + VpcSecurityGroupIDs []string + type DBClusterCreateOptions struct + AvailabilityZones []string + BackupRetentionPeriod int + CopyTagsToSnapshot bool + DBSubnetGroupName string + DeletionProtection bool + EnableIAMDatabaseAuthentication bool + EngineMode string + EngineVersion string + KmsKeyID string + ManageMasterUserPassword bool + MasterUsername string + PreferredBackupWindow string + PreferredMaintenanceWindow string + ServerlessV2ScalingConfig *ServerlessV2ScalingConfiguration + StorageEncrypted bool + StorageType string + VpcSecurityGroupIDs []string + type DBClusterDeleteOptions struct + FinalDBSnapshotIdentifier string + SkipFinalSnapshot bool + type DBClusterEndpoint struct + CustomEndpointType string + DBClusterEndpointArn string + DBClusterEndpointIdentifier string + DBClusterEndpointResourceIdentifier string + DBClusterIdentifier string + Endpoint string + EndpointType string + ExcludedMembers []string + StaticMembers []string + Status string + type DBClusterFilters struct + Engine string + EngineVersion string + Status string + type DBClusterMember struct + DBInstanceIdentifier string + IsClusterWriter bool + type DBClusterModifyOptions struct + BackupRetentionPeriod int + BackupRetentionPeriodSet bool + CopyTagsToSnapshot bool + CopyTagsToSnapshotSet bool + DeletionProtection bool + DeletionProtectionSet bool + EnableIAMDatabaseAuthentication bool + EngineVersion string + IamAuthSet bool + ManageMasterUserPassword bool + PreferredBackupWindow string + PreferredMaintenanceWindow string + ServerlessV2ScalingConfig *ServerlessV2ScalingConfiguration + VpcSecurityGroupIDs []string + type DBClusterParameterGroup struct + DBClusterParameterGroupArn string + DBClusterParameterGroupName string + DBParameterGroupFamily string + Description string + type DBClusterSnapshot struct + AllocatedStorage int + ClusterCreateTime string + DBClusterIdentifier string + DBClusterSnapshotArn string + DBClusterSnapshotIdentifier string + Engine string + EngineVersion string + IAMDatabaseAuthenticationEnabled bool + KmsKeyID string + PercentProgress int + Port int + RestoreAttributeValues []string + SnapshotCreateTime string + SnapshotType string + Status string + StorageEncrypted bool + VpcID string + type DBInstance struct + AutoMinorVersionUpgrade bool + AvailabilityZone string + CopyTagsToSnapshot bool + DBClusterIdentifier string + DBInstanceArn string + DBInstanceClass string + DBInstanceIdentifier string + DBInstanceStatus string + DBParameterGroupName string + DBSubnetGroupName string + EnableIAMDatabaseAuthentication bool + Endpoint string + Engine string + EngineVersion string + InstanceCreateTime string + MultiAZ bool + Port int + PreferredBackupWindow string + PreferredMaintenanceWindow string + PromotionTier int + PubliclyAccessible bool + StorageEncrypted bool + type DBInstanceCreateOptions struct + AutoMinorVersionUpgrade bool + AvailabilityZone string + CopyTagsToSnapshot bool + DBParameterGroupName string + EnableIAMDatabaseAuthentication bool + PreferredBackupWindow string + PreferredMaintenanceWindow string + PromotionTier int + StorageEncrypted bool + type DBInstanceModifyOptions struct + AutoMinorVersionUpgrade bool + AutoMinorVersionUpgradeSet bool + AvailabilityZone string + CopyTagsToSnapshot bool + CopyTagsToSnapshotSet bool + DBParameterGroupName string + EnableIAMDatabaseAuthentication bool + IamAuthSet bool + PreferredBackupWindow string + PreferredMaintenanceWindow string + PromotionTier int + PromotionTierSet bool + type DBParameterGroup struct + DBParameterGroupArn string + DBParameterGroupFamily string + DBParameterGroupName string + Description string + type DBSubnetGroup struct + DBSubnetGroupArn string + DBSubnetGroupDescription string + DBSubnetGroupName string + Status string + SubnetIDs []string + VpcID string + type EventSubscription struct + CustSubscriptionID string + Enabled bool + EventCategoriesList []string + EventSubscriptionArn string + SnsTopicARN string + SourceIDs []string + SourceType string + Status string + SubscriptionCreationTime string + type GlobalCluster struct + DeletionProtection bool + Engine string + EngineVersion string + GlobalClusterArn string + GlobalClusterIdentifier string + GlobalClusterMembers []GlobalClusterMember + GlobalClusterResourceID string + Status string + StorageEncrypted bool + type GlobalClusterMember struct + DBClusterARN string + IsWriter bool + type Handler struct + Backend StorageBackend + func NewHandler(backend StorageBackend) *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) AccountID() string + func (b *InMemoryBackend) AddClusterInternal(id string) *DBCluster + func (b *InMemoryBackend) AddClusterParameterGroupInternal(name, family string) *DBClusterParameterGroup + func (b *InMemoryBackend) AddEventSubscriptionInternal(name, snsTopicARN string) *EventSubscription + func (b *InMemoryBackend) AddParameterGroupInternal(name, family string) *DBParameterGroup + func (b *InMemoryBackend) AddRoleToDBCluster(ctx context.Context, clusterID, roleARN string) error + func (b *InMemoryBackend) AddSnapshotInternal(snapshotID, clusterID string) *DBClusterSnapshot + func (b *InMemoryBackend) AddSourceIdentifierToSubscription(ctx context.Context, name, sourceID string) (*EventSubscription, error) + func (b *InMemoryBackend) AddTagsToResource(ctx context.Context, arnStr string, tags []Tag) error + func (b *InMemoryBackend) ApplyPendingMaintenanceAction(_ context.Context, resourceID, applyAction, optInType string) error + func (b *InMemoryBackend) CopyDBClusterParameterGroup(ctx context.Context, sourceName, targetName, targetDescription string) (*DBClusterParameterGroup, error) + func (b *InMemoryBackend) CopyDBClusterSnapshot(ctx context.Context, sourceSnapshotID, targetSnapshotID string) (*DBClusterSnapshot, error) + func (b *InMemoryBackend) CopyDBParameterGroup(ctx context.Context, sourceName, targetName, targetDescription string) (*DBParameterGroup, error) + func (b *InMemoryBackend) CreateDBCluster(ctx context.Context, id, paramGroupName string, port int, ...) (*DBCluster, error) + func (b *InMemoryBackend) CreateDBClusterEndpoint(ctx context.Context, endpointID, clusterID, endpointType string) (*DBClusterEndpoint, error) + func (b *InMemoryBackend) CreateDBClusterParameterGroup(ctx context.Context, name, family, description string) (*DBClusterParameterGroup, error) + func (b *InMemoryBackend) CreateDBClusterSnapshot(ctx context.Context, snapshotID, clusterID string) (*DBClusterSnapshot, error) + func (b *InMemoryBackend) CreateDBInstance(ctx context.Context, id, clusterID, instanceClass string, ...) (*DBInstance, error) + func (b *InMemoryBackend) CreateDBParameterGroup(ctx context.Context, name, family, description string) (*DBParameterGroup, 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, sourceIDs []string, ...) (*EventSubscription, error) + func (b *InMemoryBackend) CreateGlobalCluster(ctx context.Context, globalClusterID, sourceDBClusterID string) (*GlobalCluster, error) + func (b *InMemoryBackend) DeleteDBCluster(ctx context.Context, id string, opts DBClusterDeleteOptions) (*DBCluster, error) + func (b *InMemoryBackend) DeleteDBClusterEndpoint(ctx context.Context, endpointID string) (*DBClusterEndpoint, 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) DeleteDBParameterGroup(ctx context.Context, name string) 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, globalClusterID string) (*GlobalCluster, error) + func (b *InMemoryBackend) DescribeDBClusterEndpoints(ctx context.Context, endpointID, clusterID string) ([]DBClusterEndpoint, error) + func (b *InMemoryBackend) DescribeDBClusterParameterGroups(ctx context.Context, name string) ([]DBClusterParameterGroup, error) + func (b *InMemoryBackend) DescribeDBClusterSnapshots(ctx context.Context, snapshotID, clusterID, snapshotTypeFilter string) ([]DBClusterSnapshot, error) + func (b *InMemoryBackend) DescribeDBClusters(ctx context.Context, id string, filters DBClusterFilters) ([]DBCluster, error) + func (b *InMemoryBackend) DescribeDBInstances(ctx context.Context, id, clusterFilter string) ([]DBInstance, error) + func (b *InMemoryBackend) DescribeDBParameterGroups(ctx context.Context, name string) ([]DBParameterGroup, error) + func (b *InMemoryBackend) DescribeDBSubnetGroups(ctx context.Context, name string) ([]DBSubnetGroup, error) + func (b *InMemoryBackend) DescribeEventSubscriptions(ctx context.Context, name string) ([]EventSubscription, error) + func (b *InMemoryBackend) DescribeGlobalClusters(_ context.Context) []GlobalCluster + func (b *InMemoryBackend) FailoverDBCluster(ctx context.Context, id, targetInstanceID string) (*DBCluster, error) + func (b *InMemoryBackend) FailoverGlobalCluster(_ context.Context, globalClusterID, _ string) (*GlobalCluster, error) + func (b *InMemoryBackend) ListTagsForResource(ctx context.Context, arnStr string) ([]Tag, error) + func (b *InMemoryBackend) ModifyDBCluster(ctx context.Context, id, paramGroupName string, opts DBClusterModifyOptions) (*DBCluster, error) + func (b *InMemoryBackend) ModifyDBClusterEndpoint(ctx context.Context, endpointID, endpointType string) (*DBClusterEndpoint, error) + func (b *InMemoryBackend) ModifyDBClusterParameterGroup(ctx context.Context, name string) (*DBClusterParameterGroup, error) + func (b *InMemoryBackend) ModifyDBClusterSnapshotAttribute(ctx context.Context, snapshotID, attributeName string, ...) (*DBClusterSnapshot, error) + func (b *InMemoryBackend) ModifyDBInstance(ctx context.Context, id, instanceClass string, opts DBInstanceModifyOptions) (*DBInstance, error) + func (b *InMemoryBackend) ModifyDBParameterGroup(ctx context.Context, name string) (*DBParameterGroup, 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, enabled string, ...) (*EventSubscription, error) + func (b *InMemoryBackend) ModifyGlobalCluster(_ context.Context, globalClusterID string) (*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, dbClusterARN string) (*GlobalCluster, error) + func (b *InMemoryBackend) RemoveRoleFromDBCluster(ctx context.Context, clusterID, roleARN string) error + func (b *InMemoryBackend) RemoveSourceIdentifierFromSubscription(ctx context.Context, name, sourceID string) (*EventSubscription, error) + func (b *InMemoryBackend) RemoveTagsFromResource(ctx context.Context, arnStr string, keys []string) error + func (b *InMemoryBackend) Reset() + func (b *InMemoryBackend) ResetDBClusterParameterGroup(ctx context.Context, name string) (*DBClusterParameterGroup, error) + func (b *InMemoryBackend) ResetDBParameterGroup(ctx context.Context, name string) (*DBParameterGroup, error) + func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error + func (b *InMemoryBackend) RestoreDBClusterFromSnapshot(ctx context.Context, snapshotID, clusterID string) (*DBCluster, error) + func (b *InMemoryBackend) RestoreDBClusterToPointInTime(ctx context.Context, srcClusterID, 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, globalClusterID, _ string) (*GlobalCluster, error) + type MasterUserManagedSecret struct + SecretARN string + SecretStatus string + type Provider struct + func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error) + func (p *Provider) Name() string + type ServerlessV2ScalingConfiguration struct + MaxCapacity float64 + MinCapacity float64 + type StorageBackend interface + AccountID func() string + AddRoleToDBCluster func(ctx context.Context, clusterID, roleARN string) error + AddSourceIdentifierToSubscription func(ctx context.Context, name, sourceID string) (*EventSubscription, error) + AddTagsToResource func(ctx context.Context, arn string, tags []Tag) error + ApplyPendingMaintenanceAction func(ctx context.Context, resourceID, applyAction, optInType string) error + CopyDBClusterParameterGroup func(ctx context.Context, sourceName, targetName, targetDescription string) (*DBClusterParameterGroup, error) + CopyDBClusterSnapshot func(ctx context.Context, sourceSnapshotID, targetSnapshotID string) (*DBClusterSnapshot, error) + CopyDBParameterGroup func(ctx context.Context, sourceName, targetName, targetDescription string) (*DBParameterGroup, error) + CreateDBCluster func(ctx context.Context, id, paramGroupName string, port int, ...) (*DBCluster, error) + CreateDBClusterEndpoint func(ctx context.Context, endpointID, clusterID, endpointType string) (*DBClusterEndpoint, error) + CreateDBClusterParameterGroup func(ctx context.Context, name, family, description string) (*DBClusterParameterGroup, error) + CreateDBClusterSnapshot func(ctx context.Context, snapshotID, clusterID string) (*DBClusterSnapshot, error) + CreateDBInstance func(ctx context.Context, id, clusterID, instanceClass string, ...) (*DBInstance, error) + CreateDBParameterGroup func(ctx context.Context, name, family, description string) (*DBParameterGroup, error) + CreateDBSubnetGroup func(ctx context.Context, name, description, vpcID string, subnetIDs []string) (*DBSubnetGroup, error) + CreateEventSubscription func(ctx context.Context, name, snsTopicARN, sourceType string, sourceIDs []string, ...) (*EventSubscription, error) + CreateGlobalCluster func(ctx context.Context, globalClusterID, sourceDBClusterID string) (*GlobalCluster, error) + DeleteDBCluster func(ctx context.Context, id string, opts DBClusterDeleteOptions) (*DBCluster, error) + DeleteDBClusterEndpoint func(ctx context.Context, endpointID string) (*DBClusterEndpoint, error) + DeleteDBClusterParameterGroup func(ctx context.Context, name string) error + DeleteDBClusterSnapshot func(ctx context.Context, snapshotID string) (*DBClusterSnapshot, error) + DeleteDBInstance func(ctx context.Context, id string) (*DBInstance, error) + DeleteDBParameterGroup func(ctx context.Context, name string) error + DeleteDBSubnetGroup func(ctx context.Context, name string) error + DeleteEventSubscription func(ctx context.Context, name string) (*EventSubscription, error) + DeleteGlobalCluster func(ctx context.Context, globalClusterID string) (*GlobalCluster, error) + DescribeDBClusterEndpoints func(ctx context.Context, endpointID, clusterID string) ([]DBClusterEndpoint, error) + DescribeDBClusterParameterGroups func(ctx context.Context, name string) ([]DBClusterParameterGroup, error) + DescribeDBClusterSnapshots func(ctx context.Context, snapshotID, clusterID, snapshotTypeFilter string) ([]DBClusterSnapshot, error) + DescribeDBClusters func(ctx context.Context, id string, filters DBClusterFilters) ([]DBCluster, error) + DescribeDBInstances func(ctx context.Context, id, clusterFilter string) ([]DBInstance, error) + DescribeDBParameterGroups func(ctx context.Context, name string) ([]DBParameterGroup, error) + DescribeDBSubnetGroups func(ctx context.Context, name string) ([]DBSubnetGroup, error) + DescribeEventSubscriptions func(ctx context.Context, name string) ([]EventSubscription, error) + DescribeGlobalClusters func(ctx context.Context) []GlobalCluster + FailoverDBCluster func(ctx context.Context, id, targetInstanceID string) (*DBCluster, error) + FailoverGlobalCluster func(ctx context.Context, globalClusterID, targetDBClusterID string) (*GlobalCluster, error) + ListTagsForResource func(ctx context.Context, arn string) ([]Tag, error) + ModifyDBCluster func(ctx context.Context, id, paramGroupName string, opts DBClusterModifyOptions) (*DBCluster, error) + ModifyDBClusterEndpoint func(ctx context.Context, endpointID, endpointType string) (*DBClusterEndpoint, error) + ModifyDBClusterParameterGroup func(ctx context.Context, name string) (*DBClusterParameterGroup, error) + ModifyDBClusterSnapshotAttribute func(ctx context.Context, snapshotID, attributeName string, ...) (*DBClusterSnapshot, error) + ModifyDBInstance func(ctx context.Context, id, instanceClass string, opts DBInstanceModifyOptions) (*DBInstance, error) + ModifyDBParameterGroup func(ctx context.Context, name string) (*DBParameterGroup, error) + ModifyDBSubnetGroup func(ctx context.Context, name, description string, subnetIDs []string) (*DBSubnetGroup, error) + ModifyEventSubscription func(ctx context.Context, name, snsTopicARN, sourceType, enabled string, ...) (*EventSubscription, error) + ModifyGlobalCluster func(ctx context.Context, globalClusterID string) (*GlobalCluster, error) + RebootDBInstance func(ctx context.Context, id string) (*DBInstance, error) + Region func() string + RemoveFromGlobalCluster func(ctx context.Context, globalClusterID, dbClusterID string) (*GlobalCluster, error) + RemoveRoleFromDBCluster func(ctx context.Context, clusterID, roleARN string) error + RemoveSourceIdentifierFromSubscription func(ctx context.Context, name, sourceID string) (*EventSubscription, error) + RemoveTagsFromResource func(ctx context.Context, arn string, keys []string) error + Reset func() + ResetDBClusterParameterGroup func(ctx context.Context, name string) (*DBClusterParameterGroup, error) + ResetDBParameterGroup func(ctx context.Context, name string) (*DBParameterGroup, error) + Restore func(ctx context.Context, data []byte) error + RestoreDBClusterFromSnapshot func(ctx context.Context, snapshotID, clusterID string) (*DBCluster, error) + RestoreDBClusterToPointInTime func(ctx context.Context, srcClusterID, targetClusterID string) (*DBCluster, error) + Snapshot func(ctx context.Context) []byte + StartDBCluster func(ctx context.Context, id string) (*DBCluster, error) + StopDBCluster func(ctx context.Context, id string) (*DBCluster, error) + SwitchoverGlobalCluster func(ctx context.Context, globalClusterID, targetDBClusterID string) (*GlobalCluster, error) + type Tag struct + Key string + Value string
Go to main page