dms

package

Go to main page

Versions in this module

v1

v1.5.0

Aug 24, 2026

Changes in this version

type Endpoint

+ CertificateArn string

+ ExternalTableDefinition string

+ ExtraConnectionAttributes string

+ KmsKeyID string

+ ServiceAccessRoleArn string

+ SslMode string

+ type EndpointConnectionSettings struct

+ CertificateArn string

+ ExternalTableDefinition string

+ ExtraConnectionAttributes string

+ KmsKeyID string

+ ServiceAccessRoleArn string

+ SslMode string

type ReplicationInstance

+ DNSNameServers string

+ KmsKeyID string

+ NetworkType string

+ PreferredMaintenanceWindow string

+ type ReplicationInstanceSettings struct

+ DNSNameServers string

+ KmsKeyID string

+ NetworkType string

+ PreferredMaintenanceWindow string

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

+ type ComputeConfig struct

+ AvailabilityZone string

+ DNSNameServers string

+ KMSKeyID string

+ MaxCapacityUnits *int32

+ MinCapacityUnits *int32

+ MultiAZ *bool

+ PreferredMaintenanceWindow string

+ ReplicationSubnetGroupID string

+ VPCSecurityGroupIDs []string

+ type CreateReplicationConfigParams struct

+ ComputeConfig *ComputeConfig

+ Identifier string

+ ReplicationType string

+ SourceEndpointArn string

+ TableMappings string

+ TargetEndpointArn string

+ type DataProviderDescriptor struct

+ DataProviderArn string

+ DataProviderName string

+ SecretsManagerAccessRoleArn string

+ SecretsManagerSecretId string

+ type DataProviderDescriptorInput struct

+ DataProviderIdentifier string

+ SecretsManagerAccessRoleArn string

+ SecretsManagerSecretId string

type MetadataModelRequest

+ PropertiesDefinition string

type MigrationProject

+ InstanceProfileArn string

+ InstanceProfileName string

+ SourceDataProviderDescriptors []DataProviderDescriptor

+ TargetDataProviderDescriptors []DataProviderDescriptor

type ReplicationConfig

+ ComputeConfig *ComputeConfig

+ TableMappings string

v1.3.0

Aug 3, 2026

v1.2.0

Aug 3, 2026

Changes in this version

type AssessmentRun

+ CreationDate time.Time

+ IndividualAssessments []*IndividualAssessment

+ IsLatestTaskAssessmentRun bool

+ ResultLocationBucket string

+ ResultLocationFolder string

+ ResultStatistic AssessmentRunResultStatistic

+ ServiceAccessRoleArn string

+ type AssessmentRunResultStatistic struct

+ Cancelled int32

+ Error int32

+ Failed int32

+ Passed int32

+ Skipped int32

+ Warning int32

type Endpoint

+ Password string

type InMemoryBackend

+ func (b *InMemoryBackend) DescribeAllAssessmentResults(ctx context.Context) ([]*AssessmentRun, error)

+ func (b *InMemoryBackend) DescribeAssessmentResult(ctx context.Context, taskArn string) (*AssessmentRun, error)

+ func (b *InMemoryBackend) DescribeAssessmentRunsFiltered(ctx context.Context, f assessmentRunFilters) ([]*AssessmentRun, error)

+ func (b *InMemoryBackend) DescribeIndividualAssessments(ctx context.Context, f assessmentRunFilters) ([]*IndividualAssessment, error)

+ func (b *InMemoryBackend) ReloadReplicationTables(ctx context.Context, arnOrID string) (*ReplicationConfig, error)

+ func (b *InMemoryBackend) ReloadTables(ctx context.Context, arnOrID string) (*ReplicationTask, error)

+ type IndividualAssessment struct

+ IndividualAssessmentName string

+ ReplicationTaskArn string

+ ReplicationTaskAssessmentRunArn string

+ ReplicationTaskIndividualAssessmentArn string

+ StartDate time.Time

+ Status 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 ErrAlreadyExists = awserr.New("ResourceAlreadyExistsFault", awserr.ErrConflict)

+ var ErrInvalidState = awserr.New("InvalidResourceStateFault", awserr.ErrInvalidParameter)

+ var ErrNilAppContext = errors.New("DMS provider: nil AppContext")

+ var ErrNotFound = awserr.New("ResourceNotFoundFault", awserr.ErrNotFound)

+ var ErrValidation = awserr.New("ValidationException", awserr.ErrInvalidParameter)

+ type AssessmentRun struct

+ AssessmentRunName string

+ Region string

+ ReplicationTaskArn string

+ ReplicationTaskAssessmentRunArn string

+ Status string

+ type Certificate struct

+ AccountID string

+ CertificateArn string

+ CertificateIdentifier string

+ CertificatePem string

+ Region string

+ type Connection struct

+ EndpointArn string

+ EndpointIdentifier string

+ LastFailureMessage string

+ Region string

+ ReplicationInstanceArn string

+ ReplicationInstanceIdentifier string

+ Status string

+ type DataMigration struct

+ AccountID string

+ CreationTime time.Time

+ DataMigrationArn string

+ DataMigrationName string

+ DataMigrationStatus string

+ DataMigrationType string

+ EnableCloudwatchLogs bool

+ MigrationProjectArn string

+ NumberOfJobs int32

+ Region string

+ SelectionRules string

+ ServiceAccessRoleArn string

+ Tags *tags.Tags

+ type DataProvider struct

+ AccountID string

+ CreationTime time.Time

+ DataProviderArn string

+ DataProviderName string

+ Description string

+ Engine string

+ Region string

+ Tags *tags.Tags

+ type Endpoint struct

+ AccountID string

+ CreationTime time.Time

+ DatabaseName string

+ EndpointArn string

+ EndpointIdentifier string

+ EndpointType string

+ EngineName string

+ Port int32

+ Region string

+ ServerName string

+ Status string

+ Tags *tags.Tags

+ Username string

+ type Event struct

+ Date string

+ EventCategories []string

+ Message string

+ SourceIdentifier string

+ SourceType string

+ type EventSubscription struct

+ AccountID string

+ CreationTime time.Time

+ Enabled bool

+ EventCategories []string

+ Region string

+ SnsTopicArn string

+ SourceIDsList []string

+ SourceType string

+ Status string

+ SubscriptionName string

+ Tags *tags.Tags

+ type FleetAdvisorCollector struct

+ AccountID string

+ CollectorHealthCheck string

+ CollectorName string

+ CollectorReferencedID string

+ CollectorVersion string

+ CreatedDate time.Time

+ Description string

+ LastDataReceived string

+ ModifiedDate string

+ Region string

+ RegisteredDate string

+ S3BucketName string

+ ServiceAccessRoleArn string

+ Tags *tags.Tags

+ type FleetAdvisorDatabase struct

+ CollectorReferencedID string

+ DatabaseID string

+ DatabaseName string

+ EngineName string

+ IPAddress string

+ Region string

+ type Handler struct

+ Backend *InMemoryBackend

+ func NewHandler(backend *InMemoryBackend) *Handler

+ func (h *Handler) ChaosOperations() []string

+ func (h *Handler) ChaosRegions() []string

+ func (h *Handler) ChaosServiceName() string

+ func (h *Handler) ExtractOperation(c *echo.Context) string

+ func (h *Handler) ExtractResource(c *echo.Context) string

+ func (h *Handler) GetSupportedOperations() []string

+ func (h *Handler) Handler() echo.HandlerFunc

+ func (h *Handler) MatchPriority() int

+ func (h *Handler) Name() string

+ func (h *Handler) Reset()

+ func (h *Handler) Restore(ctx context.Context, data []byte) error

+ func (h *Handler) RouteMatcher() service.Matcher

+ func (h *Handler) Snapshot(ctx context.Context) []byte

+ type InMemoryBackend struct

+ func NewInMemoryBackend(accountID, region string) *InMemoryBackend

+ func (b *InMemoryBackend) AccountID() string

+ func (b *InMemoryBackend) AddDataMigrationInternal(name, migrationType string)

+ func (b *InMemoryBackend) AddDataProviderInternal(name, engine string)

+ func (b *InMemoryBackend) AddEndpointInternal(identifier, endpointType, engineName string)

+ func (b *InMemoryBackend) AddEventSubscriptionInternal(name, snsTopicArn string)

+ func (b *InMemoryBackend) AddFleetAdvisorCollectorInternal(name string)

+ func (b *InMemoryBackend) AddInstanceProfileInternal(name string)

+ func (b *InMemoryBackend) AddReplicationInstanceInternal(identifier, class string)

+ func (b *InMemoryBackend) AddReplicationTaskInternal(identifier, srcARN, tgtARN, instARN, migrationType string)

+ func (b *InMemoryBackend) AddTagsToResource(ctx context.Context, resourceArn string, kv map[string]string) error

+ func (b *InMemoryBackend) ApplyPendingMaintenanceAction(ctx context.Context, replicationInstanceArn, applyAction, optInType string) (*ReplicationInstance, error)

+ func (b *InMemoryBackend) BatchStartRecommendations(ctx context.Context) error

+ func (b *InMemoryBackend) CancelMetadataModelConversion(ctx context.Context, migrationProjectIdentifier, requestIdentifier string) (string, error)

+ func (b *InMemoryBackend) CancelMetadataModelCreation(ctx context.Context, migrationProjectIdentifier, requestIdentifier string) (string, error)

+ func (b *InMemoryBackend) CancelReplicationTaskAssessmentRun(ctx context.Context, replicationTaskAssessmentRunArn string) error

+ func (b *InMemoryBackend) CreateDataMigration(ctx context.Context, ...) (*DataMigration, error)

+ func (b *InMemoryBackend) CreateDataProvider(ctx context.Context, name, engine, description string, kv map[string]string) (*DataProvider, error)

+ func (b *InMemoryBackend) CreateEndpoint(ctx context.Context, ...) (*Endpoint, error)

+ func (b *InMemoryBackend) CreateEventSubscription(ctx context.Context, subscriptionName, snsTopicArn, sourceType string, ...) (*EventSubscription, error)

+ func (b *InMemoryBackend) CreateFleetAdvisorCollector(ctx context.Context, ...) (*FleetAdvisorCollector, error)

+ func (b *InMemoryBackend) CreateInstanceProfile(ctx context.Context, ...) (*InstanceProfile, error)

+ func (b *InMemoryBackend) CreateMigrationProject(ctx context.Context, name, description string, kv map[string]string) (*MigrationProject, error)

+ func (b *InMemoryBackend) CreateReplicationConfig(ctx context.Context, ...) (*ReplicationConfig, error)

+ func (b *InMemoryBackend) CreateReplicationInstance(ctx context.Context, identifier, class, engineVersion, availabilityZone string, ...) (*ReplicationInstance, error)

+ func (b *InMemoryBackend) CreateReplicationSubnetGroup(ctx context.Context, identifier, description, vpcID string, ...) (*ReplicationSubnetGroup, error)

+ func (b *InMemoryBackend) CreateReplicationTask(ctx context.Context, ...) (*ReplicationTask, error)

+ func (b *InMemoryBackend) DeleteAssessmentRun(ctx context.Context, runArn string) (*AssessmentRun, error)

+ func (b *InMemoryBackend) DeleteCertificate(ctx context.Context, identifierOrArn string) (*Certificate, error)

+ func (b *InMemoryBackend) DeleteConnection(ctx context.Context, replicationInstanceArn, endpointArn string) (*Connection, error)

+ func (b *InMemoryBackend) DeleteDataMigration(ctx context.Context, nameOrArn string) (*DataMigration, error)

+ func (b *InMemoryBackend) DeleteDataProvider(ctx context.Context, nameOrArn string) (*DataProvider, error)

+ func (b *InMemoryBackend) DeleteEndpoint(ctx context.Context, arnOrID string) (*Endpoint, error)

+ func (b *InMemoryBackend) DeleteEventSubscription(ctx context.Context, name string) (*EventSubscription, error)

+ func (b *InMemoryBackend) DeleteFleetAdvisorCollector(ctx context.Context, nameOrID string) error

+ func (b *InMemoryBackend) DeleteFleetAdvisorDatabases(ctx context.Context, ids []string) ([]string, error)

+ func (b *InMemoryBackend) DeleteInstanceProfile(ctx context.Context, nameOrArn string) error

+ func (b *InMemoryBackend) DeleteMigrationProject(ctx context.Context, nameOrArn string) error

+ func (b *InMemoryBackend) DeleteReplicationConfig(ctx context.Context, identifierOrArn string) error

+ func (b *InMemoryBackend) DeleteReplicationInstance(ctx context.Context, arnOrID string) error

+ func (b *InMemoryBackend) DeleteReplicationSubnetGroup(ctx context.Context, identifierOrArn string) error

+ func (b *InMemoryBackend) DeleteReplicationTask(ctx context.Context, arnOrID string) (*ReplicationTask, error)

+ func (b *InMemoryBackend) DescribeAssessmentRuns(ctx context.Context, taskArn string) ([]*AssessmentRun, error)

+ func (b *InMemoryBackend) DescribeCertificates(ctx context.Context) ([]*Certificate, error)

+ func (b *InMemoryBackend) DescribeConnections(ctx context.Context, replicationInstanceArn, endpointArn string) ([]*Connection, error)

+ func (b *InMemoryBackend) DescribeDataMigrations(ctx context.Context, nameOrArn string) ([]*DataMigration, error)

+ func (b *InMemoryBackend) DescribeDataProviders(ctx context.Context, nameOrArn string) ([]*DataProvider, error)

+ func (b *InMemoryBackend) DescribeEndpoints(ctx context.Context, identifierOrArn string) ([]*Endpoint, error)

+ func (b *InMemoryBackend) DescribeEventSubscriptions(ctx context.Context, name string) ([]*EventSubscription, error)

+ func (b *InMemoryBackend) DescribeEvents(ctx context.Context) ([]*Event, error)

+ func (b *InMemoryBackend) DescribeFleetAdvisorCollectors(ctx context.Context) ([]*FleetAdvisorCollector, error)

+ func (b *InMemoryBackend) DescribeFleetAdvisorDatabases(ctx context.Context) ([]*FleetAdvisorDatabase, error)

+ func (b *InMemoryBackend) DescribeInstanceProfiles(ctx context.Context) ([]*InstanceProfile, error)

+ func (b *InMemoryBackend) DescribeMigrationProjects(ctx context.Context) ([]*MigrationProject, error)

+ func (b *InMemoryBackend) DescribeRecommendations(ctx context.Context) ([]*Recommendation, error)

+ func (b *InMemoryBackend) DescribeReplicationConfigs(ctx context.Context) ([]*ReplicationConfig, error)

+ func (b *InMemoryBackend) DescribeReplicationInstances(ctx context.Context, identifierOrArn string) ([]*ReplicationInstance, error)

+ func (b *InMemoryBackend) DescribeReplicationSubnetGroups(ctx context.Context) ([]*ReplicationSubnetGroup, error)

+ func (b *InMemoryBackend) DescribeReplicationTasks(ctx context.Context, arnOrID string) ([]*ReplicationTask, error)

+ func (b *InMemoryBackend) DescribeReplications(ctx context.Context, replicationConfigIDOrArn string) ([]*ReplicationConfig, error)

+ func (b *InMemoryBackend) DescribeSchemas(ctx context.Context, endpointARN string) ([]string, error)

+ func (b *InMemoryBackend) ImportCertificate(ctx context.Context, identifier, certPem string) (*Certificate, error)

+ func (b *InMemoryBackend) ListMetadataModelRequests(ctx context.Context, projectIdentifier, reqType string) ([]*MetadataModelRequest, error)

+ func (b *InMemoryBackend) ListTagsForResource(ctx context.Context, resourceArn string) (map[string]string, error)

+ func (b *InMemoryBackend) ModifyDataMigration(ctx context.Context, nameOrArn, migrationType, serviceAccessRoleArn string, ...) (*DataMigration, error)

+ func (b *InMemoryBackend) ModifyDataProvider(ctx context.Context, nameOrArn, engine, description string) (*DataProvider, error)

+ func (b *InMemoryBackend) ModifyEndpoint(ctx context.Context, arnOrID, serverName, databaseName, username string, ...) (*Endpoint, error)

+ func (b *InMemoryBackend) ModifyEventSubscription(ctx context.Context, name string, enabled *bool) (*EventSubscription, error)

+ func (b *InMemoryBackend) ModifyInstanceProfile(ctx context.Context, ...) (*InstanceProfile, error)

+ func (b *InMemoryBackend) ModifyMigrationProject(ctx context.Context, nameOrArn, description string) (*MigrationProject, error)

+ func (b *InMemoryBackend) ModifyReplicationConfig(ctx context.Context, identifierOrArn, replicationType string) (*ReplicationConfig, error)

+ func (b *InMemoryBackend) ModifyReplicationInstance(ctx context.Context, arnOrID, class, engineVersion string, ...) (*ReplicationInstance, error)

+ func (b *InMemoryBackend) ModifyReplicationSubnetGroup(ctx context.Context, identifierOrArn, description string) (*ReplicationSubnetGroup, error)

+ func (b *InMemoryBackend) ModifyReplicationTask(ctx context.Context, ...) (*ReplicationTask, error)

+ func (b *InMemoryBackend) MoveReplicationTask(ctx context.Context, taskArnOrID, targetInstanceArn string) (*ReplicationTask, error)

+ func (b *InMemoryBackend) PaginationSecret() string

+ func (b *InMemoryBackend) RebootReplicationInstance(ctx context.Context, arnOrID string) (*ReplicationInstance, error)

+ func (b *InMemoryBackend) RefreshSchemas(ctx context.Context, endpointARN string) error

+ func (b *InMemoryBackend) Region() string

+ func (b *InMemoryBackend) RemoveTagsFromResource(ctx context.Context, resourceArn string, tagKeys []string) error

+ func (b *InMemoryBackend) Reset()

+ func (b *InMemoryBackend) Restore(ctx context.Context, data []byte) error

+ func (b *InMemoryBackend) Snapshot(ctx context.Context) []byte

+ func (b *InMemoryBackend) StartAssessmentRun(ctx context.Context, taskArn, _, _, assessmentRunName string) (*AssessmentRun, error)

+ func (b *InMemoryBackend) StartDataMigration(ctx context.Context, nameOrArn string) (*DataMigration, error)

+ func (b *InMemoryBackend) StartMetadataModelRequest(ctx context.Context, projectIdentifier, reqType, selectionRules string) (string, error)

+ func (b *InMemoryBackend) StartRecommendation(ctx context.Context, databaseID string) error

+ func (b *InMemoryBackend) StartReplication(ctx context.Context, replicationConfigArn, startReplicationType string) (*ReplicationConfig, error)

+ func (b *InMemoryBackend) StartReplicationTask(ctx context.Context, arnOrID string) (*ReplicationTask, error)

+ func (b *InMemoryBackend) StopDataMigration(ctx context.Context, nameOrArn string) (*DataMigration, error)

+ func (b *InMemoryBackend) StopReplication(ctx context.Context, replicationConfigArn string) (*ReplicationConfig, error)

+ func (b *InMemoryBackend) StopReplicationTask(ctx context.Context, arnOrID string) (*ReplicationTask, error)

+ func (b *InMemoryBackend) TestConnection(ctx context.Context, replicationInstanceArn, endpointArn string) (*Connection, error)

+ type InstanceProfile struct

+ AccountID string

+ AvailabilityZone string

+ CreationTime time.Time

+ Description string

+ InstanceProfileArn string

+ InstanceProfileName string

+ KmsKeyArn string

+ NetworkType string

+ PubliclyAccessible bool

+ Region string

+ SubnetGroupIdentifier string

+ Tags *tags.Tags

+ type MetadataModelRequest struct

+ MigrationProjectIdentifier string

+ Region string

+ RequestIdentifier string

+ RequestType string

+ SelectionRules string

+ Status string

+ type MigrationProject struct

+ AccountID string

+ Description string

+ MigrationProjectArn string

+ MigrationProjectIdentifier string

+ MigrationProjectName string

+ Region string

+ Tags *tags.Tags

+ type Provider struct

+ func (p *Provider) Init(ctx *service.AppContext) (service.Registerable, error)

+ func (p *Provider) Name() string

+ type Recommendation struct

+ DatabaseID string

+ EngineName string

+ Status string

+ type ReplicationConfig struct

+ AccountID string

+ Region string

+ ReplicationConfigArn string

+ ReplicationConfigIdentifier string

+ ReplicationType string

+ SourceEndpointArn string

+ StartReplicationType string

+ Status string

+ Tags *tags.Tags

+ TargetEndpointArn string

+ type ReplicationInstance struct

+ AccountID string

+ AllocatedStorage int32

+ AutoMinorVersionUpgrade bool

+ AvailabilityZone string

+ CreationTime time.Time

+ EngineVersion string

+ MultiAZ bool

+ PrivateIPAddress string

+ PubliclyAccessible bool

+ Region string

+ ReplicationInstanceArn string

+ ReplicationInstanceClass string

+ ReplicationInstanceIdentifier string

+ ReplicationInstanceStatus string

+ Tags *tags.Tags

+ type ReplicationSubnetGroup struct

+ AccountID string

+ Region string

+ ReplicationSubnetGroupArn string

+ ReplicationSubnetGroupDescription string

+ ReplicationSubnetGroupIdentifier string

+ Tags *tags.Tags

+ VpcID string

+ type ReplicationTask struct

+ AccountID string

+ CreationTime time.Time

+ MigrationType string

+ Region string

+ ReplicationInstanceArn string

+ ReplicationTaskArn string

+ ReplicationTaskIdentifier string

+ ReplicationTaskSettings string

+ SourceEndpointArn string

+ Status string

+ TableMappings string

+ Tags *tags.Tags

+ TargetEndpointArn string

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