databasemigrationservice

package

Go to main page

Versions in this module

v0

v0.24.0

Jul 22, 2020

v0.23.0

May 28, 2020

v0.22.0

Apr 27, 2020

Changes in this version

type CreateEndpointInput

+ NeptuneSettings *NeptuneSettings

type CreateReplicationTaskInput

+ TaskData *string

type Endpoint

+ NeptuneSettings *NeptuneSettings

type ModifyEndpointInput

+ NeptuneSettings *NeptuneSettings

type ModifyReplicationTaskInput

+ TaskData *string

+ type NeptuneSettings struct

+ ErrorRetryDuration *int64

+ IamAuthEnabled *bool

+ MaxFileSize *int64

+ MaxRetryCount *int64

+ S3BucketFolder *string

+ S3BucketName *string

+ ServiceAccessRoleArn *string

+ func (s *NeptuneSettings) Validate() error

+ func (s NeptuneSettings) String() string

type ReplicationTask

+ TaskData *string

type SupportedEndpointType

+ ReplicationInstanceEngineMinimumVersion *string

v0.21.0

Apr 22, 2020

v0.20.0

Mar 17, 2020

Changes in this version

type CreateEndpointInput

+ KafkaSettings *KafkaSettings

type Endpoint

+ KafkaSettings *KafkaSettings

+ type KafkaSettings struct

+ Broker *string

+ Topic *string

+ func (s KafkaSettings) String() string

type KinesisSettings

+ IncludeControlDetails *bool

+ IncludePartitionValue *bool

+ IncludeTableAlterOperations *bool

+ IncludeTransactionDetails *bool

+ PartitionIncludeSchemaTable *bool

type MessageFormatValue

+ const MessageFormatValueJsonUnformatted

type ModifyEndpointInput

+ KafkaSettings *KafkaSettings

type S3Settings

+ CdcInsertsAndUpdates *bool

type TableStatistics

+ FullLoadEndTime *time.Time

+ FullLoadReloaded *bool

+ FullLoadStartTime *time.Time

v0.19.0

Jan 30, 2020

v0.18.0

Dec 12, 2019

v0.17.0

Nov 21, 2019

v0.16.0

Nov 13, 2019

Changes in this version

type ReplicationTaskStats

+ FreshStartDate *time.Time

+ FullLoadFinishDate *time.Time

+ FullLoadStartDate *time.Time

+ StartDate *time.Time

+ StopDate *time.Time

v0.15.0

Oct 18, 2019

v0.14.0

Oct 8, 2019

v0.13.0

Oct 2, 2019

Changes in this version

type Client

+ func (c *Client) DeleteConnectionRequest(input *DeleteConnectionInput) DeleteConnectionRequest

+ type DeleteConnectionInput struct

+ EndpointArn *string

+ ReplicationInstanceArn *string

+ func (s *DeleteConnectionInput) Validate() error

+ func (s DeleteConnectionInput) String() string

+ type DeleteConnectionOutput struct

+ Connection *Connection

+ func (s DeleteConnectionOutput) String() string

+ type DeleteConnectionRequest struct

+ Copy func(*DeleteConnectionInput) DeleteConnectionRequest

+ Input *DeleteConnectionInput

+ func (r DeleteConnectionRequest) Send(ctx context.Context) (*DeleteConnectionResponse, error)

+ type DeleteConnectionResponse struct

+ func (r *DeleteConnectionResponse) SDKResponseMetdata() *aws.Response

type S3Settings

+ ParquetTimestampInMillisecond *bool

v0.12.0

Sep 17, 2019

v0.11.0

Aug 23, 2019

v0.10.0

Jul 25, 2019

Changes in this version

type DescribeAccountAttributesOutput

+ UniqueAccountIdentifier *string

type OrderableReplicationInstance

+ ReleaseStatus ReleaseStatusValues

+ type ReleaseStatusValues string

+ const ReleaseStatusValuesBeta

+ func (enum ReleaseStatusValues) MarshalValue() (string, error)

+ func (enum ReleaseStatusValues) MarshalValueBuf(b []byte) ([]byte, error)

type S3Settings

+ IncludeOpForFullLoad *bool

+ TimestampColumnName *string

v0.9.0

May 28, 2019

Changes in this version

+ const ServiceID

+ type AddTagsToResourceResponse struct

+ func (r *AddTagsToResourceResponse) SDKResponseMetdata() *aws.Response

+ type ApplyPendingMaintenanceActionResponse struct

+ func (r *ApplyPendingMaintenanceActionResponse) SDKResponseMetdata() *aws.Response

+ type Client struct

+ func (c *Client) AddTagsToResourceRequest(input *AddTagsToResourceInput) AddTagsToResourceRequest

+ func (c *Client) ApplyPendingMaintenanceActionRequest(input *ApplyPendingMaintenanceActionInput) ApplyPendingMaintenanceActionRequest

+ func (c *Client) CreateEndpointRequest(input *CreateEndpointInput) CreateEndpointRequest

+ func (c *Client) CreateEventSubscriptionRequest(input *CreateEventSubscriptionInput) CreateEventSubscriptionRequest

+ func (c *Client) CreateReplicationInstanceRequest(input *CreateReplicationInstanceInput) CreateReplicationInstanceRequest

+ func (c *Client) CreateReplicationSubnetGroupRequest(input *CreateReplicationSubnetGroupInput) CreateReplicationSubnetGroupRequest

+ func (c *Client) CreateReplicationTaskRequest(input *CreateReplicationTaskInput) CreateReplicationTaskRequest

+ func (c *Client) DeleteCertificateRequest(input *DeleteCertificateInput) DeleteCertificateRequest

+ func (c *Client) DeleteEndpointRequest(input *DeleteEndpointInput) DeleteEndpointRequest

+ func (c *Client) DeleteEventSubscriptionRequest(input *DeleteEventSubscriptionInput) DeleteEventSubscriptionRequest

+ func (c *Client) DeleteReplicationInstanceRequest(input *DeleteReplicationInstanceInput) DeleteReplicationInstanceRequest

+ func (c *Client) DeleteReplicationSubnetGroupRequest(input *DeleteReplicationSubnetGroupInput) DeleteReplicationSubnetGroupRequest

+ func (c *Client) DeleteReplicationTaskRequest(input *DeleteReplicationTaskInput) DeleteReplicationTaskRequest

+ func (c *Client) DescribeAccountAttributesRequest(input *DescribeAccountAttributesInput) DescribeAccountAttributesRequest

+ func (c *Client) DescribeCertificatesRequest(input *DescribeCertificatesInput) DescribeCertificatesRequest

+ func (c *Client) DescribeConnectionsRequest(input *DescribeConnectionsInput) DescribeConnectionsRequest

+ func (c *Client) DescribeEndpointTypesRequest(input *DescribeEndpointTypesInput) DescribeEndpointTypesRequest

+ func (c *Client) DescribeEndpointsRequest(input *DescribeEndpointsInput) DescribeEndpointsRequest

+ func (c *Client) DescribeEventCategoriesRequest(input *DescribeEventCategoriesInput) DescribeEventCategoriesRequest

+ func (c *Client) DescribeEventSubscriptionsRequest(input *DescribeEventSubscriptionsInput) DescribeEventSubscriptionsRequest

+ func (c *Client) DescribeEventsRequest(input *DescribeEventsInput) DescribeEventsRequest

+ func (c *Client) DescribeOrderableReplicationInstancesRequest(input *DescribeOrderableReplicationInstancesInput) DescribeOrderableReplicationInstancesRequest

+ func (c *Client) DescribePendingMaintenanceActionsRequest(input *DescribePendingMaintenanceActionsInput) DescribePendingMaintenanceActionsRequest

+ func (c *Client) DescribeRefreshSchemasStatusRequest(input *DescribeRefreshSchemasStatusInput) DescribeRefreshSchemasStatusRequest

+ func (c *Client) DescribeReplicationInstanceTaskLogsRequest(input *DescribeReplicationInstanceTaskLogsInput) DescribeReplicationInstanceTaskLogsRequest

+ func (c *Client) DescribeReplicationInstancesRequest(input *DescribeReplicationInstancesInput) DescribeReplicationInstancesRequest

+ func (c *Client) DescribeReplicationSubnetGroupsRequest(input *DescribeReplicationSubnetGroupsInput) DescribeReplicationSubnetGroupsRequest

+ func (c *Client) DescribeReplicationTaskAssessmentResultsRequest(input *DescribeReplicationTaskAssessmentResultsInput) DescribeReplicationTaskAssessmentResultsRequest

+ func (c *Client) DescribeReplicationTasksRequest(input *DescribeReplicationTasksInput) DescribeReplicationTasksRequest

+ func (c *Client) DescribeSchemasRequest(input *DescribeSchemasInput) DescribeSchemasRequest

+ func (c *Client) DescribeTableStatisticsRequest(input *DescribeTableStatisticsInput) DescribeTableStatisticsRequest

+ func (c *Client) ImportCertificateRequest(input *ImportCertificateInput) ImportCertificateRequest

+ func (c *Client) ListTagsForResourceRequest(input *ListTagsForResourceInput) ListTagsForResourceRequest

+ func (c *Client) ModifyEndpointRequest(input *ModifyEndpointInput) ModifyEndpointRequest

+ func (c *Client) ModifyEventSubscriptionRequest(input *ModifyEventSubscriptionInput) ModifyEventSubscriptionRequest

+ func (c *Client) ModifyReplicationInstanceRequest(input *ModifyReplicationInstanceInput) ModifyReplicationInstanceRequest

+ func (c *Client) ModifyReplicationSubnetGroupRequest(input *ModifyReplicationSubnetGroupInput) ModifyReplicationSubnetGroupRequest

+ func (c *Client) ModifyReplicationTaskRequest(input *ModifyReplicationTaskInput) ModifyReplicationTaskRequest

+ func (c *Client) RebootReplicationInstanceRequest(input *RebootReplicationInstanceInput) RebootReplicationInstanceRequest

+ func (c *Client) RefreshSchemasRequest(input *RefreshSchemasInput) RefreshSchemasRequest

+ func (c *Client) ReloadTablesRequest(input *ReloadTablesInput) ReloadTablesRequest

+ func (c *Client) RemoveTagsFromResourceRequest(input *RemoveTagsFromResourceInput) RemoveTagsFromResourceRequest

+ func (c *Client) StartReplicationTaskAssessmentRequest(input *StartReplicationTaskAssessmentInput) StartReplicationTaskAssessmentRequest

+ func (c *Client) StartReplicationTaskRequest(input *StartReplicationTaskInput) StartReplicationTaskRequest

+ func (c *Client) StopReplicationTaskRequest(input *StopReplicationTaskInput) StopReplicationTaskRequest

+ func (c *Client) TestConnectionRequest(input *TestConnectionInput) TestConnectionRequest

+ func (c *Client) WaitUntilEndpointDeleted(ctx context.Context, input *DescribeEndpointsInput, opts ...aws.WaiterOption) error

+ func (c *Client) WaitUntilReplicationInstanceAvailable(ctx context.Context, input *DescribeReplicationInstancesInput, ...) error

+ func (c *Client) WaitUntilReplicationInstanceDeleted(ctx context.Context, input *DescribeReplicationInstancesInput, ...) error

+ func (c *Client) WaitUntilReplicationTaskDeleted(ctx context.Context, input *DescribeReplicationTasksInput, ...) error

+ func (c *Client) WaitUntilReplicationTaskReady(ctx context.Context, input *DescribeReplicationTasksInput, ...) error

+ func (c *Client) WaitUntilReplicationTaskRunning(ctx context.Context, input *DescribeReplicationTasksInput, ...) error

+ func (c *Client) WaitUntilReplicationTaskStopped(ctx context.Context, input *DescribeReplicationTasksInput, ...) error

+ func (c *Client) WaitUntilTestConnectionSucceeds(ctx context.Context, input *DescribeConnectionsInput, opts ...aws.WaiterOption) error

+ type CreateEndpointResponse struct

+ func (r *CreateEndpointResponse) SDKResponseMetdata() *aws.Response

+ type CreateEventSubscriptionResponse struct

+ func (r *CreateEventSubscriptionResponse) SDKResponseMetdata() *aws.Response

+ type CreateReplicationInstanceResponse struct

+ func (r *CreateReplicationInstanceResponse) SDKResponseMetdata() *aws.Response

+ type CreateReplicationSubnetGroupResponse struct

+ func (r *CreateReplicationSubnetGroupResponse) SDKResponseMetdata() *aws.Response

+ type CreateReplicationTaskResponse struct

+ func (r *CreateReplicationTaskResponse) SDKResponseMetdata() *aws.Response

+ type DeleteCertificateResponse struct

+ func (r *DeleteCertificateResponse) SDKResponseMetdata() *aws.Response

+ type DeleteEndpointResponse struct

+ func (r *DeleteEndpointResponse) SDKResponseMetdata() *aws.Response

+ type DeleteEventSubscriptionResponse struct

+ func (r *DeleteEventSubscriptionResponse) SDKResponseMetdata() *aws.Response

+ type DeleteReplicationInstanceResponse struct

+ func (r *DeleteReplicationInstanceResponse) SDKResponseMetdata() *aws.Response

+ type DeleteReplicationSubnetGroupResponse struct

+ func (r *DeleteReplicationSubnetGroupResponse) SDKResponseMetdata() *aws.Response

+ type DeleteReplicationTaskResponse struct

+ func (r *DeleteReplicationTaskResponse) SDKResponseMetdata() *aws.Response

+ type DescribeAccountAttributesResponse struct

+ func (r *DescribeAccountAttributesResponse) SDKResponseMetdata() *aws.Response

+ type DescribeCertificatesPaginator struct

+ func NewDescribeCertificatesPaginator(req DescribeCertificatesRequest) DescribeCertificatesPaginator

+ func (p *DescribeCertificatesPaginator) CurrentPage() *DescribeCertificatesOutput

+ type DescribeCertificatesResponse struct

+ func (r *DescribeCertificatesResponse) SDKResponseMetdata() *aws.Response

+ type DescribeConnectionsPaginator struct

+ func NewDescribeConnectionsPaginator(req DescribeConnectionsRequest) DescribeConnectionsPaginator

+ func (p *DescribeConnectionsPaginator) CurrentPage() *DescribeConnectionsOutput

+ type DescribeConnectionsResponse struct

+ func (r *DescribeConnectionsResponse) SDKResponseMetdata() *aws.Response

+ type DescribeEndpointTypesPaginator struct

+ func NewDescribeEndpointTypesPaginator(req DescribeEndpointTypesRequest) DescribeEndpointTypesPaginator

+ func (p *DescribeEndpointTypesPaginator) CurrentPage() *DescribeEndpointTypesOutput

+ type DescribeEndpointTypesResponse struct

+ func (r *DescribeEndpointTypesResponse) SDKResponseMetdata() *aws.Response

+ type DescribeEndpointsPaginator struct

+ func NewDescribeEndpointsPaginator(req DescribeEndpointsRequest) DescribeEndpointsPaginator

+ func (p *DescribeEndpointsPaginator) CurrentPage() *DescribeEndpointsOutput

+ type DescribeEndpointsResponse struct

+ func (r *DescribeEndpointsResponse) SDKResponseMetdata() *aws.Response

+ type DescribeEventCategoriesResponse struct

+ func (r *DescribeEventCategoriesResponse) SDKResponseMetdata() *aws.Response

+ type DescribeEventSubscriptionsPaginator struct

+ func NewDescribeEventSubscriptionsPaginator(req DescribeEventSubscriptionsRequest) DescribeEventSubscriptionsPaginator

+ func (p *DescribeEventSubscriptionsPaginator) CurrentPage() *DescribeEventSubscriptionsOutput

+ type DescribeEventSubscriptionsResponse struct

+ func (r *DescribeEventSubscriptionsResponse) SDKResponseMetdata() *aws.Response

+ type DescribeEventsPaginator struct

+ func NewDescribeEventsPaginator(req DescribeEventsRequest) DescribeEventsPaginator

+ func (p *DescribeEventsPaginator) CurrentPage() *DescribeEventsOutput

+ type DescribeEventsResponse struct

+ func (r *DescribeEventsResponse) SDKResponseMetdata() *aws.Response

+ type DescribeOrderableReplicationInstancesPaginator struct

+ func NewDescribeOrderableReplicationInstancesPaginator(req DescribeOrderableReplicationInstancesRequest) DescribeOrderableReplicationInstancesPaginator

+ func (p *DescribeOrderableReplicationInstancesPaginator) CurrentPage() *DescribeOrderableReplicationInstancesOutput

+ type DescribeOrderableReplicationInstancesResponse struct

+ func (r *DescribeOrderableReplicationInstancesResponse) SDKResponseMetdata() *aws.Response

+ type DescribePendingMaintenanceActionsPaginator struct

+ func NewDescribePendingMaintenanceActionsPaginator(req DescribePendingMaintenanceActionsRequest) DescribePendingMaintenanceActionsPaginator

+ func (p *DescribePendingMaintenanceActionsPaginator) CurrentPage() *DescribePendingMaintenanceActionsOutput

+ type DescribePendingMaintenanceActionsResponse struct

+ func (r *DescribePendingMaintenanceActionsResponse) SDKResponseMetdata() *aws.Response

+ type DescribeRefreshSchemasStatusResponse struct

+ func (r *DescribeRefreshSchemasStatusResponse) SDKResponseMetdata() *aws.Response

+ type DescribeReplicationInstanceTaskLogsPaginator struct

+ func NewDescribeReplicationInstanceTaskLogsPaginator(req DescribeReplicationInstanceTaskLogsRequest) DescribeReplicationInstanceTaskLogsPaginator

+ func (p *DescribeReplicationInstanceTaskLogsPaginator) CurrentPage() *DescribeReplicationInstanceTaskLogsOutput

+ type DescribeReplicationInstanceTaskLogsResponse struct

+ func (r *DescribeReplicationInstanceTaskLogsResponse) SDKResponseMetdata() *aws.Response

+ type DescribeReplicationInstancesPaginator struct

+ func NewDescribeReplicationInstancesPaginator(req DescribeReplicationInstancesRequest) DescribeReplicationInstancesPaginator

+ func (p *DescribeReplicationInstancesPaginator) CurrentPage() *DescribeReplicationInstancesOutput

+ type DescribeReplicationInstancesResponse struct

+ func (r *DescribeReplicationInstancesResponse) SDKResponseMetdata() *aws.Response

+ type DescribeReplicationSubnetGroupsPaginator struct

+ func NewDescribeReplicationSubnetGroupsPaginator(req DescribeReplicationSubnetGroupsRequest) DescribeReplicationSubnetGroupsPaginator

+ func (p *DescribeReplicationSubnetGroupsPaginator) CurrentPage() *DescribeReplicationSubnetGroupsOutput

+ type DescribeReplicationSubnetGroupsResponse struct

+ func (r *DescribeReplicationSubnetGroupsResponse) SDKResponseMetdata() *aws.Response

+ type DescribeReplicationTaskAssessmentResultsPaginator struct

+ func NewDescribeReplicationTaskAssessmentResultsPaginator(req DescribeReplicationTaskAssessmentResultsRequest) DescribeReplicationTaskAssessmentResultsPaginator

+ func (p *DescribeReplicationTaskAssessmentResultsPaginator) CurrentPage() *DescribeReplicationTaskAssessmentResultsOutput

+ type DescribeReplicationTaskAssessmentResultsResponse struct

+ func (r *DescribeReplicationTaskAssessmentResultsResponse) SDKResponseMetdata() *aws.Response

+ type DescribeReplicationTasksPaginator struct

+ func NewDescribeReplicationTasksPaginator(req DescribeReplicationTasksRequest) DescribeReplicationTasksPaginator

+ func (p *DescribeReplicationTasksPaginator) CurrentPage() *DescribeReplicationTasksOutput

+ type DescribeReplicationTasksResponse struct

+ func (r *DescribeReplicationTasksResponse) SDKResponseMetdata() *aws.Response

+ type DescribeSchemasPaginator struct

+ func NewDescribeSchemasPaginator(req DescribeSchemasRequest) DescribeSchemasPaginator

+ func (p *DescribeSchemasPaginator) CurrentPage() *DescribeSchemasOutput

+ type DescribeSchemasResponse struct

+ func (r *DescribeSchemasResponse) SDKResponseMetdata() *aws.Response

+ type DescribeTableStatisticsPaginator struct

+ func NewDescribeTableStatisticsPaginator(req DescribeTableStatisticsRequest) DescribeTableStatisticsPaginator

+ func (p *DescribeTableStatisticsPaginator) CurrentPage() *DescribeTableStatisticsOutput

+ type DescribeTableStatisticsResponse struct

+ func (r *DescribeTableStatisticsResponse) SDKResponseMetdata() *aws.Response

+ type ImportCertificateResponse struct

+ func (r *ImportCertificateResponse) SDKResponseMetdata() *aws.Response

+ type ListTagsForResourceResponse struct

+ func (r *ListTagsForResourceResponse) SDKResponseMetdata() *aws.Response

+ type ModifyEndpointResponse struct

+ func (r *ModifyEndpointResponse) SDKResponseMetdata() *aws.Response

+ type ModifyEventSubscriptionResponse struct

+ func (r *ModifyEventSubscriptionResponse) SDKResponseMetdata() *aws.Response

+ type ModifyReplicationInstanceResponse struct

+ func (r *ModifyReplicationInstanceResponse) SDKResponseMetdata() *aws.Response

+ type ModifyReplicationSubnetGroupResponse struct

+ func (r *ModifyReplicationSubnetGroupResponse) SDKResponseMetdata() *aws.Response

+ type ModifyReplicationTaskResponse struct

+ func (r *ModifyReplicationTaskResponse) SDKResponseMetdata() *aws.Response

+ type RebootReplicationInstanceResponse struct

+ func (r *RebootReplicationInstanceResponse) SDKResponseMetdata() *aws.Response

+ type RefreshSchemasResponse struct

+ func (r *RefreshSchemasResponse) SDKResponseMetdata() *aws.Response

+ type ReloadTablesResponse struct

+ func (r *ReloadTablesResponse) SDKResponseMetdata() *aws.Response

+ type RemoveTagsFromResourceResponse struct

+ func (r *RemoveTagsFromResourceResponse) SDKResponseMetdata() *aws.Response

+ type StartReplicationTaskAssessmentResponse struct

+ func (r *StartReplicationTaskAssessmentResponse) SDKResponseMetdata() *aws.Response

+ type StartReplicationTaskResponse struct

+ func (r *StartReplicationTaskResponse) SDKResponseMetdata() *aws.Response

+ type StopReplicationTaskResponse struct

+ func (r *StopReplicationTaskResponse) SDKResponseMetdata() *aws.Response

+ type TestConnectionResponse struct

+ func (r *TestConnectionResponse) SDKResponseMetdata() *aws.Response

v0.8.0

Apr 25, 2019

Changes in this version

+ const ErrCodeKMSAccessDeniedFault

+ const ErrCodeKMSDisabledFault

+ const ErrCodeKMSInvalidStateFault

+ const ErrCodeKMSNotFoundFault

+ const ErrCodeKMSThrottlingFault

+ type ApplyPendingMaintenanceActionInput struct

+ ApplyAction *string

+ OptInType *string

+ ReplicationInstanceArn *string

+ func (s *ApplyPendingMaintenanceActionInput) Validate() error

+ func (s ApplyPendingMaintenanceActionInput) GoString() string

+ func (s ApplyPendingMaintenanceActionInput) String() string

+ type ApplyPendingMaintenanceActionOutput struct

+ ResourcePendingMaintenanceActions *ResourcePendingMaintenanceActions

+ func (s ApplyPendingMaintenanceActionOutput) GoString() string

+ func (s ApplyPendingMaintenanceActionOutput) SDKResponseMetadata() aws.Response

+ func (s ApplyPendingMaintenanceActionOutput) String() string

+ type ApplyPendingMaintenanceActionRequest struct

+ Copy func(*ApplyPendingMaintenanceActionInput) ApplyPendingMaintenanceActionRequest

+ Input *ApplyPendingMaintenanceActionInput

+ func (r ApplyPendingMaintenanceActionRequest) Send(ctx context.Context) (*ApplyPendingMaintenanceActionOutput, error)

type CreateEndpointInput

+ RedshiftSettings *RedshiftSettings

+ type DataFormatValue string

+ const DataFormatValueCsv

+ const DataFormatValueParquet

+ func (enum DataFormatValue) MarshalValue() (string, error)

+ func (enum DataFormatValue) MarshalValueBuf(b []byte) ([]byte, error)

type DatabaseMigrationService

+ func (c *DatabaseMigrationService) ApplyPendingMaintenanceActionRequest(input *ApplyPendingMaintenanceActionInput) ApplyPendingMaintenanceActionRequest

+ func (c *DatabaseMigrationService) DescribePendingMaintenanceActionsRequest(input *DescribePendingMaintenanceActionsInput) DescribePendingMaintenanceActionsRequest

+ type DescribePendingMaintenanceActionsInput struct

+ Filters []Filter

+ Marker *string

+ MaxRecords *int64

+ ReplicationInstanceArn *string

+ func (s *DescribePendingMaintenanceActionsInput) Validate() error

+ func (s DescribePendingMaintenanceActionsInput) GoString() string

+ func (s DescribePendingMaintenanceActionsInput) String() string

+ type DescribePendingMaintenanceActionsOutput struct

+ Marker *string

+ PendingMaintenanceActions []ResourcePendingMaintenanceActions

+ func (s DescribePendingMaintenanceActionsOutput) GoString() string

+ func (s DescribePendingMaintenanceActionsOutput) SDKResponseMetadata() aws.Response

+ func (s DescribePendingMaintenanceActionsOutput) String() string

+ type DescribePendingMaintenanceActionsPager struct

+ func (p *DescribePendingMaintenanceActionsPager) CurrentPage() *DescribePendingMaintenanceActionsOutput

+ type DescribePendingMaintenanceActionsRequest struct

+ Copy func(*DescribePendingMaintenanceActionsInput) DescribePendingMaintenanceActionsRequest

+ Input *DescribePendingMaintenanceActionsInput

+ func (p *DescribePendingMaintenanceActionsRequest) Paginate(opts ...aws.Option) DescribePendingMaintenanceActionsPager

+ func (r DescribePendingMaintenanceActionsRequest) Send(ctx context.Context) (*DescribePendingMaintenanceActionsOutput, error)

type DescribeReplicationTasksInput

+ WithoutSettings *bool

+ type EncodingTypeValue string

+ const EncodingTypeValuePlain

+ const EncodingTypeValuePlainDictionary

+ const EncodingTypeValueRleDictionary

+ func (enum EncodingTypeValue) MarshalValue() (string, error)

+ func (enum EncodingTypeValue) MarshalValueBuf(b []byte) ([]byte, error)

+ type EncryptionModeValue string

+ const EncryptionModeValueSseKms

+ const EncryptionModeValueSseS3

+ func (enum EncryptionModeValue) MarshalValue() (string, error)

+ func (enum EncryptionModeValue) MarshalValueBuf(b []byte) ([]byte, error)

type Endpoint

+ RedshiftSettings *RedshiftSettings

type ModifyEndpointInput

+ RedshiftSettings *RedshiftSettings

type OrderableReplicationInstance

+ AvailabilityZones []string

+ type ParquetVersionValue string

+ const ParquetVersionValueParquet10

+ const ParquetVersionValueParquet20

+ func (enum ParquetVersionValue) MarshalValue() (string, error)

+ func (enum ParquetVersionValue) MarshalValueBuf(b []byte) ([]byte, error)

+ type PendingMaintenanceAction struct

+ Action *string

+ AutoAppliedAfterDate *time.Time

+ CurrentApplyDate *time.Time

+ Description *string

+ ForcedApplyDate *time.Time

+ OptInStatus *string

+ func (s PendingMaintenanceAction) GoString() string

+ func (s PendingMaintenanceAction) String() string

+ type RedshiftSettings struct

+ AcceptAnyDate *bool

+ AfterConnectScript *string

+ BucketFolder *string

+ BucketName *string

+ ConnectionTimeout *int64

+ DatabaseName *string

+ DateFormat *string

+ EmptyAsNull *bool

+ EncryptionMode EncryptionModeValue

+ FileTransferUploadStreams *int64

+ LoadTimeout *int64

+ MaxFileSize *int64

+ Password *string

+ Port *int64

+ RemoveQuotes *bool

+ ReplaceChars *string

+ ReplaceInvalidChars *string

+ ServerName *string

+ ServerSideEncryptionKmsKeyId *string

+ ServiceAccessRoleArn *string

+ TimeFormat *string

+ TrimBlanks *bool

+ TruncateColumns *bool

+ Username *string

+ WriteBufferSize *int64

+ func (s RedshiftSettings) GoString() string

+ func (s RedshiftSettings) String() string

+ type ResourcePendingMaintenanceActions struct

+ PendingMaintenanceActionDetails []PendingMaintenanceAction

+ ResourceIdentifier *string

+ func (s ResourcePendingMaintenanceActions) GoString() string

+ func (s ResourcePendingMaintenanceActions) String() string

type S3Settings

+ CdcInsertsOnly *bool

+ DataFormat DataFormatValue

+ DataPageSize *int64

+ DictPageSizeLimit *int64

+ EnableStatistics *bool

+ EncodingType EncodingTypeValue

+ EncryptionMode EncryptionModeValue

+ ParquetVersion ParquetVersionValue

+ RowGroupLength *int64

+ ServerSideEncryptionKmsKeyId *string

v0.7.0

Jan 3, 2019

v0.6.0

Dec 3, 2018

Changes in this version

type CreateEndpointInput

+ ElasticsearchSettings *ElasticsearchSettings

+ KinesisSettings *KinesisSettings

type CreateReplicationInstanceInput

+ DnsNameServers *string

type DatabaseMigrationService

+ func (c *DatabaseMigrationService) WaitUntilEndpointDeleted(input *DescribeEndpointsInput) error

+ func (c *DatabaseMigrationService) WaitUntilEndpointDeletedWithContext(ctx aws.Context, input *DescribeEndpointsInput, opts ...aws.WaiterOption) error

+ func (c *DatabaseMigrationService) WaitUntilReplicationInstanceAvailable(input *DescribeReplicationInstancesInput) error

+ func (c *DatabaseMigrationService) WaitUntilReplicationInstanceAvailableWithContext(ctx aws.Context, input *DescribeReplicationInstancesInput, ...) error

+ func (c *DatabaseMigrationService) WaitUntilReplicationInstanceDeleted(input *DescribeReplicationInstancesInput) error

+ func (c *DatabaseMigrationService) WaitUntilReplicationInstanceDeletedWithContext(ctx aws.Context, input *DescribeReplicationInstancesInput, ...) error

+ func (c *DatabaseMigrationService) WaitUntilReplicationTaskDeleted(input *DescribeReplicationTasksInput) error

+ func (c *DatabaseMigrationService) WaitUntilReplicationTaskDeletedWithContext(ctx aws.Context, input *DescribeReplicationTasksInput, ...) error

+ func (c *DatabaseMigrationService) WaitUntilReplicationTaskReady(input *DescribeReplicationTasksInput) error

+ func (c *DatabaseMigrationService) WaitUntilReplicationTaskReadyWithContext(ctx aws.Context, input *DescribeReplicationTasksInput, ...) error

+ func (c *DatabaseMigrationService) WaitUntilReplicationTaskRunning(input *DescribeReplicationTasksInput) error

+ func (c *DatabaseMigrationService) WaitUntilReplicationTaskRunningWithContext(ctx aws.Context, input *DescribeReplicationTasksInput, ...) error

+ func (c *DatabaseMigrationService) WaitUntilReplicationTaskStopped(input *DescribeReplicationTasksInput) error

+ func (c *DatabaseMigrationService) WaitUntilReplicationTaskStoppedWithContext(ctx aws.Context, input *DescribeReplicationTasksInput, ...) error

+ func (c *DatabaseMigrationService) WaitUntilTestConnectionSucceeds(input *TestConnectionInput) error

+ func (c *DatabaseMigrationService) WaitUntilTestConnectionSucceedsWithContext(ctx aws.Context, input *TestConnectionInput, opts ...aws.WaiterOption) error

+ type ElasticsearchSettings struct

+ EndpointUri *string

+ ErrorRetryDuration *int64

+ FullLoadErrorPercentage *int64

+ ServiceAccessRoleArn *string

+ func (s *ElasticsearchSettings) Validate() error

+ func (s ElasticsearchSettings) GoString() string

+ func (s ElasticsearchSettings) String() string

type Endpoint

+ ElasticsearchSettings *ElasticsearchSettings

+ KinesisSettings *KinesisSettings

+ type KinesisSettings struct

+ MessageFormat MessageFormatValue

+ ServiceAccessRoleArn *string

+ StreamArn *string

+ func (s KinesisSettings) GoString() string

+ func (s KinesisSettings) String() string

+ type MessageFormatValue string

+ const MessageFormatValueJson

+ func (enum MessageFormatValue) MarshalValue() (string, error)

+ func (enum MessageFormatValue) MarshalValueBuf(b []byte) ([]byte, error)

type ModifyEndpointInput

+ ElasticsearchSettings *ElasticsearchSettings

+ KinesisSettings *KinesisSettings

type ReplicationInstance

+ DnsNameServers *string

v0.5.0

Sep 27, 2018

Changes in this version

type CreateEndpointInput

+ DmsTransferSettings *DmsTransferSettings

+ type DmsTransferSettings struct

+ BucketName *string

+ ServiceAccessRoleArn *string

+ func (s DmsTransferSettings) GoString() string

+ func (s DmsTransferSettings) String() string

type Endpoint

+ DmsTransferSettings *DmsTransferSettings

type ModifyEndpointInput

+ DmsTransferSettings *DmsTransferSettings

+ type ReloadOptionValue string

+ const ReloadOptionValueDataReload

+ const ReloadOptionValueValidateOnly

+ func (enum ReloadOptionValue) MarshalValue() (string, error)

+ func (enum ReloadOptionValue) MarshalValueBuf(b []byte) ([]byte, error)

type ReloadTablesInput

+ ReloadOption ReloadOptionValue

type TableStatistics

+ ValidationStateDetails *string

v0.4.0

May 26, 2018

Changes in this version

type CreateEndpointInput

+ ExternalTableDefinition *string

+ ServiceAccessRoleArn *string

type CreateReplicationTaskInput

+ CdcStartPosition *string

+ CdcStopPosition *string

type Endpoint

+ EngineDisplayName *string

+ ExternalTableDefinition *string

+ ServiceAccessRoleArn *string

type ModifyEndpointInput

+ ExternalTableDefinition *string

+ ServiceAccessRoleArn *string

type ModifyReplicationTaskInput

+ CdcStartPosition *string

+ CdcStopPosition *string

type MongoDbSettings

+ KmsKeyId *string

type ReplicationInstance

+ FreeUntil *time.Time

type ReplicationTask

+ CdcStartPosition *string

+ CdcStopPosition *string

+ RecoveryCheckpoint *string

type StartReplicationTaskInput

+ CdcStartPosition *string

+ CdcStopPosition *string

type SupportedEndpointType

+ EngineDisplayName *string

v0.3.0

Mar 8, 2018

Changes in this version

type AddTagsToResourceRequest

+ Copy func(*AddTagsToResourceInput) AddTagsToResourceRequest

type AuthMechanismValue

+ func (enum AuthMechanismValue) MarshalValue() (string, error)

+ func (enum AuthMechanismValue) MarshalValueBuf(b []byte) ([]byte, error)

type AuthTypeValue

+ func (enum AuthTypeValue) MarshalValue() (string, error)

+ func (enum AuthTypeValue) MarshalValueBuf(b []byte) ([]byte, error)

type CompressionTypeValue

+ func (enum CompressionTypeValue) MarshalValue() (string, error)

+ func (enum CompressionTypeValue) MarshalValueBuf(b []byte) ([]byte, error)

type CreateEndpointRequest

+ Copy func(*CreateEndpointInput) CreateEndpointRequest

type CreateEventSubscriptionRequest

+ Copy func(*CreateEventSubscriptionInput) CreateEventSubscriptionRequest

type CreateReplicationInstanceRequest

+ Copy func(*CreateReplicationInstanceInput) CreateReplicationInstanceRequest

type CreateReplicationSubnetGroupRequest

+ Copy func(*CreateReplicationSubnetGroupInput) CreateReplicationSubnetGroupRequest

type CreateReplicationTaskRequest

+ Copy func(*CreateReplicationTaskInput) CreateReplicationTaskRequest

type DatabaseMigrationService

+ func (c *DatabaseMigrationService) DescribeReplicationInstanceTaskLogsRequest(input *DescribeReplicationInstanceTaskLogsInput) DescribeReplicationInstanceTaskLogsRequest

+ func (c *DatabaseMigrationService) RebootReplicationInstanceRequest(input *RebootReplicationInstanceInput) RebootReplicationInstanceRequest

type DeleteCertificateRequest

+ Copy func(*DeleteCertificateInput) DeleteCertificateRequest

type DeleteEndpointRequest

+ Copy func(*DeleteEndpointInput) DeleteEndpointRequest

type DeleteEventSubscriptionRequest

+ Copy func(*DeleteEventSubscriptionInput) DeleteEventSubscriptionRequest

type DeleteReplicationInstanceRequest

+ Copy func(*DeleteReplicationInstanceInput) DeleteReplicationInstanceRequest

type DeleteReplicationSubnetGroupRequest

+ Copy func(*DeleteReplicationSubnetGroupInput) DeleteReplicationSubnetGroupRequest

type DeleteReplicationTaskRequest

+ Copy func(*DeleteReplicationTaskInput) DeleteReplicationTaskRequest

type DescribeAccountAttributesRequest

+ Copy func(*DescribeAccountAttributesInput) DescribeAccountAttributesRequest

+ type DescribeCertificatesPager struct

+ func (p *DescribeCertificatesPager) CurrentPage() *DescribeCertificatesOutput

type DescribeCertificatesRequest

+ Copy func(*DescribeCertificatesInput) DescribeCertificatesRequest

+ func (p *DescribeCertificatesRequest) Paginate(opts ...aws.Option) DescribeCertificatesPager

+ type DescribeConnectionsPager struct

+ func (p *DescribeConnectionsPager) CurrentPage() *DescribeConnectionsOutput

type DescribeConnectionsRequest

+ Copy func(*DescribeConnectionsInput) DescribeConnectionsRequest

+ func (p *DescribeConnectionsRequest) Paginate(opts ...aws.Option) DescribeConnectionsPager

+ type DescribeEndpointTypesPager struct

+ func (p *DescribeEndpointTypesPager) CurrentPage() *DescribeEndpointTypesOutput

type DescribeEndpointTypesRequest

+ Copy func(*DescribeEndpointTypesInput) DescribeEndpointTypesRequest

+ func (p *DescribeEndpointTypesRequest) Paginate(opts ...aws.Option) DescribeEndpointTypesPager

+ type DescribeEndpointsPager struct

+ func (p *DescribeEndpointsPager) CurrentPage() *DescribeEndpointsOutput

type DescribeEndpointsRequest

+ Copy func(*DescribeEndpointsInput) DescribeEndpointsRequest

+ func (p *DescribeEndpointsRequest) Paginate(opts ...aws.Option) DescribeEndpointsPager

type DescribeEventCategoriesRequest

+ Copy func(*DescribeEventCategoriesInput) DescribeEventCategoriesRequest

+ type DescribeEventSubscriptionsPager struct

+ func (p *DescribeEventSubscriptionsPager) CurrentPage() *DescribeEventSubscriptionsOutput

type DescribeEventSubscriptionsRequest

+ Copy func(*DescribeEventSubscriptionsInput) DescribeEventSubscriptionsRequest

+ func (p *DescribeEventSubscriptionsRequest) Paginate(opts ...aws.Option) DescribeEventSubscriptionsPager

+ type DescribeEventsPager struct

+ func (p *DescribeEventsPager) CurrentPage() *DescribeEventsOutput

type DescribeEventsRequest

+ Copy func(*DescribeEventsInput) DescribeEventsRequest

+ func (p *DescribeEventsRequest) Paginate(opts ...aws.Option) DescribeEventsPager

+ type DescribeOrderableReplicationInstancesPager struct

+ func (p *DescribeOrderableReplicationInstancesPager) CurrentPage() *DescribeOrderableReplicationInstancesOutput

type DescribeOrderableReplicationInstancesRequest

+ Copy func(*DescribeOrderableReplicationInstancesInput) DescribeOrderableReplicationInstancesRequest

+ func (p *DescribeOrderableReplicationInstancesRequest) Paginate(opts ...aws.Option) DescribeOrderableReplicationInstancesPager

type DescribeRefreshSchemasStatusRequest

+ Copy func(*DescribeRefreshSchemasStatusInput) DescribeRefreshSchemasStatusRequest

+ type DescribeReplicationInstanceTaskLogsInput struct

+ Marker *string

+ MaxRecords *int64

+ ReplicationInstanceArn *string

+ func (s *DescribeReplicationInstanceTaskLogsInput) Validate() error

+ func (s DescribeReplicationInstanceTaskLogsInput) GoString() string

+ func (s DescribeReplicationInstanceTaskLogsInput) String() string

+ type DescribeReplicationInstanceTaskLogsOutput struct

+ Marker *string

+ ReplicationInstanceArn *string

+ ReplicationInstanceTaskLogs []ReplicationInstanceTaskLog

+ func (s DescribeReplicationInstanceTaskLogsOutput) GoString() string

+ func (s DescribeReplicationInstanceTaskLogsOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeReplicationInstanceTaskLogsOutput) String() string

+ type DescribeReplicationInstanceTaskLogsPager struct

+ func (p *DescribeReplicationInstanceTaskLogsPager) CurrentPage() *DescribeReplicationInstanceTaskLogsOutput

+ type DescribeReplicationInstanceTaskLogsRequest struct

+ Copy func(*DescribeReplicationInstanceTaskLogsInput) DescribeReplicationInstanceTaskLogsRequest

+ Input *DescribeReplicationInstanceTaskLogsInput

+ func (p *DescribeReplicationInstanceTaskLogsRequest) Paginate(opts ...aws.Option) DescribeReplicationInstanceTaskLogsPager

+ func (r DescribeReplicationInstanceTaskLogsRequest) Send() (*DescribeReplicationInstanceTaskLogsOutput, error)

+ type DescribeReplicationInstancesPager struct

+ func (p *DescribeReplicationInstancesPager) CurrentPage() *DescribeReplicationInstancesOutput

type DescribeReplicationInstancesRequest

+ Copy func(*DescribeReplicationInstancesInput) DescribeReplicationInstancesRequest

+ func (p *DescribeReplicationInstancesRequest) Paginate(opts ...aws.Option) DescribeReplicationInstancesPager

+ type DescribeReplicationSubnetGroupsPager struct

+ func (p *DescribeReplicationSubnetGroupsPager) CurrentPage() *DescribeReplicationSubnetGroupsOutput

type DescribeReplicationSubnetGroupsRequest

+ Copy func(*DescribeReplicationSubnetGroupsInput) DescribeReplicationSubnetGroupsRequest

+ func (p *DescribeReplicationSubnetGroupsRequest) Paginate(opts ...aws.Option) DescribeReplicationSubnetGroupsPager

+ type DescribeReplicationTaskAssessmentResultsPager struct

+ func (p *DescribeReplicationTaskAssessmentResultsPager) CurrentPage() *DescribeReplicationTaskAssessmentResultsOutput

type DescribeReplicationTaskAssessmentResultsRequest

+ Copy func(*DescribeReplicationTaskAssessmentResultsInput) DescribeReplicationTaskAssessmentResultsRequest

+ func (p *DescribeReplicationTaskAssessmentResultsRequest) Paginate(opts ...aws.Option) DescribeReplicationTaskAssessmentResultsPager

+ type DescribeReplicationTasksPager struct

+ func (p *DescribeReplicationTasksPager) CurrentPage() *DescribeReplicationTasksOutput

type DescribeReplicationTasksRequest

+ Copy func(*DescribeReplicationTasksInput) DescribeReplicationTasksRequest

+ func (p *DescribeReplicationTasksRequest) Paginate(opts ...aws.Option) DescribeReplicationTasksPager

+ type DescribeSchemasPager struct

+ func (p *DescribeSchemasPager) CurrentPage() *DescribeSchemasOutput

type DescribeSchemasRequest

+ Copy func(*DescribeSchemasInput) DescribeSchemasRequest

+ func (p *DescribeSchemasRequest) Paginate(opts ...aws.Option) DescribeSchemasPager

+ type DescribeTableStatisticsPager struct

+ func (p *DescribeTableStatisticsPager) CurrentPage() *DescribeTableStatisticsOutput

type DescribeTableStatisticsRequest

+ Copy func(*DescribeTableStatisticsInput) DescribeTableStatisticsRequest

+ func (p *DescribeTableStatisticsRequest) Paginate(opts ...aws.Option) DescribeTableStatisticsPager

type DmsSslModeValue

+ func (enum DmsSslModeValue) MarshalValue() (string, error)

+ func (enum DmsSslModeValue) MarshalValueBuf(b []byte) ([]byte, error)

type ImportCertificateRequest

+ Copy func(*ImportCertificateInput) ImportCertificateRequest

type ListTagsForResourceRequest

+ Copy func(*ListTagsForResourceInput) ListTagsForResourceRequest

type MigrationTypeValue

+ func (enum MigrationTypeValue) MarshalValue() (string, error)

+ func (enum MigrationTypeValue) MarshalValueBuf(b []byte) ([]byte, error)

type ModifyEndpointRequest

+ Copy func(*ModifyEndpointInput) ModifyEndpointRequest

type ModifyEventSubscriptionRequest

+ Copy func(*ModifyEventSubscriptionInput) ModifyEventSubscriptionRequest

type ModifyReplicationInstanceRequest

+ Copy func(*ModifyReplicationInstanceInput) ModifyReplicationInstanceRequest

type ModifyReplicationSubnetGroupRequest

+ Copy func(*ModifyReplicationSubnetGroupInput) ModifyReplicationSubnetGroupRequest

type ModifyReplicationTaskRequest

+ Copy func(*ModifyReplicationTaskInput) ModifyReplicationTaskRequest

type NestingLevelValue

+ func (enum NestingLevelValue) MarshalValue() (string, error)

+ func (enum NestingLevelValue) MarshalValueBuf(b []byte) ([]byte, error)

+ type RebootReplicationInstanceInput struct

+ ForceFailover *bool

+ ReplicationInstanceArn *string

+ func (s *RebootReplicationInstanceInput) Validate() error

+ func (s RebootReplicationInstanceInput) GoString() string

+ func (s RebootReplicationInstanceInput) String() string

+ type RebootReplicationInstanceOutput struct

+ ReplicationInstance *ReplicationInstance

+ func (s RebootReplicationInstanceOutput) GoString() string

+ func (s RebootReplicationInstanceOutput) SDKResponseMetadata() aws.Response

+ func (s RebootReplicationInstanceOutput) String() string

+ type RebootReplicationInstanceRequest struct

+ Copy func(*RebootReplicationInstanceInput) RebootReplicationInstanceRequest

+ Input *RebootReplicationInstanceInput

+ func (r RebootReplicationInstanceRequest) Send() (*RebootReplicationInstanceOutput, error)

type RefreshSchemasRequest

+ Copy func(*RefreshSchemasInput) RefreshSchemasRequest

type RefreshSchemasStatusTypeValue

+ func (enum RefreshSchemasStatusTypeValue) MarshalValue() (string, error)

+ func (enum RefreshSchemasStatusTypeValue) MarshalValueBuf(b []byte) ([]byte, error)

type ReloadTablesRequest

+ Copy func(*ReloadTablesInput) ReloadTablesRequest

type RemoveTagsFromResourceRequest

+ Copy func(*RemoveTagsFromResourceInput) RemoveTagsFromResourceRequest

type ReplicationEndpointTypeValue

+ func (enum ReplicationEndpointTypeValue) MarshalValue() (string, error)

+ func (enum ReplicationEndpointTypeValue) MarshalValueBuf(b []byte) ([]byte, error)

+ type ReplicationInstanceTaskLog struct

+ ReplicationInstanceTaskLogSize *int64

+ ReplicationTaskArn *string

+ ReplicationTaskName *string

+ func (s ReplicationInstanceTaskLog) GoString() string

+ func (s ReplicationInstanceTaskLog) String() string

type SourceType

+ func (enum SourceType) MarshalValue() (string, error)

+ func (enum SourceType) MarshalValueBuf(b []byte) ([]byte, error)

type StartReplicationTaskAssessmentRequest

+ Copy func(*StartReplicationTaskAssessmentInput) StartReplicationTaskAssessmentRequest

type StartReplicationTaskRequest

+ Copy func(*StartReplicationTaskInput) StartReplicationTaskRequest

type StartReplicationTaskTypeValue

+ func (enum StartReplicationTaskTypeValue) MarshalValue() (string, error)

+ func (enum StartReplicationTaskTypeValue) MarshalValueBuf(b []byte) ([]byte, error)

type StopReplicationTaskRequest

+ Copy func(*StopReplicationTaskInput) StopReplicationTaskRequest

type TestConnectionRequest

+ Copy func(*TestConnectionInput) TestConnectionRequest

v0.2.0

Jan 15, 2018

Changes in this version

type DatabaseMigrationService

+ func (c *DatabaseMigrationService) DescribeReplicationTaskAssessmentResultsPages(input *DescribeReplicationTaskAssessmentResultsInput, ...) error

+ func (c *DatabaseMigrationService) DescribeReplicationTaskAssessmentResultsPagesWithContext(ctx aws.Context, input *DescribeReplicationTaskAssessmentResultsInput, ...) error

+ func (c *DatabaseMigrationService) DescribeReplicationTaskAssessmentResultsRequest(input *DescribeReplicationTaskAssessmentResultsInput) DescribeReplicationTaskAssessmentResultsRequest

+ func (c *DatabaseMigrationService) StartReplicationTaskAssessmentRequest(input *StartReplicationTaskAssessmentInput) StartReplicationTaskAssessmentRequest

+ type DescribeReplicationTaskAssessmentResultsInput struct

+ Marker *string

+ MaxRecords *int64

+ ReplicationTaskArn *string

+ func (s *DescribeReplicationTaskAssessmentResultsInput) SetMarker(v string) *DescribeReplicationTaskAssessmentResultsInput

+ func (s *DescribeReplicationTaskAssessmentResultsInput) SetMaxRecords(v int64) *DescribeReplicationTaskAssessmentResultsInput

+ func (s *DescribeReplicationTaskAssessmentResultsInput) SetReplicationTaskArn(v string) *DescribeReplicationTaskAssessmentResultsInput

+ func (s DescribeReplicationTaskAssessmentResultsInput) GoString() string

+ func (s DescribeReplicationTaskAssessmentResultsInput) String() string

+ type DescribeReplicationTaskAssessmentResultsOutput struct

+ BucketName *string

+ Marker *string

+ ReplicationTaskAssessmentResults []ReplicationTaskAssessmentResult

+ func (s *DescribeReplicationTaskAssessmentResultsOutput) SetBucketName(v string) *DescribeReplicationTaskAssessmentResultsOutput

+ func (s *DescribeReplicationTaskAssessmentResultsOutput) SetMarker(v string) *DescribeReplicationTaskAssessmentResultsOutput

+ func (s *DescribeReplicationTaskAssessmentResultsOutput) SetReplicationTaskAssessmentResults(v []ReplicationTaskAssessmentResult) *DescribeReplicationTaskAssessmentResultsOutput

+ func (s DescribeReplicationTaskAssessmentResultsOutput) GoString() string

+ func (s DescribeReplicationTaskAssessmentResultsOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeReplicationTaskAssessmentResultsOutput) String() string

+ type DescribeReplicationTaskAssessmentResultsRequest struct

+ Input *DescribeReplicationTaskAssessmentResultsInput

+ func (r DescribeReplicationTaskAssessmentResultsRequest) Send() (*DescribeReplicationTaskAssessmentResultsOutput, error)

type DescribeTableStatisticsInput

+ Filters []Filter

+ func (s *DescribeTableStatisticsInput) SetFilters(v []Filter) *DescribeTableStatisticsInput

+ type ReplicationTaskAssessmentResult struct

+ AssessmentResults *string

+ AssessmentResultsFile *string

+ AssessmentStatus *string

+ ReplicationTaskArn *string

+ ReplicationTaskIdentifier *string

+ ReplicationTaskLastAssessmentDate *time.Time

+ S3ObjectUrl *string

+ func (s *ReplicationTaskAssessmentResult) SetAssessmentResults(v string) *ReplicationTaskAssessmentResult

+ func (s *ReplicationTaskAssessmentResult) SetAssessmentResultsFile(v string) *ReplicationTaskAssessmentResult

+ func (s *ReplicationTaskAssessmentResult) SetAssessmentStatus(v string) *ReplicationTaskAssessmentResult

+ func (s *ReplicationTaskAssessmentResult) SetReplicationTaskArn(v string) *ReplicationTaskAssessmentResult

+ func (s *ReplicationTaskAssessmentResult) SetReplicationTaskIdentifier(v string) *ReplicationTaskAssessmentResult

+ func (s *ReplicationTaskAssessmentResult) SetReplicationTaskLastAssessmentDate(v time.Time) *ReplicationTaskAssessmentResult

+ func (s *ReplicationTaskAssessmentResult) SetS3ObjectUrl(v string) *ReplicationTaskAssessmentResult

+ func (s ReplicationTaskAssessmentResult) GoString() string

+ func (s ReplicationTaskAssessmentResult) String() string

+ type StartReplicationTaskAssessmentInput struct

+ ReplicationTaskArn *string

+ func (s *StartReplicationTaskAssessmentInput) SetReplicationTaskArn(v string) *StartReplicationTaskAssessmentInput

+ func (s *StartReplicationTaskAssessmentInput) Validate() error

+ func (s StartReplicationTaskAssessmentInput) GoString() string

+ func (s StartReplicationTaskAssessmentInput) String() string

+ type StartReplicationTaskAssessmentOutput struct

+ ReplicationTask *ReplicationTask

+ func (s *StartReplicationTaskAssessmentOutput) SetReplicationTask(v *ReplicationTask) *StartReplicationTaskAssessmentOutput

+ func (s StartReplicationTaskAssessmentOutput) GoString() string

+ func (s StartReplicationTaskAssessmentOutput) SDKResponseMetadata() aws.Response

+ func (s StartReplicationTaskAssessmentOutput) String() string

+ type StartReplicationTaskAssessmentRequest struct

+ Input *StartReplicationTaskAssessmentInput

+ func (r StartReplicationTaskAssessmentRequest) Send() (*StartReplicationTaskAssessmentOutput, error)

type TableStatistics

+ ValidationFailedRecords *int64

+ ValidationPendingRecords *int64

+ ValidationState *string

+ ValidationSuspendedRecords *int64

+ func (s *TableStatistics) SetValidationFailedRecords(v int64) *TableStatistics

+ func (s *TableStatistics) SetValidationPendingRecords(v int64) *TableStatistics

+ func (s *TableStatistics) SetValidationState(v string) *TableStatistics

+ func (s *TableStatistics) SetValidationSuspendedRecords(v int64) *TableStatistics

v0.1.0

Dec 21, 2017

Changes in this version

+ const EndpointsID

+ const ErrCodeAccessDeniedFault

+ const ErrCodeInsufficientResourceCapacityFault

+ const ErrCodeInvalidCertificateFault

+ const ErrCodeInvalidResourceStateFault

+ const ErrCodeInvalidSubnet

+ const ErrCodeKMSKeyNotAccessibleFault

+ const ErrCodeReplicationSubnetGroupDoesNotCoverEnoughAZs

+ const ErrCodeResourceAlreadyExistsFault

+ const ErrCodeResourceNotFoundFault

+ const ErrCodeResourceQuotaExceededFault

+ const ErrCodeSNSInvalidTopicFault

+ const ErrCodeSNSNoAuthorizationFault

+ const ErrCodeStorageQuotaExceededFault

+ const ErrCodeSubnetAlreadyInUse

+ const ErrCodeUpgradeDependencyFailureFault

+ const ServiceName

+ type AccountQuota struct

+ AccountQuotaName *string

+ Max *int64

+ Used *int64

+ func (s *AccountQuota) SetAccountQuotaName(v string) *AccountQuota

+ func (s *AccountQuota) SetMax(v int64) *AccountQuota

+ func (s *AccountQuota) SetUsed(v int64) *AccountQuota

+ func (s AccountQuota) GoString() string

+ func (s AccountQuota) String() string

+ type AddTagsToResourceInput struct

+ ResourceArn *string

+ Tags []Tag

+ func (s *AddTagsToResourceInput) SetResourceArn(v string) *AddTagsToResourceInput

+ func (s *AddTagsToResourceInput) SetTags(v []Tag) *AddTagsToResourceInput

+ func (s *AddTagsToResourceInput) Validate() error

+ func (s AddTagsToResourceInput) GoString() string

+ func (s AddTagsToResourceInput) String() string

+ type AddTagsToResourceOutput struct

+ func (s AddTagsToResourceOutput) GoString() string

+ func (s AddTagsToResourceOutput) SDKResponseMetadata() aws.Response

+ func (s AddTagsToResourceOutput) String() string

+ type AddTagsToResourceRequest struct

+ Input *AddTagsToResourceInput

+ func (r AddTagsToResourceRequest) Send() (*AddTagsToResourceOutput, error)

+ type AuthMechanismValue string

+ const AuthMechanismValueDefault

+ const AuthMechanismValueMongodbCr

+ const AuthMechanismValueScramSha1

+ type AuthTypeValue string

+ const AuthTypeValueNo

+ const AuthTypeValuePassword

+ type AvailabilityZone struct

+ Name *string

+ func (s *AvailabilityZone) SetName(v string) *AvailabilityZone

+ func (s AvailabilityZone) GoString() string

+ func (s AvailabilityZone) String() string

+ type Certificate struct

+ CertificateArn *string

+ CertificateCreationDate *time.Time

+ CertificateIdentifier *string

+ CertificateOwner *string

+ CertificatePem *string

+ CertificateWallet []byte

+ KeyLength *int64

+ SigningAlgorithm *string

+ ValidFromDate *time.Time

+ ValidToDate *time.Time

+ func (s *Certificate) SetCertificateArn(v string) *Certificate

+ func (s *Certificate) SetCertificateCreationDate(v time.Time) *Certificate

+ func (s *Certificate) SetCertificateIdentifier(v string) *Certificate

+ func (s *Certificate) SetCertificateOwner(v string) *Certificate

+ func (s *Certificate) SetCertificatePem(v string) *Certificate

+ func (s *Certificate) SetCertificateWallet(v []byte) *Certificate

+ func (s *Certificate) SetKeyLength(v int64) *Certificate

+ func (s *Certificate) SetSigningAlgorithm(v string) *Certificate

+ func (s *Certificate) SetValidFromDate(v time.Time) *Certificate

+ func (s *Certificate) SetValidToDate(v time.Time) *Certificate

+ func (s Certificate) GoString() string

+ func (s Certificate) String() string

+ type CompressionTypeValue string

+ const CompressionTypeValueGzip

+ const CompressionTypeValueNone

+ type Connection struct

+ EndpointArn *string

+ EndpointIdentifier *string

+ LastFailureMessage *string

+ ReplicationInstanceArn *string

+ ReplicationInstanceIdentifier *string

+ Status *string

+ func (s *Connection) SetEndpointArn(v string) *Connection

+ func (s *Connection) SetEndpointIdentifier(v string) *Connection

+ func (s *Connection) SetLastFailureMessage(v string) *Connection

+ func (s *Connection) SetReplicationInstanceArn(v string) *Connection

+ func (s *Connection) SetReplicationInstanceIdentifier(v string) *Connection

+ func (s *Connection) SetStatus(v string) *Connection

+ func (s Connection) GoString() string

+ func (s Connection) String() string

+ type CreateEndpointInput struct

+ CertificateArn *string

+ DatabaseName *string

+ DynamoDbSettings *DynamoDbSettings

+ EndpointIdentifier *string

+ EndpointType ReplicationEndpointTypeValue

+ EngineName *string

+ ExtraConnectionAttributes *string

+ KmsKeyId *string

+ MongoDbSettings *MongoDbSettings

+ Password *string

+ Port *int64

+ S3Settings *S3Settings

+ ServerName *string

+ SslMode DmsSslModeValue

+ Tags []Tag

+ Username *string

+ func (s *CreateEndpointInput) SetCertificateArn(v string) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetDatabaseName(v string) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetDynamoDbSettings(v *DynamoDbSettings) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetEndpointIdentifier(v string) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetEndpointType(v ReplicationEndpointTypeValue) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetEngineName(v string) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetExtraConnectionAttributes(v string) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetKmsKeyId(v string) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetMongoDbSettings(v *MongoDbSettings) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetPassword(v string) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetPort(v int64) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetS3Settings(v *S3Settings) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetServerName(v string) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetSslMode(v DmsSslModeValue) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetTags(v []Tag) *CreateEndpointInput

+ func (s *CreateEndpointInput) SetUsername(v string) *CreateEndpointInput

+ func (s *CreateEndpointInput) Validate() error

+ func (s CreateEndpointInput) GoString() string

+ func (s CreateEndpointInput) String() string

+ type CreateEndpointOutput struct

+ Endpoint *Endpoint

+ func (s *CreateEndpointOutput) SetEndpoint(v *Endpoint) *CreateEndpointOutput

+ func (s CreateEndpointOutput) GoString() string

+ func (s CreateEndpointOutput) SDKResponseMetadata() aws.Response

+ func (s CreateEndpointOutput) String() string

+ type CreateEndpointRequest struct

+ Input *CreateEndpointInput

+ func (r CreateEndpointRequest) Send() (*CreateEndpointOutput, error)

+ type CreateEventSubscriptionInput struct

+ Enabled *bool

+ EventCategories []string

+ SnsTopicArn *string

+ SourceIds []string

+ SourceType *string

+ SubscriptionName *string

+ Tags []Tag

+ func (s *CreateEventSubscriptionInput) SetEnabled(v bool) *CreateEventSubscriptionInput

+ func (s *CreateEventSubscriptionInput) SetEventCategories(v []string) *CreateEventSubscriptionInput

+ func (s *CreateEventSubscriptionInput) SetSnsTopicArn(v string) *CreateEventSubscriptionInput

+ func (s *CreateEventSubscriptionInput) SetSourceIds(v []string) *CreateEventSubscriptionInput

+ func (s *CreateEventSubscriptionInput) SetSourceType(v string) *CreateEventSubscriptionInput

+ func (s *CreateEventSubscriptionInput) SetSubscriptionName(v string) *CreateEventSubscriptionInput

+ func (s *CreateEventSubscriptionInput) SetTags(v []Tag) *CreateEventSubscriptionInput

+ func (s *CreateEventSubscriptionInput) Validate() error

+ func (s CreateEventSubscriptionInput) GoString() string

+ func (s CreateEventSubscriptionInput) String() string

+ type CreateEventSubscriptionOutput struct

+ EventSubscription *EventSubscription

+ func (s *CreateEventSubscriptionOutput) SetEventSubscription(v *EventSubscription) *CreateEventSubscriptionOutput

+ func (s CreateEventSubscriptionOutput) GoString() string

+ func (s CreateEventSubscriptionOutput) SDKResponseMetadata() aws.Response

+ func (s CreateEventSubscriptionOutput) String() string

+ type CreateEventSubscriptionRequest struct

+ Input *CreateEventSubscriptionInput

+ func (r CreateEventSubscriptionRequest) Send() (*CreateEventSubscriptionOutput, error)

+ type CreateReplicationInstanceInput struct

+ AllocatedStorage *int64

+ AutoMinorVersionUpgrade *bool

+ AvailabilityZone *string

+ EngineVersion *string

+ KmsKeyId *string

+ MultiAZ *bool

+ PreferredMaintenanceWindow *string

+ PubliclyAccessible *bool

+ ReplicationInstanceClass *string

+ ReplicationInstanceIdentifier *string

+ ReplicationSubnetGroupIdentifier *string

+ Tags []Tag

+ VpcSecurityGroupIds []string

+ func (s *CreateReplicationInstanceInput) SetAllocatedStorage(v int64) *CreateReplicationInstanceInput

+ func (s *CreateReplicationInstanceInput) SetAutoMinorVersionUpgrade(v bool) *CreateReplicationInstanceInput

+ func (s *CreateReplicationInstanceInput) SetAvailabilityZone(v string) *CreateReplicationInstanceInput

+ func (s *CreateReplicationInstanceInput) SetEngineVersion(v string) *CreateReplicationInstanceInput

+ func (s *CreateReplicationInstanceInput) SetKmsKeyId(v string) *CreateReplicationInstanceInput

+ func (s *CreateReplicationInstanceInput) SetMultiAZ(v bool) *CreateReplicationInstanceInput

+ func (s *CreateReplicationInstanceInput) SetPreferredMaintenanceWindow(v string) *CreateReplicationInstanceInput

+ func (s *CreateReplicationInstanceInput) SetPubliclyAccessible(v bool) *CreateReplicationInstanceInput

+ func (s *CreateReplicationInstanceInput) SetReplicationInstanceClass(v string) *CreateReplicationInstanceInput

+ func (s *CreateReplicationInstanceInput) SetReplicationInstanceIdentifier(v string) *CreateReplicationInstanceInput

+ func (s *CreateReplicationInstanceInput) SetReplicationSubnetGroupIdentifier(v string) *CreateReplicationInstanceInput

+ func (s *CreateReplicationInstanceInput) SetTags(v []Tag) *CreateReplicationInstanceInput

+ func (s *CreateReplicationInstanceInput) SetVpcSecurityGroupIds(v []string) *CreateReplicationInstanceInput

+ func (s *CreateReplicationInstanceInput) Validate() error

+ func (s CreateReplicationInstanceInput) GoString() string

+ func (s CreateReplicationInstanceInput) String() string

+ type CreateReplicationInstanceOutput struct

+ ReplicationInstance *ReplicationInstance

+ func (s *CreateReplicationInstanceOutput) SetReplicationInstance(v *ReplicationInstance) *CreateReplicationInstanceOutput

+ func (s CreateReplicationInstanceOutput) GoString() string

+ func (s CreateReplicationInstanceOutput) SDKResponseMetadata() aws.Response

+ func (s CreateReplicationInstanceOutput) String() string

+ type CreateReplicationInstanceRequest struct

+ Input *CreateReplicationInstanceInput

+ func (r CreateReplicationInstanceRequest) Send() (*CreateReplicationInstanceOutput, error)

+ type CreateReplicationSubnetGroupInput struct

+ ReplicationSubnetGroupDescription *string

+ ReplicationSubnetGroupIdentifier *string

+ SubnetIds []string

+ Tags []Tag

+ func (s *CreateReplicationSubnetGroupInput) SetReplicationSubnetGroupDescription(v string) *CreateReplicationSubnetGroupInput

+ func (s *CreateReplicationSubnetGroupInput) SetReplicationSubnetGroupIdentifier(v string) *CreateReplicationSubnetGroupInput

+ func (s *CreateReplicationSubnetGroupInput) SetSubnetIds(v []string) *CreateReplicationSubnetGroupInput

+ func (s *CreateReplicationSubnetGroupInput) SetTags(v []Tag) *CreateReplicationSubnetGroupInput

+ func (s *CreateReplicationSubnetGroupInput) Validate() error

+ func (s CreateReplicationSubnetGroupInput) GoString() string

+ func (s CreateReplicationSubnetGroupInput) String() string

+ type CreateReplicationSubnetGroupOutput struct

+ ReplicationSubnetGroup *ReplicationSubnetGroup

+ func (s *CreateReplicationSubnetGroupOutput) SetReplicationSubnetGroup(v *ReplicationSubnetGroup) *CreateReplicationSubnetGroupOutput

+ func (s CreateReplicationSubnetGroupOutput) GoString() string

+ func (s CreateReplicationSubnetGroupOutput) SDKResponseMetadata() aws.Response

+ func (s CreateReplicationSubnetGroupOutput) String() string

+ type CreateReplicationSubnetGroupRequest struct

+ Input *CreateReplicationSubnetGroupInput

+ func (r CreateReplicationSubnetGroupRequest) Send() (*CreateReplicationSubnetGroupOutput, error)

+ type CreateReplicationTaskInput struct

+ CdcStartTime *time.Time

+ MigrationType MigrationTypeValue

+ ReplicationInstanceArn *string

+ ReplicationTaskIdentifier *string

+ ReplicationTaskSettings *string

+ SourceEndpointArn *string

+ TableMappings *string

+ Tags []Tag

+ TargetEndpointArn *string

+ func (s *CreateReplicationTaskInput) SetCdcStartTime(v time.Time) *CreateReplicationTaskInput

+ func (s *CreateReplicationTaskInput) SetMigrationType(v MigrationTypeValue) *CreateReplicationTaskInput

+ func (s *CreateReplicationTaskInput) SetReplicationInstanceArn(v string) *CreateReplicationTaskInput

+ func (s *CreateReplicationTaskInput) SetReplicationTaskIdentifier(v string) *CreateReplicationTaskInput

+ func (s *CreateReplicationTaskInput) SetReplicationTaskSettings(v string) *CreateReplicationTaskInput

+ func (s *CreateReplicationTaskInput) SetSourceEndpointArn(v string) *CreateReplicationTaskInput

+ func (s *CreateReplicationTaskInput) SetTableMappings(v string) *CreateReplicationTaskInput

+ func (s *CreateReplicationTaskInput) SetTags(v []Tag) *CreateReplicationTaskInput

+ func (s *CreateReplicationTaskInput) SetTargetEndpointArn(v string) *CreateReplicationTaskInput

+ func (s *CreateReplicationTaskInput) Validate() error

+ func (s CreateReplicationTaskInput) GoString() string

+ func (s CreateReplicationTaskInput) String() string

+ type CreateReplicationTaskOutput struct

+ ReplicationTask *ReplicationTask

+ func (s *CreateReplicationTaskOutput) SetReplicationTask(v *ReplicationTask) *CreateReplicationTaskOutput

+ func (s CreateReplicationTaskOutput) GoString() string

+ func (s CreateReplicationTaskOutput) SDKResponseMetadata() aws.Response

+ func (s CreateReplicationTaskOutput) String() string

+ type CreateReplicationTaskRequest struct

+ Input *CreateReplicationTaskInput

+ func (r CreateReplicationTaskRequest) Send() (*CreateReplicationTaskOutput, error)

+ type DatabaseMigrationService struct

+ func New(config aws.Config) *DatabaseMigrationService

+ func (c *DatabaseMigrationService) AddTagsToResourceRequest(input *AddTagsToResourceInput) AddTagsToResourceRequest

+ func (c *DatabaseMigrationService) CreateEndpointRequest(input *CreateEndpointInput) CreateEndpointRequest

+ func (c *DatabaseMigrationService) CreateEventSubscriptionRequest(input *CreateEventSubscriptionInput) CreateEventSubscriptionRequest

+ func (c *DatabaseMigrationService) CreateReplicationInstanceRequest(input *CreateReplicationInstanceInput) CreateReplicationInstanceRequest

+ func (c *DatabaseMigrationService) CreateReplicationSubnetGroupRequest(input *CreateReplicationSubnetGroupInput) CreateReplicationSubnetGroupRequest

+ func (c *DatabaseMigrationService) CreateReplicationTaskRequest(input *CreateReplicationTaskInput) CreateReplicationTaskRequest

+ func (c *DatabaseMigrationService) DeleteCertificateRequest(input *DeleteCertificateInput) DeleteCertificateRequest

+ func (c *DatabaseMigrationService) DeleteEndpointRequest(input *DeleteEndpointInput) DeleteEndpointRequest

+ func (c *DatabaseMigrationService) DeleteEventSubscriptionRequest(input *DeleteEventSubscriptionInput) DeleteEventSubscriptionRequest

+ func (c *DatabaseMigrationService) DeleteReplicationInstanceRequest(input *DeleteReplicationInstanceInput) DeleteReplicationInstanceRequest

+ func (c *DatabaseMigrationService) DeleteReplicationSubnetGroupRequest(input *DeleteReplicationSubnetGroupInput) DeleteReplicationSubnetGroupRequest

+ func (c *DatabaseMigrationService) DeleteReplicationTaskRequest(input *DeleteReplicationTaskInput) DeleteReplicationTaskRequest

+ func (c *DatabaseMigrationService) DescribeAccountAttributesRequest(input *DescribeAccountAttributesInput) DescribeAccountAttributesRequest

+ func (c *DatabaseMigrationService) DescribeCertificatesPages(input *DescribeCertificatesInput, ...) error

+ func (c *DatabaseMigrationService) DescribeCertificatesPagesWithContext(ctx aws.Context, input *DescribeCertificatesInput, ...) error

+ func (c *DatabaseMigrationService) DescribeCertificatesRequest(input *DescribeCertificatesInput) DescribeCertificatesRequest

+ func (c *DatabaseMigrationService) DescribeConnectionsPages(input *DescribeConnectionsInput, ...) error

+ func (c *DatabaseMigrationService) DescribeConnectionsPagesWithContext(ctx aws.Context, input *DescribeConnectionsInput, ...) error

+ func (c *DatabaseMigrationService) DescribeConnectionsRequest(input *DescribeConnectionsInput) DescribeConnectionsRequest

+ func (c *DatabaseMigrationService) DescribeEndpointTypesPages(input *DescribeEndpointTypesInput, ...) error

+ func (c *DatabaseMigrationService) DescribeEndpointTypesPagesWithContext(ctx aws.Context, input *DescribeEndpointTypesInput, ...) error

+ func (c *DatabaseMigrationService) DescribeEndpointTypesRequest(input *DescribeEndpointTypesInput) DescribeEndpointTypesRequest

+ func (c *DatabaseMigrationService) DescribeEndpointsPages(input *DescribeEndpointsInput, fn func(*DescribeEndpointsOutput, bool) bool) error

+ func (c *DatabaseMigrationService) DescribeEndpointsPagesWithContext(ctx aws.Context, input *DescribeEndpointsInput, ...) error

+ func (c *DatabaseMigrationService) DescribeEndpointsRequest(input *DescribeEndpointsInput) DescribeEndpointsRequest

+ func (c *DatabaseMigrationService) DescribeEventCategoriesRequest(input *DescribeEventCategoriesInput) DescribeEventCategoriesRequest

+ func (c *DatabaseMigrationService) DescribeEventSubscriptionsPages(input *DescribeEventSubscriptionsInput, ...) error

+ func (c *DatabaseMigrationService) DescribeEventSubscriptionsPagesWithContext(ctx aws.Context, input *DescribeEventSubscriptionsInput, ...) error

+ func (c *DatabaseMigrationService) DescribeEventSubscriptionsRequest(input *DescribeEventSubscriptionsInput) DescribeEventSubscriptionsRequest

+ func (c *DatabaseMigrationService) DescribeEventsPages(input *DescribeEventsInput, fn func(*DescribeEventsOutput, bool) bool) error

+ func (c *DatabaseMigrationService) DescribeEventsPagesWithContext(ctx aws.Context, input *DescribeEventsInput, ...) error

+ func (c *DatabaseMigrationService) DescribeEventsRequest(input *DescribeEventsInput) DescribeEventsRequest

+ func (c *DatabaseMigrationService) DescribeOrderableReplicationInstancesPages(input *DescribeOrderableReplicationInstancesInput, ...) error

+ func (c *DatabaseMigrationService) DescribeOrderableReplicationInstancesPagesWithContext(ctx aws.Context, input *DescribeOrderableReplicationInstancesInput, ...) error

+ func (c *DatabaseMigrationService) DescribeOrderableReplicationInstancesRequest(input *DescribeOrderableReplicationInstancesInput) DescribeOrderableReplicationInstancesRequest

+ func (c *DatabaseMigrationService) DescribeRefreshSchemasStatusRequest(input *DescribeRefreshSchemasStatusInput) DescribeRefreshSchemasStatusRequest

+ func (c *DatabaseMigrationService) DescribeReplicationInstancesPages(input *DescribeReplicationInstancesInput, ...) error

+ func (c *DatabaseMigrationService) DescribeReplicationInstancesPagesWithContext(ctx aws.Context, input *DescribeReplicationInstancesInput, ...) error

+ func (c *DatabaseMigrationService) DescribeReplicationInstancesRequest(input *DescribeReplicationInstancesInput) DescribeReplicationInstancesRequest

+ func (c *DatabaseMigrationService) DescribeReplicationSubnetGroupsPages(input *DescribeReplicationSubnetGroupsInput, ...) error

+ func (c *DatabaseMigrationService) DescribeReplicationSubnetGroupsPagesWithContext(ctx aws.Context, input *DescribeReplicationSubnetGroupsInput, ...) error

+ func (c *DatabaseMigrationService) DescribeReplicationSubnetGroupsRequest(input *DescribeReplicationSubnetGroupsInput) DescribeReplicationSubnetGroupsRequest

+ func (c *DatabaseMigrationService) DescribeReplicationTasksPages(input *DescribeReplicationTasksInput, ...) error

+ func (c *DatabaseMigrationService) DescribeReplicationTasksPagesWithContext(ctx aws.Context, input *DescribeReplicationTasksInput, ...) error

+ func (c *DatabaseMigrationService) DescribeReplicationTasksRequest(input *DescribeReplicationTasksInput) DescribeReplicationTasksRequest

+ func (c *DatabaseMigrationService) DescribeSchemasPages(input *DescribeSchemasInput, fn func(*DescribeSchemasOutput, bool) bool) error

+ func (c *DatabaseMigrationService) DescribeSchemasPagesWithContext(ctx aws.Context, input *DescribeSchemasInput, ...) error

+ func (c *DatabaseMigrationService) DescribeSchemasRequest(input *DescribeSchemasInput) DescribeSchemasRequest

+ func (c *DatabaseMigrationService) DescribeTableStatisticsPages(input *DescribeTableStatisticsInput, ...) error

+ func (c *DatabaseMigrationService) DescribeTableStatisticsPagesWithContext(ctx aws.Context, input *DescribeTableStatisticsInput, ...) error

+ func (c *DatabaseMigrationService) DescribeTableStatisticsRequest(input *DescribeTableStatisticsInput) DescribeTableStatisticsRequest

+ func (c *DatabaseMigrationService) ImportCertificateRequest(input *ImportCertificateInput) ImportCertificateRequest

+ func (c *DatabaseMigrationService) ListTagsForResourceRequest(input *ListTagsForResourceInput) ListTagsForResourceRequest

+ func (c *DatabaseMigrationService) ModifyEndpointRequest(input *ModifyEndpointInput) ModifyEndpointRequest

+ func (c *DatabaseMigrationService) ModifyEventSubscriptionRequest(input *ModifyEventSubscriptionInput) ModifyEventSubscriptionRequest

+ func (c *DatabaseMigrationService) ModifyReplicationInstanceRequest(input *ModifyReplicationInstanceInput) ModifyReplicationInstanceRequest

+ func (c *DatabaseMigrationService) ModifyReplicationSubnetGroupRequest(input *ModifyReplicationSubnetGroupInput) ModifyReplicationSubnetGroupRequest

+ func (c *DatabaseMigrationService) ModifyReplicationTaskRequest(input *ModifyReplicationTaskInput) ModifyReplicationTaskRequest

+ func (c *DatabaseMigrationService) RefreshSchemasRequest(input *RefreshSchemasInput) RefreshSchemasRequest

+ func (c *DatabaseMigrationService) ReloadTablesRequest(input *ReloadTablesInput) ReloadTablesRequest

+ func (c *DatabaseMigrationService) RemoveTagsFromResourceRequest(input *RemoveTagsFromResourceInput) RemoveTagsFromResourceRequest

+ func (c *DatabaseMigrationService) StartReplicationTaskRequest(input *StartReplicationTaskInput) StartReplicationTaskRequest

+ func (c *DatabaseMigrationService) StopReplicationTaskRequest(input *StopReplicationTaskInput) StopReplicationTaskRequest

+ func (c *DatabaseMigrationService) TestConnectionRequest(input *TestConnectionInput) TestConnectionRequest

+ type DeleteCertificateInput struct

+ CertificateArn *string

+ func (s *DeleteCertificateInput) SetCertificateArn(v string) *DeleteCertificateInput

+ func (s *DeleteCertificateInput) Validate() error

+ func (s DeleteCertificateInput) GoString() string

+ func (s DeleteCertificateInput) String() string

+ type DeleteCertificateOutput struct

+ Certificate *Certificate

+ func (s *DeleteCertificateOutput) SetCertificate(v *Certificate) *DeleteCertificateOutput

+ func (s DeleteCertificateOutput) GoString() string

+ func (s DeleteCertificateOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteCertificateOutput) String() string

+ type DeleteCertificateRequest struct

+ Input *DeleteCertificateInput

+ func (r DeleteCertificateRequest) Send() (*DeleteCertificateOutput, error)

+ type DeleteEndpointInput struct

+ EndpointArn *string

+ func (s *DeleteEndpointInput) SetEndpointArn(v string) *DeleteEndpointInput

+ func (s *DeleteEndpointInput) Validate() error

+ func (s DeleteEndpointInput) GoString() string

+ func (s DeleteEndpointInput) String() string

+ type DeleteEndpointOutput struct

+ Endpoint *Endpoint

+ func (s *DeleteEndpointOutput) SetEndpoint(v *Endpoint) *DeleteEndpointOutput

+ func (s DeleteEndpointOutput) GoString() string

+ func (s DeleteEndpointOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteEndpointOutput) String() string

+ type DeleteEndpointRequest struct

+ Input *DeleteEndpointInput

+ func (r DeleteEndpointRequest) Send() (*DeleteEndpointOutput, error)

+ type DeleteEventSubscriptionInput struct

+ SubscriptionName *string

+ func (s *DeleteEventSubscriptionInput) SetSubscriptionName(v string) *DeleteEventSubscriptionInput

+ func (s *DeleteEventSubscriptionInput) Validate() error

+ func (s DeleteEventSubscriptionInput) GoString() string

+ func (s DeleteEventSubscriptionInput) String() string

+ type DeleteEventSubscriptionOutput struct

+ EventSubscription *EventSubscription

+ func (s *DeleteEventSubscriptionOutput) SetEventSubscription(v *EventSubscription) *DeleteEventSubscriptionOutput

+ func (s DeleteEventSubscriptionOutput) GoString() string

+ func (s DeleteEventSubscriptionOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteEventSubscriptionOutput) String() string

+ type DeleteEventSubscriptionRequest struct

+ Input *DeleteEventSubscriptionInput

+ func (r DeleteEventSubscriptionRequest) Send() (*DeleteEventSubscriptionOutput, error)

+ type DeleteReplicationInstanceInput struct

+ ReplicationInstanceArn *string

+ func (s *DeleteReplicationInstanceInput) SetReplicationInstanceArn(v string) *DeleteReplicationInstanceInput

+ func (s *DeleteReplicationInstanceInput) Validate() error

+ func (s DeleteReplicationInstanceInput) GoString() string

+ func (s DeleteReplicationInstanceInput) String() string

+ type DeleteReplicationInstanceOutput struct

+ ReplicationInstance *ReplicationInstance

+ func (s *DeleteReplicationInstanceOutput) SetReplicationInstance(v *ReplicationInstance) *DeleteReplicationInstanceOutput

+ func (s DeleteReplicationInstanceOutput) GoString() string

+ func (s DeleteReplicationInstanceOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteReplicationInstanceOutput) String() string

+ type DeleteReplicationInstanceRequest struct

+ Input *DeleteReplicationInstanceInput

+ func (r DeleteReplicationInstanceRequest) Send() (*DeleteReplicationInstanceOutput, error)

+ type DeleteReplicationSubnetGroupInput struct

+ ReplicationSubnetGroupIdentifier *string

+ func (s *DeleteReplicationSubnetGroupInput) SetReplicationSubnetGroupIdentifier(v string) *DeleteReplicationSubnetGroupInput

+ func (s *DeleteReplicationSubnetGroupInput) Validate() error

+ func (s DeleteReplicationSubnetGroupInput) GoString() string

+ func (s DeleteReplicationSubnetGroupInput) String() string

+ type DeleteReplicationSubnetGroupOutput struct

+ func (s DeleteReplicationSubnetGroupOutput) GoString() string

+ func (s DeleteReplicationSubnetGroupOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteReplicationSubnetGroupOutput) String() string

+ type DeleteReplicationSubnetGroupRequest struct

+ Input *DeleteReplicationSubnetGroupInput

+ func (r DeleteReplicationSubnetGroupRequest) Send() (*DeleteReplicationSubnetGroupOutput, error)

+ type DeleteReplicationTaskInput struct

+ ReplicationTaskArn *string

+ func (s *DeleteReplicationTaskInput) SetReplicationTaskArn(v string) *DeleteReplicationTaskInput

+ func (s *DeleteReplicationTaskInput) Validate() error

+ func (s DeleteReplicationTaskInput) GoString() string

+ func (s DeleteReplicationTaskInput) String() string

+ type DeleteReplicationTaskOutput struct

+ ReplicationTask *ReplicationTask

+ func (s *DeleteReplicationTaskOutput) SetReplicationTask(v *ReplicationTask) *DeleteReplicationTaskOutput

+ func (s DeleteReplicationTaskOutput) GoString() string

+ func (s DeleteReplicationTaskOutput) SDKResponseMetadata() aws.Response

+ func (s DeleteReplicationTaskOutput) String() string

+ type DeleteReplicationTaskRequest struct

+ Input *DeleteReplicationTaskInput

+ func (r DeleteReplicationTaskRequest) Send() (*DeleteReplicationTaskOutput, error)

+ type DescribeAccountAttributesInput struct

+ func (s DescribeAccountAttributesInput) GoString() string

+ func (s DescribeAccountAttributesInput) String() string

+ type DescribeAccountAttributesOutput struct

+ AccountQuotas []AccountQuota

+ func (s *DescribeAccountAttributesOutput) SetAccountQuotas(v []AccountQuota) *DescribeAccountAttributesOutput

+ func (s DescribeAccountAttributesOutput) GoString() string

+ func (s DescribeAccountAttributesOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeAccountAttributesOutput) String() string

+ type DescribeAccountAttributesRequest struct

+ Input *DescribeAccountAttributesInput

+ func (r DescribeAccountAttributesRequest) Send() (*DescribeAccountAttributesOutput, error)

+ type DescribeCertificatesInput struct

+ Filters []Filter

+ Marker *string

+ MaxRecords *int64

+ func (s *DescribeCertificatesInput) SetFilters(v []Filter) *DescribeCertificatesInput

+ func (s *DescribeCertificatesInput) SetMarker(v string) *DescribeCertificatesInput

+ func (s *DescribeCertificatesInput) SetMaxRecords(v int64) *DescribeCertificatesInput

+ func (s *DescribeCertificatesInput) Validate() error

+ func (s DescribeCertificatesInput) GoString() string

+ func (s DescribeCertificatesInput) String() string

+ type DescribeCertificatesOutput struct

+ Certificates []Certificate

+ Marker *string

+ func (s *DescribeCertificatesOutput) SetCertificates(v []Certificate) *DescribeCertificatesOutput

+ func (s *DescribeCertificatesOutput) SetMarker(v string) *DescribeCertificatesOutput

+ func (s DescribeCertificatesOutput) GoString() string

+ func (s DescribeCertificatesOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeCertificatesOutput) String() string

+ type DescribeCertificatesRequest struct

+ Input *DescribeCertificatesInput

+ func (r DescribeCertificatesRequest) Send() (*DescribeCertificatesOutput, error)

+ type DescribeConnectionsInput struct

+ Filters []Filter

+ Marker *string

+ MaxRecords *int64

+ func (s *DescribeConnectionsInput) SetFilters(v []Filter) *DescribeConnectionsInput

+ func (s *DescribeConnectionsInput) SetMarker(v string) *DescribeConnectionsInput

+ func (s *DescribeConnectionsInput) SetMaxRecords(v int64) *DescribeConnectionsInput

+ func (s *DescribeConnectionsInput) Validate() error

+ func (s DescribeConnectionsInput) GoString() string

+ func (s DescribeConnectionsInput) String() string

+ type DescribeConnectionsOutput struct

+ Connections []Connection

+ Marker *string

+ func (s *DescribeConnectionsOutput) SetConnections(v []Connection) *DescribeConnectionsOutput

+ func (s *DescribeConnectionsOutput) SetMarker(v string) *DescribeConnectionsOutput

+ func (s DescribeConnectionsOutput) GoString() string

+ func (s DescribeConnectionsOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeConnectionsOutput) String() string

+ type DescribeConnectionsRequest struct

+ Input *DescribeConnectionsInput

+ func (r DescribeConnectionsRequest) Send() (*DescribeConnectionsOutput, error)

+ type DescribeEndpointTypesInput struct

+ Filters []Filter

+ Marker *string

+ MaxRecords *int64

+ func (s *DescribeEndpointTypesInput) SetFilters(v []Filter) *DescribeEndpointTypesInput

+ func (s *DescribeEndpointTypesInput) SetMarker(v string) *DescribeEndpointTypesInput

+ func (s *DescribeEndpointTypesInput) SetMaxRecords(v int64) *DescribeEndpointTypesInput

+ func (s *DescribeEndpointTypesInput) Validate() error

+ func (s DescribeEndpointTypesInput) GoString() string

+ func (s DescribeEndpointTypesInput) String() string

+ type DescribeEndpointTypesOutput struct

+ Marker *string

+ SupportedEndpointTypes []SupportedEndpointType

+ func (s *DescribeEndpointTypesOutput) SetMarker(v string) *DescribeEndpointTypesOutput

+ func (s *DescribeEndpointTypesOutput) SetSupportedEndpointTypes(v []SupportedEndpointType) *DescribeEndpointTypesOutput

+ func (s DescribeEndpointTypesOutput) GoString() string

+ func (s DescribeEndpointTypesOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeEndpointTypesOutput) String() string

+ type DescribeEndpointTypesRequest struct

+ Input *DescribeEndpointTypesInput

+ func (r DescribeEndpointTypesRequest) Send() (*DescribeEndpointTypesOutput, error)

+ type DescribeEndpointsInput struct

+ Filters []Filter

+ Marker *string

+ MaxRecords *int64

+ func (s *DescribeEndpointsInput) SetFilters(v []Filter) *DescribeEndpointsInput

+ func (s *DescribeEndpointsInput) SetMarker(v string) *DescribeEndpointsInput

+ func (s *DescribeEndpointsInput) SetMaxRecords(v int64) *DescribeEndpointsInput

+ func (s *DescribeEndpointsInput) Validate() error

+ func (s DescribeEndpointsInput) GoString() string

+ func (s DescribeEndpointsInput) String() string

+ type DescribeEndpointsOutput struct

+ Endpoints []Endpoint

+ Marker *string

+ func (s *DescribeEndpointsOutput) SetEndpoints(v []Endpoint) *DescribeEndpointsOutput

+ func (s *DescribeEndpointsOutput) SetMarker(v string) *DescribeEndpointsOutput

+ func (s DescribeEndpointsOutput) GoString() string

+ func (s DescribeEndpointsOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeEndpointsOutput) String() string

+ type DescribeEndpointsRequest struct

+ Input *DescribeEndpointsInput

+ func (r DescribeEndpointsRequest) Send() (*DescribeEndpointsOutput, error)

+ type DescribeEventCategoriesInput struct

+ Filters []Filter

+ SourceType *string

+ func (s *DescribeEventCategoriesInput) SetFilters(v []Filter) *DescribeEventCategoriesInput

+ func (s *DescribeEventCategoriesInput) SetSourceType(v string) *DescribeEventCategoriesInput

+ func (s *DescribeEventCategoriesInput) Validate() error

+ func (s DescribeEventCategoriesInput) GoString() string

+ func (s DescribeEventCategoriesInput) String() string

+ type DescribeEventCategoriesOutput struct

+ EventCategoryGroupList []EventCategoryGroup

+ func (s *DescribeEventCategoriesOutput) SetEventCategoryGroupList(v []EventCategoryGroup) *DescribeEventCategoriesOutput

+ func (s DescribeEventCategoriesOutput) GoString() string

+ func (s DescribeEventCategoriesOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeEventCategoriesOutput) String() string

+ type DescribeEventCategoriesRequest struct

+ Input *DescribeEventCategoriesInput

+ func (r DescribeEventCategoriesRequest) Send() (*DescribeEventCategoriesOutput, error)

+ type DescribeEventSubscriptionsInput struct

+ Filters []Filter

+ Marker *string

+ MaxRecords *int64

+ SubscriptionName *string

+ func (s *DescribeEventSubscriptionsInput) SetFilters(v []Filter) *DescribeEventSubscriptionsInput

+ func (s *DescribeEventSubscriptionsInput) SetMarker(v string) *DescribeEventSubscriptionsInput

+ func (s *DescribeEventSubscriptionsInput) SetMaxRecords(v int64) *DescribeEventSubscriptionsInput

+ func (s *DescribeEventSubscriptionsInput) SetSubscriptionName(v string) *DescribeEventSubscriptionsInput

+ func (s *DescribeEventSubscriptionsInput) Validate() error

+ func (s DescribeEventSubscriptionsInput) GoString() string

+ func (s DescribeEventSubscriptionsInput) String() string

+ type DescribeEventSubscriptionsOutput struct

+ EventSubscriptionsList []EventSubscription

+ Marker *string

+ func (s *DescribeEventSubscriptionsOutput) SetEventSubscriptionsList(v []EventSubscription) *DescribeEventSubscriptionsOutput

+ func (s *DescribeEventSubscriptionsOutput) SetMarker(v string) *DescribeEventSubscriptionsOutput

+ func (s DescribeEventSubscriptionsOutput) GoString() string

+ func (s DescribeEventSubscriptionsOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeEventSubscriptionsOutput) String() string

+ type DescribeEventSubscriptionsRequest struct

+ Input *DescribeEventSubscriptionsInput

+ func (r DescribeEventSubscriptionsRequest) Send() (*DescribeEventSubscriptionsOutput, error)

+ type DescribeEventsInput struct

+ Duration *int64

+ EndTime *time.Time

+ EventCategories []string

+ Filters []Filter

+ Marker *string

+ MaxRecords *int64

+ SourceIdentifier *string

+ SourceType SourceType

+ StartTime *time.Time

+ func (s *DescribeEventsInput) SetDuration(v int64) *DescribeEventsInput

+ func (s *DescribeEventsInput) SetEndTime(v time.Time) *DescribeEventsInput

+ func (s *DescribeEventsInput) SetEventCategories(v []string) *DescribeEventsInput

+ func (s *DescribeEventsInput) SetFilters(v []Filter) *DescribeEventsInput

+ func (s *DescribeEventsInput) SetMarker(v string) *DescribeEventsInput

+ func (s *DescribeEventsInput) SetMaxRecords(v int64) *DescribeEventsInput

+ func (s *DescribeEventsInput) SetSourceIdentifier(v string) *DescribeEventsInput

+ func (s *DescribeEventsInput) SetSourceType(v SourceType) *DescribeEventsInput

+ func (s *DescribeEventsInput) SetStartTime(v time.Time) *DescribeEventsInput

+ func (s *DescribeEventsInput) Validate() error

+ func (s DescribeEventsInput) GoString() string

+ func (s DescribeEventsInput) String() string

+ type DescribeEventsOutput struct

+ Events []Event

+ Marker *string

+ func (s *DescribeEventsOutput) SetEvents(v []Event) *DescribeEventsOutput

+ func (s *DescribeEventsOutput) SetMarker(v string) *DescribeEventsOutput

+ func (s DescribeEventsOutput) GoString() string

+ func (s DescribeEventsOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeEventsOutput) String() string

+ type DescribeEventsRequest struct

+ Input *DescribeEventsInput

+ func (r DescribeEventsRequest) Send() (*DescribeEventsOutput, error)

+ type DescribeOrderableReplicationInstancesInput struct

+ Marker *string

+ MaxRecords *int64

+ func (s *DescribeOrderableReplicationInstancesInput) SetMarker(v string) *DescribeOrderableReplicationInstancesInput

+ func (s *DescribeOrderableReplicationInstancesInput) SetMaxRecords(v int64) *DescribeOrderableReplicationInstancesInput

+ func (s DescribeOrderableReplicationInstancesInput) GoString() string

+ func (s DescribeOrderableReplicationInstancesInput) String() string

+ type DescribeOrderableReplicationInstancesOutput struct

+ Marker *string

+ OrderableReplicationInstances []OrderableReplicationInstance

+ func (s *DescribeOrderableReplicationInstancesOutput) SetMarker(v string) *DescribeOrderableReplicationInstancesOutput

+ func (s *DescribeOrderableReplicationInstancesOutput) SetOrderableReplicationInstances(v []OrderableReplicationInstance) *DescribeOrderableReplicationInstancesOutput

+ func (s DescribeOrderableReplicationInstancesOutput) GoString() string

+ func (s DescribeOrderableReplicationInstancesOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeOrderableReplicationInstancesOutput) String() string

+ type DescribeOrderableReplicationInstancesRequest struct

+ Input *DescribeOrderableReplicationInstancesInput

+ func (r DescribeOrderableReplicationInstancesRequest) Send() (*DescribeOrderableReplicationInstancesOutput, error)

+ type DescribeRefreshSchemasStatusInput struct

+ EndpointArn *string

+ func (s *DescribeRefreshSchemasStatusInput) SetEndpointArn(v string) *DescribeRefreshSchemasStatusInput

+ func (s *DescribeRefreshSchemasStatusInput) Validate() error

+ func (s DescribeRefreshSchemasStatusInput) GoString() string

+ func (s DescribeRefreshSchemasStatusInput) String() string

+ type DescribeRefreshSchemasStatusOutput struct

+ RefreshSchemasStatus *RefreshSchemasStatus

+ func (s *DescribeRefreshSchemasStatusOutput) SetRefreshSchemasStatus(v *RefreshSchemasStatus) *DescribeRefreshSchemasStatusOutput

+ func (s DescribeRefreshSchemasStatusOutput) GoString() string

+ func (s DescribeRefreshSchemasStatusOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeRefreshSchemasStatusOutput) String() string

+ type DescribeRefreshSchemasStatusRequest struct

+ Input *DescribeRefreshSchemasStatusInput

+ func (r DescribeRefreshSchemasStatusRequest) Send() (*DescribeRefreshSchemasStatusOutput, error)

+ type DescribeReplicationInstancesInput struct

+ Filters []Filter

+ Marker *string

+ MaxRecords *int64

+ func (s *DescribeReplicationInstancesInput) SetFilters(v []Filter) *DescribeReplicationInstancesInput

+ func (s *DescribeReplicationInstancesInput) SetMarker(v string) *DescribeReplicationInstancesInput

+ func (s *DescribeReplicationInstancesInput) SetMaxRecords(v int64) *DescribeReplicationInstancesInput

+ func (s *DescribeReplicationInstancesInput) Validate() error

+ func (s DescribeReplicationInstancesInput) GoString() string

+ func (s DescribeReplicationInstancesInput) String() string

+ type DescribeReplicationInstancesOutput struct

+ Marker *string

+ ReplicationInstances []ReplicationInstance

+ func (s *DescribeReplicationInstancesOutput) SetMarker(v string) *DescribeReplicationInstancesOutput

+ func (s *DescribeReplicationInstancesOutput) SetReplicationInstances(v []ReplicationInstance) *DescribeReplicationInstancesOutput

+ func (s DescribeReplicationInstancesOutput) GoString() string

+ func (s DescribeReplicationInstancesOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeReplicationInstancesOutput) String() string

+ type DescribeReplicationInstancesRequest struct

+ Input *DescribeReplicationInstancesInput

+ func (r DescribeReplicationInstancesRequest) Send() (*DescribeReplicationInstancesOutput, error)

+ type DescribeReplicationSubnetGroupsInput struct

+ Filters []Filter

+ Marker *string

+ MaxRecords *int64

+ func (s *DescribeReplicationSubnetGroupsInput) SetFilters(v []Filter) *DescribeReplicationSubnetGroupsInput

+ func (s *DescribeReplicationSubnetGroupsInput) SetMarker(v string) *DescribeReplicationSubnetGroupsInput

+ func (s *DescribeReplicationSubnetGroupsInput) SetMaxRecords(v int64) *DescribeReplicationSubnetGroupsInput

+ func (s *DescribeReplicationSubnetGroupsInput) Validate() error

+ func (s DescribeReplicationSubnetGroupsInput) GoString() string

+ func (s DescribeReplicationSubnetGroupsInput) String() string

+ type DescribeReplicationSubnetGroupsOutput struct

+ Marker *string

+ ReplicationSubnetGroups []ReplicationSubnetGroup

+ func (s *DescribeReplicationSubnetGroupsOutput) SetMarker(v string) *DescribeReplicationSubnetGroupsOutput

+ func (s *DescribeReplicationSubnetGroupsOutput) SetReplicationSubnetGroups(v []ReplicationSubnetGroup) *DescribeReplicationSubnetGroupsOutput

+ func (s DescribeReplicationSubnetGroupsOutput) GoString() string

+ func (s DescribeReplicationSubnetGroupsOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeReplicationSubnetGroupsOutput) String() string

+ type DescribeReplicationSubnetGroupsRequest struct

+ Input *DescribeReplicationSubnetGroupsInput

+ func (r DescribeReplicationSubnetGroupsRequest) Send() (*DescribeReplicationSubnetGroupsOutput, error)

+ type DescribeReplicationTasksInput struct

+ Filters []Filter

+ Marker *string

+ MaxRecords *int64

+ func (s *DescribeReplicationTasksInput) SetFilters(v []Filter) *DescribeReplicationTasksInput

+ func (s *DescribeReplicationTasksInput) SetMarker(v string) *DescribeReplicationTasksInput

+ func (s *DescribeReplicationTasksInput) SetMaxRecords(v int64) *DescribeReplicationTasksInput

+ func (s *DescribeReplicationTasksInput) Validate() error

+ func (s DescribeReplicationTasksInput) GoString() string

+ func (s DescribeReplicationTasksInput) String() string

+ type DescribeReplicationTasksOutput struct

+ Marker *string

+ ReplicationTasks []ReplicationTask

+ func (s *DescribeReplicationTasksOutput) SetMarker(v string) *DescribeReplicationTasksOutput

+ func (s *DescribeReplicationTasksOutput) SetReplicationTasks(v []ReplicationTask) *DescribeReplicationTasksOutput

+ func (s DescribeReplicationTasksOutput) GoString() string

+ func (s DescribeReplicationTasksOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeReplicationTasksOutput) String() string

+ type DescribeReplicationTasksRequest struct

+ Input *DescribeReplicationTasksInput

+ func (r DescribeReplicationTasksRequest) Send() (*DescribeReplicationTasksOutput, error)

+ type DescribeSchemasInput struct

+ EndpointArn *string

+ Marker *string

+ MaxRecords *int64

+ func (s *DescribeSchemasInput) SetEndpointArn(v string) *DescribeSchemasInput

+ func (s *DescribeSchemasInput) SetMarker(v string) *DescribeSchemasInput

+ func (s *DescribeSchemasInput) SetMaxRecords(v int64) *DescribeSchemasInput

+ func (s *DescribeSchemasInput) Validate() error

+ func (s DescribeSchemasInput) GoString() string

+ func (s DescribeSchemasInput) String() string

+ type DescribeSchemasOutput struct

+ Marker *string

+ Schemas []string

+ func (s *DescribeSchemasOutput) SetMarker(v string) *DescribeSchemasOutput

+ func (s *DescribeSchemasOutput) SetSchemas(v []string) *DescribeSchemasOutput

+ func (s DescribeSchemasOutput) GoString() string

+ func (s DescribeSchemasOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeSchemasOutput) String() string

+ type DescribeSchemasRequest struct

+ Input *DescribeSchemasInput

+ func (r DescribeSchemasRequest) Send() (*DescribeSchemasOutput, error)

+ type DescribeTableStatisticsInput struct

+ Marker *string

+ MaxRecords *int64

+ ReplicationTaskArn *string

+ func (s *DescribeTableStatisticsInput) SetMarker(v string) *DescribeTableStatisticsInput

+ func (s *DescribeTableStatisticsInput) SetMaxRecords(v int64) *DescribeTableStatisticsInput

+ func (s *DescribeTableStatisticsInput) SetReplicationTaskArn(v string) *DescribeTableStatisticsInput

+ func (s *DescribeTableStatisticsInput) Validate() error

+ func (s DescribeTableStatisticsInput) GoString() string

+ func (s DescribeTableStatisticsInput) String() string

+ type DescribeTableStatisticsOutput struct

+ Marker *string

+ ReplicationTaskArn *string

+ TableStatistics []TableStatistics

+ func (s *DescribeTableStatisticsOutput) SetMarker(v string) *DescribeTableStatisticsOutput

+ func (s *DescribeTableStatisticsOutput) SetReplicationTaskArn(v string) *DescribeTableStatisticsOutput

+ func (s *DescribeTableStatisticsOutput) SetTableStatistics(v []TableStatistics) *DescribeTableStatisticsOutput

+ func (s DescribeTableStatisticsOutput) GoString() string

+ func (s DescribeTableStatisticsOutput) SDKResponseMetadata() aws.Response

+ func (s DescribeTableStatisticsOutput) String() string

+ type DescribeTableStatisticsRequest struct

+ Input *DescribeTableStatisticsInput

+ func (r DescribeTableStatisticsRequest) Send() (*DescribeTableStatisticsOutput, error)

+ type DmsSslModeValue string

+ const DmsSslModeValueNone

+ const DmsSslModeValueRequire

+ const DmsSslModeValueVerifyCa

+ const DmsSslModeValueVerifyFull

+ type DynamoDbSettings struct

+ ServiceAccessRoleArn *string

+ func (s *DynamoDbSettings) SetServiceAccessRoleArn(v string) *DynamoDbSettings

+ func (s *DynamoDbSettings) Validate() error

+ func (s DynamoDbSettings) GoString() string

+ func (s DynamoDbSettings) String() string

+ type Endpoint struct

+ CertificateArn *string

+ DatabaseName *string

+ DynamoDbSettings *DynamoDbSettings

+ EndpointArn *string

+ EndpointIdentifier *string

+ EndpointType ReplicationEndpointTypeValue

+ EngineName *string

+ ExternalId *string

+ ExtraConnectionAttributes *string

+ KmsKeyId *string

+ MongoDbSettings *MongoDbSettings

+ Port *int64

+ S3Settings *S3Settings

+ ServerName *string

+ SslMode DmsSslModeValue

+ Status *string

+ Username *string

+ func (s *Endpoint) SetCertificateArn(v string) *Endpoint

+ func (s *Endpoint) SetDatabaseName(v string) *Endpoint

+ func (s *Endpoint) SetDynamoDbSettings(v *DynamoDbSettings) *Endpoint

+ func (s *Endpoint) SetEndpointArn(v string) *Endpoint

+ func (s *Endpoint) SetEndpointIdentifier(v string) *Endpoint

+ func (s *Endpoint) SetEndpointType(v ReplicationEndpointTypeValue) *Endpoint

+ func (s *Endpoint) SetEngineName(v string) *Endpoint

+ func (s *Endpoint) SetExternalId(v string) *Endpoint

+ func (s *Endpoint) SetExtraConnectionAttributes(v string) *Endpoint

+ func (s *Endpoint) SetKmsKeyId(v string) *Endpoint

+ func (s *Endpoint) SetMongoDbSettings(v *MongoDbSettings) *Endpoint

+ func (s *Endpoint) SetPort(v int64) *Endpoint

+ func (s *Endpoint) SetS3Settings(v *S3Settings) *Endpoint

+ func (s *Endpoint) SetServerName(v string) *Endpoint

+ func (s *Endpoint) SetSslMode(v DmsSslModeValue) *Endpoint

+ func (s *Endpoint) SetStatus(v string) *Endpoint

+ func (s *Endpoint) SetUsername(v string) *Endpoint

+ func (s Endpoint) GoString() string

+ func (s Endpoint) String() string

+ type Event struct

+ Date *time.Time

+ EventCategories []string

+ Message *string

+ SourceIdentifier *string

+ SourceType SourceType

+ func (s *Event) SetDate(v time.Time) *Event

+ func (s *Event) SetEventCategories(v []string) *Event

+ func (s *Event) SetMessage(v string) *Event

+ func (s *Event) SetSourceIdentifier(v string) *Event

+ func (s *Event) SetSourceType(v SourceType) *Event

+ func (s Event) GoString() string

+ func (s Event) String() string

+ type EventCategoryGroup struct

+ EventCategories []string

+ SourceType *string

+ func (s *EventCategoryGroup) SetEventCategories(v []string) *EventCategoryGroup

+ func (s *EventCategoryGroup) SetSourceType(v string) *EventCategoryGroup

+ func (s EventCategoryGroup) GoString() string

+ func (s EventCategoryGroup) String() string

+ type EventSubscription struct

+ CustSubscriptionId *string

+ CustomerAwsId *string

+ Enabled *bool

+ EventCategoriesList []string

+ SnsTopicArn *string

+ SourceIdsList []string

+ SourceType *string

+ Status *string

+ SubscriptionCreationTime *string

+ func (s *EventSubscription) SetCustSubscriptionId(v string) *EventSubscription

+ func (s *EventSubscription) SetCustomerAwsId(v string) *EventSubscription

+ func (s *EventSubscription) SetEnabled(v bool) *EventSubscription

+ func (s *EventSubscription) SetEventCategoriesList(v []string) *EventSubscription

+ func (s *EventSubscription) SetSnsTopicArn(v string) *EventSubscription

+ func (s *EventSubscription) SetSourceIdsList(v []string) *EventSubscription

+ func (s *EventSubscription) SetSourceType(v string) *EventSubscription

+ func (s *EventSubscription) SetStatus(v string) *EventSubscription

+ func (s *EventSubscription) SetSubscriptionCreationTime(v string) *EventSubscription

+ func (s EventSubscription) GoString() string

+ func (s EventSubscription) String() string

+ type Filter struct

+ Name *string

+ Values []string

+ func (s *Filter) SetName(v string) *Filter

+ func (s *Filter) SetValues(v []string) *Filter

+ func (s *Filter) Validate() error

+ func (s Filter) GoString() string

+ func (s Filter) String() string

+ type ImportCertificateInput struct

+ CertificateIdentifier *string

+ CertificatePem *string

+ CertificateWallet []byte

+ Tags []Tag

+ func (s *ImportCertificateInput) SetCertificateIdentifier(v string) *ImportCertificateInput

+ func (s *ImportCertificateInput) SetCertificatePem(v string) *ImportCertificateInput

+ func (s *ImportCertificateInput) SetCertificateWallet(v []byte) *ImportCertificateInput

+ func (s *ImportCertificateInput) SetTags(v []Tag) *ImportCertificateInput

+ func (s *ImportCertificateInput) Validate() error

+ func (s ImportCertificateInput) GoString() string

+ func (s ImportCertificateInput) String() string

+ type ImportCertificateOutput struct

+ Certificate *Certificate

+ func (s *ImportCertificateOutput) SetCertificate(v *Certificate) *ImportCertificateOutput

+ func (s ImportCertificateOutput) GoString() string

+ func (s ImportCertificateOutput) SDKResponseMetadata() aws.Response

+ func (s ImportCertificateOutput) String() string

+ type ImportCertificateRequest struct

+ Input *ImportCertificateInput

+ func (r ImportCertificateRequest) Send() (*ImportCertificateOutput, error)

+ type ListTagsForResourceInput struct

+ ResourceArn *string

+ func (s *ListTagsForResourceInput) SetResourceArn(v string) *ListTagsForResourceInput

+ func (s *ListTagsForResourceInput) Validate() error

+ func (s ListTagsForResourceInput) GoString() string

+ func (s ListTagsForResourceInput) String() string

+ type ListTagsForResourceOutput struct

+ TagList []Tag

+ func (s *ListTagsForResourceOutput) SetTagList(v []Tag) *ListTagsForResourceOutput

+ func (s ListTagsForResourceOutput) GoString() string

+ func (s ListTagsForResourceOutput) SDKResponseMetadata() aws.Response

+ func (s ListTagsForResourceOutput) String() string

+ type ListTagsForResourceRequest struct

+ Input *ListTagsForResourceInput

+ func (r ListTagsForResourceRequest) Send() (*ListTagsForResourceOutput, error)

+ type MigrationTypeValue string

+ const MigrationTypeValueCdc

+ const MigrationTypeValueFullLoad

+ const MigrationTypeValueFullLoadAndCdc

+ type ModifyEndpointInput struct

+ CertificateArn *string

+ DatabaseName *string

+ DynamoDbSettings *DynamoDbSettings

+ EndpointArn *string

+ EndpointIdentifier *string

+ EndpointType ReplicationEndpointTypeValue

+ EngineName *string

+ ExtraConnectionAttributes *string

+ MongoDbSettings *MongoDbSettings

+ Password *string

+ Port *int64

+ S3Settings *S3Settings

+ ServerName *string

+ SslMode DmsSslModeValue

+ Username *string

+ func (s *ModifyEndpointInput) SetCertificateArn(v string) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) SetDatabaseName(v string) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) SetDynamoDbSettings(v *DynamoDbSettings) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) SetEndpointArn(v string) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) SetEndpointIdentifier(v string) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) SetEndpointType(v ReplicationEndpointTypeValue) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) SetEngineName(v string) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) SetExtraConnectionAttributes(v string) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) SetMongoDbSettings(v *MongoDbSettings) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) SetPassword(v string) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) SetPort(v int64) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) SetS3Settings(v *S3Settings) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) SetServerName(v string) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) SetSslMode(v DmsSslModeValue) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) SetUsername(v string) *ModifyEndpointInput

+ func (s *ModifyEndpointInput) Validate() error

+ func (s ModifyEndpointInput) GoString() string

+ func (s ModifyEndpointInput) String() string

+ type ModifyEndpointOutput struct

+ Endpoint *Endpoint

+ func (s *ModifyEndpointOutput) SetEndpoint(v *Endpoint) *ModifyEndpointOutput

+ func (s ModifyEndpointOutput) GoString() string

+ func (s ModifyEndpointOutput) SDKResponseMetadata() aws.Response

+ func (s ModifyEndpointOutput) String() string

+ type ModifyEndpointRequest struct

+ Input *ModifyEndpointInput

+ func (r ModifyEndpointRequest) Send() (*ModifyEndpointOutput, error)

+ type ModifyEventSubscriptionInput struct

+ Enabled *bool

+ EventCategories []string

+ SnsTopicArn *string

+ SourceType *string

+ SubscriptionName *string

+ func (s *ModifyEventSubscriptionInput) SetEnabled(v bool) *ModifyEventSubscriptionInput

+ func (s *ModifyEventSubscriptionInput) SetEventCategories(v []string) *ModifyEventSubscriptionInput

+ func (s *ModifyEventSubscriptionInput) SetSnsTopicArn(v string) *ModifyEventSubscriptionInput

+ func (s *ModifyEventSubscriptionInput) SetSourceType(v string) *ModifyEventSubscriptionInput

+ func (s *ModifyEventSubscriptionInput) SetSubscriptionName(v string) *ModifyEventSubscriptionInput

+ func (s *ModifyEventSubscriptionInput) Validate() error

+ func (s ModifyEventSubscriptionInput) GoString() string

+ func (s ModifyEventSubscriptionInput) String() string

+ type ModifyEventSubscriptionOutput struct

+ EventSubscription *EventSubscription

+ func (s *ModifyEventSubscriptionOutput) SetEventSubscription(v *EventSubscription) *ModifyEventSubscriptionOutput

+ func (s ModifyEventSubscriptionOutput) GoString() string

+ func (s ModifyEventSubscriptionOutput) SDKResponseMetadata() aws.Response

+ func (s ModifyEventSubscriptionOutput) String() string

+ type ModifyEventSubscriptionRequest struct

+ Input *ModifyEventSubscriptionInput

+ func (r ModifyEventSubscriptionRequest) Send() (*ModifyEventSubscriptionOutput, error)

+ type ModifyReplicationInstanceInput struct

+ AllocatedStorage *int64

+ AllowMajorVersionUpgrade *bool

+ ApplyImmediately *bool

+ AutoMinorVersionUpgrade *bool

+ EngineVersion *string

+ MultiAZ *bool

+ PreferredMaintenanceWindow *string

+ ReplicationInstanceArn *string

+ ReplicationInstanceClass *string

+ ReplicationInstanceIdentifier *string

+ VpcSecurityGroupIds []string

+ func (s *ModifyReplicationInstanceInput) SetAllocatedStorage(v int64) *ModifyReplicationInstanceInput

+ func (s *ModifyReplicationInstanceInput) SetAllowMajorVersionUpgrade(v bool) *ModifyReplicationInstanceInput

+ func (s *ModifyReplicationInstanceInput) SetApplyImmediately(v bool) *ModifyReplicationInstanceInput

+ func (s *ModifyReplicationInstanceInput) SetAutoMinorVersionUpgrade(v bool) *ModifyReplicationInstanceInput

+ func (s *ModifyReplicationInstanceInput) SetEngineVersion(v string) *ModifyReplicationInstanceInput

+ func (s *ModifyReplicationInstanceInput) SetMultiAZ(v bool) *ModifyReplicationInstanceInput

+ func (s *ModifyReplicationInstanceInput) SetPreferredMaintenanceWindow(v string) *ModifyReplicationInstanceInput

+ func (s *ModifyReplicationInstanceInput) SetReplicationInstanceArn(v string) *ModifyReplicationInstanceInput

+ func (s *ModifyReplicationInstanceInput) SetReplicationInstanceClass(v string) *ModifyReplicationInstanceInput

+ func (s *ModifyReplicationInstanceInput) SetReplicationInstanceIdentifier(v string) *ModifyReplicationInstanceInput

+ func (s *ModifyReplicationInstanceInput) SetVpcSecurityGroupIds(v []string) *ModifyReplicationInstanceInput

+ func (s *ModifyReplicationInstanceInput) Validate() error

+ func (s ModifyReplicationInstanceInput) GoString() string

+ func (s ModifyReplicationInstanceInput) String() string

+ type ModifyReplicationInstanceOutput struct

+ ReplicationInstance *ReplicationInstance

+ func (s *ModifyReplicationInstanceOutput) SetReplicationInstance(v *ReplicationInstance) *ModifyReplicationInstanceOutput

+ func (s ModifyReplicationInstanceOutput) GoString() string

+ func (s ModifyReplicationInstanceOutput) SDKResponseMetadata() aws.Response

+ func (s ModifyReplicationInstanceOutput) String() string

+ type ModifyReplicationInstanceRequest struct

+ Input *ModifyReplicationInstanceInput

+ func (r ModifyReplicationInstanceRequest) Send() (*ModifyReplicationInstanceOutput, error)

+ type ModifyReplicationSubnetGroupInput struct

+ ReplicationSubnetGroupDescription *string

+ ReplicationSubnetGroupIdentifier *string

+ SubnetIds []string

+ func (s *ModifyReplicationSubnetGroupInput) SetReplicationSubnetGroupDescription(v string) *ModifyReplicationSubnetGroupInput

+ func (s *ModifyReplicationSubnetGroupInput) SetReplicationSubnetGroupIdentifier(v string) *ModifyReplicationSubnetGroupInput

+ func (s *ModifyReplicationSubnetGroupInput) SetSubnetIds(v []string) *ModifyReplicationSubnetGroupInput

+ func (s *ModifyReplicationSubnetGroupInput) Validate() error

+ func (s ModifyReplicationSubnetGroupInput) GoString() string

+ func (s ModifyReplicationSubnetGroupInput) String() string

+ type ModifyReplicationSubnetGroupOutput struct

+ ReplicationSubnetGroup *ReplicationSubnetGroup

+ func (s *ModifyReplicationSubnetGroupOutput) SetReplicationSubnetGroup(v *ReplicationSubnetGroup) *ModifyReplicationSubnetGroupOutput

+ func (s ModifyReplicationSubnetGroupOutput) GoString() string

+ func (s ModifyReplicationSubnetGroupOutput) SDKResponseMetadata() aws.Response

+ func (s ModifyReplicationSubnetGroupOutput) String() string

+ type ModifyReplicationSubnetGroupRequest struct

+ Input *ModifyReplicationSubnetGroupInput

+ func (r ModifyReplicationSubnetGroupRequest) Send() (*ModifyReplicationSubnetGroupOutput, error)

+ type ModifyReplicationTaskInput struct

+ CdcStartTime *time.Time

+ MigrationType MigrationTypeValue

+ ReplicationTaskArn *string

+ ReplicationTaskIdentifier *string

+ ReplicationTaskSettings *string

+ TableMappings *string

+ func (s *ModifyReplicationTaskInput) SetCdcStartTime(v time.Time) *ModifyReplicationTaskInput

+ func (s *ModifyReplicationTaskInput) SetMigrationType(v MigrationTypeValue) *ModifyReplicationTaskInput

+ func (s *ModifyReplicationTaskInput) SetReplicationTaskArn(v string) *ModifyReplicationTaskInput

+ func (s *ModifyReplicationTaskInput) SetReplicationTaskIdentifier(v string) *ModifyReplicationTaskInput

+ func (s *ModifyReplicationTaskInput) SetReplicationTaskSettings(v string) *ModifyReplicationTaskInput

+ func (s *ModifyReplicationTaskInput) SetTableMappings(v string) *ModifyReplicationTaskInput

+ func (s *ModifyReplicationTaskInput) Validate() error

+ func (s ModifyReplicationTaskInput) GoString() string

+ func (s ModifyReplicationTaskInput) String() string

+ type ModifyReplicationTaskOutput struct

+ ReplicationTask *ReplicationTask

+ func (s *ModifyReplicationTaskOutput) SetReplicationTask(v *ReplicationTask) *ModifyReplicationTaskOutput

+ func (s ModifyReplicationTaskOutput) GoString() string

+ func (s ModifyReplicationTaskOutput) SDKResponseMetadata() aws.Response

+ func (s ModifyReplicationTaskOutput) String() string

+ type ModifyReplicationTaskRequest struct

+ Input *ModifyReplicationTaskInput

+ func (r ModifyReplicationTaskRequest) Send() (*ModifyReplicationTaskOutput, error)

+ type MongoDbSettings struct

+ AuthMechanism AuthMechanismValue

+ AuthSource *string

+ AuthType AuthTypeValue

+ DatabaseName *string

+ DocsToInvestigate *string

+ ExtractDocId *string

+ NestingLevel NestingLevelValue

+ Password *string

+ Port *int64

+ ServerName *string

+ Username *string

+ func (s *MongoDbSettings) SetAuthMechanism(v AuthMechanismValue) *MongoDbSettings

+ func (s *MongoDbSettings) SetAuthSource(v string) *MongoDbSettings

+ func (s *MongoDbSettings) SetAuthType(v AuthTypeValue) *MongoDbSettings

+ func (s *MongoDbSettings) SetDatabaseName(v string) *MongoDbSettings

+ func (s *MongoDbSettings) SetDocsToInvestigate(v string) *MongoDbSettings

+ func (s *MongoDbSettings) SetExtractDocId(v string) *MongoDbSettings

+ func (s *MongoDbSettings) SetNestingLevel(v NestingLevelValue) *MongoDbSettings

+ func (s *MongoDbSettings) SetPassword(v string) *MongoDbSettings

+ func (s *MongoDbSettings) SetPort(v int64) *MongoDbSettings

+ func (s *MongoDbSettings) SetServerName(v string) *MongoDbSettings

+ func (s *MongoDbSettings) SetUsername(v string) *MongoDbSettings

+ func (s MongoDbSettings) GoString() string

+ func (s MongoDbSettings) String() string

+ type NestingLevelValue string

+ const NestingLevelValueNone

+ const NestingLevelValueOne

+ type OrderableReplicationInstance struct

+ DefaultAllocatedStorage *int64

+ EngineVersion *string

+ IncludedAllocatedStorage *int64

+ MaxAllocatedStorage *int64

+ MinAllocatedStorage *int64

+ ReplicationInstanceClass *string

+ StorageType *string

+ func (s *OrderableReplicationInstance) SetDefaultAllocatedStorage(v int64) *OrderableReplicationInstance

+ func (s *OrderableReplicationInstance) SetEngineVersion(v string) *OrderableReplicationInstance

+ func (s *OrderableReplicationInstance) SetIncludedAllocatedStorage(v int64) *OrderableReplicationInstance

+ func (s *OrderableReplicationInstance) SetMaxAllocatedStorage(v int64) *OrderableReplicationInstance

+ func (s *OrderableReplicationInstance) SetMinAllocatedStorage(v int64) *OrderableReplicationInstance

+ func (s *OrderableReplicationInstance) SetReplicationInstanceClass(v string) *OrderableReplicationInstance

+ func (s *OrderableReplicationInstance) SetStorageType(v string) *OrderableReplicationInstance

+ func (s OrderableReplicationInstance) GoString() string

+ func (s OrderableReplicationInstance) String() string

+ type RefreshSchemasInput struct

+ EndpointArn *string

+ ReplicationInstanceArn *string

+ func (s *RefreshSchemasInput) SetEndpointArn(v string) *RefreshSchemasInput

+ func (s *RefreshSchemasInput) SetReplicationInstanceArn(v string) *RefreshSchemasInput

+ func (s *RefreshSchemasInput) Validate() error

+ func (s RefreshSchemasInput) GoString() string

+ func (s RefreshSchemasInput) String() string

+ type RefreshSchemasOutput struct

+ RefreshSchemasStatus *RefreshSchemasStatus

+ func (s *RefreshSchemasOutput) SetRefreshSchemasStatus(v *RefreshSchemasStatus) *RefreshSchemasOutput

+ func (s RefreshSchemasOutput) GoString() string

+ func (s RefreshSchemasOutput) SDKResponseMetadata() aws.Response

+ func (s RefreshSchemasOutput) String() string

+ type RefreshSchemasRequest struct

+ Input *RefreshSchemasInput

+ func (r RefreshSchemasRequest) Send() (*RefreshSchemasOutput, error)

+ type RefreshSchemasStatus struct

+ EndpointArn *string

+ LastFailureMessage *string

+ LastRefreshDate *time.Time

+ ReplicationInstanceArn *string

+ Status RefreshSchemasStatusTypeValue

+ func (s *RefreshSchemasStatus) SetEndpointArn(v string) *RefreshSchemasStatus

+ func (s *RefreshSchemasStatus) SetLastFailureMessage(v string) *RefreshSchemasStatus

+ func (s *RefreshSchemasStatus) SetLastRefreshDate(v time.Time) *RefreshSchemasStatus

+ func (s *RefreshSchemasStatus) SetReplicationInstanceArn(v string) *RefreshSchemasStatus

+ func (s *RefreshSchemasStatus) SetStatus(v RefreshSchemasStatusTypeValue) *RefreshSchemasStatus

+ func (s RefreshSchemasStatus) GoString() string

+ func (s RefreshSchemasStatus) String() string

+ type RefreshSchemasStatusTypeValue string

+ const RefreshSchemasStatusTypeValueFailed

+ const RefreshSchemasStatusTypeValueRefreshing

+ const RefreshSchemasStatusTypeValueSuccessful

+ type ReloadTablesInput struct

+ ReplicationTaskArn *string

+ TablesToReload []TableToReload

+ func (s *ReloadTablesInput) SetReplicationTaskArn(v string) *ReloadTablesInput

+ func (s *ReloadTablesInput) SetTablesToReload(v []TableToReload) *ReloadTablesInput

+ func (s *ReloadTablesInput) Validate() error

+ func (s ReloadTablesInput) GoString() string

+ func (s ReloadTablesInput) String() string

+ type ReloadTablesOutput struct

+ ReplicationTaskArn *string

+ func (s *ReloadTablesOutput) SetReplicationTaskArn(v string) *ReloadTablesOutput

+ func (s ReloadTablesOutput) GoString() string

+ func (s ReloadTablesOutput) SDKResponseMetadata() aws.Response

+ func (s ReloadTablesOutput) String() string

+ type ReloadTablesRequest struct

+ Input *ReloadTablesInput

+ func (r ReloadTablesRequest) Send() (*ReloadTablesOutput, error)

+ type RemoveTagsFromResourceInput struct

+ ResourceArn *string

+ TagKeys []string

+ func (s *RemoveTagsFromResourceInput) SetResourceArn(v string) *RemoveTagsFromResourceInput

+ func (s *RemoveTagsFromResourceInput) SetTagKeys(v []string) *RemoveTagsFromResourceInput

+ func (s *RemoveTagsFromResourceInput) Validate() error

+ func (s RemoveTagsFromResourceInput) GoString() string

+ func (s RemoveTagsFromResourceInput) String() string

+ type RemoveTagsFromResourceOutput struct

+ func (s RemoveTagsFromResourceOutput) GoString() string

+ func (s RemoveTagsFromResourceOutput) SDKResponseMetadata() aws.Response

+ func (s RemoveTagsFromResourceOutput) String() string

+ type RemoveTagsFromResourceRequest struct

+ Input *RemoveTagsFromResourceInput

+ func (r RemoveTagsFromResourceRequest) Send() (*RemoveTagsFromResourceOutput, error)

+ type ReplicationEndpointTypeValue string

+ const ReplicationEndpointTypeValueSource

+ const ReplicationEndpointTypeValueTarget

+ type ReplicationInstance struct

+ AllocatedStorage *int64

+ AutoMinorVersionUpgrade *bool

+ AvailabilityZone *string

+ EngineVersion *string

+ InstanceCreateTime *time.Time

+ KmsKeyId *string

+ MultiAZ *bool

+ PendingModifiedValues *ReplicationPendingModifiedValues

+ PreferredMaintenanceWindow *string

+ PubliclyAccessible *bool

+ ReplicationInstanceArn *string

+ ReplicationInstanceClass *string

+ ReplicationInstanceIdentifier *string

+ ReplicationInstancePrivateIpAddress *string

+ ReplicationInstancePrivateIpAddresses []string

+ ReplicationInstancePublicIpAddress *string

+ ReplicationInstancePublicIpAddresses []string

+ ReplicationInstanceStatus *string

+ ReplicationSubnetGroup *ReplicationSubnetGroup

+ SecondaryAvailabilityZone *string

+ VpcSecurityGroups []VpcSecurityGroupMembership

+ func (s *ReplicationInstance) SetAllocatedStorage(v int64) *ReplicationInstance

+ func (s *ReplicationInstance) SetAutoMinorVersionUpgrade(v bool) *ReplicationInstance

+ func (s *ReplicationInstance) SetAvailabilityZone(v string) *ReplicationInstance

+ func (s *ReplicationInstance) SetEngineVersion(v string) *ReplicationInstance

+ func (s *ReplicationInstance) SetInstanceCreateTime(v time.Time) *ReplicationInstance

+ func (s *ReplicationInstance) SetKmsKeyId(v string) *ReplicationInstance

+ func (s *ReplicationInstance) SetMultiAZ(v bool) *ReplicationInstance

+ func (s *ReplicationInstance) SetPendingModifiedValues(v *ReplicationPendingModifiedValues) *ReplicationInstance

+ func (s *ReplicationInstance) SetPreferredMaintenanceWindow(v string) *ReplicationInstance

+ func (s *ReplicationInstance) SetPubliclyAccessible(v bool) *ReplicationInstance

+ func (s *ReplicationInstance) SetReplicationInstanceArn(v string) *ReplicationInstance

+ func (s *ReplicationInstance) SetReplicationInstanceClass(v string) *ReplicationInstance

+ func (s *ReplicationInstance) SetReplicationInstanceIdentifier(v string) *ReplicationInstance

+ func (s *ReplicationInstance) SetReplicationInstancePrivateIpAddress(v string) *ReplicationInstance

+ func (s *ReplicationInstance) SetReplicationInstancePrivateIpAddresses(v []string) *ReplicationInstance

+ func (s *ReplicationInstance) SetReplicationInstancePublicIpAddress(v string) *ReplicationInstance

+ func (s *ReplicationInstance) SetReplicationInstancePublicIpAddresses(v []string) *ReplicationInstance

+ func (s *ReplicationInstance) SetReplicationInstanceStatus(v string) *ReplicationInstance

+ func (s *ReplicationInstance) SetReplicationSubnetGroup(v *ReplicationSubnetGroup) *ReplicationInstance

+ func (s *ReplicationInstance) SetSecondaryAvailabilityZone(v string) *ReplicationInstance

+ func (s *ReplicationInstance) SetVpcSecurityGroups(v []VpcSecurityGroupMembership) *ReplicationInstance

+ func (s ReplicationInstance) GoString() string

+ func (s ReplicationInstance) String() string

+ type ReplicationPendingModifiedValues struct

+ AllocatedStorage *int64

+ EngineVersion *string

+ MultiAZ *bool

+ ReplicationInstanceClass *string

+ func (s *ReplicationPendingModifiedValues) SetAllocatedStorage(v int64) *ReplicationPendingModifiedValues

+ func (s *ReplicationPendingModifiedValues) SetEngineVersion(v string) *ReplicationPendingModifiedValues

+ func (s *ReplicationPendingModifiedValues) SetMultiAZ(v bool) *ReplicationPendingModifiedValues

+ func (s *ReplicationPendingModifiedValues) SetReplicationInstanceClass(v string) *ReplicationPendingModifiedValues

+ func (s ReplicationPendingModifiedValues) GoString() string

+ func (s ReplicationPendingModifiedValues) String() string

+ type ReplicationSubnetGroup struct

+ ReplicationSubnetGroupDescription *string

+ ReplicationSubnetGroupIdentifier *string

+ SubnetGroupStatus *string

+ Subnets []Subnet

+ VpcId *string

+ func (s *ReplicationSubnetGroup) SetReplicationSubnetGroupDescription(v string) *ReplicationSubnetGroup

+ func (s *ReplicationSubnetGroup) SetReplicationSubnetGroupIdentifier(v string) *ReplicationSubnetGroup

+ func (s *ReplicationSubnetGroup) SetSubnetGroupStatus(v string) *ReplicationSubnetGroup

+ func (s *ReplicationSubnetGroup) SetSubnets(v []Subnet) *ReplicationSubnetGroup

+ func (s *ReplicationSubnetGroup) SetVpcId(v string) *ReplicationSubnetGroup

+ func (s ReplicationSubnetGroup) GoString() string

+ func (s ReplicationSubnetGroup) String() string

+ type ReplicationTask struct

+ LastFailureMessage *string

+ MigrationType MigrationTypeValue

+ ReplicationInstanceArn *string

+ ReplicationTaskArn *string

+ ReplicationTaskCreationDate *time.Time

+ ReplicationTaskIdentifier *string

+ ReplicationTaskSettings *string

+ ReplicationTaskStartDate *time.Time

+ ReplicationTaskStats *ReplicationTaskStats

+ SourceEndpointArn *string

+ Status *string

+ StopReason *string

+ TableMappings *string

+ TargetEndpointArn *string

+ func (s *ReplicationTask) SetLastFailureMessage(v string) *ReplicationTask

+ func (s *ReplicationTask) SetMigrationType(v MigrationTypeValue) *ReplicationTask

+ func (s *ReplicationTask) SetReplicationInstanceArn(v string) *ReplicationTask

+ func (s *ReplicationTask) SetReplicationTaskArn(v string) *ReplicationTask

+ func (s *ReplicationTask) SetReplicationTaskCreationDate(v time.Time) *ReplicationTask

+ func (s *ReplicationTask) SetReplicationTaskIdentifier(v string) *ReplicationTask

+ func (s *ReplicationTask) SetReplicationTaskSettings(v string) *ReplicationTask

+ func (s *ReplicationTask) SetReplicationTaskStartDate(v time.Time) *ReplicationTask

+ func (s *ReplicationTask) SetReplicationTaskStats(v *ReplicationTaskStats) *ReplicationTask

+ func (s *ReplicationTask) SetSourceEndpointArn(v string) *ReplicationTask

+ func (s *ReplicationTask) SetStatus(v string) *ReplicationTask

+ func (s *ReplicationTask) SetStopReason(v string) *ReplicationTask

+ func (s *ReplicationTask) SetTableMappings(v string) *ReplicationTask

+ func (s *ReplicationTask) SetTargetEndpointArn(v string) *ReplicationTask

+ func (s ReplicationTask) GoString() string

+ func (s ReplicationTask) String() string

+ type ReplicationTaskStats struct

+ ElapsedTimeMillis *int64

+ FullLoadProgressPercent *int64

+ TablesErrored *int64

+ TablesLoaded *int64

+ TablesLoading *int64

+ TablesQueued *int64

+ func (s *ReplicationTaskStats) SetElapsedTimeMillis(v int64) *ReplicationTaskStats

+ func (s *ReplicationTaskStats) SetFullLoadProgressPercent(v int64) *ReplicationTaskStats

+ func (s *ReplicationTaskStats) SetTablesErrored(v int64) *ReplicationTaskStats

+ func (s *ReplicationTaskStats) SetTablesLoaded(v int64) *ReplicationTaskStats

+ func (s *ReplicationTaskStats) SetTablesLoading(v int64) *ReplicationTaskStats

+ func (s *ReplicationTaskStats) SetTablesQueued(v int64) *ReplicationTaskStats

+ func (s ReplicationTaskStats) GoString() string

+ func (s ReplicationTaskStats) String() string

+ type S3Settings struct

+ BucketFolder *string

+ BucketName *string

+ CompressionType CompressionTypeValue

+ CsvDelimiter *string

+ CsvRowDelimiter *string

+ ExternalTableDefinition *string

+ ServiceAccessRoleArn *string

+ func (s *S3Settings) SetBucketFolder(v string) *S3Settings

+ func (s *S3Settings) SetBucketName(v string) *S3Settings

+ func (s *S3Settings) SetCompressionType(v CompressionTypeValue) *S3Settings

+ func (s *S3Settings) SetCsvDelimiter(v string) *S3Settings

+ func (s *S3Settings) SetCsvRowDelimiter(v string) *S3Settings

+ func (s *S3Settings) SetExternalTableDefinition(v string) *S3Settings

+ func (s *S3Settings) SetServiceAccessRoleArn(v string) *S3Settings

+ func (s S3Settings) GoString() string

+ func (s S3Settings) String() string

+ type SourceType string

+ const SourceTypeReplicationInstance

+ type StartReplicationTaskInput struct

+ CdcStartTime *time.Time

+ ReplicationTaskArn *string

+ StartReplicationTaskType StartReplicationTaskTypeValue

+ func (s *StartReplicationTaskInput) SetCdcStartTime(v time.Time) *StartReplicationTaskInput

+ func (s *StartReplicationTaskInput) SetReplicationTaskArn(v string) *StartReplicationTaskInput

+ func (s *StartReplicationTaskInput) SetStartReplicationTaskType(v StartReplicationTaskTypeValue) *StartReplicationTaskInput

+ func (s *StartReplicationTaskInput) Validate() error

+ func (s StartReplicationTaskInput) GoString() string

+ func (s StartReplicationTaskInput) String() string

+ type StartReplicationTaskOutput struct

+ ReplicationTask *ReplicationTask

+ func (s *StartReplicationTaskOutput) SetReplicationTask(v *ReplicationTask) *StartReplicationTaskOutput

+ func (s StartReplicationTaskOutput) GoString() string

+ func (s StartReplicationTaskOutput) SDKResponseMetadata() aws.Response

+ func (s StartReplicationTaskOutput) String() string

+ type StartReplicationTaskRequest struct

+ Input *StartReplicationTaskInput

+ func (r StartReplicationTaskRequest) Send() (*StartReplicationTaskOutput, error)

+ type StartReplicationTaskTypeValue string

+ const StartReplicationTaskTypeValueReloadTarget

+ const StartReplicationTaskTypeValueResumeProcessing

+ const StartReplicationTaskTypeValueStartReplication

+ type StopReplicationTaskInput struct

+ ReplicationTaskArn *string

+ func (s *StopReplicationTaskInput) SetReplicationTaskArn(v string) *StopReplicationTaskInput

+ func (s *StopReplicationTaskInput) Validate() error

+ func (s StopReplicationTaskInput) GoString() string

+ func (s StopReplicationTaskInput) String() string

+ type StopReplicationTaskOutput struct

+ ReplicationTask *ReplicationTask

+ func (s *StopReplicationTaskOutput) SetReplicationTask(v *ReplicationTask) *StopReplicationTaskOutput

+ func (s StopReplicationTaskOutput) GoString() string

+ func (s StopReplicationTaskOutput) SDKResponseMetadata() aws.Response

+ func (s StopReplicationTaskOutput) String() string

+ type StopReplicationTaskRequest struct

+ Input *StopReplicationTaskInput

+ func (r StopReplicationTaskRequest) Send() (*StopReplicationTaskOutput, error)

+ type Subnet struct

+ SubnetAvailabilityZone *AvailabilityZone

+ SubnetIdentifier *string

+ SubnetStatus *string

+ func (s *Subnet) SetSubnetAvailabilityZone(v *AvailabilityZone) *Subnet

+ func (s *Subnet) SetSubnetIdentifier(v string) *Subnet

+ func (s *Subnet) SetSubnetStatus(v string) *Subnet

+ func (s Subnet) GoString() string

+ func (s Subnet) String() string

+ type SupportedEndpointType struct

+ EndpointType ReplicationEndpointTypeValue

+ EngineName *string

+ SupportsCDC *bool

+ func (s *SupportedEndpointType) SetEndpointType(v ReplicationEndpointTypeValue) *SupportedEndpointType

+ func (s *SupportedEndpointType) SetEngineName(v string) *SupportedEndpointType

+ func (s *SupportedEndpointType) SetSupportsCDC(v bool) *SupportedEndpointType

+ func (s SupportedEndpointType) GoString() string

+ func (s SupportedEndpointType) String() string

+ type TableStatistics struct

+ Ddls *int64

+ Deletes *int64

+ FullLoadCondtnlChkFailedRows *int64

+ FullLoadErrorRows *int64

+ FullLoadRows *int64

+ Inserts *int64

+ LastUpdateTime *time.Time

+ SchemaName *string

+ TableName *string

+ TableState *string

+ Updates *int64

+ func (s *TableStatistics) SetDdls(v int64) *TableStatistics

+ func (s *TableStatistics) SetDeletes(v int64) *TableStatistics

+ func (s *TableStatistics) SetFullLoadCondtnlChkFailedRows(v int64) *TableStatistics

+ func (s *TableStatistics) SetFullLoadErrorRows(v int64) *TableStatistics

+ func (s *TableStatistics) SetFullLoadRows(v int64) *TableStatistics

+ func (s *TableStatistics) SetInserts(v int64) *TableStatistics

+ func (s *TableStatistics) SetLastUpdateTime(v time.Time) *TableStatistics

+ func (s *TableStatistics) SetSchemaName(v string) *TableStatistics

+ func (s *TableStatistics) SetTableName(v string) *TableStatistics

+ func (s *TableStatistics) SetTableState(v string) *TableStatistics

+ func (s *TableStatistics) SetUpdates(v int64) *TableStatistics

+ func (s TableStatistics) GoString() string

+ func (s TableStatistics) String() string

+ type TableToReload struct

+ SchemaName *string

+ TableName *string

+ func (s *TableToReload) SetSchemaName(v string) *TableToReload

+ func (s *TableToReload) SetTableName(v string) *TableToReload

+ func (s TableToReload) GoString() string

+ func (s TableToReload) String() string

+ type Tag struct

+ Key *string

+ Value *string

+ func (s *Tag) SetKey(v string) *Tag

+ func (s *Tag) SetValue(v string) *Tag

+ func (s Tag) GoString() string

+ func (s Tag) String() string

+ type TestConnectionInput struct

+ EndpointArn *string

+ ReplicationInstanceArn *string

+ func (s *TestConnectionInput) SetEndpointArn(v string) *TestConnectionInput

+ func (s *TestConnectionInput) SetReplicationInstanceArn(v string) *TestConnectionInput

+ func (s *TestConnectionInput) Validate() error

+ func (s TestConnectionInput) GoString() string

+ func (s TestConnectionInput) String() string

+ type TestConnectionOutput struct

+ Connection *Connection

+ func (s *TestConnectionOutput) SetConnection(v *Connection) *TestConnectionOutput

+ func (s TestConnectionOutput) GoString() string

+ func (s TestConnectionOutput) SDKResponseMetadata() aws.Response

+ func (s TestConnectionOutput) String() string

+ type TestConnectionRequest struct

+ Input *TestConnectionInput

+ func (r TestConnectionRequest) Send() (*TestConnectionOutput, error)

+ type VpcSecurityGroupMembership struct

+ Status *string

+ VpcSecurityGroupId *string

+ func (s *VpcSecurityGroupMembership) SetStatus(v string) *VpcSecurityGroupMembership

+ func (s *VpcSecurityGroupMembership) SetVpcSecurityGroupId(v string) *VpcSecurityGroupMembership

+ func (s VpcSecurityGroupMembership) GoString() string

+ func (s VpcSecurityGroupMembership) String() string

Incompatible versions in this module

v2.0.0-preview.4+incompatible

May 26, 2018

v2.0.0-preview.3+incompatible

Mar 8, 2018

v2.0.0-preview.2+incompatible

Jan 15, 2018

v2.0.0-preview.1+incompatible

Dec 21, 2017

Other modules containing this package

github.com/aws/aws-sdk-go-v2/service/databasemigrationservice

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