v1alpha1

package

Go to main page

Versions in this module

v0

v0.5.0

May 8, 2022

Changes in this version

type EndpointSpecKafkaSettings

+ IncludeControlDetails *bool

+ IncludeNullAndEmpty *bool

+ IncludePartitionValue *bool

+ IncludeTableAlterOperations *bool

+ IncludeTransactionDetails *bool

+ MessageFormat *string

+ MessageMaxBytes *int64

+ NoHexPrefix *bool

+ PartitionIncludeSchemaTable *bool

+ SaslPassword *string

+ SaslUsername *string

+ SecurityProtocol *string

+ SslCaCertificateArn *string

+ SslClientCertificateArn *string

+ SslClientKeyArn *string

+ SslClientKeyPassword *string

type EndpointSpecKinesisSettings

+ IncludeControlDetails *bool

+ IncludeNullAndEmpty *bool

+ IncludePartitionValue *bool

+ IncludeTableAlterOperations *bool

+ IncludeTransactionDetails *bool

+ PartitionIncludeSchemaTable *bool

type EndpointSpecResource

+ SecretsManagerAccessRoleArn *string

+ SecretsManagerArn *string

type EndpointSpecS3Settings

+ AddColumnName *bool

+ CannedACLForObjects *string

+ CdcInsertsAndUpdates *bool

+ CdcInsertsOnly *bool

+ CdcMaxBatchInterval *int64

+ CdcMinFileSize *int64

+ CdcPath *string

+ CsvNoSupValue *string

+ CsvNullValue *string

+ DataFormat *string

+ DataPageSize *int64

+ DatePartitionDelimiter *string

+ DatePartitionSequence *string

+ DictPageSizeLimit *int64

+ EnableStatistics *bool

+ EncodingType *string

+ EncryptionMode *string

+ IgnoreHeadersRow *int64

+ IncludeOpForFullLoad *bool

+ MaxFileSize *int64

+ ParquetTimestampInMillisecond *bool

+ ParquetVersion *string

+ PreserveTransactions *bool

+ Rfc4180 *bool

+ RowGroupLength *int64

+ ServerSideEncryptionKmsKeyID *string

+ TimestampColumnName *string

+ UseCsvNoSupValue *bool

type ReplicationTaskSpecResource

+ CdcStartPosition *string

v0.4.0

Oct 20, 2021

Changes in this version

type CertificateSpec

+ BackendRef *core.LocalObjectReference

type EndpointSpec

+ BackendRef *core.LocalObjectReference

type EventSubscriptionSpec

+ BackendRef *core.LocalObjectReference

type ReplicationInstanceSpec

+ BackendRef *core.LocalObjectReference

type ReplicationSubnetGroupSpec

+ BackendRef *core.LocalObjectReference

type ReplicationTaskSpec

+ BackendRef *core.LocalObjectReference

v0.3.0

Aug 2, 2021

v0.2.0

Jul 13, 2021

v0.1.1

Jul 13, 2021

Changes in this version

type CertificateSpec

+ State *CertificateSpecResource

type EndpointSpec

+ State *EndpointSpecResource

type EventSubscriptionSpec

+ State *EventSubscriptionSpecResource

type ReplicationInstanceSpec

+ State *ReplicationInstanceSpecResource

type ReplicationSubnetGroupSpec

+ State *ReplicationSubnetGroupSpecResource

type ReplicationTaskSpec

+ State *ReplicationTaskSpecResource

v0.1.0

Jul 2, 2021

Changes in this version

+ var AddToScheme = localSchemeBuilder.AddToScheme

+ var SchemeBuilder runtime.SchemeBuilder

+ var SchemeGroupVersion = schema.GroupVersion

+ func GetDecoder() map[string]jsoniter.ValDecoder

+ func GetEncoder() map[string]jsoniter.ValEncoder

+ func Kind(kind string) schema.GroupKind

+ func Resource(resource string) schema.GroupResource

+ 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 (r *Certificate) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *Certificate) ValidateCreate() error

+ func (r *Certificate) ValidateDelete() error

+ func (r *Certificate) ValidateUpdate(old runtime.Object) error

+ type CertificateList struct

+ Items []Certificate

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

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

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

+ type CertificateSpec struct

+ KubeformOutput *CertificateSpecResource

+ ProviderRef core.LocalObjectReference

+ Resource CertificateSpecResource

+ SecretRef *core.LocalObjectReference

+ TerminationPolicy base.TerminationPolicy

+ UpdatePolicy base.UpdatePolicy

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

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

+ type CertificateSpecResource struct

+ CertificateArn *string

+ CertificateID *string

+ CertificatePem *string

+ CertificateWallet *string

+ ID string

+ Tags *map[string]string

+ TagsAll *map[string]string

+ func (in *CertificateSpecResource) DeepCopy() *CertificateSpecResource

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

+ type CertificateStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase status.Status

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

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

+ 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 (r *Endpoint) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *Endpoint) ValidateCreate() error

+ func (r *Endpoint) ValidateDelete() error

+ func (r *Endpoint) ValidateUpdate(old runtime.Object) error

+ type EndpointList struct

+ Items []Endpoint

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

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

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

+ type EndpointSpec struct

+ KubeformOutput *EndpointSpecResource

+ ProviderRef core.LocalObjectReference

+ Resource EndpointSpecResource

+ SecretRef *core.LocalObjectReference

+ TerminationPolicy base.TerminationPolicy

+ UpdatePolicy base.UpdatePolicy

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

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

+ type EndpointSpecElasticsearchSettings struct

+ EndpointURI *string

+ ErrorRetryDuration *int64

+ FullLoadErrorPercentage *int64

+ ServiceAccessRoleArn *string

+ func (in *EndpointSpecElasticsearchSettings) DeepCopy() *EndpointSpecElasticsearchSettings

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

+ type EndpointSpecElasticsearchSettingsCodec struct

+ func (EndpointSpecElasticsearchSettingsCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (EndpointSpecElasticsearchSettingsCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (EndpointSpecElasticsearchSettingsCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type EndpointSpecKafkaSettings struct

+ Broker *string

+ Topic *string

+ func (in *EndpointSpecKafkaSettings) DeepCopy() *EndpointSpecKafkaSettings

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

+ type EndpointSpecKafkaSettingsCodec struct

+ func (EndpointSpecKafkaSettingsCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (EndpointSpecKafkaSettingsCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (EndpointSpecKafkaSettingsCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type EndpointSpecKinesisSettings struct

+ MessageFormat *string

+ ServiceAccessRoleArn *string

+ StreamArn *string

+ func (in *EndpointSpecKinesisSettings) DeepCopy() *EndpointSpecKinesisSettings

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

+ type EndpointSpecKinesisSettingsCodec struct

+ func (EndpointSpecKinesisSettingsCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (EndpointSpecKinesisSettingsCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (EndpointSpecKinesisSettingsCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type EndpointSpecMongodbSettings struct

+ AuthMechanism *string

+ AuthSource *string

+ AuthType *string

+ DocsToInvestigate *string

+ ExtractDocID *string

+ NestingLevel *string

+ func (in *EndpointSpecMongodbSettings) DeepCopy() *EndpointSpecMongodbSettings

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

+ type EndpointSpecMongodbSettingsCodec struct

+ func (EndpointSpecMongodbSettingsCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (EndpointSpecMongodbSettingsCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (EndpointSpecMongodbSettingsCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type EndpointSpecResource struct

+ CertificateArn *string

+ DatabaseName *string

+ ElasticsearchSettings *EndpointSpecElasticsearchSettings

+ EndpointArn *string

+ EndpointID *string

+ EndpointType *string

+ EngineName *string

+ ExtraConnectionAttributes *string

+ ID string

+ KafkaSettings *EndpointSpecKafkaSettings

+ KinesisSettings *EndpointSpecKinesisSettings

+ KmsKeyArn *string

+ MongodbSettings *EndpointSpecMongodbSettings

+ Password *string

+ Port *int64

+ S3Settings *EndpointSpecS3Settings

+ ServerName *string

+ ServiceAccessRole *string

+ SslMode *string

+ Tags *map[string]string

+ TagsAll *map[string]string

+ Username *string

+ func (in *EndpointSpecResource) DeepCopy() *EndpointSpecResource

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

+ type EndpointSpecS3Settings struct

+ BucketFolder *string

+ BucketName *string

+ CompressionType *string

+ CsvDelimiter *string

+ CsvRowDelimiter *string

+ DatePartitionEnabled *bool

+ ExternalTableDefinition *string

+ ServiceAccessRoleArn *string

+ func (in *EndpointSpecS3Settings) DeepCopy() *EndpointSpecS3Settings

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

+ type EndpointSpecS3SettingsCodec struct

+ func (EndpointSpecS3SettingsCodec) Decode(ptr unsafe.Pointer, iter *jsoniter.Iterator)

+ func (EndpointSpecS3SettingsCodec) Encode(ptr unsafe.Pointer, stream *jsoniter.Stream)

+ func (EndpointSpecS3SettingsCodec) IsEmpty(ptr unsafe.Pointer) bool

+ type EndpointStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase status.Status

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

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

+ 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 (r *EventSubscription) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *EventSubscription) ValidateCreate() error

+ func (r *EventSubscription) ValidateDelete() error

+ func (r *EventSubscription) ValidateUpdate(old runtime.Object) error

+ type EventSubscriptionList struct

+ Items []EventSubscription

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

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

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

+ type EventSubscriptionSpec struct

+ KubeformOutput *EventSubscriptionSpecResource

+ ProviderRef core.LocalObjectReference

+ Resource EventSubscriptionSpecResource

+ TerminationPolicy base.TerminationPolicy

+ UpdatePolicy base.UpdatePolicy

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

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

+ type EventSubscriptionSpecResource struct

+ Arn *string

+ Enabled *bool

+ EventCategories []string

+ ID string

+ Name *string

+ SnsTopicArn *string

+ SourceIDS []string

+ SourceType *string

+ Tags *map[string]string

+ TagsAll *map[string]string

+ Timeouts *base.ResourceTimeout

+ func (in *EventSubscriptionSpecResource) DeepCopy() *EventSubscriptionSpecResource

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

+ type EventSubscriptionStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase status.Status

+ 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 (r *ReplicationInstance) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *ReplicationInstance) ValidateCreate() error

+ func (r *ReplicationInstance) ValidateDelete() error

+ func (r *ReplicationInstance) ValidateUpdate(old runtime.Object) error

+ type ReplicationInstanceList struct

+ Items []ReplicationInstance

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

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

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

+ type ReplicationInstanceSpec struct

+ KubeformOutput *ReplicationInstanceSpecResource

+ ProviderRef core.LocalObjectReference

+ Resource ReplicationInstanceSpecResource

+ TerminationPolicy base.TerminationPolicy

+ UpdatePolicy base.UpdatePolicy

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

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

+ type ReplicationInstanceSpecResource struct

+ AllocatedStorage *int64

+ AllowMajorVersionUpgrade *bool

+ ApplyImmediately *bool

+ AutoMinorVersionUpgrade *bool

+ AvailabilityZone *string

+ EngineVersion *string

+ ID string

+ KmsKeyArn *string

+ MultiAz *bool

+ PreferredMaintenanceWindow *string

+ PubliclyAccessible *bool

+ ReplicationInstanceArn *string

+ ReplicationInstanceClass *string

+ ReplicationInstanceID *string

+ ReplicationInstancePrivateIPS []string

+ ReplicationInstancePublicIPS []string

+ ReplicationSubnetGroupID *string

+ Tags *map[string]string

+ TagsAll *map[string]string

+ Timeouts *base.ResourceTimeout

+ VpcSecurityGroupIDS []string

+ func (in *ReplicationInstanceSpecResource) DeepCopy() *ReplicationInstanceSpecResource

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

+ type ReplicationInstanceStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase status.Status

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

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

+ 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 (r *ReplicationSubnetGroup) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *ReplicationSubnetGroup) ValidateCreate() error

+ func (r *ReplicationSubnetGroup) ValidateDelete() error

+ func (r *ReplicationSubnetGroup) ValidateUpdate(old runtime.Object) error

+ type ReplicationSubnetGroupList struct

+ Items []ReplicationSubnetGroup

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

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

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

+ type ReplicationSubnetGroupSpec struct

+ KubeformOutput *ReplicationSubnetGroupSpecResource

+ ProviderRef core.LocalObjectReference

+ Resource ReplicationSubnetGroupSpecResource

+ TerminationPolicy base.TerminationPolicy

+ UpdatePolicy base.UpdatePolicy

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

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

+ type ReplicationSubnetGroupSpecResource struct

+ ID string

+ ReplicationSubnetGroupArn *string

+ ReplicationSubnetGroupDescription *string

+ ReplicationSubnetGroupID *string

+ SubnetIDS []string

+ Tags *map[string]string

+ TagsAll *map[string]string

+ VpcID *string

+ func (in *ReplicationSubnetGroupSpecResource) DeepCopy() *ReplicationSubnetGroupSpecResource

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

+ type ReplicationSubnetGroupStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase status.Status

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

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

+ 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 (r *ReplicationTask) SetupWebhookWithManager(mgr ctrl.Manager) error

+ func (r *ReplicationTask) ValidateCreate() error

+ func (r *ReplicationTask) ValidateDelete() error

+ func (r *ReplicationTask) ValidateUpdate(old runtime.Object) error

+ type ReplicationTaskList struct

+ Items []ReplicationTask

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

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

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

+ type ReplicationTaskSpec struct

+ KubeformOutput *ReplicationTaskSpecResource

+ ProviderRef core.LocalObjectReference

+ Resource ReplicationTaskSpecResource

+ TerminationPolicy base.TerminationPolicy

+ UpdatePolicy base.UpdatePolicy

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

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

+ type ReplicationTaskSpecResource struct

+ CdcStartTime *string

+ ID string

+ MigrationType *string

+ ReplicationInstanceArn *string

+ ReplicationTaskArn *string

+ ReplicationTaskID *string

+ ReplicationTaskSettings *string

+ SourceEndpointArn *string

+ TableMappings *string

+ Tags *map[string]string

+ TagsAll *map[string]string

+ TargetEndpointArn *string

+ func (in *ReplicationTaskSpecResource) DeepCopy() *ReplicationTaskSpecResource

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

+ type ReplicationTaskStatus struct

+ Conditions []kmapi.Condition

+ ObservedGeneration int64

+ Phase status.Status

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

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

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