v1alpha1

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 8, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Overview

+groupName=dms.aws.kubeform.com

Index

Constants

This section is empty.

Variables

View Source 
var (
	// TODO: move SchemeBuilder with zz_generated.deepcopy.go to k8s.io/api.
	// localSchemeBuilder and AddToScheme will stay in k8s.io/kubernetes.
	SchemeBuilder runtime.SchemeBuilder

	AddToScheme = localSchemeBuilder.AddToScheme
)
View Source 
var SchemeGroupVersion = schema.GroupVersion{Group: dms.GroupName, Version: "v1alpha1"}

Functions

func GetDecoder 

func GetDecoder() map[string]jsoniter.ValDecoder

func GetEncoder 

func GetEncoder() map[string]jsoniter.ValEncoder

func Kind 

func Kind(kind string) schema.GroupKind

Kind takes an unqualified kind and returns a Group qualified GroupKind

func Resource 

func Resource(resource string) schema.GroupResource

Resource takes an unqualified resource and returns a Group qualified GroupResource

Types

type Certificate 

type Certificate struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              CertificateSpec   `json:"spec,omitempty"`
	Status            CertificateStatus `json:"status,omitempty"`
}

func (*Certificate) DeepCopy 

func (in *Certificate) DeepCopy() *Certificate

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Certificate.

func (*Certificate) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Certificate) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Certificate) SetupWebhookWithManager 

func (r *Certificate) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Certificate) ValidateCreate 

func (r *Certificate) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Certificate) ValidateDelete 

func (r *Certificate) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Certificate) ValidateUpdate 

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

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type CertificateList 

type CertificateList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of Certificate CRD objects
	Items []Certificate `json:"items,omitempty"`
}

CertificateList is a list of Certificates

func (*CertificateList) DeepCopy 

func (in *CertificateList) DeepCopy() *CertificateList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CertificateList.

func (*CertificateList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*CertificateList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type CertificateSpec 

type CertificateSpec struct {
	State *CertificateSpecResource `json:"state,omitempty" tf:"-"`

	Resource CertificateSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	SecretRef *core.LocalObjectReference `json:"secretRef,omitempty" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*CertificateSpec) DeepCopy 

func (in *CertificateSpec) DeepCopy() *CertificateSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CertificateSpec.

func (*CertificateSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CertificateSpecResource 

type CertificateSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	CertificateArn *string `json:"certificateArn,omitempty" tf:"certificate_arn"`
	CertificateID  *string `json:"certificateID" tf:"certificate_id"`
	// +optional
	CertificatePem *string `json:"-" sensitive:"true" tf:"certificate_pem"`
	// +optional
	CertificateWallet *string `json:"-" sensitive:"true" tf:"certificate_wallet"`
	// +optional
	Tags *map[string]string `json:"tags,omitempty" tf:"tags"`
	// +optional
	TagsAll *map[string]string `json:"tagsAll,omitempty" tf:"tags_all"`
}

func (*CertificateSpecResource) DeepCopy 

func (in *CertificateSpecResource) DeepCopy() *CertificateSpecResource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CertificateSpecResource.

func (*CertificateSpecResource) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type CertificateStatus 

type CertificateStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*CertificateStatus) DeepCopy 

func (in *CertificateStatus) DeepCopy() *CertificateStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CertificateStatus.

func (*CertificateStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type Endpoint 

type Endpoint struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              EndpointSpec   `json:"spec,omitempty"`
	Status            EndpointStatus `json:"status,omitempty"`
}

func (*Endpoint) DeepCopy 

func (in *Endpoint) DeepCopy() *Endpoint

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Endpoint.

func (*Endpoint) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*Endpoint) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*Endpoint) SetupWebhookWithManager 

func (r *Endpoint) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*Endpoint) ValidateCreate 

func (r *Endpoint) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*Endpoint) ValidateDelete 

func (r *Endpoint) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*Endpoint) ValidateUpdate 

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

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type EndpointList 

type EndpointList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of Endpoint CRD objects
	Items []Endpoint `json:"items,omitempty"`
}

EndpointList is a list of Endpoints

func (*EndpointList) DeepCopy 

func (in *EndpointList) DeepCopy() *EndpointList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointList.

func (*EndpointList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*EndpointList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type EndpointSpec 

type EndpointSpec struct {
	State *EndpointSpecResource `json:"state,omitempty" tf:"-"`

	Resource EndpointSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	SecretRef *core.LocalObjectReference `json:"secretRef,omitempty" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*EndpointSpec) DeepCopy 

func (in *EndpointSpec) DeepCopy() *EndpointSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointSpec.

func (*EndpointSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EndpointSpecElasticsearchSettings 

type EndpointSpecElasticsearchSettings struct {
	EndpointURI *string `json:"endpointURI" tf:"endpoint_uri"`
	// +optional
	ErrorRetryDuration *int64 `json:"errorRetryDuration,omitempty" tf:"error_retry_duration"`
	// +optional
	FullLoadErrorPercentage *int64  `json:"fullLoadErrorPercentage,omitempty" tf:"full_load_error_percentage"`
	ServiceAccessRoleArn    *string `json:"serviceAccessRoleArn" tf:"service_access_role_arn"`
}

func (*EndpointSpecElasticsearchSettings) DeepCopy 

func (in *EndpointSpecElasticsearchSettings) DeepCopy() *EndpointSpecElasticsearchSettings

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointSpecElasticsearchSettings.

func (*EndpointSpecElasticsearchSettings) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EndpointSpecElasticsearchSettingsCodec 

type EndpointSpecElasticsearchSettingsCodec struct {
}

+k8s:deepcopy-gen=false

func (EndpointSpecElasticsearchSettingsCodec) Decode 

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

func (EndpointSpecElasticsearchSettingsCodec) Encode 

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

func (EndpointSpecElasticsearchSettingsCodec) IsEmpty 

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

type EndpointSpecKafkaSettings 

type EndpointSpecKafkaSettings struct {
	Broker *string `json:"broker" tf:"broker"`
	// +optional
	IncludeControlDetails *bool `json:"includeControlDetails,omitempty" tf:"include_control_details"`
	// +optional
	IncludeNullAndEmpty *bool `json:"includeNullAndEmpty,omitempty" tf:"include_null_and_empty"`
	// +optional
	IncludePartitionValue *bool `json:"includePartitionValue,omitempty" tf:"include_partition_value"`
	// +optional
	IncludeTableAlterOperations *bool `json:"includeTableAlterOperations,omitempty" tf:"include_table_alter_operations"`
	// +optional
	IncludeTransactionDetails *bool `json:"includeTransactionDetails,omitempty" tf:"include_transaction_details"`
	// +optional
	MessageFormat *string `json:"messageFormat,omitempty" tf:"message_format"`
	// +optional
	MessageMaxBytes *int64 `json:"messageMaxBytes,omitempty" tf:"message_max_bytes"`
	// +optional
	NoHexPrefix *bool `json:"noHexPrefix,omitempty" tf:"no_hex_prefix"`
	// +optional
	PartitionIncludeSchemaTable *bool `json:"partitionIncludeSchemaTable,omitempty" tf:"partition_include_schema_table"`
	// +optional
	SaslPassword *string `json:"-" sensitive:"true" tf:"sasl_password"`
	// +optional
	SaslUsername *string `json:"saslUsername,omitempty" tf:"sasl_username"`
	// +optional
	SecurityProtocol *string `json:"securityProtocol,omitempty" tf:"security_protocol"`
	// +optional
	SslCaCertificateArn *string `json:"sslCaCertificateArn,omitempty" tf:"ssl_ca_certificate_arn"`
	// +optional
	SslClientCertificateArn *string `json:"sslClientCertificateArn,omitempty" tf:"ssl_client_certificate_arn"`
	// +optional
	SslClientKeyArn *string `json:"sslClientKeyArn,omitempty" tf:"ssl_client_key_arn"`
	// +optional
	SslClientKeyPassword *string `json:"-" sensitive:"true" tf:"ssl_client_key_password"`
	// +optional
	Topic *string `json:"topic,omitempty" tf:"topic"`
}

func (*EndpointSpecKafkaSettings) DeepCopy 

func (in *EndpointSpecKafkaSettings) DeepCopy() *EndpointSpecKafkaSettings

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointSpecKafkaSettings.

func (*EndpointSpecKafkaSettings) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EndpointSpecKafkaSettingsCodec 

type EndpointSpecKafkaSettingsCodec struct {
}

+k8s:deepcopy-gen=false

func (EndpointSpecKafkaSettingsCodec) Decode 

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

func (EndpointSpecKafkaSettingsCodec) Encode 

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

func (EndpointSpecKafkaSettingsCodec) IsEmpty 

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

type EndpointSpecKinesisSettings 

type EndpointSpecKinesisSettings struct {
	// +optional
	IncludeControlDetails *bool `json:"includeControlDetails,omitempty" tf:"include_control_details"`
	// +optional
	IncludeNullAndEmpty *bool `json:"includeNullAndEmpty,omitempty" tf:"include_null_and_empty"`
	// +optional
	IncludePartitionValue *bool `json:"includePartitionValue,omitempty" tf:"include_partition_value"`
	// +optional
	IncludeTableAlterOperations *bool `json:"includeTableAlterOperations,omitempty" tf:"include_table_alter_operations"`
	// +optional
	IncludeTransactionDetails *bool `json:"includeTransactionDetails,omitempty" tf:"include_transaction_details"`
	// +optional
	MessageFormat *string `json:"messageFormat,omitempty" tf:"message_format"`
	// +optional
	PartitionIncludeSchemaTable *bool `json:"partitionIncludeSchemaTable,omitempty" tf:"partition_include_schema_table"`
	// +optional
	ServiceAccessRoleArn *string `json:"serviceAccessRoleArn,omitempty" tf:"service_access_role_arn"`
	// +optional
	StreamArn *string `json:"streamArn,omitempty" tf:"stream_arn"`
}

func (*EndpointSpecKinesisSettings) DeepCopy 

func (in *EndpointSpecKinesisSettings) DeepCopy() *EndpointSpecKinesisSettings

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointSpecKinesisSettings.

func (*EndpointSpecKinesisSettings) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EndpointSpecKinesisSettingsCodec 

type EndpointSpecKinesisSettingsCodec struct {
}

+k8s:deepcopy-gen=false

func (EndpointSpecKinesisSettingsCodec) Decode 

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

func (EndpointSpecKinesisSettingsCodec) Encode 

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

func (EndpointSpecKinesisSettingsCodec) IsEmpty 

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

type EndpointSpecMongodbSettings 

type EndpointSpecMongodbSettings struct {
	// +optional
	AuthMechanism *string `json:"authMechanism,omitempty" tf:"auth_mechanism"`
	// +optional
	AuthSource *string `json:"authSource,omitempty" tf:"auth_source"`
	// +optional
	AuthType *string `json:"authType,omitempty" tf:"auth_type"`
	// +optional
	DocsToInvestigate *string `json:"docsToInvestigate,omitempty" tf:"docs_to_investigate"`
	// +optional
	ExtractDocID *string `json:"extractDocID,omitempty" tf:"extract_doc_id"`
	// +optional
	NestingLevel *string `json:"nestingLevel,omitempty" tf:"nesting_level"`
}

func (*EndpointSpecMongodbSettings) DeepCopy 

func (in *EndpointSpecMongodbSettings) DeepCopy() *EndpointSpecMongodbSettings

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointSpecMongodbSettings.

func (*EndpointSpecMongodbSettings) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EndpointSpecMongodbSettingsCodec 

type EndpointSpecMongodbSettingsCodec struct {
}

+k8s:deepcopy-gen=false

func (EndpointSpecMongodbSettingsCodec) Decode 

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

func (EndpointSpecMongodbSettingsCodec) Encode 

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

func (EndpointSpecMongodbSettingsCodec) IsEmpty 

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

type EndpointSpecResource 

type EndpointSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	CertificateArn *string `json:"certificateArn,omitempty" tf:"certificate_arn"`
	// +optional
	DatabaseName *string `json:"databaseName,omitempty" tf:"database_name"`
	// +optional
	ElasticsearchSettings *EndpointSpecElasticsearchSettings `json:"elasticsearchSettings,omitempty" tf:"elasticsearch_settings"`
	// +optional
	EndpointArn  *string `json:"endpointArn,omitempty" tf:"endpoint_arn"`
	EndpointID   *string `json:"endpointID" tf:"endpoint_id"`
	EndpointType *string `json:"endpointType" tf:"endpoint_type"`
	EngineName   *string `json:"engineName" tf:"engine_name"`
	// +optional
	ExtraConnectionAttributes *string `json:"extraConnectionAttributes,omitempty" tf:"extra_connection_attributes"`
	// +optional
	KafkaSettings *EndpointSpecKafkaSettings `json:"kafkaSettings,omitempty" tf:"kafka_settings"`
	// +optional
	KinesisSettings *EndpointSpecKinesisSettings `json:"kinesisSettings,omitempty" tf:"kinesis_settings"`
	// +optional
	KmsKeyArn *string `json:"kmsKeyArn,omitempty" tf:"kms_key_arn"`
	// +optional
	MongodbSettings *EndpointSpecMongodbSettings `json:"mongodbSettings,omitempty" tf:"mongodb_settings"`
	// +optional
	Password *string `json:"-" sensitive:"true" tf:"password"`
	// +optional
	Port *int64 `json:"port,omitempty" tf:"port"`
	// +optional
	S3Settings *EndpointSpecS3Settings `json:"s3Settings,omitempty" tf:"s3_settings"`
	// +optional
	SecretsManagerAccessRoleArn *string `json:"secretsManagerAccessRoleArn,omitempty" tf:"secrets_manager_access_role_arn"`
	// +optional
	SecretsManagerArn *string `json:"secretsManagerArn,omitempty" tf:"secrets_manager_arn"`
	// +optional
	ServerName *string `json:"serverName,omitempty" tf:"server_name"`
	// +optional
	ServiceAccessRole *string `json:"serviceAccessRole,omitempty" tf:"service_access_role"`
	// +optional
	SslMode *string `json:"sslMode,omitempty" tf:"ssl_mode"`
	// +optional
	Tags *map[string]string `json:"tags,omitempty" tf:"tags"`
	// +optional
	TagsAll *map[string]string `json:"tagsAll,omitempty" tf:"tags_all"`
	// +optional
	Username *string `json:"username,omitempty" tf:"username"`
}

func (*EndpointSpecResource) DeepCopy 

func (in *EndpointSpecResource) DeepCopy() *EndpointSpecResource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointSpecResource.

func (*EndpointSpecResource) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EndpointSpecS3Settings 

type EndpointSpecS3Settings struct {
	// +optional
	AddColumnName *bool `json:"addColumnName,omitempty" tf:"add_column_name"`
	// +optional
	BucketFolder *string `json:"bucketFolder,omitempty" tf:"bucket_folder"`
	// +optional
	BucketName *string `json:"bucketName,omitempty" tf:"bucket_name"`
	// +optional
	CannedACLForObjects *string `json:"cannedACLForObjects,omitempty" tf:"canned_acl_for_objects"`
	// +optional
	CdcInsertsAndUpdates *bool `json:"cdcInsertsAndUpdates,omitempty" tf:"cdc_inserts_and_updates"`
	// +optional
	CdcInsertsOnly *bool `json:"cdcInsertsOnly,omitempty" tf:"cdc_inserts_only"`
	// +optional
	CdcMaxBatchInterval *int64 `json:"cdcMaxBatchInterval,omitempty" tf:"cdc_max_batch_interval"`
	// +optional
	CdcMinFileSize *int64 `json:"cdcMinFileSize,omitempty" tf:"cdc_min_file_size"`
	// +optional
	CdcPath *string `json:"cdcPath,omitempty" tf:"cdc_path"`
	// +optional
	CompressionType *string `json:"compressionType,omitempty" tf:"compression_type"`
	// +optional
	CsvDelimiter *string `json:"csvDelimiter,omitempty" tf:"csv_delimiter"`
	// +optional
	CsvNoSupValue *string `json:"csvNoSupValue,omitempty" tf:"csv_no_sup_value"`
	// +optional
	CsvNullValue *string `json:"csvNullValue,omitempty" tf:"csv_null_value"`
	// +optional
	CsvRowDelimiter *string `json:"csvRowDelimiter,omitempty" tf:"csv_row_delimiter"`
	// +optional
	DataFormat *string `json:"dataFormat,omitempty" tf:"data_format"`
	// +optional
	DataPageSize *int64 `json:"dataPageSize,omitempty" tf:"data_page_size"`
	// +optional
	DatePartitionDelimiter *string `json:"datePartitionDelimiter,omitempty" tf:"date_partition_delimiter"`
	// +optional
	DatePartitionEnabled *bool `json:"datePartitionEnabled,omitempty" tf:"date_partition_enabled"`
	// +optional
	DatePartitionSequence *string `json:"datePartitionSequence,omitempty" tf:"date_partition_sequence"`
	// +optional
	DictPageSizeLimit *int64 `json:"dictPageSizeLimit,omitempty" tf:"dict_page_size_limit"`
	// +optional
	EnableStatistics *bool `json:"enableStatistics,omitempty" tf:"enable_statistics"`
	// +optional
	EncodingType *string `json:"encodingType,omitempty" tf:"encoding_type"`
	// +optional
	EncryptionMode *string `json:"encryptionMode,omitempty" tf:"encryption_mode"`
	// +optional
	ExternalTableDefinition *string `json:"externalTableDefinition,omitempty" tf:"external_table_definition"`
	// +optional
	IgnoreHeadersRow *int64 `json:"ignoreHeadersRow,omitempty" tf:"ignore_headers_row"`
	// +optional
	IncludeOpForFullLoad *bool `json:"includeOpForFullLoad,omitempty" tf:"include_op_for_full_load"`
	// +optional
	MaxFileSize *int64 `json:"maxFileSize,omitempty" tf:"max_file_size"`
	// +optional
	ParquetTimestampInMillisecond *bool `json:"parquetTimestampInMillisecond,omitempty" tf:"parquet_timestamp_in_millisecond"`
	// +optional
	ParquetVersion *string `json:"parquetVersion,omitempty" tf:"parquet_version"`
	// +optional
	PreserveTransactions *bool `json:"preserveTransactions,omitempty" tf:"preserve_transactions"`
	// +optional
	Rfc4180 *bool `json:"rfc4180,omitempty" tf:"rfc_4180"`
	// +optional
	RowGroupLength *int64 `json:"rowGroupLength,omitempty" tf:"row_group_length"`
	// +optional
	ServerSideEncryptionKmsKeyID *string `json:"serverSideEncryptionKmsKeyID,omitempty" tf:"server_side_encryption_kms_key_id"`
	// +optional
	ServiceAccessRoleArn *string `json:"serviceAccessRoleArn,omitempty" tf:"service_access_role_arn"`
	// +optional
	TimestampColumnName *string `json:"timestampColumnName,omitempty" tf:"timestamp_column_name"`
	// +optional
	UseCsvNoSupValue *bool `json:"useCsvNoSupValue,omitempty" tf:"use_csv_no_sup_value"`
}

func (*EndpointSpecS3Settings) DeepCopy 

func (in *EndpointSpecS3Settings) DeepCopy() *EndpointSpecS3Settings

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointSpecS3Settings.

func (*EndpointSpecS3Settings) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EndpointSpecS3SettingsCodec 

type EndpointSpecS3SettingsCodec struct {
}

+k8s:deepcopy-gen=false

func (EndpointSpecS3SettingsCodec) Decode 

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

func (EndpointSpecS3SettingsCodec) Encode 

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

func (EndpointSpecS3SettingsCodec) IsEmpty 

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

type EndpointStatus 

type EndpointStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*EndpointStatus) DeepCopy 

func (in *EndpointStatus) DeepCopy() *EndpointStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointStatus.

func (*EndpointStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EventSubscription 

type EventSubscription struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              EventSubscriptionSpec   `json:"spec,omitempty"`
	Status            EventSubscriptionStatus `json:"status,omitempty"`
}

func (*EventSubscription) DeepCopy 

func (in *EventSubscription) DeepCopy() *EventSubscription

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSubscription.

func (*EventSubscription) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*EventSubscription) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*EventSubscription) SetupWebhookWithManager 

func (r *EventSubscription) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*EventSubscription) ValidateCreate 

func (r *EventSubscription) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*EventSubscription) ValidateDelete 

func (r *EventSubscription) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*EventSubscription) ValidateUpdate 

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

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type EventSubscriptionList 

type EventSubscriptionList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of EventSubscription CRD objects
	Items []EventSubscription `json:"items,omitempty"`
}

EventSubscriptionList is a list of EventSubscriptions

func (*EventSubscriptionList) DeepCopy 

func (in *EventSubscriptionList) DeepCopy() *EventSubscriptionList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSubscriptionList.

func (*EventSubscriptionList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*EventSubscriptionList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type EventSubscriptionSpec 

type EventSubscriptionSpec struct {
	State *EventSubscriptionSpecResource `json:"state,omitempty" tf:"-"`

	Resource EventSubscriptionSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*EventSubscriptionSpec) DeepCopy 

func (in *EventSubscriptionSpec) DeepCopy() *EventSubscriptionSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSubscriptionSpec.

func (*EventSubscriptionSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EventSubscriptionSpecResource 

type EventSubscriptionSpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	Arn *string `json:"arn,omitempty" tf:"arn"`
	// +optional
	Enabled         *bool    `json:"enabled,omitempty" tf:"enabled"`
	EventCategories []string `json:"eventCategories" tf:"event_categories"`
	Name            *string  `json:"name" tf:"name"`
	SnsTopicArn     *string  `json:"snsTopicArn" tf:"sns_topic_arn"`
	// +optional
	SourceIDS []string `json:"sourceIDS,omitempty" tf:"source_ids"`
	// +optional
	SourceType *string `json:"sourceType,omitempty" tf:"source_type"`
	// +optional
	Tags *map[string]string `json:"tags,omitempty" tf:"tags"`
	// +optional
	TagsAll *map[string]string `json:"tagsAll,omitempty" tf:"tags_all"`
}

func (*EventSubscriptionSpecResource) DeepCopy 

func (in *EventSubscriptionSpecResource) DeepCopy() *EventSubscriptionSpecResource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSubscriptionSpecResource.

func (*EventSubscriptionSpecResource) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type EventSubscriptionStatus 

type EventSubscriptionStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*EventSubscriptionStatus) DeepCopy 

func (in *EventSubscriptionStatus) DeepCopy() *EventSubscriptionStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EventSubscriptionStatus.

func (*EventSubscriptionStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReplicationInstance 

type ReplicationInstance struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ReplicationInstanceSpec   `json:"spec,omitempty"`
	Status            ReplicationInstanceStatus `json:"status,omitempty"`
}

func (*ReplicationInstance) DeepCopy 

func (in *ReplicationInstance) DeepCopy() *ReplicationInstance

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationInstance.

func (*ReplicationInstance) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ReplicationInstance) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ReplicationInstance) SetupWebhookWithManager 

func (r *ReplicationInstance) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*ReplicationInstance) ValidateCreate 

func (r *ReplicationInstance) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*ReplicationInstance) ValidateDelete 

func (r *ReplicationInstance) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*ReplicationInstance) ValidateUpdate 

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

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type ReplicationInstanceList 

type ReplicationInstanceList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of ReplicationInstance CRD objects
	Items []ReplicationInstance `json:"items,omitempty"`
}

ReplicationInstanceList is a list of ReplicationInstances

func (*ReplicationInstanceList) DeepCopy 

func (in *ReplicationInstanceList) DeepCopy() *ReplicationInstanceList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationInstanceList.

func (*ReplicationInstanceList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ReplicationInstanceList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ReplicationInstanceSpec 

type ReplicationInstanceSpec struct {
	State *ReplicationInstanceSpecResource `json:"state,omitempty" tf:"-"`

	Resource ReplicationInstanceSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*ReplicationInstanceSpec) DeepCopy 

func (in *ReplicationInstanceSpec) DeepCopy() *ReplicationInstanceSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationInstanceSpec.

func (*ReplicationInstanceSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReplicationInstanceSpecResource 

type ReplicationInstanceSpecResource struct {
	Timeouts *base.ResourceTimeout `json:"timeouts,omitempty" tf:"timeouts"`

	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	AllocatedStorage *int64 `json:"allocatedStorage,omitempty" tf:"allocated_storage"`
	// +optional
	AllowMajorVersionUpgrade *bool `json:"allowMajorVersionUpgrade,omitempty" tf:"allow_major_version_upgrade"`
	// +optional
	ApplyImmediately *bool `json:"applyImmediately,omitempty" tf:"apply_immediately"`
	// +optional
	AutoMinorVersionUpgrade *bool `json:"autoMinorVersionUpgrade,omitempty" tf:"auto_minor_version_upgrade"`
	// +optional
	AvailabilityZone *string `json:"availabilityZone,omitempty" tf:"availability_zone"`
	// +optional
	EngineVersion *string `json:"engineVersion,omitempty" tf:"engine_version"`
	// +optional
	KmsKeyArn *string `json:"kmsKeyArn,omitempty" tf:"kms_key_arn"`
	// +optional
	MultiAz *bool `json:"multiAz,omitempty" tf:"multi_az"`
	// +optional
	PreferredMaintenanceWindow *string `json:"preferredMaintenanceWindow,omitempty" tf:"preferred_maintenance_window"`
	// +optional
	PubliclyAccessible *bool `json:"publiclyAccessible,omitempty" tf:"publicly_accessible"`
	// +optional
	ReplicationInstanceArn   *string `json:"replicationInstanceArn,omitempty" tf:"replication_instance_arn"`
	ReplicationInstanceClass *string `json:"replicationInstanceClass" tf:"replication_instance_class"`
	ReplicationInstanceID    *string `json:"replicationInstanceID" tf:"replication_instance_id"`
	// +optional
	ReplicationInstancePrivateIPS []string `json:"replicationInstancePrivateIPS,omitempty" tf:"replication_instance_private_ips"`
	// +optional
	ReplicationInstancePublicIPS []string `json:"replicationInstancePublicIPS,omitempty" tf:"replication_instance_public_ips"`
	// +optional
	ReplicationSubnetGroupID *string `json:"replicationSubnetGroupID,omitempty" tf:"replication_subnet_group_id"`
	// +optional
	Tags *map[string]string `json:"tags,omitempty" tf:"tags"`
	// +optional
	TagsAll *map[string]string `json:"tagsAll,omitempty" tf:"tags_all"`
	// +optional
	VpcSecurityGroupIDS []string `json:"vpcSecurityGroupIDS,omitempty" tf:"vpc_security_group_ids"`
}

func (*ReplicationInstanceSpecResource) DeepCopy 

func (in *ReplicationInstanceSpecResource) DeepCopy() *ReplicationInstanceSpecResource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationInstanceSpecResource.

func (*ReplicationInstanceSpecResource) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReplicationInstanceStatus 

type ReplicationInstanceStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*ReplicationInstanceStatus) DeepCopy 

func (in *ReplicationInstanceStatus) DeepCopy() *ReplicationInstanceStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationInstanceStatus.

func (*ReplicationInstanceStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReplicationSubnetGroup 

type ReplicationSubnetGroup struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ReplicationSubnetGroupSpec   `json:"spec,omitempty"`
	Status            ReplicationSubnetGroupStatus `json:"status,omitempty"`
}

func (*ReplicationSubnetGroup) DeepCopy 

func (in *ReplicationSubnetGroup) DeepCopy() *ReplicationSubnetGroup

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationSubnetGroup.

func (*ReplicationSubnetGroup) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ReplicationSubnetGroup) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ReplicationSubnetGroup) SetupWebhookWithManager 

func (r *ReplicationSubnetGroup) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*ReplicationSubnetGroup) ValidateCreate 

func (r *ReplicationSubnetGroup) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*ReplicationSubnetGroup) ValidateDelete 

func (r *ReplicationSubnetGroup) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*ReplicationSubnetGroup) ValidateUpdate 

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

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type ReplicationSubnetGroupList 

type ReplicationSubnetGroupList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of ReplicationSubnetGroup CRD objects
	Items []ReplicationSubnetGroup `json:"items,omitempty"`
}

ReplicationSubnetGroupList is a list of ReplicationSubnetGroups

func (*ReplicationSubnetGroupList) DeepCopy 

func (in *ReplicationSubnetGroupList) DeepCopy() *ReplicationSubnetGroupList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationSubnetGroupList.

func (*ReplicationSubnetGroupList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ReplicationSubnetGroupList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ReplicationSubnetGroupSpec 

type ReplicationSubnetGroupSpec struct {
	State *ReplicationSubnetGroupSpecResource `json:"state,omitempty" tf:"-"`

	Resource ReplicationSubnetGroupSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*ReplicationSubnetGroupSpec) DeepCopy 

func (in *ReplicationSubnetGroupSpec) DeepCopy() *ReplicationSubnetGroupSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationSubnetGroupSpec.

func (*ReplicationSubnetGroupSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReplicationSubnetGroupSpecResource 

type ReplicationSubnetGroupSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	ReplicationSubnetGroupArn         *string  `json:"replicationSubnetGroupArn,omitempty" tf:"replication_subnet_group_arn"`
	ReplicationSubnetGroupDescription *string  `json:"replicationSubnetGroupDescription" tf:"replication_subnet_group_description"`
	ReplicationSubnetGroupID          *string  `json:"replicationSubnetGroupID" tf:"replication_subnet_group_id"`
	SubnetIDS                         []string `json:"subnetIDS" tf:"subnet_ids"`
	// +optional
	Tags *map[string]string `json:"tags,omitempty" tf:"tags"`
	// +optional
	TagsAll *map[string]string `json:"tagsAll,omitempty" tf:"tags_all"`
	// +optional
	VpcID *string `json:"vpcID,omitempty" tf:"vpc_id"`
}

func (*ReplicationSubnetGroupSpecResource) DeepCopy 

func (in *ReplicationSubnetGroupSpecResource) DeepCopy() *ReplicationSubnetGroupSpecResource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationSubnetGroupSpecResource.

func (*ReplicationSubnetGroupSpecResource) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReplicationSubnetGroupStatus 

type ReplicationSubnetGroupStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*ReplicationSubnetGroupStatus) DeepCopy 

func (in *ReplicationSubnetGroupStatus) DeepCopy() *ReplicationSubnetGroupStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationSubnetGroupStatus.

func (*ReplicationSubnetGroupStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReplicationTask 

type ReplicationTask struct {
	metav1.TypeMeta   `json:",inline,omitempty"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ReplicationTaskSpec   `json:"spec,omitempty"`
	Status            ReplicationTaskStatus `json:"status,omitempty"`
}

func (*ReplicationTask) DeepCopy 

func (in *ReplicationTask) DeepCopy() *ReplicationTask

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationTask.

func (*ReplicationTask) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ReplicationTask) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

func (*ReplicationTask) SetupWebhookWithManager 

func (r *ReplicationTask) SetupWebhookWithManager(mgr ctrl.Manager) error

func (*ReplicationTask) ValidateCreate 

func (r *ReplicationTask) ValidateCreate() error

ValidateCreate implements webhook.Validator so a webhook will be registered for the type

func (*ReplicationTask) ValidateDelete 

func (r *ReplicationTask) ValidateDelete() error

ValidateDelete implements webhook.Validator so a webhook will be registered for the type

func (*ReplicationTask) ValidateUpdate 

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

ValidateUpdate implements webhook.Validator so a webhook will be registered for the type

type ReplicationTaskList 

type ReplicationTaskList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	// Items is a list of ReplicationTask CRD objects
	Items []ReplicationTask `json:"items,omitempty"`
}

ReplicationTaskList is a list of ReplicationTasks

func (*ReplicationTaskList) DeepCopy 

func (in *ReplicationTaskList) DeepCopy() *ReplicationTaskList

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationTaskList.

func (*ReplicationTaskList) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

func (*ReplicationTaskList) DeepCopyObject 

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

DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.

type ReplicationTaskSpec 

type ReplicationTaskSpec struct {
	State *ReplicationTaskSpecResource `json:"state,omitempty" tf:"-"`

	Resource ReplicationTaskSpecResource `json:"resource" tf:"resource"`

	UpdatePolicy base.UpdatePolicy `json:"updatePolicy,omitempty" tf:"-"`

	TerminationPolicy base.TerminationPolicy `json:"terminationPolicy,omitempty" tf:"-"`

	ProviderRef core.LocalObjectReference `json:"providerRef" tf:"-"`

	BackendRef *core.LocalObjectReference `json:"backendRef,omitempty" tf:"-"`
}

func (*ReplicationTaskSpec) DeepCopy 

func (in *ReplicationTaskSpec) DeepCopy() *ReplicationTaskSpec

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationTaskSpec.

func (*ReplicationTaskSpec) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReplicationTaskSpecResource 

type ReplicationTaskSpecResource struct {
	ID string `json:"id,omitempty" tf:"id,omitempty"`

	// +optional
	CdcStartPosition *string `json:"cdcStartPosition,omitempty" tf:"cdc_start_position"`
	// +optional
	CdcStartTime           *string `json:"cdcStartTime,omitempty" tf:"cdc_start_time"`
	MigrationType          *string `json:"migrationType" tf:"migration_type"`
	ReplicationInstanceArn *string `json:"replicationInstanceArn" tf:"replication_instance_arn"`
	// +optional
	ReplicationTaskArn *string `json:"replicationTaskArn,omitempty" tf:"replication_task_arn"`
	ReplicationTaskID  *string `json:"replicationTaskID" tf:"replication_task_id"`
	// +optional
	ReplicationTaskSettings *string `json:"replicationTaskSettings,omitempty" tf:"replication_task_settings"`
	SourceEndpointArn       *string `json:"sourceEndpointArn" tf:"source_endpoint_arn"`
	TableMappings           *string `json:"tableMappings" tf:"table_mappings"`
	// +optional
	Tags *map[string]string `json:"tags,omitempty" tf:"tags"`
	// +optional
	TagsAll           *map[string]string `json:"tagsAll,omitempty" tf:"tags_all"`
	TargetEndpointArn *string            `json:"targetEndpointArn" tf:"target_endpoint_arn"`
}

func (*ReplicationTaskSpecResource) DeepCopy 

func (in *ReplicationTaskSpecResource) DeepCopy() *ReplicationTaskSpecResource

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationTaskSpecResource.

func (*ReplicationTaskSpecResource) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

type ReplicationTaskStatus 

type ReplicationTaskStatus struct {
	// Resource generation, which is updated on mutation by the API Server.
	// +optional
	ObservedGeneration int64 `json:"observedGeneration,omitempty"`
	// +optional
	Phase status.Status `json:"phase,omitempty"`
	// +optional
	Conditions []kmapi.Condition `json:"conditions,omitempty"`
}

func (*ReplicationTaskStatus) DeepCopy 

func (in *ReplicationTaskStatus) DeepCopy() *ReplicationTaskStatus

DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationTaskStatus.

func (*ReplicationTaskStatus) DeepCopyInto 

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

DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.