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 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