Documentation
¶
Index ¶
- type ConnectionTest
- type DMSCertificate
- type DMSService
- type Endpoint
- type EventSubscription
- type ReplicationInstance
- type ReplicationSubnetGroup
- type ReplicationTask
- type Store
- func (s *Store) AddTagsToResource(arn string, tags map[string]string) bool
- func (s *Store) CreateCertificate(id, pem string, tags map[string]string) (*DMSCertificate, error)
- func (s *Store) CreateEndpoint(id, endpointType, engine, server string, port int, db, username string) (*Endpoint, error)
- func (s *Store) CreateEventSubscription(id, snsTopicArn, sourceType string, sourceIds, eventCategories []string) (*EventSubscription, error)
- func (s *Store) CreateReplicationInstance(id, class string, storage int, engineVersion, az string, ...) (*ReplicationInstance, error)
- func (s *Store) CreateReplicationSubnetGroup(id, description string, subnetIds []string, tags map[string]string) (*ReplicationSubnetGroup, error)
- func (s *Store) CreateReplicationTask(id, sourceArn, targetArn, instanceArn, migrationType, tableMappings string) (*ReplicationTask, error)
- func (s *Store) DeleteCertificate(id string) bool
- func (s *Store) DeleteEndpoint(id string) bool
- func (s *Store) DeleteEventSubscription(id string) bool
- func (s *Store) DeleteReplicationInstance(id string) (*ReplicationInstance, bool)
- func (s *Store) DeleteReplicationSubnetGroup(id string) bool
- func (s *Store) DeleteReplicationTask(arn string) bool
- func (s *Store) DescribeCertificates() []*DMSCertificate
- func (s *Store) DescribeConnections() []ConnectionTest
- func (s *Store) DescribeReplicationSubnetGroups() []*ReplicationSubnetGroup
- func (s *Store) GetEndpoint(id string) (*Endpoint, bool)
- func (s *Store) GetEventSubscription(id string) (*EventSubscription, bool)
- func (s *Store) GetReplicationInstance(id string) (*ReplicationInstance, bool)
- func (s *Store) GetReplicationTask(id string) (*ReplicationTask, bool)
- func (s *Store) GetReplicationTaskStats(arn string) (loaded, loading, errored int, ok bool)
- func (s *Store) ListEndpoints() []*Endpoint
- func (s *Store) ListEventSubscriptions() []*EventSubscription
- func (s *Store) ListReplicationInstances() []*ReplicationInstance
- func (s *Store) ListReplicationTasks() []*ReplicationTask
- func (s *Store) ListTagsForResource(arn string) (map[string]string, bool)
- func (s *Store) ModifyEndpoint(id, server, db, username string, port int) (*Endpoint, bool)
- func (s *Store) ModifyReplicationInstance(id, newClass string, multiAZ *bool) (*ReplicationInstance, bool)
- func (s *Store) ModifyReplicationSubnetGroup(id, description string, subnetIds []string) (*ReplicationSubnetGroup, bool)
- func (s *Store) RemoveTagsFromResource(arn string, keys []string) bool
- func (s *Store) StartReplicationTask(arn string) (*ReplicationTask, error)
- func (s *Store) StopReplicationTask(arn string) (*ReplicationTask, error)
- func (s *Store) TestConnection(endpointArn, replicationInstanceArn string) (*ConnectionTest, error)
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 (*Store) AddTagsToResource ¶
AddTagsToResource adds tags to a DMS resource.
func (*Store) CreateCertificate ¶
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 ¶
DeleteCertificate removes a DMS certificate.
func (*Store) DeleteEndpoint ¶
DeleteEndpoint removes an endpoint.
func (*Store) DeleteEventSubscription ¶
DeleteEventSubscription removes an event subscription.
func (*Store) DeleteReplicationInstance ¶
func (s *Store) DeleteReplicationInstance(id string) (*ReplicationInstance, bool)
DeleteReplicationInstance removes a replication instance.
func (*Store) DeleteReplicationSubnetGroup ¶
DeleteReplicationSubnetGroup removes a subnet group.
func (*Store) DeleteReplicationTask ¶
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 ¶
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 ¶
GetReplicationTaskStats returns table statistics for a task.
func (*Store) ListEndpoints ¶
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 ¶
ListTagsForResource returns tags for a DMS resource.
func (*Store) ModifyEndpoint ¶
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 ¶
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).