neptune

type DBCluster struct {
	ServerlessV2ScalingConfig       *ServerlessV2ScalingConfiguration `json:"ServerlessV2ScalingConfiguration,omitempty"`
	MasterUserManagedSecret         *MasterUserManagedSecret          `json:"MasterUserManagedSecret,omitempty"`
	KmsKeyID                        string                            `json:"KmsKeyID"`
	HostedZoneID                    string                            `json:"HostedZoneId"`
	Engine                          string                            `json:"Engine"`
	EngineVersion                   string                            `json:"EngineVersion"`
	DBClusterIdentifier             string                            `json:"DBClusterIdentifier"`
	Status                          string                            `json:"Status"`
	DBClusterParameterGroupName     string                            `json:"DBClusterParameterGroupName"`
	DBSubnetGroupName               string                            `json:"DBSubnetGroupName"`
	Endpoint                        string                            `json:"Endpoint"`
	ReaderEndpoint                  string                            `json:"ReaderEndpoint"`
	PreferredBackupWindow           string                            `json:"PreferredBackupWindow"`
	PreferredMaintenanceWindow      string                            `json:"PreferredMaintenanceWindow"`
	DBClusterArn                    string                            `json:"DBClusterArn"`
	DBClusterResourceID             string                            `json:"DbClusterResourceId"`
	ClusterCreateTime               string                            `json:"ClusterCreateTime"`
	StorageType                     string                            `json:"StorageType"`
	EngineMode                      string                            `json:"EngineMode"`
	MasterUsername                  string                            `json:"MasterUsername"`
	AvailabilityZones               []string                          `json:"AvailabilityZones"`
	VpcSecurityGroupIDs             []string                          `json:"VpcSecurityGroupIds"`
	AssociatedRoles                 []string                          `json:"AssociatedRoles"`
	DBClusterMembers                []DBClusterMember                 `json:"DBClusterMembers"`
	Port                            int                               `json:"Port"`
	BackupRetentionPeriod           int                               `json:"BackupRetentionPeriod"`
	AllocatedStorage                int                               `json:"AllocatedStorage"`
	EnableIAMDatabaseAuthentication bool                              `json:"EnableIAMDatabaseAuthentication"`
	StorageEncrypted                bool                              `json:"StorageEncrypted"`
	MultiAZ                         bool                              `json:"MultiAZ"`
	DeletionProtection              bool                              `json:"DeletionProtection"`
	CopyTagsToSnapshot              bool                              `json:"CopyTagsToSnapshot"`
	// contains filtered or unexported fields
}

type DBClusterCreateOptions struct {
	ServerlessV2ScalingConfig       *ServerlessV2ScalingConfiguration
	DBSubnetGroupName               string
	StorageType                     string
	EngineVersion                   string
	EngineMode                      string
	KmsKeyID                        string
	PreferredBackupWindow           string
	MasterUsername                  string
	PreferredMaintenanceWindow      string
	AvailabilityZones               []string
	VpcSecurityGroupIDs             []string
	BackupRetentionPeriod           int
	EnableIAMDatabaseAuthentication bool
	ManageMasterUserPassword        bool
	StorageEncrypted                bool
	DeletionProtection              bool
	CopyTagsToSnapshot              bool
}

type DBClusterDeleteOptions struct {
	FinalDBSnapshotIdentifier string
	SkipFinalSnapshot         bool
}

type DBClusterEndpoint struct {
	DBClusterEndpointIdentifier         string   `json:"DBClusterEndpointIdentifier"`
	DBClusterIdentifier                 string   `json:"DBClusterIdentifier"`
	DBClusterEndpointArn                string   `json:"DBClusterEndpointArn"`
	DBClusterEndpointResourceIdentifier string   `json:"DBClusterEndpointResourceIdentifier"`
	EndpointType                        string   `json:"EndpointType"`
	CustomEndpointType                  string   `json:"CustomEndpointType"`
	Status                              string   `json:"Status"`
	Endpoint                            string   `json:"Endpoint"`
	StaticMembers                       []string `json:"StaticMembers"`
	ExcludedMembers                     []string `json:"ExcludedMembers"`
	// contains filtered or unexported fields
}

type DBClusterFilters struct {
	Engine        string
	EngineVersion string
	Status        string
}

type DBClusterMember struct {
	DBInstanceIdentifier string `json:"DBInstanceIdentifier"`
	IsClusterWriter      bool   `json:"IsClusterWriter"`
}

type DBClusterModifyOptions struct {
	ServerlessV2ScalingConfig       *ServerlessV2ScalingConfiguration
	EngineVersion                   string
	PreferredBackupWindow           string
	PreferredMaintenanceWindow      string
	VpcSecurityGroupIDs             []string
	BackupRetentionPeriod           int
	EnableIAMDatabaseAuthentication bool
	IamAuthSet                      bool
	ManageMasterUserPassword        bool
	DeletionProtection              bool
	DeletionProtectionSet           bool
	CopyTagsToSnapshot              bool
	CopyTagsToSnapshotSet           bool
	BackupRetentionPeriodSet        bool
}

type DBClusterParameterGroup struct {
	DBClusterParameterGroupName string `json:"DBClusterParameterGroupName"`
	DBClusterParameterGroupArn  string `json:"DBClusterParameterGroupArn"`
	DBParameterGroupFamily      string `json:"DBParameterGroupFamily"`
	Description                 string `json:"Description"`
	// contains filtered or unexported fields
}

type DBClusterSnapshot struct {
	DBClusterSnapshotIdentifier string `json:"DBClusterSnapshotIdentifier"`
	DBClusterSnapshotArn        string `json:"DBClusterSnapshotArn"`
	DBClusterIdentifier         string `json:"DBClusterIdentifier"`
	Engine                      string `json:"Engine"`
	EngineVersion               string `json:"EngineVersion"`
	Status                      string `json:"Status"`
	SnapshotType                string `json:"SnapshotType"`
	SnapshotCreateTime          string `json:"SnapshotCreateTime"`
	ClusterCreateTime           string `json:"ClusterCreateTime"`
	KmsKeyID                    string `json:"KmsKeyId"`
	VpcID                       string `json:"VpcId"`
	// RestoreAttributeValues holds the account IDs (or "all") authorized to
	// copy/restore this manual snapshot via the "restore" DB cluster snapshot
	// attribute -- the only attribute Neptune's API models (see
	// ModifyDBClusterSnapshotAttribute/DescribeDBClusterSnapshotAttributes).
	RestoreAttributeValues           []string `json:"RestoreAttributeValues"`
	Port                             int      `json:"Port"`
	PercentProgress                  int      `json:"PercentProgress"`
	AllocatedStorage                 int      `json:"AllocatedStorage"`
	StorageEncrypted                 bool     `json:"StorageEncrypted"`
	IAMDatabaseAuthenticationEnabled bool     `json:"IAMDatabaseAuthenticationEnabled"`
	// contains filtered or unexported fields
}

type DBInstance struct {
	DBInstanceIdentifier            string `json:"DBInstanceIdentifier"`
	DBInstanceArn                   string `json:"DBInstanceArn"`
	DBClusterIdentifier             string `json:"DBClusterIdentifier"`
	DBInstanceClass                 string `json:"DBInstanceClass"`
	Engine                          string `json:"Engine"`
	EngineVersion                   string `json:"EngineVersion"`
	DBInstanceStatus                string `json:"DBInstanceStatus"`
	InstanceCreateTime              string `json:"InstanceCreateTime"`
	Endpoint                        string `json:"Endpoint"`
	DBSubnetGroupName               string `json:"DBSubnetGroupName"`
	DBParameterGroupName            string `json:"DBParameterGroupName"`
	PreferredMaintenanceWindow      string `json:"PreferredMaintenanceWindow"`
	PreferredBackupWindow           string `json:"PreferredBackupWindow"`
	AvailabilityZone                string `json:"AvailabilityZone"`
	Port                            int    `json:"Port"`
	PromotionTier                   int    `json:"PromotionTier"`
	StorageEncrypted                bool   `json:"StorageEncrypted"`
	AutoMinorVersionUpgrade         bool   `json:"AutoMinorVersionUpgrade"`
	CopyTagsToSnapshot              bool   `json:"CopyTagsToSnapshot"`
	EnableIAMDatabaseAuthentication bool   `json:"EnableIAMDatabaseAuthentication"`
	MultiAZ                         bool   `json:"MultiAZ"`
	PubliclyAccessible              bool   `json:"PubliclyAccessible"`
	// contains filtered or unexported fields
}

type DBInstanceCreateOptions struct {
	DBParameterGroupName            string
	PreferredMaintenanceWindow      string
	PreferredBackupWindow           string
	AvailabilityZone                string
	PromotionTier                   int
	AutoMinorVersionUpgrade         bool
	CopyTagsToSnapshot              bool
	EnableIAMDatabaseAuthentication bool
	StorageEncrypted                bool
}

type DBInstanceModifyOptions struct {
	DBParameterGroupName            string
	PreferredMaintenanceWindow      string
	PreferredBackupWindow           string
	AvailabilityZone                string
	PromotionTier                   int
	AutoMinorVersionUpgrade         bool
	AutoMinorVersionUpgradeSet      bool
	CopyTagsToSnapshot              bool
	CopyTagsToSnapshotSet           bool
	EnableIAMDatabaseAuthentication bool
	IamAuthSet                      bool
	PromotionTierSet                bool
}

type DBParameterGroup struct {
	DBParameterGroupName   string `json:"DBParameterGroupName"`
	DBParameterGroupArn    string `json:"DBParameterGroupArn"`
	DBParameterGroupFamily string `json:"DBParameterGroupFamily"`
	Description            string `json:"Description"`
	// contains filtered or unexported fields
}

type DBSubnetGroup struct {
	DBSubnetGroupName        string   `json:"DBSubnetGroupName"`
	DBSubnetGroupArn         string   `json:"DBSubnetGroupArn"`
	DBSubnetGroupDescription string   `json:"DBSubnetGroupDescription"`
	VpcID                    string   `json:"VpcID"`
	Status                   string   `json:"Status"`
	SubnetIDs                []string `json:"SubnetIDs"`
	// contains filtered or unexported fields
}

type EventSubscription struct {
	CustSubscriptionID       string   `json:"CustSubscriptionID"`
	SnsTopicARN              string   `json:"SnsTopicARN"`
	EventSubscriptionArn     string   `json:"EventSubscriptionArn"`
	Status                   string   `json:"Status"`
	SourceType               string   `json:"SourceType"`
	SubscriptionCreationTime string   `json:"SubscriptionCreationTime"`
	SourceIDs                []string `json:"SourceIDs"`
	EventCategoriesList      []string `json:"EventCategoriesList"`
	Enabled                  bool     `json:"Enabled"`
	// contains filtered or unexported fields
}

type GlobalCluster struct {
	GlobalClusterIdentifier string                `json:"GlobalClusterIdentifier"`
	GlobalClusterArn        string                `json:"GlobalClusterArn"`
	GlobalClusterResourceID string                `json:"GlobalClusterResourceId"`
	Status                  string                `json:"Status"`
	Engine                  string                `json:"Engine"`
	EngineVersion           string                `json:"EngineVersion"`
	GlobalClusterMembers    []GlobalClusterMember `json:"GlobalClusterMembers"`
	StorageEncrypted        bool                  `json:"StorageEncrypted"`
	DeletionProtection      bool                  `json:"DeletionProtection"`
}

type GlobalClusterMember struct {
	DBClusterARN string `json:"DBClusterARN"`
	IsWriter     bool   `json:"IsWriter"`
}

type Handler struct {
	Backend StorageBackend
}

type InMemoryBackend struct {
	// contains filtered or unexported fields
}

type MasterUserManagedSecret struct {
	SecretARN    string `json:"secretArn"`
	SecretStatus string `json:"secretStatus"`
}

type Provider struct{}

type ServerlessV2ScalingConfiguration struct {
	MinCapacity float64 `json:"minCapacity"`
	MaxCapacity float64 `json:"maxCapacity"`
}

type StorageBackend interface {
	// Cluster operations
	CreateDBCluster(
		ctx context.Context,
		id, paramGroupName string,
		port int,
		opts DBClusterCreateOptions,
	) (*DBCluster, error)
	DescribeDBClusters(
		ctx context.Context,
		id string,
		filters DBClusterFilters,
	) ([]DBCluster, error)
	DeleteDBCluster(ctx context.Context, id string, opts DBClusterDeleteOptions) (*DBCluster, error)
	ModifyDBCluster(
		ctx context.Context,
		id, paramGroupName string,
		opts DBClusterModifyOptions,
	) (*DBCluster, error)
	StopDBCluster(ctx context.Context, id string) (*DBCluster, error)
	StartDBCluster(ctx context.Context, id string) (*DBCluster, error)
	FailoverDBCluster(ctx context.Context, id, targetInstanceID string) (*DBCluster, error)

	// Instance operations
	CreateDBInstance(
		ctx context.Context,
		id, clusterID, instanceClass string,
		opts DBInstanceCreateOptions,
	) (*DBInstance, error)
	DescribeDBInstances(ctx context.Context, id, clusterFilter string) ([]DBInstance, error)
	DeleteDBInstance(ctx context.Context, id string) (*DBInstance, error)
	ModifyDBInstance(
		ctx context.Context,
		id, instanceClass string,
		opts DBInstanceModifyOptions,
	) (*DBInstance, error)
	RebootDBInstance(ctx context.Context, id string) (*DBInstance, error)

	// Subnet group operations
	CreateDBSubnetGroup(
		ctx context.Context,
		name, description, vpcID string,
		subnetIDs []string,
	) (*DBSubnetGroup, error)
	DescribeDBSubnetGroups(ctx context.Context, name string) ([]DBSubnetGroup, error)
	DeleteDBSubnetGroup(ctx context.Context, name string) error

	// Cluster parameter group operations
	CreateDBClusterParameterGroup(
		ctx context.Context,
		name, family, description string,
	) (*DBClusterParameterGroup, error)
	DescribeDBClusterParameterGroups(
		ctx context.Context,
		name string,
	) ([]DBClusterParameterGroup, error)
	DeleteDBClusterParameterGroup(ctx context.Context, name string) error
	ModifyDBClusterParameterGroup(
		ctx context.Context,
		name string,
	) (*DBClusterParameterGroup, error)

	// Cluster snapshot operations
	CreateDBClusterSnapshot(
		ctx context.Context,
		snapshotID, clusterID string,
	) (*DBClusterSnapshot, error)
	DescribeDBClusterSnapshots(
		ctx context.Context,
		snapshotID, clusterID, snapshotTypeFilter string,
	) ([]DBClusterSnapshot, error)
	DeleteDBClusterSnapshot(ctx context.Context, snapshotID string) (*DBClusterSnapshot, error)
	ModifyDBClusterSnapshotAttribute(
		ctx context.Context,
		snapshotID, attributeName string,
		valuesToAdd, valuesToRemove []string,
	) (*DBClusterSnapshot, error)

	// Tag operations
	AddTagsToResource(ctx context.Context, arn string, tags []Tag) error
	RemoveTagsFromResource(ctx context.Context, arn string, keys []string) error
	ListTagsForResource(ctx context.Context, arn string) ([]Tag, error)

	// New operations (Issue #902)
	AddRoleToDBCluster(ctx context.Context, clusterID, roleARN string) error
	AddSourceIdentifierToSubscription(
		ctx context.Context,
		name, sourceID string,
	) (*EventSubscription, error)
	ApplyPendingMaintenanceAction(
		ctx context.Context,
		resourceID, applyAction, optInType string,
	) error
	CopyDBClusterParameterGroup(
		ctx context.Context,
		sourceName, targetName, targetDescription string,
	) (*DBClusterParameterGroup, error)
	CopyDBClusterSnapshot(
		ctx context.Context,
		sourceSnapshotID, targetSnapshotID string,
	) (*DBClusterSnapshot, error)
	CopyDBParameterGroup(
		ctx context.Context,
		sourceName, targetName, targetDescription string,
	) (*DBParameterGroup, error)
	CreateDBClusterEndpoint(
		ctx context.Context,
		endpointID, clusterID, endpointType string,
	) (*DBClusterEndpoint, error)
	CreateDBParameterGroup(
		ctx context.Context,
		name, family, description string,
	) (*DBParameterGroup, error)
	CreateEventSubscription(
		ctx context.Context,
		name, snsTopicARN, sourceType string,
		sourceIDs []string,
		enabled bool,
	) (*EventSubscription, error)
	CreateGlobalCluster(
		ctx context.Context,
		globalClusterID, sourceDBClusterID string,
	) (*GlobalCluster, error)
	DescribeGlobalClusters(ctx context.Context) []GlobalCluster

	// Cluster endpoint operations
	DeleteDBClusterEndpoint(ctx context.Context, endpointID string) (*DBClusterEndpoint, error)
	DescribeDBClusterEndpoints(
		ctx context.Context,
		endpointID, clusterID string,
	) ([]DBClusterEndpoint, error)
	ModifyDBClusterEndpoint(
		ctx context.Context,
		endpointID, endpointType string,
	) (*DBClusterEndpoint, error)

	// DB parameter group operations
	DeleteDBParameterGroup(ctx context.Context, name string) error
	DescribeDBParameterGroups(ctx context.Context, name string) ([]DBParameterGroup, error)
	ModifyDBParameterGroup(ctx context.Context, name string) (*DBParameterGroup, error)
	ResetDBParameterGroup(ctx context.Context, name string) (*DBParameterGroup, error)

	// Cluster parameter group extended operations
	ResetDBClusterParameterGroup(ctx context.Context, name string) (*DBClusterParameterGroup, error)

	// Event subscription extended operations
	DeleteEventSubscription(ctx context.Context, name string) (*EventSubscription, error)
	DescribeEventSubscriptions(ctx context.Context, name string) ([]EventSubscription, error)
	ModifyEventSubscription(
		ctx context.Context,
		name, snsTopicARN, sourceType, enabled string,
		eventCategories []string,
	) (*EventSubscription, error)
	RemoveSourceIdentifierFromSubscription(
		ctx context.Context,
		name, sourceID string,
	) (*EventSubscription, error)

	// Global cluster extended operations
	DeleteGlobalCluster(ctx context.Context, globalClusterID string) (*GlobalCluster, error)
	FailoverGlobalCluster(
		ctx context.Context,
		globalClusterID, targetDBClusterID string,
	) (*GlobalCluster, error)
	ModifyGlobalCluster(ctx context.Context, globalClusterID string) (*GlobalCluster, error)
	RemoveFromGlobalCluster(
		ctx context.Context,
		globalClusterID, dbClusterID string,
	) (*GlobalCluster, error)
	SwitchoverGlobalCluster(
		ctx context.Context,
		globalClusterID, targetDBClusterID string,
	) (*GlobalCluster, error)

	// Role operations
	RemoveRoleFromDBCluster(ctx context.Context, clusterID, roleARN string) error

	// Restore operations
	RestoreDBClusterFromSnapshot(
		ctx context.Context,
		snapshotID, clusterID string,
	) (*DBCluster, error)
	RestoreDBClusterToPointInTime(
		ctx context.Context,
		srcClusterID, targetClusterID string,
	) (*DBCluster, error)

	// Subnet group extended operations
	ModifyDBSubnetGroup(ctx context.Context, name, description string, subnetIDs []string) (*DBSubnetGroup, error)

	// Lifecycle
	Reset()
	Region() string
	AccountID() string
	Snapshot(ctx context.Context) []byte
	Restore(ctx context.Context, data []byte) error
}

type Tag struct {
	Key   string `json:"Key"`
	Value string `json:"Value"`
}