v1beta1

Jun 13, 2024

Changes in this version

type Endpoint

+ func (tr *Endpoint) ConvertFrom(srcRaw conversion.Hub) error

+ func (tr *Endpoint) ConvertTo(dstRaw conversion.Hub) error

May 24, 2024

Changes in this version

type CertificateInitParameters

+ CertificatePemSecretRef *v1.SecretKeySelector

+ CertificateWalletSecretRef *v1.SecretKeySelector

type EndpointInitParameters

+ PasswordSecretRef *v1.SecretKeySelector

type KafkaSettingsInitParameters

+ SSLClientKeyPasswordSecretRef *v1.SecretKeySelector

+ SaslPasswordSecretRef *v1.SecretKeySelector

type RedisSettingsInitParameters

+ AuthPasswordSecretRef *v1.SecretKeySelector

type ReplicationTaskInitParameters

+ ResourceIdentifier *string

type ReplicationTaskObservation

+ ResourceIdentifier *string

type ReplicationTaskParameters

+ ResourceIdentifier *string

Feb 1, 2024

Changes in this version

type ElasticsearchSettingsInitParameters

+ UseNewMappingType *bool

type ElasticsearchSettingsObservation

+ UseNewMappingType *bool

type ElasticsearchSettingsParameters

+ UseNewMappingType *bool

type EndpointInitParameters

+ PauseReplicationTasks *bool

+ PostgresSettings []PostgresSettingsInitParameters

type EndpointObservation

+ PauseReplicationTasks *bool

+ PostgresSettings []PostgresSettingsObservation

type EndpointParameters

+ PauseReplicationTasks *bool

+ PostgresSettings []PostgresSettingsParameters

+ type PostgresSettingsInitParameters struct

+ AfterConnectScript *string

+ BabelfishDatabaseName *string

+ CaptureDdls *bool

+ DatabaseMode *string

+ DdlArtifactsSchema *string

+ ExecuteTimeout *float64

+ FailTasksOnLobTruncation *bool

+ HeartbeatEnable *bool

+ HeartbeatFrequency *float64

+ HeartbeatSchema *string

+ MapBooleanAsBoolean *bool

+ MapJsonbAsClob *bool

+ MapLongVarcharAs *string

+ MaxFileSize *float64

+ PluginName *string

+ SlotName *string

+ func (in *PostgresSettingsInitParameters) DeepCopy() *PostgresSettingsInitParameters

+ func (in *PostgresSettingsInitParameters) DeepCopyInto(out *PostgresSettingsInitParameters)

+ type PostgresSettingsObservation struct

+ AfterConnectScript *string

+ BabelfishDatabaseName *string

+ CaptureDdls *bool

+ DatabaseMode *string

+ DdlArtifactsSchema *string

+ ExecuteTimeout *float64

+ FailTasksOnLobTruncation *bool

+ HeartbeatEnable *bool

+ HeartbeatFrequency *float64

+ HeartbeatSchema *string

+ MapBooleanAsBoolean *bool

+ MapJsonbAsClob *bool

+ MapLongVarcharAs *string

+ MaxFileSize *float64

+ PluginName *string

+ SlotName *string

+ func (in *PostgresSettingsObservation) DeepCopy() *PostgresSettingsObservation

+ func (in *PostgresSettingsObservation) DeepCopyInto(out *PostgresSettingsObservation)

+ type PostgresSettingsParameters struct

+ AfterConnectScript *string

+ BabelfishDatabaseName *string

+ CaptureDdls *bool

+ DatabaseMode *string

+ DdlArtifactsSchema *string

+ ExecuteTimeout *float64

+ FailTasksOnLobTruncation *bool

+ HeartbeatEnable *bool

+ HeartbeatFrequency *float64

+ HeartbeatSchema *string

+ MapBooleanAsBoolean *bool

+ MapJsonbAsClob *bool

+ MapLongVarcharAs *string

+ MaxFileSize *float64

+ PluginName *string

+ SlotName *string

+ func (in *PostgresSettingsParameters) DeepCopy() *PostgresSettingsParameters

+ func (in *PostgresSettingsParameters) DeepCopyInto(out *PostgresSettingsParameters)

type ReplicationInstanceInitParameters

+ NetworkType *string

type ReplicationInstanceObservation

+ NetworkType *string

type ReplicationInstanceParameters

+ NetworkType *string

type S3EndpointInitParameters

+ GlueCatalogGeneration *bool

type S3EndpointObservation

+ GlueCatalogGeneration *bool

type S3EndpointParameters

+ GlueCatalogGeneration *bool

type S3SettingsInitParameters

+ GlueCatalogGeneration *bool

type S3SettingsObservation

+ GlueCatalogGeneration *bool

type S3SettingsParameters

+ GlueCatalogGeneration *bool

Feb 16, 2024

Changes in this version

type Certificate

+ func (tr *Certificate) Hub()

type Endpoint

+ func (tr *Endpoint) Hub()

type EventSubscription

+ func (tr *EventSubscription) Hub()

type ReplicationInstance

+ func (tr *ReplicationInstance) Hub()

type ReplicationSubnetGroup

+ func (tr *ReplicationSubnetGroup) Hub()

type ReplicationTask

+ func (tr *ReplicationTask) Hub()

type S3Endpoint

+ func (tr *S3Endpoint) Hub()

Dec 28, 2023

Changes in this version

type EndpointInitParameters

+ KMSKeyArn *string

+ KMSKeyArnRef *v1.Reference

+ KMSKeyArnSelector *v1.Selector

+ SecretsManagerAccessRoleArn *string

+ SecretsManagerAccessRoleArnRef *v1.Reference

+ SecretsManagerAccessRoleArnSelector *v1.Selector

+ ServiceAccessRole *string

+ ServiceAccessRoleRef *v1.Reference

+ ServiceAccessRoleSelector *v1.Selector

type EventSubscriptionInitParameters

+ SnsTopicArn *string

+ SnsTopicArnRef *v1.Reference

+ SnsTopicArnSelector *v1.Selector

type ReplicationInstanceInitParameters

+ KMSKeyArn *string

+ KMSKeyArnRef *v1.Reference

+ KMSKeyArnSelector *v1.Selector

+ ReplicationSubnetGroupID *string

+ ReplicationSubnetGroupIDRef *v1.Reference

+ ReplicationSubnetGroupIDSelector *v1.Selector

+ VPCSecurityGroupIDRefs []v1.Reference

+ VPCSecurityGroupIDSelector *v1.Selector

+ VPCSecurityGroupIds []*string

type ReplicationSubnetGroupInitParameters

+ SubnetIDRefs []v1.Reference

+ SubnetIDSelector *v1.Selector

+ SubnetIds []*string

type ReplicationTaskInitParameters

+ ReplicationInstanceArn *string

+ ReplicationInstanceArnRef *v1.Reference

+ ReplicationInstanceArnSelector *v1.Selector

+ SourceEndpointArn *string

+ SourceEndpointArnRef *v1.Reference

+ SourceEndpointArnSelector *v1.Selector

+ TargetEndpointArn *string

+ TargetEndpointArnRef *v1.Reference

+ TargetEndpointArnSelector *v1.Selector

type S3EndpointInitParameters

+ KMSKeyArn *string

+ KMSKeyArnRef *v1.Reference

+ KMSKeyArnSelector *v1.Selector

+ ServerSideEncryptionKMSKeyID *string

+ ServerSideEncryptionKMSKeyIDRef *v1.Reference

+ ServerSideEncryptionKMSKeyIDSelector *v1.Selector

+ ServiceAccessRoleArn *string

+ ServiceAccessRoleArnRef *v1.Reference

+ ServiceAccessRoleArnSelector *v1.Selector

Nov 16, 2023

Changes in this version

type Certificate

+ func (tr *Certificate) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type Endpoint

+ func (tr *Endpoint) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type EventSubscription

+ func (tr *EventSubscription) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type ReplicationInstance

+ func (tr *ReplicationInstance) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type ReplicationSubnetGroup

+ func (tr *ReplicationSubnetGroup) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type ReplicationTask

+ func (tr *ReplicationTask) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

type S3Endpoint

+ func (tr *S3Endpoint) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

Aug 1, 2023

Changes in this version

type Certificate

+ func (mg *Certificate) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *Certificate) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *Certificate) GetInitParameters() (map[string]any, error)

+ type CertificateInitParameters struct

+ Tags map[string]*string

+ func (in *CertificateInitParameters) DeepCopy() *CertificateInitParameters

+ func (in *CertificateInitParameters) DeepCopyInto(out *CertificateInitParameters)

type CertificateSpec

+ InitProvider CertificateInitParameters

+ type ElasticsearchSettingsInitParameters struct

+ EndpointURI *string

+ ErrorRetryDuration *float64

+ FullLoadErrorPercentage *float64

+ ServiceAccessRoleArn *string

+ func (in *ElasticsearchSettingsInitParameters) DeepCopy() *ElasticsearchSettingsInitParameters

+ func (in *ElasticsearchSettingsInitParameters) DeepCopyInto(out *ElasticsearchSettingsInitParameters)

type Endpoint

+ func (mg *Endpoint) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *Endpoint) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *Endpoint) GetInitParameters() (map[string]any, error)

+ type EndpointInitParameters struct

+ CertificateArn *string

+ DatabaseName *string

+ ElasticsearchSettings []ElasticsearchSettingsInitParameters

+ EndpointType *string

+ EngineName *string

+ ExtraConnectionAttributes *string

+ KafkaSettings []KafkaSettingsInitParameters

+ KinesisSettings []KinesisSettingsInitParameters

+ MongodbSettings []MongodbSettingsInitParameters

+ Port *float64

+ RedisSettings []RedisSettingsInitParameters

+ RedshiftSettings []RedshiftSettingsInitParameters

+ S3Settings []S3SettingsInitParameters

+ SSLMode *string

+ SecretsManagerArn *string

+ ServerName *string

+ Tags map[string]*string

+ Username *string

+ func (in *EndpointInitParameters) DeepCopy() *EndpointInitParameters

+ func (in *EndpointInitParameters) DeepCopyInto(out *EndpointInitParameters)

type EndpointSpec

+ InitProvider EndpointInitParameters

type EventSubscription

+ func (mg *EventSubscription) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *EventSubscription) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *EventSubscription) GetInitParameters() (map[string]any, error)

+ type EventSubscriptionInitParameters struct

+ Enabled *bool

+ EventCategories []*string

+ SourceIds []*string

+ SourceType *string

+ Tags map[string]*string

+ func (in *EventSubscriptionInitParameters) DeepCopy() *EventSubscriptionInitParameters

+ func (in *EventSubscriptionInitParameters) DeepCopyInto(out *EventSubscriptionInitParameters)

type EventSubscriptionSpec

+ InitProvider EventSubscriptionInitParameters

+ type KafkaSettingsInitParameters struct

+ Broker *string

+ IncludeControlDetails *bool

+ IncludeNullAndEmpty *bool

+ IncludePartitionValue *bool

+ IncludeTableAlterOperations *bool

+ IncludeTransactionDetails *bool

+ MessageFormat *string

+ MessageMaxBytes *float64

+ NoHexPrefix *bool

+ PartitionIncludeSchemaTable *bool

+ SSLCACertificateArn *string

+ SSLClientCertificateArn *string

+ SSLClientKeyArn *string

+ SaslUsername *string

+ SecurityProtocol *string

+ Topic *string

+ func (in *KafkaSettingsInitParameters) DeepCopy() *KafkaSettingsInitParameters

+ func (in *KafkaSettingsInitParameters) DeepCopyInto(out *KafkaSettingsInitParameters)

+ type KinesisSettingsInitParameters struct

+ IncludeControlDetails *bool

+ IncludeNullAndEmpty *bool

+ IncludePartitionValue *bool

+ IncludeTableAlterOperations *bool

+ IncludeTransactionDetails *bool

+ MessageFormat *string

+ PartitionIncludeSchemaTable *bool

+ ServiceAccessRoleArn *string

+ StreamArn *string

+ func (in *KinesisSettingsInitParameters) DeepCopy() *KinesisSettingsInitParameters

+ func (in *KinesisSettingsInitParameters) DeepCopyInto(out *KinesisSettingsInitParameters)

+ type MongodbSettingsInitParameters struct

+ AuthMechanism *string

+ AuthSource *string

+ AuthType *string

+ DocsToInvestigate *string

+ ExtractDocID *string

+ NestingLevel *string

+ func (in *MongodbSettingsInitParameters) DeepCopy() *MongodbSettingsInitParameters

+ func (in *MongodbSettingsInitParameters) DeepCopyInto(out *MongodbSettingsInitParameters)

+ type RedisSettingsInitParameters struct

+ AuthType *string

+ AuthUserName *string

+ Port *float64

+ SSLCACertificateArn *string

+ SSLSecurityProtocol *string

+ ServerName *string

+ func (in *RedisSettingsInitParameters) DeepCopy() *RedisSettingsInitParameters

+ func (in *RedisSettingsInitParameters) DeepCopyInto(out *RedisSettingsInitParameters)

+ type RedshiftSettingsInitParameters struct

+ BucketFolder *string

+ BucketName *string

+ EncryptionMode *string

+ ServerSideEncryptionKMSKeyID *string

+ ServiceAccessRoleArn *string

+ func (in *RedshiftSettingsInitParameters) DeepCopy() *RedshiftSettingsInitParameters

+ func (in *RedshiftSettingsInitParameters) DeepCopyInto(out *RedshiftSettingsInitParameters)

type ReplicationInstance

+ func (mg *ReplicationInstance) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *ReplicationInstance) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *ReplicationInstance) GetInitParameters() (map[string]any, error)

+ type ReplicationInstanceInitParameters struct

+ AllocatedStorage *float64

+ AllowMajorVersionUpgrade *bool

+ ApplyImmediately *bool

+ AutoMinorVersionUpgrade *bool

+ AvailabilityZone *string

+ EngineVersion *string

+ MultiAz *bool

+ PreferredMaintenanceWindow *string

+ PubliclyAccessible *bool

+ ReplicationInstanceClass *string

+ Tags map[string]*string

+ func (in *ReplicationInstanceInitParameters) DeepCopy() *ReplicationInstanceInitParameters

+ func (in *ReplicationInstanceInitParameters) DeepCopyInto(out *ReplicationInstanceInitParameters)

type ReplicationInstanceSpec

+ InitProvider ReplicationInstanceInitParameters

type ReplicationSubnetGroup

+ func (mg *ReplicationSubnetGroup) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *ReplicationSubnetGroup) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *ReplicationSubnetGroup) GetInitParameters() (map[string]any, error)

+ type ReplicationSubnetGroupInitParameters struct

+ ReplicationSubnetGroupDescription *string

+ Tags map[string]*string

+ func (in *ReplicationSubnetGroupInitParameters) DeepCopy() *ReplicationSubnetGroupInitParameters

+ func (in *ReplicationSubnetGroupInitParameters) DeepCopyInto(out *ReplicationSubnetGroupInitParameters)

type ReplicationSubnetGroupSpec

+ InitProvider ReplicationSubnetGroupInitParameters

type ReplicationTask

+ func (mg *ReplicationTask) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *ReplicationTask) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *ReplicationTask) GetInitParameters() (map[string]any, error)

+ type ReplicationTaskInitParameters struct

+ CdcStartPosition *string

+ CdcStartTime *string

+ MigrationType *string

+ ReplicationTaskSettings *string

+ StartReplicationTask *bool

+ TableMappings *string

+ Tags map[string]*string

+ func (in *ReplicationTaskInitParameters) DeepCopy() *ReplicationTaskInitParameters

+ func (in *ReplicationTaskInitParameters) DeepCopyInto(out *ReplicationTaskInitParameters)

type ReplicationTaskSpec

+ InitProvider ReplicationTaskInitParameters

type S3Endpoint

+ func (mg *S3Endpoint) GetManagementPolicies() xpv1.ManagementPolicies

+ func (mg *S3Endpoint) SetManagementPolicies(r xpv1.ManagementPolicies)

+ func (tr *S3Endpoint) GetInitParameters() (map[string]any, error)

+ type S3EndpointInitParameters struct

+ AddColumnName *bool

+ AddTrailingPaddingCharacter *bool

+ BucketFolder *string

+ BucketName *string

+ CannedACLForObjects *string

+ CdcInsertsAndUpdates *bool

+ CdcInsertsOnly *bool

+ CdcMaxBatchInterval *float64

+ CdcMinFileSize *float64

+ CdcPath *string

+ CertificateArn *string

+ CompressionType *string

+ CsvDelimiter *string

+ CsvNoSupValue *string

+ CsvNullValue *string

+ CsvRowDelimiter *string

+ DataFormat *string

+ DataPageSize *float64

+ DatePartitionDelimiter *string

+ DatePartitionEnabled *bool

+ DatePartitionSequence *string

+ DatePartitionTimezone *string

+ DetachTargetOnLobLookupFailureParquet *bool

+ DictPageSizeLimit *float64

+ EnableStatistics *bool

+ EncodingType *string

+ EncryptionMode *string

+ EndpointType *string

+ ExpectedBucketOwner *string

+ ExternalTableDefinition *string

+ IgnoreHeaderRows *float64

+ IncludeOpForFullLoad *bool

+ MaxFileSize *float64

+ ParquetTimestampInMillisecond *bool

+ ParquetVersion *string

+ PreserveTransactions *bool

+ Rfc4180 *bool

+ RowGroupLength *float64

+ SSLMode *string

+ Tags map[string]*string

+ TimestampColumnName *string

+ UseCsvNoSupValue *bool

+ UseTaskStartTimeForFullLoadTimestamp *bool

+ func (in *S3EndpointInitParameters) DeepCopy() *S3EndpointInitParameters

+ func (in *S3EndpointInitParameters) DeepCopyInto(out *S3EndpointInitParameters)

type S3EndpointSpec

+ InitProvider S3EndpointInitParameters

+ type S3SettingsInitParameters struct

+ AddColumnName *bool

+ BucketFolder *string

+ BucketName *string

+ CannedACLForObjects *string

+ CdcInsertsAndUpdates *bool

+ CdcInsertsOnly *bool

+ CdcMaxBatchInterval *float64

+ CdcMinFileSize *float64

+ CdcPath *string

+ CompressionType *string

+ CsvDelimiter *string

+ CsvNoSupValue *string

+ CsvNullValue *string

+ CsvRowDelimiter *string

+ DataFormat *string

+ DataPageSize *float64

+ DatePartitionDelimiter *string

+ DatePartitionEnabled *bool

+ DatePartitionSequence *string

+ DictPageSizeLimit *float64

+ EnableStatistics *bool

+ EncodingType *string

+ EncryptionMode *string

+ ExternalTableDefinition *string

+ IgnoreHeaderRows *float64

+ IgnoreHeadersRow *float64

+ IncludeOpForFullLoad *bool

+ MaxFileSize *float64

+ ParquetTimestampInMillisecond *bool

+ ParquetVersion *string

+ PreserveTransactions *bool

+ Rfc4180 *bool

+ RowGroupLength *float64

+ ServerSideEncryptionKMSKeyID *string

+ ServiceAccessRoleArn *string

+ TimestampColumnName *string

+ UseCsvNoSupValue *bool

+ UseTaskStartTimeForFullLoadTimestamp *bool

+ func (in *S3SettingsInitParameters) DeepCopy() *S3SettingsInitParameters

+ func (in *S3SettingsInitParameters) DeepCopyInto(out *S3SettingsInitParameters)

Jun 28, 2023

Changes in this version

type EndpointParameters

+ ServiceAccessRoleRef *v1.Reference

+ ServiceAccessRoleSelector *v1.Selector

May 15, 2023

Changes in this version

type S3EndpointObservation

+ DetachTargetOnLobLookupFailureParquet *bool

type S3EndpointParameters

+ DetachTargetOnLobLookupFailureParquet *bool

Apr 26, 2023

Changes in this version

type Certificate

+ func (mg *Certificate) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *Certificate) SetManagementPolicy(r xpv1.ManagementPolicy)

type CertificateObservation

+ Tags map[string]*string

type ElasticsearchSettingsObservation

+ EndpointURI *string

+ ErrorRetryDuration *float64

+ FullLoadErrorPercentage *float64

+ ServiceAccessRoleArn *string

type Endpoint

+ func (mg *Endpoint) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *Endpoint) SetManagementPolicy(r xpv1.ManagementPolicy)

type EndpointObservation

+ CertificateArn *string

+ DatabaseName *string

+ ElasticsearchSettings []ElasticsearchSettingsObservation

+ EndpointType *string

+ EngineName *string

+ ExtraConnectionAttributes *string

+ KMSKeyArn *string

+ KafkaSettings []KafkaSettingsObservation

+ KinesisSettings []KinesisSettingsObservation

+ MongodbSettings []MongodbSettingsObservation

+ Port *float64

+ RedisSettings []RedisSettingsObservation

+ RedshiftSettings []RedshiftSettingsObservation

+ S3Settings []S3SettingsObservation

+ SSLMode *string

+ SecretsManagerAccessRoleArn *string

+ SecretsManagerArn *string

+ ServerName *string

+ ServiceAccessRole *string

+ Tags map[string]*string

+ Username *string

type EventSubscription

+ func (mg *EventSubscription) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *EventSubscription) SetManagementPolicy(r xpv1.ManagementPolicy)

type EventSubscriptionObservation

+ Enabled *bool

+ EventCategories []*string

+ SnsTopicArn *string

+ SourceIds []*string

+ SourceType *string

+ Tags map[string]*string

type KafkaSettingsObservation

+ Broker *string

+ IncludeControlDetails *bool

+ IncludeNullAndEmpty *bool

+ IncludePartitionValue *bool

+ IncludeTableAlterOperations *bool

+ IncludeTransactionDetails *bool

+ MessageFormat *string

+ MessageMaxBytes *float64

+ NoHexPrefix *bool

+ PartitionIncludeSchemaTable *bool

+ SSLCACertificateArn *string

+ SSLClientCertificateArn *string

+ SSLClientKeyArn *string

+ SaslUsername *string

+ SecurityProtocol *string

+ Topic *string

type KinesisSettingsObservation

+ IncludeControlDetails *bool

+ IncludeNullAndEmpty *bool

+ IncludePartitionValue *bool

+ IncludeTableAlterOperations *bool

+ IncludeTransactionDetails *bool

+ MessageFormat *string

+ PartitionIncludeSchemaTable *bool

+ ServiceAccessRoleArn *string

+ StreamArn *string

type MongodbSettingsObservation

+ AuthMechanism *string

+ AuthSource *string

+ AuthType *string

+ DocsToInvestigate *string

+ ExtractDocID *string

+ NestingLevel *string

type RedisSettingsObservation

+ AuthType *string

+ AuthUserName *string

+ Port *float64

+ SSLCACertificateArn *string

+ SSLSecurityProtocol *string

+ ServerName *string

type RedshiftSettingsObservation

+ BucketFolder *string

+ BucketName *string

+ EncryptionMode *string

+ ServerSideEncryptionKMSKeyID *string

+ ServiceAccessRoleArn *string

type ReplicationInstance

+ func (mg *ReplicationInstance) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *ReplicationInstance) SetManagementPolicy(r xpv1.ManagementPolicy)

type ReplicationInstanceObservation

+ AllocatedStorage *float64

+ AllowMajorVersionUpgrade *bool

+ ApplyImmediately *bool

+ AutoMinorVersionUpgrade *bool

+ AvailabilityZone *string

+ EngineVersion *string

+ KMSKeyArn *string

+ MultiAz *bool

+ PreferredMaintenanceWindow *string

+ PubliclyAccessible *bool

+ ReplicationInstanceClass *string

+ ReplicationSubnetGroupID *string

+ Tags map[string]*string

+ VPCSecurityGroupIds []*string

type ReplicationSubnetGroup

+ func (mg *ReplicationSubnetGroup) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *ReplicationSubnetGroup) SetManagementPolicy(r xpv1.ManagementPolicy)

type ReplicationSubnetGroupObservation

+ ReplicationSubnetGroupDescription *string

+ SubnetIds []*string

+ Tags map[string]*string

type ReplicationTask

+ func (mg *ReplicationTask) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *ReplicationTask) SetManagementPolicy(r xpv1.ManagementPolicy)

type ReplicationTaskObservation

+ CdcStartPosition *string

+ CdcStartTime *string

+ MigrationType *string

+ ReplicationInstanceArn *string

+ ReplicationTaskSettings *string

+ SourceEndpointArn *string

+ StartReplicationTask *bool

+ TableMappings *string

+ Tags map[string]*string

+ TargetEndpointArn *string

type S3Endpoint

+ func (mg *S3Endpoint) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *S3Endpoint) SetManagementPolicy(r xpv1.ManagementPolicy)

type S3EndpointObservation

+ AddColumnName *bool

+ AddTrailingPaddingCharacter *bool

+ BucketFolder *string

+ BucketName *string

+ CannedACLForObjects *string

+ CdcInsertsAndUpdates *bool

+ CdcInsertsOnly *bool

+ CdcMaxBatchInterval *float64

+ CdcMinFileSize *float64

+ CdcPath *string

+ CertificateArn *string

+ CompressionType *string

+ CsvDelimiter *string

+ CsvNoSupValue *string

+ CsvNullValue *string

+ CsvRowDelimiter *string

+ DataFormat *string

+ DataPageSize *float64

+ DatePartitionDelimiter *string

+ DatePartitionEnabled *bool

+ DatePartitionSequence *string

+ DatePartitionTimezone *string

+ DictPageSizeLimit *float64

+ EnableStatistics *bool

+ EncodingType *string

+ EncryptionMode *string

+ EndpointType *string

+ ExpectedBucketOwner *string

+ ExternalTableDefinition *string

+ IgnoreHeaderRows *float64

+ IncludeOpForFullLoad *bool

+ KMSKeyArn *string

+ MaxFileSize *float64

+ ParquetTimestampInMillisecond *bool

+ ParquetVersion *string

+ PreserveTransactions *bool

+ Rfc4180 *bool

+ RowGroupLength *float64

+ SSLMode *string

+ ServerSideEncryptionKMSKeyID *string

+ ServiceAccessRoleArn *string

+ Tags map[string]*string

+ TimestampColumnName *string

+ UseCsvNoSupValue *bool

+ UseTaskStartTimeForFullLoadTimestamp *bool

type S3SettingsObservation

+ AddColumnName *bool

+ BucketFolder *string

+ BucketName *string

+ CannedACLForObjects *string

+ CdcInsertsAndUpdates *bool

+ CdcInsertsOnly *bool

+ CdcMaxBatchInterval *float64

+ CdcMinFileSize *float64

+ CdcPath *string

+ CompressionType *string

+ CsvDelimiter *string

+ CsvNoSupValue *string

+ CsvNullValue *string

+ CsvRowDelimiter *string

+ DataFormat *string

+ DataPageSize *float64

+ DatePartitionDelimiter *string

+ DatePartitionEnabled *bool

+ DatePartitionSequence *string

+ DictPageSizeLimit *float64

+ EnableStatistics *bool

+ EncodingType *string

+ EncryptionMode *string

+ ExternalTableDefinition *string

+ IgnoreHeaderRows *float64

+ IgnoreHeadersRow *float64

+ IncludeOpForFullLoad *bool

+ MaxFileSize *float64

+ ParquetTimestampInMillisecond *bool

+ ParquetVersion *string

+ PreserveTransactions *bool

+ Rfc4180 *bool

+ RowGroupLength *float64

+ ServerSideEncryptionKMSKeyID *string

+ ServiceAccessRoleArn *string

+ TimestampColumnName *string

+ UseCsvNoSupValue *bool

+ UseTaskStartTimeForFullLoadTimestamp *bool

Mar 31, 2023

Changes in this version

+ var S3Endpoint_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: S3Endpoint_Kind}.String()

+ var S3Endpoint_GroupVersionKind = CRDGroupVersion.WithKind(S3Endpoint_Kind)

+ var S3Endpoint_Kind = "S3Endpoint"

+ var S3Endpoint_KindAPIVersion = S3Endpoint_Kind + "." + CRDGroupVersion.String()

+ type S3Endpoint struct

+ Spec S3EndpointSpec

+ Status S3EndpointStatus

+ func (in *S3Endpoint) DeepCopy() *S3Endpoint

+ func (in *S3Endpoint) DeepCopyInto(out *S3Endpoint)

+ func (in *S3Endpoint) DeepCopyObject() runtime.Object

+ func (mg *S3Endpoint) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *S3Endpoint) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *S3Endpoint) GetProviderConfigReference() *xpv1.Reference

+ func (mg *S3Endpoint) GetProviderReference() *xpv1.Reference

+ func (mg *S3Endpoint) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *S3Endpoint) GetTerraformResourceType() string

+ func (mg *S3Endpoint) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *S3Endpoint) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *S3Endpoint) SetConditions(c ...xpv1.Condition)

+ func (mg *S3Endpoint) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *S3Endpoint) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *S3Endpoint) SetProviderReference(r *xpv1.Reference)

+ func (mg *S3Endpoint) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *S3Endpoint) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *S3Endpoint) GetConnectionDetailsMapping() map[string]string

+ func (tr *S3Endpoint) GetID() string

+ func (tr *S3Endpoint) GetObservation() (map[string]any, error)

+ func (tr *S3Endpoint) GetParameters() (map[string]any, error)

+ func (tr *S3Endpoint) GetTerraformSchemaVersion() int

+ func (tr *S3Endpoint) LateInitialize(attrs []byte) (bool, error)

+ func (tr *S3Endpoint) SetObservation(obs map[string]any) error

+ func (tr *S3Endpoint) SetParameters(params map[string]any) error

+ type S3EndpointList struct

+ Items []S3Endpoint

+ func (in *S3EndpointList) DeepCopy() *S3EndpointList

+ func (in *S3EndpointList) DeepCopyInto(out *S3EndpointList)

+ func (in *S3EndpointList) DeepCopyObject() runtime.Object

+ func (l *S3EndpointList) GetItems() []resource.Managed

+ type S3EndpointObservation struct

+ EndpointArn *string

+ EngineDisplayName *string

+ ExternalID *string

+ ID *string

+ Status *string

+ TagsAll map[string]*string

+ func (in *S3EndpointObservation) DeepCopy() *S3EndpointObservation

+ func (in *S3EndpointObservation) DeepCopyInto(out *S3EndpointObservation)

+ type S3EndpointParameters struct

+ AddColumnName *bool

+ AddTrailingPaddingCharacter *bool

+ BucketFolder *string

+ BucketName *string

+ CannedACLForObjects *string

+ CdcInsertsAndUpdates *bool

+ CdcInsertsOnly *bool

+ CdcMaxBatchInterval *float64

+ CdcMinFileSize *float64

+ CdcPath *string

+ CertificateArn *string

+ CompressionType *string

+ CsvDelimiter *string

+ CsvNoSupValue *string

+ CsvNullValue *string

+ CsvRowDelimiter *string

+ DataFormat *string

+ DataPageSize *float64

+ DatePartitionDelimiter *string

+ DatePartitionEnabled *bool

+ DatePartitionSequence *string

+ DatePartitionTimezone *string

+ DictPageSizeLimit *float64

+ EnableStatistics *bool

+ EncodingType *string

+ EncryptionMode *string

+ EndpointType *string

+ ExpectedBucketOwner *string

+ ExternalTableDefinition *string

+ IgnoreHeaderRows *float64

+ IncludeOpForFullLoad *bool

+ KMSKeyArn *string

+ KMSKeyArnRef *v1.Reference

+ KMSKeyArnSelector *v1.Selector

+ MaxFileSize *float64

+ ParquetTimestampInMillisecond *bool

+ ParquetVersion *string

+ PreserveTransactions *bool

+ Region *string

+ Rfc4180 *bool

+ RowGroupLength *float64

+ SSLMode *string

+ ServerSideEncryptionKMSKeyID *string

+ ServerSideEncryptionKMSKeyIDRef *v1.Reference

+ ServerSideEncryptionKMSKeyIDSelector *v1.Selector

+ ServiceAccessRoleArn *string

+ ServiceAccessRoleArnRef *v1.Reference

+ ServiceAccessRoleArnSelector *v1.Selector

+ Tags map[string]*string

+ TimestampColumnName *string

+ UseCsvNoSupValue *bool

+ UseTaskStartTimeForFullLoadTimestamp *bool

+ func (in *S3EndpointParameters) DeepCopy() *S3EndpointParameters

+ func (in *S3EndpointParameters) DeepCopyInto(out *S3EndpointParameters)

+ type S3EndpointSpec struct

+ ForProvider S3EndpointParameters

+ func (in *S3EndpointSpec) DeepCopy() *S3EndpointSpec

+ func (in *S3EndpointSpec) DeepCopyInto(out *S3EndpointSpec)

+ type S3EndpointStatus struct

+ AtProvider S3EndpointObservation

+ func (in *S3EndpointStatus) DeepCopy() *S3EndpointStatus

+ func (in *S3EndpointStatus) DeepCopyInto(out *S3EndpointStatus)

Feb 7, 2023

Changes in this version

type EndpointParameters

+ RedisSettings []RedisSettingsParameters

+ RedshiftSettings []RedshiftSettingsParameters

+ type RedisSettingsObservation struct

+ func (in *RedisSettingsObservation) DeepCopy() *RedisSettingsObservation

+ func (in *RedisSettingsObservation) DeepCopyInto(out *RedisSettingsObservation)

+ type RedisSettingsParameters struct

+ AuthPasswordSecretRef *v1.SecretKeySelector

+ AuthType *string

+ AuthUserName *string

+ Port *float64

+ SSLCACertificateArn *string

+ SSLSecurityProtocol *string

+ ServerName *string

+ func (in *RedisSettingsParameters) DeepCopy() *RedisSettingsParameters

+ func (in *RedisSettingsParameters) DeepCopyInto(out *RedisSettingsParameters)

+ type RedshiftSettingsObservation struct

+ func (in *RedshiftSettingsObservation) DeepCopy() *RedshiftSettingsObservation

+ func (in *RedshiftSettingsObservation) DeepCopyInto(out *RedshiftSettingsObservation)

+ type RedshiftSettingsParameters struct

+ BucketFolder *string

+ BucketName *string

+ EncryptionMode *string

+ ServerSideEncryptionKMSKeyID *string

+ ServiceAccessRoleArn *string

+ func (in *RedshiftSettingsParameters) DeepCopy() *RedshiftSettingsParameters

+ func (in *RedshiftSettingsParameters) DeepCopyInto(out *RedshiftSettingsParameters)

type S3SettingsParameters

+ IgnoreHeaderRows *float64

+ UseTaskStartTimeForFullLoadTimestamp *bool

Jan 24, 2023

Changes in this version

+ var EventSubscription_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: EventSubscription_Kind}.String()

+ var EventSubscription_GroupVersionKind = CRDGroupVersion.WithKind(EventSubscription_Kind)

+ var EventSubscription_Kind = "EventSubscription"

+ var EventSubscription_KindAPIVersion = EventSubscription_Kind + "." + CRDGroupVersion.String()

+ var ReplicationInstance_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: ReplicationInstance_Kind}.String()

+ var ReplicationInstance_GroupVersionKind = CRDGroupVersion.WithKind(ReplicationInstance_Kind)

+ var ReplicationInstance_Kind = "ReplicationInstance"

+ var ReplicationInstance_KindAPIVersion = ReplicationInstance_Kind + "." + CRDGroupVersion.String()

+ var ReplicationTask_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: ReplicationTask_Kind}.String()

+ var ReplicationTask_GroupVersionKind = CRDGroupVersion.WithKind(ReplicationTask_Kind)

+ var ReplicationTask_Kind = "ReplicationTask"

+ var ReplicationTask_KindAPIVersion = ReplicationTask_Kind + "." + CRDGroupVersion.String()

+ type EventSubscription struct

+ Spec EventSubscriptionSpec

+ Status EventSubscriptionStatus

+ func (in *EventSubscription) DeepCopy() *EventSubscription

+ func (in *EventSubscription) DeepCopyInto(out *EventSubscription)

+ func (in *EventSubscription) DeepCopyObject() runtime.Object

+ func (mg *EventSubscription) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *EventSubscription) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *EventSubscription) GetProviderConfigReference() *xpv1.Reference

+ func (mg *EventSubscription) GetProviderReference() *xpv1.Reference

+ func (mg *EventSubscription) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *EventSubscription) GetTerraformResourceType() string

+ func (mg *EventSubscription) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *EventSubscription) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *EventSubscription) SetConditions(c ...xpv1.Condition)

+ func (mg *EventSubscription) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *EventSubscription) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *EventSubscription) SetProviderReference(r *xpv1.Reference)

+ func (mg *EventSubscription) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *EventSubscription) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *EventSubscription) GetConnectionDetailsMapping() map[string]string

+ func (tr *EventSubscription) GetID() string

+ func (tr *EventSubscription) GetObservation() (map[string]any, error)

+ func (tr *EventSubscription) GetParameters() (map[string]any, error)

+ func (tr *EventSubscription) GetTerraformSchemaVersion() int

+ func (tr *EventSubscription) LateInitialize(attrs []byte) (bool, error)

+ func (tr *EventSubscription) SetObservation(obs map[string]any) error

+ func (tr *EventSubscription) SetParameters(params map[string]any) error

+ type EventSubscriptionList struct

+ Items []EventSubscription

+ func (in *EventSubscriptionList) DeepCopy() *EventSubscriptionList

+ func (in *EventSubscriptionList) DeepCopyInto(out *EventSubscriptionList)

+ func (in *EventSubscriptionList) DeepCopyObject() runtime.Object

+ func (l *EventSubscriptionList) GetItems() []resource.Managed

+ type EventSubscriptionObservation struct

+ Arn *string

+ ID *string

+ TagsAll map[string]*string

+ func (in *EventSubscriptionObservation) DeepCopy() *EventSubscriptionObservation

+ func (in *EventSubscriptionObservation) DeepCopyInto(out *EventSubscriptionObservation)

+ type EventSubscriptionParameters struct

+ Enabled *bool

+ EventCategories []*string

+ Region *string

+ SnsTopicArn *string

+ SnsTopicArnRef *v1.Reference

+ SnsTopicArnSelector *v1.Selector

+ SourceIds []*string

+ SourceType *string

+ Tags map[string]*string

+ func (in *EventSubscriptionParameters) DeepCopy() *EventSubscriptionParameters

+ func (in *EventSubscriptionParameters) DeepCopyInto(out *EventSubscriptionParameters)

+ type EventSubscriptionSpec struct

+ ForProvider EventSubscriptionParameters

+ func (in *EventSubscriptionSpec) DeepCopy() *EventSubscriptionSpec

+ func (in *EventSubscriptionSpec) DeepCopyInto(out *EventSubscriptionSpec)

+ type EventSubscriptionStatus struct

+ AtProvider EventSubscriptionObservation

+ func (in *EventSubscriptionStatus) DeepCopy() *EventSubscriptionStatus

+ func (in *EventSubscriptionStatus) DeepCopyInto(out *EventSubscriptionStatus)

+ type ReplicationInstance struct

+ Spec ReplicationInstanceSpec

+ Status ReplicationInstanceStatus

+ func (in *ReplicationInstance) DeepCopy() *ReplicationInstance

+ func (in *ReplicationInstance) DeepCopyInto(out *ReplicationInstance)

+ func (in *ReplicationInstance) DeepCopyObject() runtime.Object

+ func (mg *ReplicationInstance) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *ReplicationInstance) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *ReplicationInstance) GetProviderConfigReference() *xpv1.Reference

+ func (mg *ReplicationInstance) GetProviderReference() *xpv1.Reference

+ func (mg *ReplicationInstance) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *ReplicationInstance) GetTerraformResourceType() string

+ func (mg *ReplicationInstance) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *ReplicationInstance) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *ReplicationInstance) SetConditions(c ...xpv1.Condition)

+ func (mg *ReplicationInstance) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *ReplicationInstance) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *ReplicationInstance) SetProviderReference(r *xpv1.Reference)

+ func (mg *ReplicationInstance) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *ReplicationInstance) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *ReplicationInstance) GetConnectionDetailsMapping() map[string]string

+ func (tr *ReplicationInstance) GetID() string

+ func (tr *ReplicationInstance) GetObservation() (map[string]any, error)

+ func (tr *ReplicationInstance) GetParameters() (map[string]any, error)

+ func (tr *ReplicationInstance) GetTerraformSchemaVersion() int

+ func (tr *ReplicationInstance) LateInitialize(attrs []byte) (bool, error)

+ func (tr *ReplicationInstance) SetObservation(obs map[string]any) error

+ func (tr *ReplicationInstance) SetParameters(params map[string]any) error

+ type ReplicationInstanceList struct

+ Items []ReplicationInstance

+ func (in *ReplicationInstanceList) DeepCopy() *ReplicationInstanceList

+ func (in *ReplicationInstanceList) DeepCopyInto(out *ReplicationInstanceList)

+ func (in *ReplicationInstanceList) DeepCopyObject() runtime.Object

+ func (l *ReplicationInstanceList) GetItems() []resource.Managed

+ type ReplicationInstanceObservation struct

+ ID *string

+ ReplicationInstanceArn *string

+ ReplicationInstancePrivateIps []*string

+ ReplicationInstancePublicIps []*string

+ TagsAll map[string]*string

+ func (in *ReplicationInstanceObservation) DeepCopy() *ReplicationInstanceObservation

+ func (in *ReplicationInstanceObservation) DeepCopyInto(out *ReplicationInstanceObservation)

+ type ReplicationInstanceParameters struct

+ AllocatedStorage *float64

+ AllowMajorVersionUpgrade *bool

+ ApplyImmediately *bool

+ AutoMinorVersionUpgrade *bool

+ AvailabilityZone *string

+ EngineVersion *string

+ KMSKeyArn *string

+ KMSKeyArnRef *v1.Reference

+ KMSKeyArnSelector *v1.Selector

+ MultiAz *bool

+ PreferredMaintenanceWindow *string

+ PubliclyAccessible *bool

+ Region *string

+ ReplicationInstanceClass *string

+ ReplicationSubnetGroupID *string

+ ReplicationSubnetGroupIDRef *v1.Reference

+ ReplicationSubnetGroupIDSelector *v1.Selector

+ Tags map[string]*string

+ VPCSecurityGroupIDRefs []v1.Reference

+ VPCSecurityGroupIDSelector *v1.Selector

+ VPCSecurityGroupIds []*string

+ func (in *ReplicationInstanceParameters) DeepCopy() *ReplicationInstanceParameters

+ func (in *ReplicationInstanceParameters) DeepCopyInto(out *ReplicationInstanceParameters)

+ type ReplicationInstanceSpec struct

+ ForProvider ReplicationInstanceParameters

+ func (in *ReplicationInstanceSpec) DeepCopy() *ReplicationInstanceSpec

+ func (in *ReplicationInstanceSpec) DeepCopyInto(out *ReplicationInstanceSpec)

+ type ReplicationInstanceStatus struct

+ AtProvider ReplicationInstanceObservation

+ func (in *ReplicationInstanceStatus) DeepCopy() *ReplicationInstanceStatus

+ func (in *ReplicationInstanceStatus) DeepCopyInto(out *ReplicationInstanceStatus)

+ type ReplicationTask struct

+ Spec ReplicationTaskSpec

+ Status ReplicationTaskStatus

+ func (in *ReplicationTask) DeepCopy() *ReplicationTask

+ func (in *ReplicationTask) DeepCopyInto(out *ReplicationTask)

+ func (in *ReplicationTask) DeepCopyObject() runtime.Object

+ func (mg *ReplicationTask) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *ReplicationTask) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *ReplicationTask) GetProviderConfigReference() *xpv1.Reference

+ func (mg *ReplicationTask) GetProviderReference() *xpv1.Reference

+ func (mg *ReplicationTask) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *ReplicationTask) GetTerraformResourceType() string

+ func (mg *ReplicationTask) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *ReplicationTask) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *ReplicationTask) SetConditions(c ...xpv1.Condition)

+ func (mg *ReplicationTask) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *ReplicationTask) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *ReplicationTask) SetProviderReference(r *xpv1.Reference)

+ func (mg *ReplicationTask) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *ReplicationTask) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *ReplicationTask) GetConnectionDetailsMapping() map[string]string

+ func (tr *ReplicationTask) GetID() string

+ func (tr *ReplicationTask) GetObservation() (map[string]any, error)

+ func (tr *ReplicationTask) GetParameters() (map[string]any, error)

+ func (tr *ReplicationTask) GetTerraformSchemaVersion() int

+ func (tr *ReplicationTask) LateInitialize(attrs []byte) (bool, error)

+ func (tr *ReplicationTask) SetObservation(obs map[string]any) error

+ func (tr *ReplicationTask) SetParameters(params map[string]any) error

+ type ReplicationTaskList struct

+ Items []ReplicationTask

+ func (in *ReplicationTaskList) DeepCopy() *ReplicationTaskList

+ func (in *ReplicationTaskList) DeepCopyInto(out *ReplicationTaskList)

+ func (in *ReplicationTaskList) DeepCopyObject() runtime.Object

+ func (l *ReplicationTaskList) GetItems() []resource.Managed

+ type ReplicationTaskObservation struct

+ ID *string

+ ReplicationTaskArn *string

+ Status *string

+ TagsAll map[string]*string

+ func (in *ReplicationTaskObservation) DeepCopy() *ReplicationTaskObservation

+ func (in *ReplicationTaskObservation) DeepCopyInto(out *ReplicationTaskObservation)

+ type ReplicationTaskParameters struct

+ CdcStartPosition *string

+ CdcStartTime *string

+ MigrationType *string

+ Region *string

+ ReplicationInstanceArn *string

+ ReplicationInstanceArnRef *v1.Reference

+ ReplicationInstanceArnSelector *v1.Selector

+ ReplicationTaskSettings *string

+ SourceEndpointArn *string

+ SourceEndpointArnRef *v1.Reference

+ SourceEndpointArnSelector *v1.Selector

+ StartReplicationTask *bool

+ TableMappings *string

+ Tags map[string]*string

+ TargetEndpointArn *string

+ TargetEndpointArnRef *v1.Reference

+ TargetEndpointArnSelector *v1.Selector

+ func (in *ReplicationTaskParameters) DeepCopy() *ReplicationTaskParameters

+ func (in *ReplicationTaskParameters) DeepCopyInto(out *ReplicationTaskParameters)

+ type ReplicationTaskSpec struct

+ ForProvider ReplicationTaskParameters

+ func (in *ReplicationTaskSpec) DeepCopy() *ReplicationTaskSpec

+ func (in *ReplicationTaskSpec) DeepCopyInto(out *ReplicationTaskSpec)

+ type ReplicationTaskStatus struct

+ AtProvider ReplicationTaskObservation

+ func (in *ReplicationTaskStatus) DeepCopy() *ReplicationTaskStatus

+ func (in *ReplicationTaskStatus) DeepCopyInto(out *ReplicationTaskStatus)

Dec 20, 2022

Changes in this version

+ const CRDGroup

+ const CRDVersion

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var CRDGroupVersion = schema.GroupVersion

+ var Certificate_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Certificate_Kind}.String()

+ var Certificate_GroupVersionKind = CRDGroupVersion.WithKind(Certificate_Kind)

+ var Certificate_Kind = "Certificate"

+ var Certificate_KindAPIVersion = Certificate_Kind + "." + CRDGroupVersion.String()

+ var Endpoint_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Endpoint_Kind}.String()

+ var Endpoint_GroupVersionKind = CRDGroupVersion.WithKind(Endpoint_Kind)

+ var Endpoint_Kind = "Endpoint"

+ var Endpoint_KindAPIVersion = Endpoint_Kind + "." + CRDGroupVersion.String()

+ var ReplicationSubnetGroup_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: ReplicationSubnetGroup_Kind}.String()

+ var ReplicationSubnetGroup_GroupVersionKind = CRDGroupVersion.WithKind(ReplicationSubnetGroup_Kind)

+ var ReplicationSubnetGroup_Kind = "ReplicationSubnetGroup"

+ var ReplicationSubnetGroup_KindAPIVersion = ReplicationSubnetGroup_Kind + "." + CRDGroupVersion.String()

+ var SchemeBuilder = &scheme.Builder

+ type Certificate struct

+ Spec CertificateSpec

+ Status CertificateStatus

+ func (in *Certificate) DeepCopy() *Certificate

+ func (in *Certificate) DeepCopyInto(out *Certificate)

+ func (in *Certificate) DeepCopyObject() runtime.Object

+ func (mg *Certificate) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *Certificate) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *Certificate) GetProviderConfigReference() *xpv1.Reference

+ func (mg *Certificate) GetProviderReference() *xpv1.Reference

+ func (mg *Certificate) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *Certificate) GetTerraformResourceType() string

+ func (mg *Certificate) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *Certificate) SetConditions(c ...xpv1.Condition)

+ func (mg *Certificate) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *Certificate) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *Certificate) SetProviderReference(r *xpv1.Reference)

+ func (mg *Certificate) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *Certificate) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *Certificate) GetConnectionDetailsMapping() map[string]string

+ func (tr *Certificate) GetID() string

+ func (tr *Certificate) GetObservation() (map[string]any, error)

+ func (tr *Certificate) GetParameters() (map[string]any, error)

+ func (tr *Certificate) GetTerraformSchemaVersion() int

+ func (tr *Certificate) LateInitialize(attrs []byte) (bool, error)

+ func (tr *Certificate) SetObservation(obs map[string]any) error

+ func (tr *Certificate) SetParameters(params map[string]any) error

+ type CertificateList struct

+ Items []Certificate

+ func (in *CertificateList) DeepCopy() *CertificateList

+ func (in *CertificateList) DeepCopyInto(out *CertificateList)

+ func (in *CertificateList) DeepCopyObject() runtime.Object

+ func (l *CertificateList) GetItems() []resource.Managed

+ type CertificateObservation struct

+ CertificateArn *string

+ ID *string

+ TagsAll map[string]*string

+ func (in *CertificateObservation) DeepCopy() *CertificateObservation

+ func (in *CertificateObservation) DeepCopyInto(out *CertificateObservation)

+ type CertificateParameters struct

+ CertificatePemSecretRef *v1.SecretKeySelector

+ CertificateWalletSecretRef *v1.SecretKeySelector

+ Region *string

+ Tags map[string]*string

+ func (in *CertificateParameters) DeepCopy() *CertificateParameters

+ func (in *CertificateParameters) DeepCopyInto(out *CertificateParameters)

+ type CertificateSpec struct

+ ForProvider CertificateParameters

+ func (in *CertificateSpec) DeepCopy() *CertificateSpec

+ func (in *CertificateSpec) DeepCopyInto(out *CertificateSpec)

+ type CertificateStatus struct

+ AtProvider CertificateObservation

+ func (in *CertificateStatus) DeepCopy() *CertificateStatus

+ func (in *CertificateStatus) DeepCopyInto(out *CertificateStatus)

+ type ElasticsearchSettingsObservation struct

+ func (in *ElasticsearchSettingsObservation) DeepCopy() *ElasticsearchSettingsObservation

+ func (in *ElasticsearchSettingsObservation) DeepCopyInto(out *ElasticsearchSettingsObservation)

+ type ElasticsearchSettingsParameters struct

+ EndpointURI *string

+ ErrorRetryDuration *float64

+ FullLoadErrorPercentage *float64

+ ServiceAccessRoleArn *string

+ func (in *ElasticsearchSettingsParameters) DeepCopy() *ElasticsearchSettingsParameters

+ func (in *ElasticsearchSettingsParameters) DeepCopyInto(out *ElasticsearchSettingsParameters)

+ type Endpoint struct

+ Spec EndpointSpec

+ Status EndpointStatus

+ func (in *Endpoint) DeepCopy() *Endpoint

+ func (in *Endpoint) DeepCopyInto(out *Endpoint)

+ func (in *Endpoint) DeepCopyObject() runtime.Object

+ func (mg *Endpoint) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *Endpoint) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *Endpoint) GetProviderConfigReference() *xpv1.Reference

+ func (mg *Endpoint) GetProviderReference() *xpv1.Reference

+ func (mg *Endpoint) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *Endpoint) GetTerraformResourceType() string

+ func (mg *Endpoint) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *Endpoint) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *Endpoint) SetConditions(c ...xpv1.Condition)

+ func (mg *Endpoint) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *Endpoint) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *Endpoint) SetProviderReference(r *xpv1.Reference)

+ func (mg *Endpoint) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *Endpoint) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *Endpoint) GetConnectionDetailsMapping() map[string]string

+ func (tr *Endpoint) GetID() string

+ func (tr *Endpoint) GetObservation() (map[string]any, error)

+ func (tr *Endpoint) GetParameters() (map[string]any, error)

+ func (tr *Endpoint) GetTerraformSchemaVersion() int

+ func (tr *Endpoint) LateInitialize(attrs []byte) (bool, error)

+ func (tr *Endpoint) SetObservation(obs map[string]any) error

+ func (tr *Endpoint) SetParameters(params map[string]any) error

+ type EndpointList struct

+ Items []Endpoint

+ func (in *EndpointList) DeepCopy() *EndpointList

+ func (in *EndpointList) DeepCopyInto(out *EndpointList)

+ func (in *EndpointList) DeepCopyObject() runtime.Object

+ func (l *EndpointList) GetItems() []resource.Managed

+ type EndpointObservation struct

+ EndpointArn *string

+ ID *string

+ TagsAll map[string]*string

+ func (in *EndpointObservation) DeepCopy() *EndpointObservation

+ func (in *EndpointObservation) DeepCopyInto(out *EndpointObservation)

+ type EndpointParameters struct

+ CertificateArn *string

+ DatabaseName *string

+ ElasticsearchSettings []ElasticsearchSettingsParameters

+ EndpointType *string

+ EngineName *string

+ ExtraConnectionAttributes *string

+ KMSKeyArn *string

+ KMSKeyArnRef *v1.Reference

+ KMSKeyArnSelector *v1.Selector

+ KafkaSettings []KafkaSettingsParameters

+ KinesisSettings []KinesisSettingsParameters

+ MongodbSettings []MongodbSettingsParameters

+ PasswordSecretRef *v1.SecretKeySelector

+ Port *float64

+ Region *string

+ S3Settings []S3SettingsParameters

+ SSLMode *string

+ SecretsManagerAccessRoleArn *string

+ SecretsManagerAccessRoleArnRef *v1.Reference

+ SecretsManagerAccessRoleArnSelector *v1.Selector

+ SecretsManagerArn *string

+ ServerName *string

+ ServiceAccessRole *string

+ Tags map[string]*string

+ Username *string

+ func (in *EndpointParameters) DeepCopy() *EndpointParameters

+ func (in *EndpointParameters) DeepCopyInto(out *EndpointParameters)

+ type EndpointSpec struct

+ ForProvider EndpointParameters

+ func (in *EndpointSpec) DeepCopy() *EndpointSpec

+ func (in *EndpointSpec) DeepCopyInto(out *EndpointSpec)

+ type EndpointStatus struct

+ AtProvider EndpointObservation

+ func (in *EndpointStatus) DeepCopy() *EndpointStatus

+ func (in *EndpointStatus) DeepCopyInto(out *EndpointStatus)

+ type KafkaSettingsObservation struct

+ func (in *KafkaSettingsObservation) DeepCopy() *KafkaSettingsObservation

+ func (in *KafkaSettingsObservation) DeepCopyInto(out *KafkaSettingsObservation)

+ type KafkaSettingsParameters struct

+ Broker *string

+ IncludeControlDetails *bool

+ IncludeNullAndEmpty *bool

+ IncludePartitionValue *bool

+ IncludeTableAlterOperations *bool

+ IncludeTransactionDetails *bool

+ MessageFormat *string

+ MessageMaxBytes *float64

+ NoHexPrefix *bool

+ PartitionIncludeSchemaTable *bool

+ SSLCACertificateArn *string

+ SSLClientCertificateArn *string

+ SSLClientKeyArn *string

+ SSLClientKeyPasswordSecretRef *v1.SecretKeySelector

+ SaslPasswordSecretRef *v1.SecretKeySelector

+ SaslUsername *string

+ SecurityProtocol *string

+ Topic *string

+ func (in *KafkaSettingsParameters) DeepCopy() *KafkaSettingsParameters

+ func (in *KafkaSettingsParameters) DeepCopyInto(out *KafkaSettingsParameters)

+ type KinesisSettingsObservation struct

+ func (in *KinesisSettingsObservation) DeepCopy() *KinesisSettingsObservation

+ func (in *KinesisSettingsObservation) DeepCopyInto(out *KinesisSettingsObservation)

+ type KinesisSettingsParameters struct

+ IncludeControlDetails *bool

+ IncludeNullAndEmpty *bool

+ IncludePartitionValue *bool

+ IncludeTableAlterOperations *bool

+ IncludeTransactionDetails *bool

+ MessageFormat *string

+ PartitionIncludeSchemaTable *bool

+ ServiceAccessRoleArn *string

+ StreamArn *string

+ func (in *KinesisSettingsParameters) DeepCopy() *KinesisSettingsParameters

+ func (in *KinesisSettingsParameters) DeepCopyInto(out *KinesisSettingsParameters)

+ type MongodbSettingsObservation struct

+ func (in *MongodbSettingsObservation) DeepCopy() *MongodbSettingsObservation

+ func (in *MongodbSettingsObservation) DeepCopyInto(out *MongodbSettingsObservation)

+ type MongodbSettingsParameters struct

+ AuthMechanism *string

+ AuthSource *string

+ AuthType *string

+ DocsToInvestigate *string

+ ExtractDocID *string

+ NestingLevel *string

+ func (in *MongodbSettingsParameters) DeepCopy() *MongodbSettingsParameters

+ func (in *MongodbSettingsParameters) DeepCopyInto(out *MongodbSettingsParameters)

+ type ReplicationSubnetGroup struct

+ Spec ReplicationSubnetGroupSpec

+ Status ReplicationSubnetGroupStatus

+ func (in *ReplicationSubnetGroup) DeepCopy() *ReplicationSubnetGroup

+ func (in *ReplicationSubnetGroup) DeepCopyInto(out *ReplicationSubnetGroup)

+ func (in *ReplicationSubnetGroup) DeepCopyObject() runtime.Object

+ func (mg *ReplicationSubnetGroup) GetCondition(ct xpv1.ConditionType) xpv1.Condition

+ func (mg *ReplicationSubnetGroup) GetDeletionPolicy() xpv1.DeletionPolicy

+ func (mg *ReplicationSubnetGroup) GetProviderConfigReference() *xpv1.Reference

+ func (mg *ReplicationSubnetGroup) GetProviderReference() *xpv1.Reference

+ func (mg *ReplicationSubnetGroup) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

+ func (mg *ReplicationSubnetGroup) GetTerraformResourceType() string

+ func (mg *ReplicationSubnetGroup) GetWriteConnectionSecretToReference() *xpv1.SecretReference

+ func (mg *ReplicationSubnetGroup) ResolveReferences(ctx context.Context, c client.Reader) error

+ func (mg *ReplicationSubnetGroup) SetConditions(c ...xpv1.Condition)

+ func (mg *ReplicationSubnetGroup) SetDeletionPolicy(r xpv1.DeletionPolicy)

+ func (mg *ReplicationSubnetGroup) SetProviderConfigReference(r *xpv1.Reference)

+ func (mg *ReplicationSubnetGroup) SetProviderReference(r *xpv1.Reference)

+ func (mg *ReplicationSubnetGroup) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

+ func (mg *ReplicationSubnetGroup) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

+ func (tr *ReplicationSubnetGroup) GetConnectionDetailsMapping() map[string]string

+ func (tr *ReplicationSubnetGroup) GetID() string

+ func (tr *ReplicationSubnetGroup) GetObservation() (map[string]any, error)

+ func (tr *ReplicationSubnetGroup) GetParameters() (map[string]any, error)

+ func (tr *ReplicationSubnetGroup) GetTerraformSchemaVersion() int

+ func (tr *ReplicationSubnetGroup) LateInitialize(attrs []byte) (bool, error)

+ func (tr *ReplicationSubnetGroup) SetObservation(obs map[string]any) error

+ func (tr *ReplicationSubnetGroup) SetParameters(params map[string]any) error

+ type ReplicationSubnetGroupList struct

+ Items []ReplicationSubnetGroup

+ func (in *ReplicationSubnetGroupList) DeepCopy() *ReplicationSubnetGroupList

+ func (in *ReplicationSubnetGroupList) DeepCopyInto(out *ReplicationSubnetGroupList)

+ func (in *ReplicationSubnetGroupList) DeepCopyObject() runtime.Object

+ func (l *ReplicationSubnetGroupList) GetItems() []resource.Managed

+ type ReplicationSubnetGroupObservation struct

+ ID *string

+ ReplicationSubnetGroupArn *string

+ TagsAll map[string]*string

+ VPCID *string

+ func (in *ReplicationSubnetGroupObservation) DeepCopy() *ReplicationSubnetGroupObservation

+ func (in *ReplicationSubnetGroupObservation) DeepCopyInto(out *ReplicationSubnetGroupObservation)

+ type ReplicationSubnetGroupParameters struct

+ Region *string

+ ReplicationSubnetGroupDescription *string

+ SubnetIDRefs []v1.Reference

+ SubnetIDSelector *v1.Selector

+ SubnetIds []*string

+ Tags map[string]*string

+ func (in *ReplicationSubnetGroupParameters) DeepCopy() *ReplicationSubnetGroupParameters

+ func (in *ReplicationSubnetGroupParameters) DeepCopyInto(out *ReplicationSubnetGroupParameters)

+ type ReplicationSubnetGroupSpec struct

+ ForProvider ReplicationSubnetGroupParameters

+ func (in *ReplicationSubnetGroupSpec) DeepCopy() *ReplicationSubnetGroupSpec

+ func (in *ReplicationSubnetGroupSpec) DeepCopyInto(out *ReplicationSubnetGroupSpec)

+ type ReplicationSubnetGroupStatus struct

+ AtProvider ReplicationSubnetGroupObservation

+ func (in *ReplicationSubnetGroupStatus) DeepCopy() *ReplicationSubnetGroupStatus

+ func (in *ReplicationSubnetGroupStatus) DeepCopyInto(out *ReplicationSubnetGroupStatus)

+ type S3SettingsObservation struct

+ func (in *S3SettingsObservation) DeepCopy() *S3SettingsObservation

+ func (in *S3SettingsObservation) DeepCopyInto(out *S3SettingsObservation)

+ type S3SettingsParameters struct

+ AddColumnName *bool

+ BucketFolder *string

+ BucketName *string

+ CannedACLForObjects *string

+ CdcInsertsAndUpdates *bool

+ CdcInsertsOnly *bool

+ CdcMaxBatchInterval *float64

+ CdcMinFileSize *float64

+ CdcPath *string

+ CompressionType *string

+ CsvDelimiter *string

+ CsvNoSupValue *string

+ CsvNullValue *string

+ CsvRowDelimiter *string

+ DataFormat *string

+ DataPageSize *float64

+ DatePartitionDelimiter *string

+ DatePartitionEnabled *bool

+ DatePartitionSequence *string

+ DictPageSizeLimit *float64

+ EnableStatistics *bool

+ EncodingType *string

+ EncryptionMode *string

+ ExternalTableDefinition *string

+ IgnoreHeadersRow *float64

+ IncludeOpForFullLoad *bool

+ MaxFileSize *float64

+ ParquetTimestampInMillisecond *bool

+ ParquetVersion *string

+ PreserveTransactions *bool

+ Rfc4180 *bool

+ RowGroupLength *float64

+ ServerSideEncryptionKMSKeyID *string

+ ServiceAccessRoleArn *string

+ TimestampColumnName *string

+ UseCsvNoSupValue *bool

+ func (in *S3SettingsParameters) DeepCopy() *S3SettingsParameters

+ func (in *S3SettingsParameters) DeepCopyInto(out *S3SettingsParameters)