dms

package
v1.10.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 4, 2026 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ConnectionTest

type ConnectionTest struct {
	EndpointArn            string
	ReplicationInstanceArn string
	Status                 string // successful, testing, failed
	FailureMessage         string
	TestedAt               time.Time
}

ConnectionTest tracks a test-connection result.

type DMSCertificate

type DMSCertificate struct {
	CertificateIdentifier string
	CertificateArn        string
	CertificatePem        string
	ValidFromDate         time.Time
	ValidToDate           time.Time
	CreatedAt             time.Time
	Tags                  map[string]string
}

DMSCertificate represents a DMS SSL certificate.

type DMSService

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

DMSService is the cloudmock implementation of the AWS Database Migration Service API.

func New

func New(accountID, region string) *DMSService

New returns a new DMSService for the given AWS account ID and region.

func (*DMSService) Actions

func (s *DMSService) Actions() []service.Action

Actions returns the list of DMS API actions supported by this service.

func (*DMSService) HandleRequest

func (s *DMSService) HandleRequest(ctx *service.RequestContext) (*service.Response, error)

HandleRequest routes an incoming DMS request to the appropriate handler.

func (*DMSService) HealthCheck

func (s *DMSService) HealthCheck() error

HealthCheck always returns nil.

func (*DMSService) Name

func (s *DMSService) Name() string

Name returns the AWS service name used for routing.

type Endpoint

type Endpoint struct {
	EndpointIdentifier string
	EndpointArn        string
	EndpointType       string // "source" or "target"
	EngineName         string
	ServerName         string
	Port               int
	DatabaseName       string
	Username           string
	Status             string
	CreatedAt          time.Time
}

Endpoint represents a DMS endpoint.

type EventSubscription

type EventSubscription struct {
	CustSubscriptionId string
	SnsTopicArn        string
	SourceType         string
	SourceIds          []string
	EventCategories    []string
	Status             string
	CreatedAt          time.Time
}

EventSubscription represents a DMS event subscription.

type ReplicationInstance

type ReplicationInstance struct {
	ReplicationInstanceIdentifier string
	ReplicationInstanceArn        string
	ReplicationInstanceClass      string
	AllocatedStorage              int
	EngineVersion                 string
	AutoMinorVersionUpgrade       bool
	AvailabilityZone              string
	MultiAZ                       bool
	PubliclyAccessible            bool
	ReplicationInstanceStatus     string
	InstanceCreateTime            time.Time
	// contains filtered or unexported fields
}

ReplicationInstance represents a DMS replication instance.

type ReplicationSubnetGroup

type ReplicationSubnetGroup struct {
	ReplicationSubnetGroupIdentifier  string
	ReplicationSubnetGroupArn         string
	ReplicationSubnetGroupDescription string
	SubnetIds                         []string
	VpcID                             string
	CreatedAt                         time.Time
	Tags                              map[string]string
}

ReplicationSubnetGroup represents a DMS replication subnet group.

type ReplicationTask

type ReplicationTask struct {
	ReplicationTaskIdentifier string
	ReplicationTaskArn        string
	SourceEndpointArn         string
	TargetEndpointArn         string
	ReplicationInstanceArn    string
	MigrationType             string
	TableMappings             string
	Status                    string
	CreatedAt                 time.Time
	StartedAt                 *time.Time
	StoppedAt                 *time.Time

	// Table statistics tracked during running state
	TablesLoaded  int
	TablesLoading int
	TablesErrored int
	// contains filtered or unexported fields
}

ReplicationTask represents a DMS replication task.

type Store

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

Store manages DMS resources in memory.

func NewStore

func NewStore(accountID, region string) *Store

NewStore returns a new empty DMS Store.

func (*Store) AddTagsToResource

func (s *Store) AddTagsToResource(arn string, tags map[string]string) bool

AddTagsToResource adds tags to a DMS resource.

func (*Store) CreateCertificate

func (s *Store) CreateCertificate(id, pem string, tags map[string]string) (*DMSCertificate, error)

CreateCertificate creates a DMS certificate.

func (*Store) CreateEndpoint

func (s *Store) CreateEndpoint(id, endpointType, engine, server string, port int, db, username string) (*Endpoint, error)

CreateEndpoint creates a new endpoint.

func (*Store) CreateEventSubscription

func (s *Store) CreateEventSubscription(id, snsTopicArn, sourceType string, sourceIds, eventCategories []string) (*EventSubscription, error)

CreateEventSubscription creates a new event subscription.

func (*Store) CreateReplicationInstance

func (s *Store) CreateReplicationInstance(id, class string, storage int, engineVersion, az string, multiAZ, publicAccess bool) (*ReplicationInstance, error)

CreateReplicationInstance creates a new replication instance.

func (*Store) CreateReplicationSubnetGroup

func (s *Store) CreateReplicationSubnetGroup(id, description string, subnetIds []string, tags map[string]string) (*ReplicationSubnetGroup, error)

CreateReplicationSubnetGroup creates a subnet group.

func (*Store) CreateReplicationTask

func (s *Store) CreateReplicationTask(id, sourceArn, targetArn, instanceArn, migrationType, tableMappings string) (*ReplicationTask, error)

CreateReplicationTask creates a new replication task.

func (*Store) DeleteCertificate

func (s *Store) DeleteCertificate(id string) bool

DeleteCertificate removes a DMS certificate.

func (*Store) DeleteEndpoint

func (s *Store) DeleteEndpoint(id string) bool

DeleteEndpoint removes an endpoint.

func (*Store) DeleteEventSubscription

func (s *Store) DeleteEventSubscription(id string) bool

DeleteEventSubscription removes an event subscription.

func (*Store) DeleteReplicationInstance

func (s *Store) DeleteReplicationInstance(id string) (*ReplicationInstance, bool)

DeleteReplicationInstance removes a replication instance.

func (*Store) DeleteReplicationSubnetGroup

func (s *Store) DeleteReplicationSubnetGroup(id string) bool

DeleteReplicationSubnetGroup removes a subnet group.

func (*Store) DeleteReplicationTask

func (s *Store) DeleteReplicationTask(arn string) bool

DeleteReplicationTask removes a replication task.

func (*Store) DescribeCertificates

func (s *Store) DescribeCertificates() []*DMSCertificate

DescribeCertificates returns all DMS certificates.

func (*Store) DescribeConnections

func (s *Store) DescribeConnections() []ConnectionTest

DescribeConnections returns all connection test results.

func (*Store) DescribeReplicationSubnetGroups

func (s *Store) DescribeReplicationSubnetGroups() []*ReplicationSubnetGroup

DescribeReplicationSubnetGroups returns all subnet groups.

func (*Store) GetEndpoint

func (s *Store) GetEndpoint(id string) (*Endpoint, bool)

GetEndpoint retrieves an endpoint by identifier.

func (*Store) GetEventSubscription

func (s *Store) GetEventSubscription(id string) (*EventSubscription, bool)

GetEventSubscription retrieves an event subscription by identifier.

func (*Store) GetReplicationInstance

func (s *Store) GetReplicationInstance(id string) (*ReplicationInstance, bool)

GetReplicationInstance retrieves a replication instance by identifier.

func (*Store) GetReplicationTask

func (s *Store) GetReplicationTask(id string) (*ReplicationTask, bool)

GetReplicationTask retrieves a replication task by identifier.

func (*Store) GetReplicationTaskStats

func (s *Store) GetReplicationTaskStats(arn string) (loaded, loading, errored int, ok bool)

GetReplicationTaskStats returns table statistics for a task.

func (*Store) ListEndpoints

func (s *Store) ListEndpoints() []*Endpoint

ListEndpoints returns all endpoints.

func (*Store) ListEventSubscriptions

func (s *Store) ListEventSubscriptions() []*EventSubscription

ListEventSubscriptions returns all event subscriptions.

func (*Store) ListReplicationInstances

func (s *Store) ListReplicationInstances() []*ReplicationInstance

ListReplicationInstances returns all replication instances.

func (*Store) ListReplicationTasks

func (s *Store) ListReplicationTasks() []*ReplicationTask

ListReplicationTasks returns all replication tasks.

func (*Store) ListTagsForResource

func (s *Store) ListTagsForResource(arn string) (map[string]string, bool)

ListTagsForResource returns tags for a DMS resource.

func (*Store) ModifyEndpoint

func (s *Store) ModifyEndpoint(id, server, db, username string, port int) (*Endpoint, bool)

ModifyEndpoint updates an endpoint.

func (*Store) ModifyReplicationInstance

func (s *Store) ModifyReplicationInstance(id, newClass string, multiAZ *bool) (*ReplicationInstance, bool)

ModifyReplicationInstance updates a replication instance.

func (*Store) ModifyReplicationSubnetGroup

func (s *Store) ModifyReplicationSubnetGroup(id, description string, subnetIds []string) (*ReplicationSubnetGroup, bool)

ModifyReplicationSubnetGroup updates a subnet group.

func (*Store) RemoveTagsFromResource

func (s *Store) RemoveTagsFromResource(arn string, keys []string) bool

RemoveTagsFromResource removes tags from a DMS resource.

func (*Store) StartReplicationTask

func (s *Store) StartReplicationTask(arn string) (*ReplicationTask, error)

StartReplicationTask starts a replication task.

func (*Store) StopReplicationTask

func (s *Store) StopReplicationTask(arn string) (*ReplicationTask, error)

StopReplicationTask stops a replication task.

func (*Store) TestConnection

func (s *Store) TestConnection(endpointArn, replicationInstanceArn string) (*ConnectionTest, error)

TestConnection tests connectivity to an endpoint (always succeeds in mock).

Jump to

Keyboard shortcuts

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