Versions in this module Expand all Collapse all v1 v1.3.0 Aug 3, 2026 v1.2.0 Aug 3, 2026 Changes in this version + var ErrQev2IdcApplicationAlreadyExists = errors.New("Qev2IdcApplicationAlreadyExists") + var ErrQev2IdcApplicationNotFound = errors.New("Qev2IdcApplicationNotExists") type Cluster + SnapshotScheduleIdentifier string + SnapshotScheduleState string type DataShare + DataShareType string type EndpointAccess + ResourceOwner string + SubnetGroupName string + VpcSecurityGroupIDs []string type InMemoryBackend + func (b *InMemoryBackend) CreateQev2IdcApplication(appName, idcInstanceArn, idcDisplayName string, tags map[string]string) (*Qev2IdcApplication, error) + func (b *InMemoryBackend) DeleteQev2IdcApplication(appArn string) error + func (b *InMemoryBackend) DescribeQev2IdcApplications(appArn, marker string, maxRecords int) ([]Qev2IdcApplication, string, error) + func (b *InMemoryBackend) ModifyQev2IdcApplication(appArn, idcDisplayName string) (*Qev2IdcApplication, error) type Integration + CreateTime time.Time + Tags map[string]string + type PauseClusterAction struct + ClusterIdentifier string + type Qev2IdcApplication struct + IdcDisplayName string + IdcInstanceArn string + IdcManagedApplicationArn string + IdcOnboardStatus string + Qev2IdcApplicationArn string + Qev2IdcApplicationName string + Tags map[string]string + type ResizeClusterAction struct + Classic bool + ClusterIdentifier string + ClusterType string + NodeType string + NumberOfNodes int + ReservedNodeID string + TargetReservedNodeOfferingID string + type ResumeClusterAction struct + ClusterIdentifier string + type ScheduledActionTarget struct + PauseCluster *PauseClusterAction + ResizeCluster *ResizeClusterAction + ResumeCluster *ResumeClusterAction type SnapshotSchedule + AssociatedClusters []string type StorageBackend + CreateQev2IdcApplication func(appName, idcInstanceArn, idcDisplayName string, tags map[string]string) (*Qev2IdcApplication, error) + DeleteQev2IdcApplication func(appArn string) error + DescribeQev2IdcApplications func(appArn, marker string, maxRecords int) ([]Qev2IdcApplication, string, error) + ModifyQev2IdcApplication func(appArn, idcDisplayName string) (*Qev2IdcApplication, error) type TableRestoreStatus + SnapshotIdentifier string 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 ErrAuthProfileAlreadyExists = errors.New("AuthenticationProfileAlreadyExists") + var ErrAuthProfileNotFound = errors.New("AuthenticationProfileNotFound") + var ErrClusterAlreadyExists = errors.New("ClusterAlreadyExists") + var ErrClusterNotFound = errors.New("ClusterNotFound") + var ErrCustomDomainAlreadyExists = errors.New("CustomDomainAssociationAlreadyExistsFault") + var ErrCustomDomainNotFound = errors.New("CustomDomainAssociationNotFoundFault") + var ErrDataShareNotFound = errors.New("DataShareNotFound") + var ErrEndpointAccessAlreadyExists = errors.New("EndpointAlreadyExists") + var ErrEndpointAccessNotFound = errors.New("EndpointNotFound") + var ErrEndpointAuthAlreadyExists = errors.New("EndpointAuthorizationAlreadyExists") + var ErrEndpointAuthNotFound = errors.New("EndpointAuthorizationNotFound") + var ErrEventSubscriptionAlreadyExists = errors.New("SubscriptionAlreadyExist") + var ErrEventSubscriptionNotFound = errors.New("SubscriptionNotFound") + var ErrHsmClientCertAlreadyExists = errors.New("HsmClientCertificateAlreadyExists") + var ErrHsmClientCertNotFound = errors.New("HsmClientCertificateNotFound") + var ErrHsmConfigAlreadyExists = errors.New("HsmConfigurationAlreadyExists") + var ErrHsmConfigNotFound = errors.New("HsmConfigurationNotFound") + var ErrIdcApplicationAlreadyExists = errors.New("IdcApplicationAlreadyExistsFault") + var ErrIdcApplicationNotFound = errors.New("IdcApplicationNotExistsFault") + var ErrIntegrationAlreadyExists = errors.New("IntegrationAlreadyExists") + var ErrIntegrationNotFound = errors.New("IntegrationNotFound") + var ErrInvalidParameter = errors.New("InvalidParameterValue") + var ErrNamespaceAlreadyExists = errors.New("ConflictException") + var ErrNamespaceNotFound = errors.New("ResourceNotFoundException") + var ErrNilAppContext = errors.New("nil AppContext passed to Redshift Provider.Init") + var ErrNilAppContextSL = errors.New("nil AppContext passed to Redshift ServerlessProvider.Init") + var ErrParameterGroupAlreadyExists = errors.New("ClusterParameterGroupAlreadyExists") + var ErrParameterGroupNotFound = errors.New("ClusterParameterGroupNotFound") + var ErrPartnerNotFound = errors.New("PartnerNotFound") + var ErrReservedNodeAlreadyExists = errors.New("ReservedNodeAlreadyExists") + var ErrReservedNodeNotFound = errors.New("ReservedNodeNotFound") + var ErrReservedNodeOfferingNotFound = errors.New("ReservedNodeOfferingNotFound") + var ErrResizeNotCancellable = errors.New("InvalidClusterState") + var ErrResizeNotFound = errors.New("ResizeNotFound") + var ErrResourcePolicyNotFound = errors.New("ResourcePolicyNotFound") + var ErrScheduledActionAlreadyExists = errors.New("ScheduledActionAlreadyExists") + var ErrScheduledActionNotFound = errors.New("ScheduledActionNotFound") + var ErrScheduledActionSLNotFound = errors.New("ResourceNotFoundException") + var ErrSecurityGroupAlreadyExists = errors.New("ClusterSecurityGroupAlreadyExists") + var ErrSecurityGroupNotFound = errors.New("ClusterSecurityGroupNotFound") + var ErrServerlessConflict = errors.New("ConflictException") + var ErrServerlessSnapshotNotFound = errors.New("ResourceNotFoundException") + var ErrSnapshotAlreadyExists = errors.New("ClusterSnapshotAlreadyExists") + var ErrSnapshotCopyAlreadyEnabled = errors.New("SnapshotCopyAlreadyEnabled") + var ErrSnapshotCopyGrantAlreadyExists = errors.New("SnapshotCopyGrantAlreadyExists") + var ErrSnapshotCopyGrantNotFound = errors.New("SnapshotCopyGrantNotFound") + var ErrSnapshotCopyNotEnabled = errors.New("CopyToRegionDisabled") + var ErrSnapshotNotFound = errors.New(errClusterSnapshotNotFound) + var ErrSnapshotScheduleAlreadyExists = errors.New("SnapshotScheduleAlreadyExists") + var ErrSnapshotScheduleNotFound = errors.New("SnapshotScheduleNotFound") + var ErrSubnetGroupAlreadyExists = errors.New("ClusterSubnetGroupAlreadyExists") + var ErrSubnetGroupNotFound = errors.New("ClusterSubnetGroupNotFound") + var ErrUsageLimitNotFound = errors.New("UsageLimitNotFound") + var ErrUsageLimitSLNotFound = errors.New("ResourceNotFoundException") + var ErrWorkgroupAlreadyExists = errors.New("ConflictException") + var ErrWorkgroupNotFound = errors.New("ResourceNotFoundException") + type AccountWithRestoreAccess struct + AccountAlias string + AccountID string + type AuthenticationProfile struct + AuthenticationProfileContent string + AuthenticationProfileName string + type Cluster struct + ClusterIdentifier string + ClusterType string + DBName string + Encrypted bool + Endpoint string + EnhancedVpcRouting bool + IamRoles []string + KmsKeyID string + MasterUsername string + NodeType string + NumberOfNodes int + PendingModifiedValues *ClusterPendingModifiedValues + Port int + PreferredMaintenanceWindow string + Status string + Tags *tags.Tags + VpcID string + type ClusterCredentials struct + DBPassword string + DBUser string + Expiration time.Time + type ClusterParameter struct + ApplyType string + DataType string + Description string + IsModifiable bool + MinimumEngineVersion string + ParameterName string + ParameterValue string + Source string + type ClusterParameterGroup struct + CreatedAt time.Time + Description string + ParameterGroupFamily string + ParameterGroupName string + Parameters []ClusterParameter + type ClusterPendingModifiedValues struct + Encrypted bool + NodeType string + NumberOfNodes int + type ClusterSecurityGroup struct + ClusterSecurityGroupName string + Description string + EC2SecurityGroups []EC2SecurityGroup + IPRanges []IPRange + type ClusterSubnetGroup struct + ClusterSubnetGroupName string + Description string + SubnetGroupStatus string + Subnets []Subnet + VpcID string + type CustomDomainAssociation struct + ClusterIdentifier string + CustomDomainCertificateArn string + CustomDomainName string + type DNSRegistrar interface + Deregister func(hostname string) + Register func(hostname string) + type DataShare struct + AllowPubliclyAccessibleConsumers bool + DataShareArn string + DataShareAssociations []DataShareAssociation + ManagedBy string + ProducerArn string + type DataShareAssociation struct + ConsumerIdentifier string + ConsumerRegion string + CreatedDate time.Time + Status string + StatusChangeDate time.Time + Type string + type EC2SecurityGroup struct + EC2SecurityGroupName string + EC2SecurityGroupOwnerID string + Status string + type EndpointAccess struct + ClusterIdentifier string + EndpointCreateTime string + EndpointName string + EndpointStatus string + Port int + VpcID string + type EndpointAuthorization struct + AllowedAllVPCs bool + AllowedVPCs []string + AuthorizeTime time.Time + ClusterIdentifier string + ClusterStatus string + EndpointCount int + Grantee string + Grantor string + Status string + type Event struct + Date time.Time + EventID string + Message string + Severity string + SourceIdentifier string + SourceType string + type EventSubscription struct + CustSubscriptionID string + CustomerAwsID string + Enabled bool + EventCategories []string + Severity string + SnsTopicArn string + SourceIDs []string + SourceType string + Status string + SubscriptionCreated time.Time + 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) Shutdown(_ context.Context) + func (h *Handler) Snapshot(ctx context.Context) []byte + func (h *Handler) StartWorker(ctx context.Context) error + type HsmClientCertificate struct + HsmClientCertificateIdentifier string + HsmClientCertificatePublicKey string + Tags map[string]string + type HsmConfiguration struct + Description string + HsmConfigurationIdentifier string + HsmIPAddress string + HsmPartitionName string + Tags map[string]string + type IPRange struct + CIDRIP string + Status string + type IdcApplication struct + IamRoleArn string + IdcApplicationArn string + IdcApplicationName string + IdcDisplayName string + IdcInstanceArn string + type InMemoryBackend struct + func NewInMemoryBackend(accountID, region string) *InMemoryBackend + func (b *InMemoryBackend) AcceptReservedNodeExchange(reservedNodeID, targetOfferingID string) (*ReservedNode, error) + func (b *InMemoryBackend) AccountID() string + func (b *InMemoryBackend) AddActiveResizeInternal(clusterID string, resize *ResizeProgress) + func (b *InMemoryBackend) AddDataShareInternal(ds *DataShare) + func (b *InMemoryBackend) AddParameterGroupInternal(pg *ClusterParameterGroup) + func (b *InMemoryBackend) AddPartner(accountID, clusterID, databaseName, partnerName string) (*Partner, error) + func (b *InMemoryBackend) AddReservedNodeInternal(node *ReservedNode) + func (b *InMemoryBackend) AddSecurityGroupInternal(sg *ClusterSecurityGroup) + func (b *InMemoryBackend) AddSnapshotInternal(snap *Snapshot) + func (b *InMemoryBackend) AddSubnetGroupInternal(sg *ClusterSubnetGroup) + func (b *InMemoryBackend) AssociateDataShareConsumer(dataShareArn, consumerArn, consumerRegion string, _ bool) (*DataShare, error) + func (b *InMemoryBackend) AuthorizeClusterSecurityGroupIngress(groupName, cidrIP, ec2GroupName, ec2GroupOwnerID string) (*ClusterSecurityGroup, error) + func (b *InMemoryBackend) AuthorizeDataShare(dataShareArn, consumerIdentifier string) (*DataShare, error) + func (b *InMemoryBackend) AuthorizeEndpointAccess(clusterID, grantee string, vpcIDs []string) (*EndpointAuthorization, error) + func (b *InMemoryBackend) AuthorizeSnapshotAccess(snapshotID, accountWithRestoreAccess string) (*Snapshot, error) + func (b *InMemoryBackend) BatchDeleteClusterSnapshots(identifiers []string) ([]SnapshotBatchError, []string) + func (b *InMemoryBackend) BatchModifyClusterSnapshots(identifiers []string, retentionPeriod int, _ bool) ([]SnapshotBatchError, []string) + func (b *InMemoryBackend) CancelResize(clusterID string) (*ResizeProgress, error) + func (b *InMemoryBackend) CopyClusterSnapshot(sourceSnapshotID, destinationSnapshotID string) (*Snapshot, error) + func (b *InMemoryBackend) CreateAuthenticationProfile(name, content string) (*AuthenticationProfile, error) + func (b *InMemoryBackend) CreateCluster(id, nodeType, dbName, masterUser string) (*Cluster, error) + func (b *InMemoryBackend) CreateClusterParameterGroup(name, family, description string) (*ClusterParameterGroup, error) + func (b *InMemoryBackend) CreateClusterSecurityGroup(name, description string) (*ClusterSecurityGroup, error) + func (b *InMemoryBackend) CreateClusterSnapshot(snapshotID, clusterID string) (*Snapshot, error) + func (b *InMemoryBackend) CreateClusterSubnetGroup(name, description, vpcID string, subnetIDs []string) (*ClusterSubnetGroup, error) + func (b *InMemoryBackend) CreateCustomDomainAssociation(clusterID, customDomainName, customDomainCertificateArn string) (*CustomDomainAssociation, error) + func (b *InMemoryBackend) CreateEndpointAccess(clusterID, endpointName, vpcID string) (*EndpointAccess, error) + func (b *InMemoryBackend) CreateEventSubscription(subscriptionName, snsTopicArn, sourceType, severity string, ...) (*EventSubscription, error) + func (b *InMemoryBackend) CreateHsmClientCertificate(id string, tagMap map[string]string) (*HsmClientCertificate, error) + func (b *InMemoryBackend) CreateHsmConfiguration(id, description, hsmIPAddress, hsmPartitionName string, ...) (*HsmConfiguration, error) + func (b *InMemoryBackend) CreateIdcApplication(appName, idcInstanceArn, idcDisplayName, iamRoleArn string) (*IdcApplication, error) + func (b *InMemoryBackend) CreateIntegration(integrationName, sourceArn, targetArn, kmsKeyID, description string) (*Integration, error) + func (b *InMemoryBackend) CreateNamespace(namespaceName, adminUsername, dbName, kmsKeyID string, ...) (*Namespace, error) + func (b *InMemoryBackend) CreateScheduledAction(name, schedule, iamRole, description, targetAction string) (*ScheduledAction, error) + func (b *InMemoryBackend) CreateServerlessScheduledAction(scheduledActionName, namespaceName, schedule, targetAction string, ...) (*ServerlessScheduledAction, error) + func (b *InMemoryBackend) CreateServerlessSnapshot(snapshotName, namespaceName string) (*ServerlessSnapshot, error) + func (b *InMemoryBackend) CreateServerlessUsageLimit(resourceArn, usageType, period, breachAction string, amount int64) (*ServerlessUsageLimit, error) + func (b *InMemoryBackend) CreateSnapshotCopyGrant(name, kmsKeyID string, tagMap map[string]string) (*SnapshotCopyGrant, error) + func (b *InMemoryBackend) CreateSnapshotSchedule(scheduleID, description string, definitions []string, tagMap map[string]string) (*SnapshotSchedule, error) + func (b *InMemoryBackend) CreateTableRestoreStatus(...) (*TableRestoreStatus, error) + func (b *InMemoryBackend) CreateTags(clusterID string, kv map[string]string) error + func (b *InMemoryBackend) CreateUsageLimit(clusterID, featureType, limitType, breachAction string, amount int64, ...) (*UsageLimit, error) + func (b *InMemoryBackend) CreateWorkgroup(workgroupName, namespaceName string, baseCapacity int, ...) (*Workgroup, error) + func (b *InMemoryBackend) DeauthorizeDataShare(dataShareArn, consumerIdentifier string) (*DataShare, error) + func (b *InMemoryBackend) DeleteAuthenticationProfile(name string) error + func (b *InMemoryBackend) DeleteCluster(id string) (*Cluster, error) + func (b *InMemoryBackend) DeleteClusterParameterGroup(name string) error + func (b *InMemoryBackend) DeleteClusterSecurityGroup(name string) error + func (b *InMemoryBackend) DeleteClusterSnapshot(snapshotID string) (*Snapshot, error) + func (b *InMemoryBackend) DeleteClusterSubnetGroup(name string) error + func (b *InMemoryBackend) DeleteCustomDomainAssociation(clusterID, customDomainName string) error + func (b *InMemoryBackend) DeleteEndpointAccess(endpointName string) (*EndpointAccess, error) + func (b *InMemoryBackend) DeleteEventSubscription(subscriptionName string) error + func (b *InMemoryBackend) DeleteHsmClientCertificate(id string) error + func (b *InMemoryBackend) DeleteHsmConfiguration(id string) error + func (b *InMemoryBackend) DeleteIdcApplication(appArn string) error + func (b *InMemoryBackend) DeleteIntegration(integrationArn string) (*Integration, error) + func (b *InMemoryBackend) DeleteNamespace(namespaceName string) (*Namespace, error) + func (b *InMemoryBackend) DeletePartner(_, clusterID, databaseName, partnerName string) error + func (b *InMemoryBackend) DeleteResourcePolicy(resourceArn string) error + func (b *InMemoryBackend) DeleteScheduledAction(name string) error + func (b *InMemoryBackend) DeleteServerlessScheduledAction(scheduledActionName string) (*ServerlessScheduledAction, error) + func (b *InMemoryBackend) DeleteServerlessSnapshot(snapshotName string) (*ServerlessSnapshot, error) + func (b *InMemoryBackend) DeleteServerlessUsageLimit(usageLimitID string) (*ServerlessUsageLimit, error) + func (b *InMemoryBackend) DeleteSnapshotCopyGrant(name string) error + func (b *InMemoryBackend) DeleteSnapshotSchedule(scheduleID string) error + func (b *InMemoryBackend) DeleteTags(clusterID string, keys []string) error + func (b *InMemoryBackend) DeleteUsageLimit(usageLimitID string) error + func (b *InMemoryBackend) DeleteWorkgroup(workgroupName string) (*Workgroup, error) + func (b *InMemoryBackend) DescribeAuthenticationProfiles(name string) ([]AuthenticationProfile, error) + func (b *InMemoryBackend) DescribeClusterParameterGroups(name string) ([]ClusterParameterGroup, error) + func (b *InMemoryBackend) DescribeClusterParameters(groupName string) ([]ClusterParameter, error) + func (b *InMemoryBackend) DescribeClusterSecurityGroups(name string) ([]ClusterSecurityGroup, error) + func (b *InMemoryBackend) DescribeClusterSnapshots(snapshotID, clusterID, snapshotType string) ([]Snapshot, error) + func (b *InMemoryBackend) DescribeClusterSubnetGroups(name string) ([]ClusterSubnetGroup, error) + func (b *InMemoryBackend) DescribeClusters(id, marker string, maxRecords int) ([]Cluster, string, error) + func (b *InMemoryBackend) DescribeCustomDomainAssociations(clusterID, customDomainName string) ([]CustomDomainAssociation, error) + func (b *InMemoryBackend) DescribeDataShares(dataShareArn string) ([]DataShare, error) + func (b *InMemoryBackend) DescribeDataSharesForConsumer(consumerArn, status string) ([]DataShare, error) + func (b *InMemoryBackend) DescribeDataSharesForProducer(producerArn, status string) ([]DataShare, error) + func (b *InMemoryBackend) DescribeDefaultClusterParameters(family string) ([]ClusterParameter, error) + func (b *InMemoryBackend) DescribeEndpointAccess(clusterID, endpointName string) ([]EndpointAccess, error) + func (b *InMemoryBackend) DescribeEndpointAuthorization(clusterID, account string, grantee bool) ([]EndpointAuthorization, error) + func (b *InMemoryBackend) DescribeEventSubscriptions(subscriptionName string) ([]EventSubscription, error) + func (b *InMemoryBackend) DescribeEvents(sourceIdentifier, sourceType string) ([]Event, error) + func (b *InMemoryBackend) DescribeHsmClientCertificates(id string) ([]HsmClientCertificate, error) + func (b *InMemoryBackend) DescribeHsmConfigurations(id string) ([]HsmConfiguration, error) + func (b *InMemoryBackend) DescribeIdcApplications(appArn string) ([]IdcApplication, error) + func (b *InMemoryBackend) DescribeIntegrations(integrationArn string) ([]Integration, error) + func (b *InMemoryBackend) DescribePartners(_, clusterID, databaseName, partnerName string) ([]Partner, error) + func (b *InMemoryBackend) DescribeReservedNodeExchangeStatus(reservedNodeID string) (string, error) + func (b *InMemoryBackend) DescribeReservedNodeOfferings(offeringID string) ([]ReservedNodeOffering, error) + func (b *InMemoryBackend) DescribeReservedNodes(reservedNodeID string) ([]ReservedNode, error) + func (b *InMemoryBackend) DescribeResize(clusterID string) (*ResizeProgress, error) + func (b *InMemoryBackend) DescribeScheduledActions(name string) ([]ScheduledAction, error) + func (b *InMemoryBackend) DescribeSnapshotCopyGrants(name string) ([]SnapshotCopyGrant, error) + func (b *InMemoryBackend) DescribeSnapshotSchedules(scheduleID string) ([]SnapshotSchedule, error) + func (b *InMemoryBackend) DescribeTableRestoreStatus(clusterID string) ([]TableRestoreStatus, error) + func (b *InMemoryBackend) DescribeTags() map[string]map[string]string + func (b *InMemoryBackend) DescribeUsageLimits(clusterID, featureType string) ([]UsageLimit, error) + func (b *InMemoryBackend) DisableLogging(clusterID string) (*LoggingStatus, error) + func (b *InMemoryBackend) DisableSnapshotCopy(clusterID string) (*Cluster, error) + func (b *InMemoryBackend) DisassociateDataShareConsumer(dataShareArn, consumerArn, _ string, _ bool) (*DataShare, error) + func (b *InMemoryBackend) EnableLogging(clusterID, bucketName, s3KeyPrefix string) (*LoggingStatus, error) + func (b *InMemoryBackend) EnableSnapshotCopy(clusterID, destinationRegion, grantName string, retentionPeriod int) (*Cluster, error) + func (b *InMemoryBackend) FailoverPrimaryCompute(clusterID string) (*Cluster, error) + func (b *InMemoryBackend) GetClusterCredentials(clusterID, dbUser string, _ bool) (*ClusterCredentials, error) + func (b *InMemoryBackend) GetClusterCredentialsWithIAM(clusterID, _ string) (*ClusterCredentials, error) + func (b *InMemoryBackend) GetCredentials(workgroupName, dbName string) (string, string, string, error) + func (b *InMemoryBackend) GetNamespace(namespaceName string) (*Namespace, error) + func (b *InMemoryBackend) GetReservedNodeExchangeOfferings(reservedNodeID string) ([]ReservedNodeOffering, error) + func (b *InMemoryBackend) GetResourcePolicy(resourceArn string) (*ResourcePolicy, error) + func (b *InMemoryBackend) GetServerlessScheduledAction(scheduledActionName string) (*ServerlessScheduledAction, error) + func (b *InMemoryBackend) GetServerlessSnapshot(snapshotName string) (*ServerlessSnapshot, error) + func (b *InMemoryBackend) GetServerlessUsageLimit(usageLimitID string) (*ServerlessUsageLimit, error) + func (b *InMemoryBackend) GetWorkgroup(workgroupName string) (*Workgroup, error) + func (b *InMemoryBackend) ListNamespaces(maxResults int, nextToken string) ([]*Namespace, string) + func (b *InMemoryBackend) ListServerlessScheduledActions(namespaceName string, maxResults int, nextToken string) ([]*ServerlessScheduledAction, string) + func (b *InMemoryBackend) ListServerlessSnapshots(namespaceName string, maxResults int, nextToken string) ([]*ServerlessSnapshot, string) + func (b *InMemoryBackend) ListServerlessUsageLimits(resourceArn string, maxResults int, nextToken string) ([]*ServerlessUsageLimit, string) + func (b *InMemoryBackend) ListWorkgroups(maxResults int, nextToken string) ([]*Workgroup, string) + func (b *InMemoryBackend) ModifyAuthenticationProfile(name, content string) (*AuthenticationProfile, error) + func (b *InMemoryBackend) ModifyCluster(id string, nodeType string, numberOfNodes int, _ string, encrypted *bool, ...) (*Cluster, error) + func (b *InMemoryBackend) ModifyClusterIamRoles(id string, addRoles, removeRoles []string) (*Cluster, error) + func (b *InMemoryBackend) ModifyClusterMaintenance(id, maintenanceTrack string, _ bool) (*Cluster, error) + func (b *InMemoryBackend) ModifyClusterParameterGroup(groupName string, params []ClusterParameter) (*ClusterParameterGroup, error) + func (b *InMemoryBackend) ModifyClusterSnapshot(snapshotID string, retentionPeriod int, _ bool) (*Snapshot, error) + func (b *InMemoryBackend) ModifyClusterSnapshotSchedule(clusterID, scheduleID string, disassociate bool) error + func (b *InMemoryBackend) ModifyClusterSubnetGroup(name, description string, subnetIDs []string) (*ClusterSubnetGroup, error) + func (b *InMemoryBackend) ModifyCustomDomainAssociation(clusterID, customDomainName, customDomainCertificateArn string) (*CustomDomainAssociation, error) + func (b *InMemoryBackend) ModifyEndpointAccess(endpointName, vpcID string) (*EndpointAccess, error) + func (b *InMemoryBackend) ModifyEventSubscription(subscriptionName, snsTopicArn, sourceType, severity string, ...) (*EventSubscription, error) + func (b *InMemoryBackend) ModifyIdcApplication(appArn, idcDisplayName, iamRoleArn string) (*IdcApplication, error) + func (b *InMemoryBackend) ModifyIntegration(integrationArn, description string) (*Integration, error) + func (b *InMemoryBackend) ModifyScheduledAction(name, schedule, iamRole, description string) (*ScheduledAction, error) + func (b *InMemoryBackend) ModifySnapshotCopyRetentionPeriod(clusterID string, retentionPeriod int) (*Cluster, error) + func (b *InMemoryBackend) ModifySnapshotSchedule(scheduleID string, definitions []string) (*SnapshotSchedule, error) + func (b *InMemoryBackend) ModifyUsageLimit(usageLimitID, breachAction string, amount int64) (*UsageLimit, error) + func (b *InMemoryBackend) PauseCluster(id string) (*Cluster, error) + func (b *InMemoryBackend) PurchaseReservedNodeOffering(offeringID, reservedNodeID string, nodeCount int) (*ReservedNode, error) + func (b *InMemoryBackend) PutResourcePolicy(resourceArn, policy string) (*ResourcePolicy, error) + func (b *InMemoryBackend) RebootCluster(id string) (*Cluster, error) + func (b *InMemoryBackend) Region() string + func (b *InMemoryBackend) RejectDataShare(dataShareArn string) (*DataShare, error) + func (b *InMemoryBackend) Reset() + func (b *InMemoryBackend) ResetClusterParameterGroup(groupName string, resetAllParameters bool, params []ClusterParameter) (*ClusterParameterGroup, error) + func (b *InMemoryBackend) ResizeCluster(id, nodeType, clusterType string, numberOfNodes int, _ bool) (*Cluster, error) + func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error + func (b *InMemoryBackend) RestoreFromClusterSnapshot(clusterID, snapshotID string) (*Cluster, error) + func (b *InMemoryBackend) ResumeCluster(id string) (*Cluster, error) + func (b *InMemoryBackend) RevokeClusterSecurityGroupIngress(groupName, cidrIP, ec2GroupName, ec2GroupOwnerID string) (*ClusterSecurityGroup, error) + func (b *InMemoryBackend) RevokeEndpointAccess(clusterID, account string, _ []string, force bool) (*EndpointAuthorization, error) + func (b *InMemoryBackend) RevokeSnapshotAccess(snapshotID, accountWithRestoreAccess string) (*Snapshot, error) + func (b *InMemoryBackend) RotateEncryptionKey(id string) (*Cluster, error) + func (b *InMemoryBackend) SetDNSRegistrar(dns DNSRegistrar) + func (b *InMemoryBackend) Snapshot(ctx context.Context) []byte + func (b *InMemoryBackend) StartReconciler(ctx context.Context) + func (b *InMemoryBackend) StopReconciler() + func (b *InMemoryBackend) UpdateNamespace(namespaceName, adminUsername, dbName, kmsKeyID string, ...) (*Namespace, error) + func (b *InMemoryBackend) UpdatePartnerStatus(_, clusterID, databaseName, partnerName, status, statusMessage string) (*Partner, error) + func (b *InMemoryBackend) UpdateServerlessScheduledAction(scheduledActionName, schedule, targetAction string, ...) (*ServerlessScheduledAction, error) + func (b *InMemoryBackend) UpdateServerlessUsageLimit(usageLimitID, breachAction string, amount int64) (*ServerlessUsageLimit, error) + func (b *InMemoryBackend) UpdateWorkgroup(workgroupName string, baseCapacity int, subnetIDs, securityGroupIDs []string) (*Workgroup, error) + type Integration struct + AdditionalEncKey string + Description string + IntegrationArn string + IntegrationName string + KmsKeyID string + SourceArn string + Status string + TargetArn string + type LoggingStatus struct + BucketName string + LastFailureTime time.Time + LastSuccessTime time.Time + LoggingEnabled bool + S3KeyPrefix string + type Namespace struct + AdminUsername string + CreationDate time.Time + DBName string + IamRoles []string + KmsKeyID string + LogExports []string + NamespaceArn string + NamespaceID string + NamespaceName string + Status string + type Partner struct + AccountID string + ClusterIdentifier string + DatabaseName string + PartnerName string + Status string + StatusMessage string + type Provider struct + func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error) + func (p *Provider) Name() string + type ReservedNode struct + CurrencyCode string + Duration int + FixedPrice float64 + NodeCount int + NodeType string + OfferingType string + ReservedNodeID string + ReservedNodeOfferingID string + StartTime time.Time + State string + UsagePrice float64 + type ReservedNodeOffering struct + CurrencyCode string + Duration int + FixedPrice float64 + NodeType string + OfferingType string + ReservedNodeOfferingID string + ReservedNodeOfferingType string + UsagePrice float64 + type ResizeProgress struct + AllowCancelResize bool + ImportTablesCompleted []string + ImportTablesInProgress []string + ImportTablesNotStarted []string + Message string + ResizeType string + Status string + TargetClusterType string + TargetNodeType string + TargetNumberOfNodes int + type ResourcePolicy struct + Policy string + ResourceArn string + type ScheduledAction struct + IamRole string + Schedule string + ScheduledActionDescription string + ScheduledActionName string + State string + TargetAction string + type ServerlessHandler struct + Backend *InMemoryBackend + func NewServerlessHandler(backend *InMemoryBackend) *ServerlessHandler + func (h *ServerlessHandler) ChaosOperations() []string + func (h *ServerlessHandler) ChaosRegions() []string + func (h *ServerlessHandler) ChaosServiceName() string + func (h *ServerlessHandler) ExtractOperation(c *echo.Context) string + func (h *ServerlessHandler) ExtractResource(_ *echo.Context) string + func (h *ServerlessHandler) GetSupportedOperations() []string + func (h *ServerlessHandler) Handler() echo.HandlerFunc + func (h *ServerlessHandler) MatchPriority() int + func (h *ServerlessHandler) Name() string + func (h *ServerlessHandler) Reset() + func (h *ServerlessHandler) RouteMatcher() service.Matcher + type ServerlessProvider struct + func (p *ServerlessProvider) Init(ctx *service.AppContext) (service.Registerable, error) + func (p *ServerlessProvider) Name() string + type ServerlessScheduledAction struct + EndTime time.Time + NamespaceName string + Schedule string + ScheduledActionArn string + ScheduledActionName string + StartTime time.Time + Status string + TargetAction string + type ServerlessSnapshot struct + AccountsWithRestoreAccess []string + AdminUsername string + NamespaceArn string + NamespaceName string + SnapshotArn string + SnapshotCreateTime time.Time + SnapshotName string + Status string + type ServerlessUsageLimit struct + Amount int64 + BreachAction string + Period string + ResourceArn string + UsageLimitArn string + UsageLimitID string + UsageType string + type Snapshot struct + AccountsWithRestoreAccess []AccountWithRestoreAccess + ClusterIdentifier string + DBName string + ManualSnapshotRetentionPeriod int + MasterUsername string + NodeType string + NumberOfNodes int + SnapshotCreateTime time.Time + SnapshotIdentifier string + SnapshotType string + Status string + type SnapshotBatchError struct + FailureCode string + FailureReason string + SnapshotClusterIdentifier string + SnapshotIdentifier string + type SnapshotCopyConfig struct + DestinationRegion string + RetentionPeriod int + SnapshotCopyGrantName string + type SnapshotCopyGrant struct + KMSKeyID string + SnapshotCopyGrantName string + Tags map[string]string + type SnapshotSchedule struct + Description string + ScheduleDefinitions []string + ScheduleIdentifier string + Tags map[string]string + type StorageBackend interface + AcceptReservedNodeExchange func(reservedNodeID, targetOfferingID string) (*ReservedNode, error) + AccountID func() string + AddActiveResizeInternal func(clusterID string, resize *ResizeProgress) + AddDataShareInternal func(ds *DataShare) + AddParameterGroupInternal func(pg *ClusterParameterGroup) + AddPartner func(accountID, clusterID, databaseName, partnerName string) (*Partner, error) + AddReservedNodeInternal func(node *ReservedNode) + AddSecurityGroupInternal func(sg *ClusterSecurityGroup) + AddSnapshotInternal func(snap *Snapshot) + AddSubnetGroupInternal func(sg *ClusterSubnetGroup) + AssociateDataShareConsumer func(dataShareArn, consumerArn, consumerRegion string, associateEntireAccount bool) (*DataShare, error) + AuthorizeClusterSecurityGroupIngress func(groupName, cidrIP, ec2GroupName, ec2GroupOwnerID string) (*ClusterSecurityGroup, error) + AuthorizeDataShare func(dataShareArn, consumerIdentifier string) (*DataShare, error) + AuthorizeEndpointAccess func(clusterID, grantee string, vpcIDs []string) (*EndpointAuthorization, error) + AuthorizeSnapshotAccess func(snapshotID, accountWithRestoreAccess string) (*Snapshot, error) + BatchDeleteClusterSnapshots func(identifiers []string) ([]SnapshotBatchError, []string) + BatchModifyClusterSnapshots func(identifiers []string, retentionPeriod int, force bool) ([]SnapshotBatchError, []string) + CancelResize func(clusterID string) (*ResizeProgress, error) + CopyClusterSnapshot func(sourceSnapshotID, destinationSnapshotID string) (*Snapshot, error) + CreateAuthenticationProfile func(name, content string) (*AuthenticationProfile, error) + CreateCluster func(id, nodeType, dbName, masterUser string) (*Cluster, error) + CreateClusterParameterGroup func(name, family, description string) (*ClusterParameterGroup, error) + CreateClusterSecurityGroup func(name, description string) (*ClusterSecurityGroup, error) + CreateClusterSnapshot func(snapshotID, clusterID string) (*Snapshot, error) + CreateClusterSubnetGroup func(name, description, vpcID string, subnetIDs []string) (*ClusterSubnetGroup, error) + CreateCustomDomainAssociation func(clusterID, customDomainName, customDomainCertificateArn string) (*CustomDomainAssociation, error) + CreateEndpointAccess func(clusterID, endpointName, vpcID string) (*EndpointAccess, error) + CreateEventSubscription func(subscriptionName, snsTopicArn, sourceType, severity string, ...) (*EventSubscription, error) + CreateHsmClientCertificate func(id string, tags map[string]string) (*HsmClientCertificate, error) + CreateHsmConfiguration func(id, description, hsmIPAddress, hsmPartitionName string, tags map[string]string) (*HsmConfiguration, error) + CreateIdcApplication func(appName, idcInstanceArn, idcDisplayName, iamRoleArn string) (*IdcApplication, error) + CreateIntegration func(integrationName, sourceArn, targetArn, kmsKeyID, description string) (*Integration, error) + CreateScheduledAction func(name, schedule, iamRole, description, targetAction string) (*ScheduledAction, error) + CreateSnapshotCopyGrant func(name, kmsKeyID string, tags map[string]string) (*SnapshotCopyGrant, error) + CreateSnapshotSchedule func(scheduleID, description string, definitions []string, tags map[string]string) (*SnapshotSchedule, error) + CreateTableRestoreStatus func(...) (*TableRestoreStatus, error) + CreateTags func(clusterID string, kv map[string]string) error + CreateUsageLimit func(clusterID, featureType, limitType, breachAction string, amount int64, ...) (*UsageLimit, error) + DeauthorizeDataShare func(dataShareArn, consumerIdentifier string) (*DataShare, error) + DeleteAuthenticationProfile func(name string) error + DeleteCluster func(id string) (*Cluster, error) + DeleteClusterParameterGroup func(name string) error + DeleteClusterSecurityGroup func(name string) error + DeleteClusterSnapshot func(snapshotID string) (*Snapshot, error) + DeleteClusterSubnetGroup func(name string) error + DeleteCustomDomainAssociation func(clusterID, customDomainName string) error + DeleteEndpointAccess func(endpointName string) (*EndpointAccess, error) + DeleteEventSubscription func(subscriptionName string) error + DeleteHsmClientCertificate func(id string) error + DeleteHsmConfiguration func(id string) error + DeleteIdcApplication func(appArn string) error + DeleteIntegration func(integrationArn string) (*Integration, error) + DeletePartner func(accountID, clusterID, databaseName, partnerName string) error + DeleteResourcePolicy func(resourceArn string) error + DeleteScheduledAction func(name string) error + DeleteSnapshotCopyGrant func(name string) error + DeleteSnapshotSchedule func(scheduleID string) error + DeleteTags func(clusterID string, keys []string) error + DeleteUsageLimit func(usageLimitID string) error + DescribeAuthenticationProfiles func(name string) ([]AuthenticationProfile, error) + DescribeClusterParameterGroups func(name string) ([]ClusterParameterGroup, error) + DescribeClusterParameters func(groupName string) ([]ClusterParameter, error) + DescribeClusterSecurityGroups func(name string) ([]ClusterSecurityGroup, error) + DescribeClusterSnapshots func(snapshotID, clusterID, snapshotType string) ([]Snapshot, error) + DescribeClusterSubnetGroups func(name string) ([]ClusterSubnetGroup, error) + DescribeClusters func(id, marker string, maxRecords int) ([]Cluster, string, error) + DescribeCustomDomainAssociations func(clusterID, customDomainName string) ([]CustomDomainAssociation, error) + DescribeDataShares func(dataShareArn string) ([]DataShare, error) + DescribeDataSharesForConsumer func(consumerArn, status string) ([]DataShare, error) + DescribeDataSharesForProducer func(producerArn, status string) ([]DataShare, error) + DescribeDefaultClusterParameters func(family string) ([]ClusterParameter, error) + DescribeEndpointAccess func(clusterID, endpointName string) ([]EndpointAccess, error) + DescribeEndpointAuthorization func(clusterID, account string, grantee bool) ([]EndpointAuthorization, error) + DescribeEventSubscriptions func(subscriptionName string) ([]EventSubscription, error) + DescribeEvents func(sourceIdentifier, sourceType string) ([]Event, error) + DescribeHsmClientCertificates func(id string) ([]HsmClientCertificate, error) + DescribeHsmConfigurations func(id string) ([]HsmConfiguration, error) + DescribeIdcApplications func(appArn string) ([]IdcApplication, error) + DescribeIntegrations func(integrationArn string) ([]Integration, error) + DescribePartners func(accountID, clusterID, databaseName, partnerName string) ([]Partner, error) + DescribeReservedNodeExchangeStatus func(reservedNodeID string) (string, error) + DescribeReservedNodeOfferings func(offeringID string) ([]ReservedNodeOffering, error) + DescribeReservedNodes func(reservedNodeID string) ([]ReservedNode, error) + DescribeResize func(clusterID string) (*ResizeProgress, error) + DescribeScheduledActions func(name string) ([]ScheduledAction, error) + DescribeSnapshotCopyGrants func(name string) ([]SnapshotCopyGrant, error) + DescribeSnapshotSchedules func(scheduleID string) ([]SnapshotSchedule, error) + DescribeTableRestoreStatus func(clusterID string) ([]TableRestoreStatus, error) + DescribeTags func() map[string]map[string]string + DescribeUsageLimits func(clusterID, featureType string) ([]UsageLimit, error) + DisableLogging func(clusterID string) (*LoggingStatus, error) + DisableSnapshotCopy func(clusterID string) (*Cluster, error) + DisassociateDataShareConsumer func(dataShareArn, consumerArn, consumerRegion string, ...) (*DataShare, error) + EnableLogging func(clusterID, bucketName, s3KeyPrefix string) (*LoggingStatus, error) + EnableSnapshotCopy func(clusterID, destinationRegion, grantName string, retentionPeriod int) (*Cluster, error) + FailoverPrimaryCompute func(clusterID string) (*Cluster, error) + GetClusterCredentials func(clusterID, dbUser string, autoCreate bool) (*ClusterCredentials, error) + GetClusterCredentialsWithIAM func(clusterID, dbName string) (*ClusterCredentials, error) + GetReservedNodeExchangeOfferings func(reservedNodeID string) ([]ReservedNodeOffering, error) + GetResourcePolicy func(resourceArn string) (*ResourcePolicy, error) + ModifyAuthenticationProfile func(name, content string) (*AuthenticationProfile, error) + ModifyCluster func(id, nodeType string, numberOfNodes int, masterUserPassword string, ...) (*Cluster, error) + ModifyClusterIamRoles func(id string, addRoles, removeRoles []string) (*Cluster, error) + ModifyClusterMaintenance func(id, maintenanceTrack string, deferMaintenance bool) (*Cluster, error) + ModifyClusterParameterGroup func(groupName string, params []ClusterParameter) (*ClusterParameterGroup, error) + ModifyClusterSnapshot func(snapshotID string, retentionPeriod int, force bool) (*Snapshot, error) + ModifyClusterSnapshotSchedule func(clusterID, scheduleID string, disassociate bool) error + ModifyClusterSubnetGroup func(name, description string, subnetIDs []string) (*ClusterSubnetGroup, error) + ModifyCustomDomainAssociation func(clusterID, customDomainName, customDomainCertificateArn string) (*CustomDomainAssociation, error) + ModifyEndpointAccess func(endpointName, vpcID string) (*EndpointAccess, error) + ModifyEventSubscription func(subscriptionName, snsTopicArn, sourceType, severity string, ...) (*EventSubscription, error) + ModifyIdcApplication func(appArn, idcDisplayName, iamRoleArn string) (*IdcApplication, error) + ModifyIntegration func(integrationArn, description string) (*Integration, error) + ModifyScheduledAction func(name, schedule, iamRole, description string) (*ScheduledAction, error) + ModifySnapshotCopyRetentionPeriod func(clusterID string, retentionPeriod int) (*Cluster, error) + ModifySnapshotSchedule func(scheduleID string, definitions []string) (*SnapshotSchedule, error) + ModifyUsageLimit func(usageLimitID, breachAction string, amount int64) (*UsageLimit, error) + PauseCluster func(id string) (*Cluster, error) + PurchaseReservedNodeOffering func(offeringID, reservedNodeID string, nodeCount int) (*ReservedNode, error) + PutResourcePolicy func(resourceArn, policy string) (*ResourcePolicy, error) + RebootCluster func(id string) (*Cluster, error) + Region func() string + RejectDataShare func(dataShareArn string) (*DataShare, error) + Reset func() + ResetClusterParameterGroup func(groupName string, resetAllParameters bool, params []ClusterParameter) (*ClusterParameterGroup, error) + ResizeCluster func(id, nodeType, clusterType string, numberOfNodes int, classic bool) (*Cluster, error) + Restore func(ctx context.Context, data []byte) error + RestoreFromClusterSnapshot func(clusterID, snapshotID string) (*Cluster, error) + ResumeCluster func(id string) (*Cluster, error) + RevokeClusterSecurityGroupIngress func(groupName, cidrIP, ec2GroupName, ec2GroupOwnerID string) (*ClusterSecurityGroup, error) + RevokeEndpointAccess func(clusterID, account string, vpcIDs []string, force bool) (*EndpointAuthorization, error) + RevokeSnapshotAccess func(snapshotID, accountWithRestoreAccess string) (*Snapshot, error) + RotateEncryptionKey func(id string) (*Cluster, error) + SetDNSRegistrar func(dns DNSRegistrar) + Snapshot func(ctx context.Context) []byte + StartReconciler func(ctx context.Context) + StopReconciler func() + UpdatePartnerStatus func(accountID, clusterID, databaseName, partnerName, status, statusMessage string) (*Partner, error) + type Subnet struct + SubnetIdentifier string + SubnetStatus string + type TableRestoreStatus struct + ClusterIdentifier string + Message string + RequestTime time.Time + SourceDatabaseName string + SourceTableName string + Status string + TableRestoreRequestID string + TargetDatabaseName string + TargetTableName string + type UsageLimit struct + Amount int64 + BreachAction string + ClusterIdentifier string + FeatureType string + LimitType string + Tags map[string]string + UsageLimitID string + type Workgroup struct + BaseCapacity int + CreationDate time.Time + Endpoint WorkgroupEndpoint + NamespaceName string + SecurityGroupIDs []string + Status string + SubnetIDs []string + WorkgroupArn string + WorkgroupID string + WorkgroupName string + type WorkgroupEndpoint struct + Address string + Port int
Go to main page