databasemigrationservice

Documentation

Index

• type Activities
  • func NewActivities(sess *session.Session, config ...*aws.Config) *Activities
  • func NewActivitiesWithSessionFactory(sessionFactory SessionFactory) *Activities
  • func (a *Activities) AddTagsToResource(ctx context.Context, input *databasemigrationservice.AddTagsToResourceInput) (*databasemigrationservice.AddTagsToResourceOutput, error)
  • func (a *Activities) ApplyPendingMaintenanceAction(ctx context.Context, ...) (*databasemigrationservice.ApplyPendingMaintenanceActionOutput, error)
  • func (a *Activities) CancelReplicationTaskAssessmentRun(ctx context.Context, ...) (*databasemigrationservice.CancelReplicationTaskAssessmentRunOutput, error)
  • func (a *Activities) CreateEndpoint(ctx context.Context, input *databasemigrationservice.CreateEndpointInput) (*databasemigrationservice.CreateEndpointOutput, error)
  • func (a *Activities) CreateEventSubscription(ctx context.Context, ...) (*databasemigrationservice.CreateEventSubscriptionOutput, error)
  • func (a *Activities) CreateReplicationInstance(ctx context.Context, ...) (*databasemigrationservice.CreateReplicationInstanceOutput, error)
  • func (a *Activities) CreateReplicationSubnetGroup(ctx context.Context, ...) (*databasemigrationservice.CreateReplicationSubnetGroupOutput, error)
  • func (a *Activities) CreateReplicationTask(ctx context.Context, ...) (*databasemigrationservice.CreateReplicationTaskOutput, error)
  • func (a *Activities) DeleteCertificate(ctx context.Context, input *databasemigrationservice.DeleteCertificateInput) (*databasemigrationservice.DeleteCertificateOutput, error)
  • func (a *Activities) DeleteConnection(ctx context.Context, input *databasemigrationservice.DeleteConnectionInput) (*databasemigrationservice.DeleteConnectionOutput, error)
  • func (a *Activities) DeleteEndpoint(ctx context.Context, input *databasemigrationservice.DeleteEndpointInput) (*databasemigrationservice.DeleteEndpointOutput, error)
  • func (a *Activities) DeleteEventSubscription(ctx context.Context, ...) (*databasemigrationservice.DeleteEventSubscriptionOutput, error)
  • func (a *Activities) DeleteReplicationInstance(ctx context.Context, ...) (*databasemigrationservice.DeleteReplicationInstanceOutput, error)
  • func (a *Activities) DeleteReplicationSubnetGroup(ctx context.Context, ...) (*databasemigrationservice.DeleteReplicationSubnetGroupOutput, error)
  • func (a *Activities) DeleteReplicationTask(ctx context.Context, ...) (*databasemigrationservice.DeleteReplicationTaskOutput, error)
  • func (a *Activities) DeleteReplicationTaskAssessmentRun(ctx context.Context, ...) (*databasemigrationservice.DeleteReplicationTaskAssessmentRunOutput, error)
  • func (a *Activities) DescribeAccountAttributes(ctx context.Context, ...) (*databasemigrationservice.DescribeAccountAttributesOutput, error)
  • func (a *Activities) DescribeApplicableIndividualAssessments(ctx context.Context, ...) (*databasemigrationservice.DescribeApplicableIndividualAssessmentsOutput, error)
  • func (a *Activities) DescribeCertificates(ctx context.Context, input *databasemigrationservice.DescribeCertificatesInput) (*databasemigrationservice.DescribeCertificatesOutput, error)
  • func (a *Activities) DescribeConnections(ctx context.Context, input *databasemigrationservice.DescribeConnectionsInput) (*databasemigrationservice.DescribeConnectionsOutput, error)
  • func (a *Activities) DescribeEndpointTypes(ctx context.Context, ...) (*databasemigrationservice.DescribeEndpointTypesOutput, error)
  • func (a *Activities) DescribeEndpoints(ctx context.Context, input *databasemigrationservice.DescribeEndpointsInput) (*databasemigrationservice.DescribeEndpointsOutput, error)
  • func (a *Activities) DescribeEventCategories(ctx context.Context, ...) (*databasemigrationservice.DescribeEventCategoriesOutput, error)
  • func (a *Activities) DescribeEventSubscriptions(ctx context.Context, ...) (*databasemigrationservice.DescribeEventSubscriptionsOutput, error)
  • func (a *Activities) DescribeEvents(ctx context.Context, input *databasemigrationservice.DescribeEventsInput) (*databasemigrationservice.DescribeEventsOutput, error)
  • func (a *Activities) DescribeOrderableReplicationInstances(ctx context.Context, ...) (*databasemigrationservice.DescribeOrderableReplicationInstancesOutput, error)
  • func (a *Activities) DescribePendingMaintenanceActions(ctx context.Context, ...) (*databasemigrationservice.DescribePendingMaintenanceActionsOutput, error)
  • func (a *Activities) DescribeRefreshSchemasStatus(ctx context.Context, ...) (*databasemigrationservice.DescribeRefreshSchemasStatusOutput, error)
  • func (a *Activities) DescribeReplicationInstanceTaskLogs(ctx context.Context, ...) (*databasemigrationservice.DescribeReplicationInstanceTaskLogsOutput, error)
  • func (a *Activities) DescribeReplicationInstances(ctx context.Context, ...) (*databasemigrationservice.DescribeReplicationInstancesOutput, error)
  • func (a *Activities) DescribeReplicationSubnetGroups(ctx context.Context, ...) (*databasemigrationservice.DescribeReplicationSubnetGroupsOutput, error)
  • func (a *Activities) DescribeReplicationTaskAssessmentResults(ctx context.Context, ...) (*databasemigrationservice.DescribeReplicationTaskAssessmentResultsOutput, ...)
  • func (a *Activities) DescribeReplicationTaskAssessmentRuns(ctx context.Context, ...) (*databasemigrationservice.DescribeReplicationTaskAssessmentRunsOutput, error)
  • func (a *Activities) DescribeReplicationTaskIndividualAssessments(ctx context.Context, ...) (*databasemigrationservice.DescribeReplicationTaskIndividualAssessmentsOutput, ...)
  • func (a *Activities) DescribeReplicationTasks(ctx context.Context, ...) (*databasemigrationservice.DescribeReplicationTasksOutput, error)
  • func (a *Activities) DescribeSchemas(ctx context.Context, input *databasemigrationservice.DescribeSchemasInput) (*databasemigrationservice.DescribeSchemasOutput, error)
  • func (a *Activities) DescribeTableStatistics(ctx context.Context, ...) (*databasemigrationservice.DescribeTableStatisticsOutput, error)
  • func (a *Activities) ImportCertificate(ctx context.Context, input *databasemigrationservice.ImportCertificateInput) (*databasemigrationservice.ImportCertificateOutput, error)
  • func (a *Activities) ListTagsForResource(ctx context.Context, input *databasemigrationservice.ListTagsForResourceInput) (*databasemigrationservice.ListTagsForResourceOutput, error)
  • func (a *Activities) ModifyEndpoint(ctx context.Context, input *databasemigrationservice.ModifyEndpointInput) (*databasemigrationservice.ModifyEndpointOutput, error)
  • func (a *Activities) ModifyEventSubscription(ctx context.Context, ...) (*databasemigrationservice.ModifyEventSubscriptionOutput, error)
  • func (a *Activities) ModifyReplicationInstance(ctx context.Context, ...) (*databasemigrationservice.ModifyReplicationInstanceOutput, error)
  • func (a *Activities) ModifyReplicationSubnetGroup(ctx context.Context, ...) (*databasemigrationservice.ModifyReplicationSubnetGroupOutput, error)
  • func (a *Activities) ModifyReplicationTask(ctx context.Context, ...) (*databasemigrationservice.ModifyReplicationTaskOutput, error)
  • func (a *Activities) MoveReplicationTask(ctx context.Context, input *databasemigrationservice.MoveReplicationTaskInput) (*databasemigrationservice.MoveReplicationTaskOutput, error)
  • func (a *Activities) RebootReplicationInstance(ctx context.Context, ...) (*databasemigrationservice.RebootReplicationInstanceOutput, error)
  • func (a *Activities) RefreshSchemas(ctx context.Context, input *databasemigrationservice.RefreshSchemasInput) (*databasemigrationservice.RefreshSchemasOutput, error)
  • func (a *Activities) ReloadTables(ctx context.Context, input *databasemigrationservice.ReloadTablesInput) (*databasemigrationservice.ReloadTablesOutput, error)
  • func (a *Activities) RemoveTagsFromResource(ctx context.Context, ...) (*databasemigrationservice.RemoveTagsFromResourceOutput, error)
  • func (a *Activities) StartReplicationTask(ctx context.Context, input *databasemigrationservice.StartReplicationTaskInput) (*databasemigrationservice.StartReplicationTaskOutput, error)
  • func (a *Activities) StartReplicationTaskAssessment(ctx context.Context, ...) (*databasemigrationservice.StartReplicationTaskAssessmentOutput, error)
  • func (a *Activities) StartReplicationTaskAssessmentRun(ctx context.Context, ...) (*databasemigrationservice.StartReplicationTaskAssessmentRunOutput, error)
  • func (a *Activities) StopReplicationTask(ctx context.Context, input *databasemigrationservice.StopReplicationTaskInput) (*databasemigrationservice.StopReplicationTaskOutput, error)
  • func (a *Activities) TestConnection(ctx context.Context, input *databasemigrationservice.TestConnectionInput) (*databasemigrationservice.TestConnectionOutput, error)
  • func (a *Activities) WaitUntilEndpointDeleted(ctx context.Context, input *databasemigrationservice.DescribeEndpointsInput) error
  • func (a *Activities) WaitUntilReplicationInstanceAvailable(ctx context.Context, ...) error
  • func (a *Activities) WaitUntilReplicationInstanceDeleted(ctx context.Context, ...) error
  • func (a *Activities) WaitUntilReplicationTaskDeleted(ctx context.Context, ...) error
  • func (a *Activities) WaitUntilReplicationTaskReady(ctx context.Context, ...) error
  • func (a *Activities) WaitUntilReplicationTaskRunning(ctx context.Context, ...) error
  • func (a *Activities) WaitUntilReplicationTaskStopped(ctx context.Context, ...) error
  • func (a *Activities) WaitUntilTestConnectionSucceeds(ctx context.Context, input *databasemigrationservice.DescribeConnectionsInput) error
• type SessionFactory

Types

type Activities

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

func NewActivities

func NewActivities(sess *session.Session, config ...*aws.Config) *Activities

func NewActivitiesWithSessionFactory

func NewActivitiesWithSessionFactory(sessionFactory SessionFactory) *Activities

func (*Activities) AddTagsToResource

func (a *Activities) AddTagsToResource(ctx context.Context, input *databasemigrationservice.AddTagsToResourceInput) (*databasemigrationservice.AddTagsToResourceOutput, error)

func (*Activities) ApplyPendingMaintenanceAction

func (a *Activities) ApplyPendingMaintenanceAction(ctx context.Context, input *databasemigrationservice.ApplyPendingMaintenanceActionInput) (*databasemigrationservice.ApplyPendingMaintenanceActionOutput, error)

func (*Activities) CancelReplicationTaskAssessmentRun

func (a *Activities) CancelReplicationTaskAssessmentRun(ctx context.Context, input *databasemigrationservice.CancelReplicationTaskAssessmentRunInput) (*databasemigrationservice.CancelReplicationTaskAssessmentRunOutput, error)

func (*Activities) CreateEndpoint

func (a *Activities) CreateEndpoint(ctx context.Context, input *databasemigrationservice.CreateEndpointInput) (*databasemigrationservice.CreateEndpointOutput, error)

func (*Activities) CreateEventSubscription

func (a *Activities) CreateEventSubscription(ctx context.Context, input *databasemigrationservice.CreateEventSubscriptionInput) (*databasemigrationservice.CreateEventSubscriptionOutput, error)

func (*Activities) CreateReplicationInstance

func (a *Activities) CreateReplicationInstance(ctx context.Context, input *databasemigrationservice.CreateReplicationInstanceInput) (*databasemigrationservice.CreateReplicationInstanceOutput, error)

func (*Activities) CreateReplicationSubnetGroup

func (a *Activities) CreateReplicationSubnetGroup(ctx context.Context, input *databasemigrationservice.CreateReplicationSubnetGroupInput) (*databasemigrationservice.CreateReplicationSubnetGroupOutput, error)

func (*Activities) CreateReplicationTask

func (a *Activities) CreateReplicationTask(ctx context.Context, input *databasemigrationservice.CreateReplicationTaskInput) (*databasemigrationservice.CreateReplicationTaskOutput, error)

func (*Activities) DeleteCertificate

func (a *Activities) DeleteCertificate(ctx context.Context, input *databasemigrationservice.DeleteCertificateInput) (*databasemigrationservice.DeleteCertificateOutput, error)

func (*Activities) DeleteConnection

func (a *Activities) DeleteConnection(ctx context.Context, input *databasemigrationservice.DeleteConnectionInput) (*databasemigrationservice.DeleteConnectionOutput, error)

func (*Activities) DeleteEndpoint

func (a *Activities) DeleteEndpoint(ctx context.Context, input *databasemigrationservice.DeleteEndpointInput) (*databasemigrationservice.DeleteEndpointOutput, error)

func (*Activities) DeleteEventSubscription

func (a *Activities) DeleteEventSubscription(ctx context.Context, input *databasemigrationservice.DeleteEventSubscriptionInput) (*databasemigrationservice.DeleteEventSubscriptionOutput, error)

func (*Activities) DeleteReplicationInstance

func (a *Activities) DeleteReplicationInstance(ctx context.Context, input *databasemigrationservice.DeleteReplicationInstanceInput) (*databasemigrationservice.DeleteReplicationInstanceOutput, error)

func (*Activities) DeleteReplicationSubnetGroup

func (a *Activities) DeleteReplicationSubnetGroup(ctx context.Context, input *databasemigrationservice.DeleteReplicationSubnetGroupInput) (*databasemigrationservice.DeleteReplicationSubnetGroupOutput, error)

func (*Activities) DeleteReplicationTask

func (a *Activities) DeleteReplicationTask(ctx context.Context, input *databasemigrationservice.DeleteReplicationTaskInput) (*databasemigrationservice.DeleteReplicationTaskOutput, error)

func (*Activities) DeleteReplicationTaskAssessmentRun

func (a *Activities) DeleteReplicationTaskAssessmentRun(ctx context.Context, input *databasemigrationservice.DeleteReplicationTaskAssessmentRunInput) (*databasemigrationservice.DeleteReplicationTaskAssessmentRunOutput, error)

func (*Activities) DescribeAccountAttributes

func (a *Activities) DescribeAccountAttributes(ctx context.Context, input *databasemigrationservice.DescribeAccountAttributesInput) (*databasemigrationservice.DescribeAccountAttributesOutput, error)

func (*Activities) DescribeApplicableIndividualAssessments

func (a *Activities) DescribeApplicableIndividualAssessments(ctx context.Context, input *databasemigrationservice.DescribeApplicableIndividualAssessmentsInput) (*databasemigrationservice.DescribeApplicableIndividualAssessmentsOutput, error)

func (*Activities) DescribeCertificates

func (a *Activities) DescribeCertificates(ctx context.Context, input *databasemigrationservice.DescribeCertificatesInput) (*databasemigrationservice.DescribeCertificatesOutput, error)

func (*Activities) DescribeConnections

func (a *Activities) DescribeConnections(ctx context.Context, input *databasemigrationservice.DescribeConnectionsInput) (*databasemigrationservice.DescribeConnectionsOutput, error)

func (*Activities) DescribeEndpointTypes

func (a *Activities) DescribeEndpointTypes(ctx context.Context, input *databasemigrationservice.DescribeEndpointTypesInput) (*databasemigrationservice.DescribeEndpointTypesOutput, error)

func (*Activities) DescribeEndpoints

func (a *Activities) DescribeEndpoints(ctx context.Context, input *databasemigrationservice.DescribeEndpointsInput) (*databasemigrationservice.DescribeEndpointsOutput, error)

func (*Activities) DescribeEventCategories

func (a *Activities) DescribeEventCategories(ctx context.Context, input *databasemigrationservice.DescribeEventCategoriesInput) (*databasemigrationservice.DescribeEventCategoriesOutput, error)

func (*Activities) DescribeEventSubscriptions

func (a *Activities) DescribeEventSubscriptions(ctx context.Context, input *databasemigrationservice.DescribeEventSubscriptionsInput) (*databasemigrationservice.DescribeEventSubscriptionsOutput, error)

func (*Activities) DescribeEvents

func (a *Activities) DescribeEvents(ctx context.Context, input *databasemigrationservice.DescribeEventsInput) (*databasemigrationservice.DescribeEventsOutput, error)

func (*Activities) DescribeOrderableReplicationInstances

func (a *Activities) DescribeOrderableReplicationInstances(ctx context.Context, input *databasemigrationservice.DescribeOrderableReplicationInstancesInput) (*databasemigrationservice.DescribeOrderableReplicationInstancesOutput, error)

func (*Activities) DescribePendingMaintenanceActions

func (a *Activities) DescribePendingMaintenanceActions(ctx context.Context, input *databasemigrationservice.DescribePendingMaintenanceActionsInput) (*databasemigrationservice.DescribePendingMaintenanceActionsOutput, error)

func (*Activities) DescribeRefreshSchemasStatus

func (a *Activities) DescribeRefreshSchemasStatus(ctx context.Context, input *databasemigrationservice.DescribeRefreshSchemasStatusInput) (*databasemigrationservice.DescribeRefreshSchemasStatusOutput, error)

func (*Activities) DescribeReplicationInstanceTaskLogs

func (a *Activities) DescribeReplicationInstanceTaskLogs(ctx context.Context, input *databasemigrationservice.DescribeReplicationInstanceTaskLogsInput) (*databasemigrationservice.DescribeReplicationInstanceTaskLogsOutput, error)

func (*Activities) DescribeReplicationInstances

func (a *Activities) DescribeReplicationInstances(ctx context.Context, input *databasemigrationservice.DescribeReplicationInstancesInput) (*databasemigrationservice.DescribeReplicationInstancesOutput, error)

func (*Activities) DescribeReplicationSubnetGroups

func (a *Activities) DescribeReplicationSubnetGroups(ctx context.Context, input *databasemigrationservice.DescribeReplicationSubnetGroupsInput) (*databasemigrationservice.DescribeReplicationSubnetGroupsOutput, error)

func (*Activities) DescribeReplicationTaskAssessmentResults

func (a *Activities) DescribeReplicationTaskAssessmentResults(ctx context.Context, input *databasemigrationservice.DescribeReplicationTaskAssessmentResultsInput) (*databasemigrationservice.DescribeReplicationTaskAssessmentResultsOutput, error)

func (*Activities) DescribeReplicationTaskAssessmentRuns

func (a *Activities) DescribeReplicationTaskAssessmentRuns(ctx context.Context, input *databasemigrationservice.DescribeReplicationTaskAssessmentRunsInput) (*databasemigrationservice.DescribeReplicationTaskAssessmentRunsOutput, error)

func (*Activities) DescribeReplicationTaskIndividualAssessments

func (a *Activities) DescribeReplicationTaskIndividualAssessments(ctx context.Context, input *databasemigrationservice.DescribeReplicationTaskIndividualAssessmentsInput) (*databasemigrationservice.DescribeReplicationTaskIndividualAssessmentsOutput, error)

func (*Activities) DescribeReplicationTasks

func (a *Activities) DescribeReplicationTasks(ctx context.Context, input *databasemigrationservice.DescribeReplicationTasksInput) (*databasemigrationservice.DescribeReplicationTasksOutput, error)

func (*Activities) DescribeSchemas

func (a *Activities) DescribeSchemas(ctx context.Context, input *databasemigrationservice.DescribeSchemasInput) (*databasemigrationservice.DescribeSchemasOutput, error)

func (*Activities) DescribeTableStatistics

func (a *Activities) DescribeTableStatistics(ctx context.Context, input *databasemigrationservice.DescribeTableStatisticsInput) (*databasemigrationservice.DescribeTableStatisticsOutput, error)

func (*Activities) ImportCertificate

func (a *Activities) ImportCertificate(ctx context.Context, input *databasemigrationservice.ImportCertificateInput) (*databasemigrationservice.ImportCertificateOutput, error)

func (*Activities) ListTagsForResource

func (a *Activities) ListTagsForResource(ctx context.Context, input *databasemigrationservice.ListTagsForResourceInput) (*databasemigrationservice.ListTagsForResourceOutput, error)

func (*Activities) ModifyEndpoint

func (a *Activities) ModifyEndpoint(ctx context.Context, input *databasemigrationservice.ModifyEndpointInput) (*databasemigrationservice.ModifyEndpointOutput, error)

func (*Activities) ModifyEventSubscription

func (a *Activities) ModifyEventSubscription(ctx context.Context, input *databasemigrationservice.ModifyEventSubscriptionInput) (*databasemigrationservice.ModifyEventSubscriptionOutput, error)

func (*Activities) ModifyReplicationInstance

func (a *Activities) ModifyReplicationInstance(ctx context.Context, input *databasemigrationservice.ModifyReplicationInstanceInput) (*databasemigrationservice.ModifyReplicationInstanceOutput, error)

func (*Activities) ModifyReplicationSubnetGroup

func (a *Activities) ModifyReplicationSubnetGroup(ctx context.Context, input *databasemigrationservice.ModifyReplicationSubnetGroupInput) (*databasemigrationservice.ModifyReplicationSubnetGroupOutput, error)

func (*Activities) ModifyReplicationTask

func (a *Activities) ModifyReplicationTask(ctx context.Context, input *databasemigrationservice.ModifyReplicationTaskInput) (*databasemigrationservice.ModifyReplicationTaskOutput, error)

func (*Activities) MoveReplicationTask

func (a *Activities) MoveReplicationTask(ctx context.Context, input *databasemigrationservice.MoveReplicationTaskInput) (*databasemigrationservice.MoveReplicationTaskOutput, error)

func (*Activities) RebootReplicationInstance

func (a *Activities) RebootReplicationInstance(ctx context.Context, input *databasemigrationservice.RebootReplicationInstanceInput) (*databasemigrationservice.RebootReplicationInstanceOutput, error)

func (*Activities) RefreshSchemas

func (a *Activities) RefreshSchemas(ctx context.Context, input *databasemigrationservice.RefreshSchemasInput) (*databasemigrationservice.RefreshSchemasOutput, error)

func (*Activities) ReloadTables

func (a *Activities) ReloadTables(ctx context.Context, input *databasemigrationservice.ReloadTablesInput) (*databasemigrationservice.ReloadTablesOutput, error)

func (*Activities) RemoveTagsFromResource

func (a *Activities) RemoveTagsFromResource(ctx context.Context, input *databasemigrationservice.RemoveTagsFromResourceInput) (*databasemigrationservice.RemoveTagsFromResourceOutput, error)

func (*Activities) StartReplicationTask

func (a *Activities) StartReplicationTask(ctx context.Context, input *databasemigrationservice.StartReplicationTaskInput) (*databasemigrationservice.StartReplicationTaskOutput, error)

func (*Activities) StartReplicationTaskAssessment

func (a *Activities) StartReplicationTaskAssessment(ctx context.Context, input *databasemigrationservice.StartReplicationTaskAssessmentInput) (*databasemigrationservice.StartReplicationTaskAssessmentOutput, error)

func (*Activities) StartReplicationTaskAssessmentRun

func (a *Activities) StartReplicationTaskAssessmentRun(ctx context.Context, input *databasemigrationservice.StartReplicationTaskAssessmentRunInput) (*databasemigrationservice.StartReplicationTaskAssessmentRunOutput, error)

func (*Activities) StopReplicationTask

func (a *Activities) StopReplicationTask(ctx context.Context, input *databasemigrationservice.StopReplicationTaskInput) (*databasemigrationservice.StopReplicationTaskOutput, error)

func (*Activities) TestConnection

func (a *Activities) TestConnection(ctx context.Context, input *databasemigrationservice.TestConnectionInput) (*databasemigrationservice.TestConnectionOutput, error)

func (*Activities) WaitUntilEndpointDeleted

func (a *Activities) WaitUntilEndpointDeleted(ctx context.Context, input *databasemigrationservice.DescribeEndpointsInput) error

func (*Activities) WaitUntilReplicationInstanceAvailable

func (a *Activities) WaitUntilReplicationInstanceAvailable(ctx context.Context, input *databasemigrationservice.DescribeReplicationInstancesInput) error

func (*Activities) WaitUntilReplicationInstanceDeleted

func (a *Activities) WaitUntilReplicationInstanceDeleted(ctx context.Context, input *databasemigrationservice.DescribeReplicationInstancesInput) error

func (*Activities) WaitUntilReplicationTaskDeleted

func (a *Activities) WaitUntilReplicationTaskDeleted(ctx context.Context, input *databasemigrationservice.DescribeReplicationTasksInput) error

func (*Activities) WaitUntilReplicationTaskReady

func (a *Activities) WaitUntilReplicationTaskReady(ctx context.Context, input *databasemigrationservice.DescribeReplicationTasksInput) error

func (*Activities) WaitUntilReplicationTaskRunning

func (a *Activities) WaitUntilReplicationTaskRunning(ctx context.Context, input *databasemigrationservice.DescribeReplicationTasksInput) error

func (*Activities) WaitUntilReplicationTaskStopped

func (a *Activities) WaitUntilReplicationTaskStopped(ctx context.Context, input *databasemigrationservice.DescribeReplicationTasksInput) error

func (*Activities) WaitUntilTestConnectionSucceeds

func (a *Activities) WaitUntilTestConnectionSucceeds(ctx context.Context, input *databasemigrationservice.DescribeConnectionsInput) error

type SessionFactory

type SessionFactory interface {
	Session(ctx context.Context) (*session.Session, error)
}

SessionFactory returns an aws.Session based on the activity context.