redshift

package

Go to main page

Versions in this module

v1

v1.5.0

Aug 24, 2026

Changes in this version

+ var ErrAuthorizationAlreadyExists = errors.New("AuthorizationAlreadyExists")

+ var ErrSecurityGroupIngressNotFound = errors.New("AuthorizationNotFound")

+ var ErrSnapshotAccessNotFound = errors.New("AuthorizationNotFound")

type InMemoryBackend

+ func (b *InMemoryBackend) GetLoggingStatus(clusterID string) (*LoggingStatus, error)

type StorageBackend

+ GetLoggingStatus func(clusterID string) (*LoggingStatus, error)

v1.4.0

Aug 19, 2026

v1.3.5

Aug 19, 2026

v1.3.4

Aug 18, 2026

v1.3.3

Aug 17, 2026

v1.3.2

Aug 16, 2026

v1.3.1

Aug 16, 2026

Changes in this version

+ var ErrCustomDomainSLConflict = errors.New("ConflictException")

+ var ErrCustomDomainSLNotFound = errors.New("ResourceNotFoundException")

+ var ErrEndpointAccessSLAlreadyExists = errors.New("ConflictException")

+ var ErrEndpointAccessSLNotFound = errors.New("ResourceNotFoundException")

+ var ErrInvalidNamespace = errors.New("InvalidNamespaceFault")

+ var ErrNamespaceRegistrationInvalidClusterState = errors.New("InvalidClusterState")

+ var ErrRecoveryPointNotFound = errors.New("ResourceNotFoundException")

+ var ErrResourcePolicySLNotFound = errors.New("ResourceNotFoundException")

+ var ErrServerlessDryRun = errors.New("DryRunException")

+ var ErrServerlessResourceNotFound = errors.New("ResourceNotFoundException")

+ var ErrServerlessTrackNotFound = errors.New("ResourceNotFoundException")

+ var ErrServerlessValidation = errors.New("ValidationException")

+ var ErrSnapshotCopyConfigSLNotFound = errors.New("ResourceNotFoundException")

+ var ErrTableRestoreSLNotFound = errors.New("ResourceNotFoundException")

type Cluster

+ CatalogArn string

+ LakehouseRegistrationStatus string

+ type ClusterLakehouseConfig struct

+ CatalogName string

+ ClusterIdentifier string

+ LakehouseIdcApplicationArn string

+ type ClusterLakehouseConfigResult struct

+ CatalogArn string

+ ClusterIdentifier string

+ LakehouseIdcApplicationArn string

+ LakehouseRegistrationStatus string

+ type ConfigParameter struct

+ ParameterKey string

+ ParameterValue string

+ type CreateNamespaceParams struct

+ AdminPasswordSecretKmsKeyID string

+ AdminUserPassword string

+ AdminUsername string

+ DBName string

+ DefaultIamRoleArn string

+ IamRoles []string

+ KmsKeyID string

+ LogExports []string

+ ManageAdminPassword bool

+ NamespaceName string

+ RedshiftIdcApplicationArn string

+ Tags map[string]string

+ type CreateScheduledActionParams struct

+ Enabled *bool

+ EndTime time.Time

+ NamespaceName string

+ RoleArn string

+ Schedule json.RawMessage

+ ScheduledActionDescription string

+ ScheduledActionName string

+ StartTime time.Time

+ TargetAction json.RawMessage

type CustomDomainAssociation

+ CustomDomainCertExpiryTime string

type IdcApplication

+ ApplicationType string

type InMemoryBackend

+ func (b *InMemoryBackend) AddRecoveryPointInternal(rp *RecoveryPoint)

+ func (b *InMemoryBackend) ConvertRecoveryPointToSnapshotSL(recoveryPointID, snapshotName string, retentionPeriod int, ...) (*ServerlessSnapshot, error)

+ func (b *InMemoryBackend) CreateCustomDomainAssociationSL(customDomainName, customDomainCertificateArn, workgroupName string) (*ServerlessCustomDomainAssociation, error)

+ func (b *InMemoryBackend) CreateEndpointAccessSL(endpointName, workgroupName, ownerAccount string, ...) (*ServerlessEndpointAccess, error)

+ func (b *InMemoryBackend) CreateSnapshotCopyConfigurationSL(namespaceName, destinationRegion, destinationKmsKeyID string, ...) (*ServerlessSnapshotCopyConfiguration, error)

+ func (b *InMemoryBackend) DeleteCustomDomainAssociationSL(customDomainName, workgroupName string) (*ServerlessCustomDomainAssociation, error)

+ func (b *InMemoryBackend) DeleteEndpointAccessSL(endpointName string) (*ServerlessEndpointAccess, error)

+ func (b *InMemoryBackend) DeleteResourcePolicySL(resourceArn string) (*ServerlessResourcePolicy, error)

+ func (b *InMemoryBackend) DeleteSnapshotCopyConfigurationSL(id string) (*ServerlessSnapshotCopyConfiguration, error)

+ func (b *InMemoryBackend) DeregisterNamespace(consumerIdentifiers []string, ...) (*NamespaceRegistration, error)

+ func (b *InMemoryBackend) GetCustomDomainAssociationSL(customDomainName, workgroupName string) (*ServerlessCustomDomainAssociation, error)

+ func (b *InMemoryBackend) GetEndpointAccessSL(endpointName string) (*ServerlessEndpointAccess, error)

+ func (b *InMemoryBackend) GetIdentityCenterAuthTokenSL(workgroupNames []string) (string, time.Time, error)

+ func (b *InMemoryBackend) GetRecoveryPointSL(recoveryPointID string) (*RecoveryPoint, error)

+ func (b *InMemoryBackend) GetResourcePolicySL(resourceArn string) (*ServerlessResourcePolicy, error)

+ func (b *InMemoryBackend) GetServerlessTrack(trackName string) (*ServerlessTrack, error)

+ func (b *InMemoryBackend) GetTableRestoreStatusSL(tableRestoreRequestID string) (*ServerlessTableRestoreStatus, error)

+ func (b *InMemoryBackend) ListCustomDomainAssociationsSL(customDomainName, customDomainCertificateArn string, maxResults int, ...) ([]*ServerlessCustomDomainAssociation, string)

+ func (b *InMemoryBackend) ListEndpointAccessSL(workgroupName, ownerAccount string, maxResults int, nextToken string) ([]*ServerlessEndpointAccess, string)

+ func (b *InMemoryBackend) ListManagedWorkgroupsSL(_ string, _ int, _ string) ([]ManagedWorkgroupListItem, string)

+ func (b *InMemoryBackend) ListRecoveryPointsSL(p ListRecoveryPointsParams) ([]*RecoveryPoint, string)

+ func (b *InMemoryBackend) ListServerlessResourceTags(resourceArn string) (map[string]string, error)

+ func (b *InMemoryBackend) ListServerlessTracks(maxResults int, nextToken string) ([]*ServerlessTrack, string)

+ func (b *InMemoryBackend) ListSnapshotCopyConfigurationsSL(namespaceName string, maxResults int, nextToken string) ([]*ServerlessSnapshotCopyConfiguration, string)

+ func (b *InMemoryBackend) ListTableRestoreStatusSL(namespaceName, workgroupName string, maxResults int, nextToken string) ([]*ServerlessTableRestoreStatus, string)

+ func (b *InMemoryBackend) ModifyAquaConfiguration(id string) (*Cluster, error)

+ func (b *InMemoryBackend) ModifyLakehouseConfiguration(p ModifyLakehouseConfigParams) (*ClusterLakehouseConfigResult, error)

+ func (b *InMemoryBackend) PutResourcePolicySL(resourceArn, policy string) (*ServerlessResourcePolicy, error)

+ func (b *InMemoryBackend) RegisterNamespace(consumerIdentifiers []string, ...) (*NamespaceRegistration, error)

+ func (b *InMemoryBackend) RestoreFromRecoveryPointSL(namespaceName, workgroupName, recoveryPointID string) (*Namespace, error)

+ func (b *InMemoryBackend) RestoreFromSnapshotSL(p RestoreFromSnapshotParams) (*Namespace, string, error)

+ func (b *InMemoryBackend) RestoreTableFromRecoveryPointSL(p RestoreTableFromSnapshotParams) (*ServerlessTableRestoreStatus, error)

+ func (b *InMemoryBackend) RestoreTableFromSnapshotSL(p RestoreTableFromSnapshotParams) (*ServerlessTableRestoreStatus, error)

+ func (b *InMemoryBackend) TagServerlessResource(resourceArn string, newTags map[string]string) error

+ func (b *InMemoryBackend) UntagServerlessResource(resourceArn string, tagKeys []string) error

+ func (b *InMemoryBackend) UpdateCustomDomainAssociationSL(customDomainName, workgroupName, customDomainCertificateArn string) (*ServerlessCustomDomainAssociation, error)

+ func (b *InMemoryBackend) UpdateEndpointAccessSL(endpointName string, vpcSecurityGroupIDs []string) (*ServerlessEndpointAccess, error)

+ func (b *InMemoryBackend) UpdateLakehouseConfigurationSL(p UpdateLakehouseConfigParams) (*LakehouseConfigResult, error)

+ func (b *InMemoryBackend) UpdateServerlessSnapshot(snapshotName string, retentionPeriod *int) (*ServerlessSnapshot, error)

+ func (b *InMemoryBackend) UpdateSnapshotCopyConfigurationSL(id string, retentionPeriod int) (*ServerlessSnapshotCopyConfiguration, error)

+ func (b *InMemoryBackend) WorkgroupNameByCustomDomainSL(customDomainName string) (string, error)

+ type LakehouseConfigResult struct

+ CatalogArn string

+ LakehouseIdcApplicationArn string

+ LakehouseRegistrationStatus string

+ NamespaceName string

+ type ListRecoveryPointsParams struct

+ EndTime time.Time

+ MaxResults int

+ NamespaceArn string

+ NamespaceName string

+ NextToken string

+ StartTime time.Time

+ type ListServerlessSnapshotsParams struct

+ EndTime time.Time

+ MaxResults int

+ NamespaceArn string

+ NamespaceName string

+ NextToken string

+ OwnerAccount string

+ StartTime time.Time

+ type ManagedWorkgroupListItem struct

+ CreationDate time.Time

+ ManagedWorkgroupID string

+ ManagedWorkgroupName string

+ SourceArn string

+ Status string

+ type ModifyLakehouseConfigParams struct

+ CatalogName string

+ ClusterIdentifier string

+ DryRun bool

+ LakehouseIdcApplicationArn string

+ LakehouseIdcRegistration string

+ LakehouseRegistration string

type Namespace

+ AdminPasswordSecretArn string

+ AdminPasswordSecretKmsKeyID string

+ CatalogArn string

+ DefaultIamRoleArn string

+ LakehouseRegistrationStatus string

+ type NamespaceRegistration struct

+ ClusterIdentifier string

+ ConsumerIdentifiers []string

+ NamespaceKey string

+ ServerlessNamespaceName string

+ ServerlessWorkgroupName string

+ Status string

+ type PerformanceTarget struct

+ Level int

+ Status string

+ type RecoveryPoint struct

+ NamespaceArn string

+ NamespaceName string

+ RecoveryPointCreateTime time.Time

+ RecoveryPointID string

+ TotalSizeInMegaBytes float64

+ WorkgroupName string

+ type RestoreFromSnapshotParams struct

+ AdminPasswordSecretKmsKeyID string

+ MaintainIntegration *bool

+ ManageAdminPassword bool

+ NamespaceName string

+ SnapshotArn string

+ SnapshotName string

+ WorkgroupName string

+ type RestoreTableFromSnapshotParams struct

+ ActivateCaseSensitiveIdentifier *bool

+ NamespaceName string

+ NewTableName string

+ RecoveryPointID string

+ SnapshotName string

+ SourceDatabaseName string

+ SourceSchemaName string

+ SourceTableName string

+ TargetDatabaseName string

+ TargetSchemaName string

+ WorkgroupName string

+ type ServerlessCustomDomainAssociation struct

+ CustomDomainCertificateArn string

+ CustomDomainCertificateExpiryTime *time.Time

+ CustomDomainName string

+ WorkgroupName string

+ type ServerlessEndpointAccess struct

+ Address string

+ EndpointArn string

+ EndpointCreateTime time.Time

+ EndpointName string

+ EndpointStatus string

+ OwnerAccount string

+ Port int

+ SubnetIDs []string

+ VpcSecurityGroupIDs []string

+ WorkgroupName string

+ type ServerlessLakehouseConfig struct

+ CatalogName string

+ LakehouseIdcApplicationArn string

+ NamespaceName string

+ type ServerlessResourcePolicy struct

+ Policy string

+ ResourceArn string

type ServerlessScheduledAction

+ RoleArn string

+ ScheduledActionDescription string

+ ScheduledActionUUID string

+ State string

type ServerlessSnapshot

+ SnapshotRetentionPeriod int

+ type ServerlessSnapshotCopyConfiguration struct

+ DestinationKmsKeyID string

+ DestinationRegion string

+ NamespaceName string

+ SnapshotCopyConfigurationArn string

+ SnapshotCopyConfigurationID string

+ SnapshotRetentionPeriod int

+ type ServerlessTableRestoreStatus struct

+ Message string

+ NamespaceName string

+ NewTableName string

+ ProgressInMegaBytes int64

+ RecoveryPointID string

+ RequestTime time.Time

+ SnapshotName string

+ SourceDatabaseName string

+ SourceSchemaName string

+ SourceTableName string

+ Status string

+ TableRestoreRequestID string

+ TargetDatabaseName string

+ TargetSchemaName string

+ TotalDataInMegaBytes int64

+ WorkgroupName string

+ type ServerlessTrack struct

+ TrackName string

+ UpdateTargets []UpdateTarget

+ WorkgroupVersion string

type StorageBackend

+ DeregisterNamespace func(consumerIdentifiers []string, ...) (*NamespaceRegistration, error)

+ ModifyAquaConfiguration func(id string) (*Cluster, error)

+ ModifyLakehouseConfiguration func(p ModifyLakehouseConfigParams) (*ClusterLakehouseConfigResult, error)

+ RegisterNamespace func(consumerIdentifiers []string, ...) (*NamespaceRegistration, error)

+ type UpdateLakehouseConfigParams struct

+ CatalogName string

+ DryRun bool

+ LakehouseIdcApplicationArn string

+ LakehouseIdcRegistration string

+ LakehouseRegistration string

+ NamespaceName string

+ type UpdateNamespaceParams struct

+ AdminPasswordSecretKmsKeyID string

+ AdminUserPassword string

+ AdminUsername string

+ DefaultIamRoleArn string

+ IamRoles []string

+ KmsKeyID string

+ LogExports []string

+ ManageAdminPassword *bool

+ type UpdateScheduledActionParams struct

+ Enabled *bool

+ EndTime time.Time

+ RoleArn string

+ Schedule json.RawMessage

+ ScheduledActionDescription *string

+ StartTime time.Time

+ TargetAction json.RawMessage

+ type UpdateTarget struct

+ TrackName string

+ WorkgroupVersion string

type Workgroup

+ ConfigParameters []ConfigParameter

+ CustomDomainCertificateArn string

+ CustomDomainCertificateExpiryTime *time.Time

+ CustomDomainName string

+ EnhancedVpcRouting bool

+ ExtraComputeForAutomaticOptimization bool

+ IPAddressType string

+ MaxCapacity int

+ Port int

+ PricePerformanceTarget *PerformanceTarget

+ PubliclyAccessible bool

+ TrackName string

+ type WorkgroupParams struct

+ BaseCapacity int

+ ConfigParameters []ConfigParameter

+ EnhancedVpcRouting bool

+ ExtraComputeForAutomaticOptimization bool

+ IPAddressType string

+ MaxCapacity int

+ Port int

+ PricePerformanceTarget *PerformanceTarget

+ PubliclyAccessible bool

+ SecurityGroupIDs []string

+ SubnetIDs []string

+ TrackName string

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

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL