Documentation
¶
Overview ¶
+kubebuilder:object:generate=true +groupName=dms.aws.upbound.io +versionName=v1beta1
Index ¶
- Constants
- Variables
- type Certificate
- 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 (tr *Certificate) GetConnectionDetailsMapping() map[string]string
- func (mg *Certificate) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *Certificate) GetID() string
- func (tr *Certificate) GetObservation() (map[string]any, error)
- func (tr *Certificate) GetParameters() (map[string]any, error)
- func (mg *Certificate) GetProviderConfigReference() *xpv1.Reference
- func (mg *Certificate) GetProviderReference() *xpv1.Reference
- func (mg *Certificate) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Certificate) GetTerraformResourceType() string
- func (tr *Certificate) GetTerraformSchemaVersion() int
- func (mg *Certificate) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *Certificate) LateInitialize(attrs []byte) (bool, error)
- func (mg *Certificate) SetConditions(c ...xpv1.Condition)
- func (mg *Certificate) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (tr *Certificate) SetObservation(obs map[string]any) error
- func (tr *Certificate) SetParameters(params map[string]any) error
- 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)
- type CertificateList
- type CertificateObservation
- type CertificateParameters
- type CertificateSpec
- type CertificateStatus
- type ElasticsearchSettingsObservation
- type ElasticsearchSettingsParameters
- type Endpoint
- 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 (tr *Endpoint) GetConnectionDetailsMapping() map[string]string
- func (mg *Endpoint) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *Endpoint) GetID() string
- func (tr *Endpoint) GetObservation() (map[string]any, error)
- func (tr *Endpoint) GetParameters() (map[string]any, error)
- func (mg *Endpoint) GetProviderConfigReference() *xpv1.Reference
- func (mg *Endpoint) GetProviderReference() *xpv1.Reference
- func (mg *Endpoint) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Endpoint) GetTerraformResourceType() string
- func (tr *Endpoint) GetTerraformSchemaVersion() int
- func (mg *Endpoint) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *Endpoint) LateInitialize(attrs []byte) (bool, error)
- 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 (tr *Endpoint) SetObservation(obs map[string]any) error
- func (tr *Endpoint) SetParameters(params map[string]any) error
- 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)
- type EndpointList
- type EndpointObservation
- type EndpointParameters
- type EndpointSpec
- type EndpointStatus
- type KafkaSettingsObservation
- type KafkaSettingsParameters
- type KinesisSettingsObservation
- type KinesisSettingsParameters
- type MongodbSettingsObservation
- type MongodbSettingsParameters
- type ReplicationSubnetGroup
- 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 (tr *ReplicationSubnetGroup) GetConnectionDetailsMapping() map[string]string
- func (mg *ReplicationSubnetGroup) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *ReplicationSubnetGroup) GetID() string
- func (tr *ReplicationSubnetGroup) GetObservation() (map[string]any, error)
- func (tr *ReplicationSubnetGroup) GetParameters() (map[string]any, error)
- func (mg *ReplicationSubnetGroup) GetProviderConfigReference() *xpv1.Reference
- func (mg *ReplicationSubnetGroup) GetProviderReference() *xpv1.Reference
- func (mg *ReplicationSubnetGroup) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *ReplicationSubnetGroup) GetTerraformResourceType() string
- func (tr *ReplicationSubnetGroup) GetTerraformSchemaVersion() int
- func (mg *ReplicationSubnetGroup) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *ReplicationSubnetGroup) LateInitialize(attrs []byte) (bool, error)
- 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 (tr *ReplicationSubnetGroup) SetObservation(obs map[string]any) error
- func (tr *ReplicationSubnetGroup) SetParameters(params map[string]any) error
- 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)
- type ReplicationSubnetGroupList
- type ReplicationSubnetGroupObservation
- type ReplicationSubnetGroupParameters
- type ReplicationSubnetGroupSpec
- type ReplicationSubnetGroupStatus
- type S3SettingsObservation
- type S3SettingsParameters
Constants ¶
const ( CRDGroup = "dms.aws.upbound.io" CRDVersion = "v1beta1" )
Package type metadata.
Variables ¶
var ( Certificate_Kind = "Certificate" Certificate_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Certificate_Kind}.String() Certificate_KindAPIVersion = Certificate_Kind + "." + CRDGroupVersion.String() Certificate_GroupVersionKind = CRDGroupVersion.WithKind(Certificate_Kind) )
Repository type metadata.
var ( Endpoint_Kind = "Endpoint" Endpoint_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Endpoint_Kind}.String() Endpoint_KindAPIVersion = Endpoint_Kind + "." + CRDGroupVersion.String() Endpoint_GroupVersionKind = CRDGroupVersion.WithKind(Endpoint_Kind) )
Repository type metadata.
var ( // CRDGroupVersion is the API Group Version used to register the objects CRDGroupVersion = schema.GroupVersion{Group: CRDGroup, Version: CRDVersion} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: CRDGroupVersion} // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme )
var ( ReplicationSubnetGroup_Kind = "ReplicationSubnetGroup" ReplicationSubnetGroup_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: ReplicationSubnetGroup_Kind}.String() ReplicationSubnetGroup_KindAPIVersion = ReplicationSubnetGroup_Kind + "." + CRDGroupVersion.String() ReplicationSubnetGroup_GroupVersionKind = CRDGroupVersion.WithKind(ReplicationSubnetGroup_Kind) )
Repository type metadata.
Functions ¶
This section is empty.
Types ¶
type Certificate ¶
type Certificate struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec CertificateSpec `json:"spec"` Status CertificateStatus `json:"status,omitempty"` }
Certificate is the Schema for the Certificates API. Provides a DMS (Data Migration Service) certificate resource. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}
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) GetCondition ¶
func (mg *Certificate) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this Certificate.
func (*Certificate) GetConnectionDetailsMapping ¶
func (tr *Certificate) GetConnectionDetailsMapping() map[string]string
GetConnectionDetailsMapping for this Certificate
func (*Certificate) GetDeletionPolicy ¶
func (mg *Certificate) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this Certificate.
func (*Certificate) GetID ¶
func (tr *Certificate) GetID() string
GetID returns ID of underlying Terraform resource of this Certificate
func (*Certificate) GetObservation ¶
func (tr *Certificate) GetObservation() (map[string]any, error)
GetObservation of this Certificate
func (*Certificate) GetParameters ¶
func (tr *Certificate) GetParameters() (map[string]any, error)
GetParameters of this Certificate
func (*Certificate) GetProviderConfigReference ¶
func (mg *Certificate) GetProviderConfigReference() *xpv1.Reference
GetProviderConfigReference of this Certificate.
func (*Certificate) GetProviderReference ¶
func (mg *Certificate) GetProviderReference() *xpv1.Reference
GetProviderReference of this Certificate. Deprecated: Use GetProviderConfigReference.
func (*Certificate) GetPublishConnectionDetailsTo ¶
func (mg *Certificate) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Certificate.
func (*Certificate) GetTerraformResourceType ¶
func (mg *Certificate) GetTerraformResourceType() string
GetTerraformResourceType returns Terraform resource type for this Certificate
func (*Certificate) GetTerraformSchemaVersion ¶
func (tr *Certificate) GetTerraformSchemaVersion() int
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*Certificate) GetWriteConnectionSecretToReference ¶
func (mg *Certificate) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this Certificate.
func (*Certificate) LateInitialize ¶
func (tr *Certificate) LateInitialize(attrs []byte) (bool, error)
LateInitialize this Certificate using its observed tfState. returns True if there are any spec changes for the resource.
func (*Certificate) SetConditions ¶
func (mg *Certificate) SetConditions(c ...xpv1.Condition)
SetConditions of this Certificate.
func (*Certificate) SetDeletionPolicy ¶
func (mg *Certificate) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Certificate.
func (*Certificate) SetObservation ¶
func (tr *Certificate) SetObservation(obs map[string]any) error
SetObservation for this Certificate
func (*Certificate) SetParameters ¶
func (tr *Certificate) SetParameters(params map[string]any) error
SetParameters for this Certificate
func (*Certificate) SetProviderConfigReference ¶
func (mg *Certificate) SetProviderConfigReference(r *xpv1.Reference)
SetProviderConfigReference of this Certificate.
func (*Certificate) SetProviderReference ¶
func (mg *Certificate) SetProviderReference(r *xpv1.Reference)
SetProviderReference of this Certificate. Deprecated: Use SetProviderConfigReference.
func (*Certificate) SetPublishConnectionDetailsTo ¶
func (mg *Certificate) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this Certificate.
func (*Certificate) SetWriteConnectionSecretToReference ¶
func (mg *Certificate) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this Certificate.
type CertificateList ¶
type CertificateList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Certificate `json:"items"` }
CertificateList contains 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.
func (*CertificateList) GetItems ¶
func (l *CertificateList) GetItems() []resource.Managed
GetItems of this CertificateList.
type CertificateObservation ¶
type CertificateObservation struct { // The Amazon Resource Name (ARN) for the certificate. CertificateArn *string `json:"certificateArn,omitempty" tf:"certificate_arn,omitempty"` ID *string `json:"id,omitempty" tf:"id,omitempty"` // A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block. TagsAll map[string]*string `json:"tagsAll,omitempty" tf:"tags_all,omitempty"` }
func (*CertificateObservation) DeepCopy ¶
func (in *CertificateObservation) DeepCopy() *CertificateObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CertificateObservation.
func (*CertificateObservation) DeepCopyInto ¶
func (in *CertificateObservation) DeepCopyInto(out *CertificateObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CertificateParameters ¶
type CertificateParameters struct { // The contents of the .pem X.509 certificate file for the certificate. Either certificate_pem or certificate_wallet must be set. // +kubebuilder:validation:Optional CertificatePemSecretRef *v1.SecretKeySelector `json:"certificatePemSecretRef,omitempty" tf:"-"` // The contents of the Oracle Wallet certificate for use with SSL, provided as a base64-encoded String. Either certificate_pem or certificate_wallet must be set. // +kubebuilder:validation:Optional CertificateWalletSecretRef *v1.SecretKeySelector `json:"certificateWalletSecretRef,omitempty" tf:"-"` // Region is the region you'd like your resource to be created in. // +upjet:crd:field:TFTag=- // +kubebuilder:validation:Required Region *string `json:"region" tf:"-"` // Key-value map of resource tags. // +kubebuilder:validation:Optional Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"` }
func (*CertificateParameters) DeepCopy ¶
func (in *CertificateParameters) DeepCopy() *CertificateParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CertificateParameters.
func (*CertificateParameters) DeepCopyInto ¶
func (in *CertificateParameters) DeepCopyInto(out *CertificateParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CertificateSpec ¶
type CertificateSpec struct { v1.ResourceSpec `json:",inline"` ForProvider CertificateParameters `json:"forProvider"` }
CertificateSpec defines the desired state of Certificate
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 CertificateStatus ¶
type CertificateStatus struct { v1.ResourceStatus `json:",inline"` AtProvider CertificateObservation `json:"atProvider,omitempty"` }
CertificateStatus defines the observed state of Certificate.
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 ElasticsearchSettingsObservation ¶
type ElasticsearchSettingsObservation struct { }
func (*ElasticsearchSettingsObservation) DeepCopy ¶
func (in *ElasticsearchSettingsObservation) DeepCopy() *ElasticsearchSettingsObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ElasticsearchSettingsObservation.
func (*ElasticsearchSettingsObservation) DeepCopyInto ¶
func (in *ElasticsearchSettingsObservation) DeepCopyInto(out *ElasticsearchSettingsObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ElasticsearchSettingsParameters ¶
type ElasticsearchSettingsParameters struct { // Endpoint for the OpenSearch cluster. // +kubebuilder:validation:Required EndpointURI *string `json:"endpointUri" tf:"endpoint_uri,omitempty"` // Maximum number of seconds for which DMS retries failed API requests to the OpenSearch cluster. Default is 300. // +kubebuilder:validation:Optional ErrorRetryDuration *float64 `json:"errorRetryDuration,omitempty" tf:"error_retry_duration,omitempty"` // Maximum percentage of records that can fail to be written before a full load operation stops. Default is 10. // +kubebuilder:validation:Optional FullLoadErrorPercentage *float64 `json:"fullLoadErrorPercentage,omitempty" tf:"full_load_error_percentage,omitempty"` // ARN of the IAM Role with permissions to write to the OpenSearch cluster. // +kubebuilder:validation:Required ServiceAccessRoleArn *string `json:"serviceAccessRoleArn" tf:"service_access_role_arn,omitempty"` }
func (*ElasticsearchSettingsParameters) DeepCopy ¶
func (in *ElasticsearchSettingsParameters) DeepCopy() *ElasticsearchSettingsParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ElasticsearchSettingsParameters.
func (*ElasticsearchSettingsParameters) DeepCopyInto ¶
func (in *ElasticsearchSettingsParameters) DeepCopyInto(out *ElasticsearchSettingsParameters)
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"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec EndpointSpec `json:"spec"` Status EndpointStatus `json:"status,omitempty"` }
Endpoint is the Schema for the Endpoints API. Provides a DMS (Data Migration Service) endpoint resource. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}
func (*Endpoint) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Endpoint.
func (*Endpoint) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Endpoint) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Endpoint) GetCondition ¶
func (mg *Endpoint) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this Endpoint.
func (*Endpoint) GetConnectionDetailsMapping ¶
GetConnectionDetailsMapping for this Endpoint
func (*Endpoint) GetDeletionPolicy ¶
func (mg *Endpoint) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this Endpoint.
func (*Endpoint) GetObservation ¶
GetObservation of this Endpoint
func (*Endpoint) GetParameters ¶
GetParameters of this Endpoint
func (*Endpoint) GetProviderConfigReference ¶
GetProviderConfigReference of this Endpoint.
func (*Endpoint) GetProviderReference ¶
GetProviderReference of this Endpoint. Deprecated: Use GetProviderConfigReference.
func (*Endpoint) GetPublishConnectionDetailsTo ¶
func (mg *Endpoint) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Endpoint.
func (*Endpoint) GetTerraformResourceType ¶
GetTerraformResourceType returns Terraform resource type for this Endpoint
func (*Endpoint) GetTerraformSchemaVersion ¶
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*Endpoint) GetWriteConnectionSecretToReference ¶
func (mg *Endpoint) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this Endpoint.
func (*Endpoint) LateInitialize ¶
LateInitialize this Endpoint using its observed tfState. returns True if there are any spec changes for the resource.
func (*Endpoint) ResolveReferences ¶
ResolveReferences of this Endpoint.
func (*Endpoint) SetConditions ¶
SetConditions of this Endpoint.
func (*Endpoint) SetDeletionPolicy ¶
func (mg *Endpoint) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Endpoint.
func (*Endpoint) SetObservation ¶
SetObservation for this Endpoint
func (*Endpoint) SetParameters ¶
SetParameters for this Endpoint
func (*Endpoint) SetProviderConfigReference ¶
SetProviderConfigReference of this Endpoint.
func (*Endpoint) SetProviderReference ¶
SetProviderReference of this Endpoint. Deprecated: Use SetProviderConfigReference.
func (*Endpoint) SetPublishConnectionDetailsTo ¶
func (mg *Endpoint) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this Endpoint.
func (*Endpoint) SetWriteConnectionSecretToReference ¶
func (mg *Endpoint) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this Endpoint.
type EndpointList ¶
type EndpointList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Endpoint `json:"items"` }
EndpointList contains 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.
func (*EndpointList) GetItems ¶
func (l *EndpointList) GetItems() []resource.Managed
GetItems of this EndpointList.
type EndpointObservation ¶
type EndpointObservation struct { // ARN for the endpoint. EndpointArn *string `json:"endpointArn,omitempty" tf:"endpoint_arn,omitempty"` ID *string `json:"id,omitempty" tf:"id,omitempty"` // Map of tags assigned to the resource, including those inherited from the provider default_tags configuration block. TagsAll map[string]*string `json:"tagsAll,omitempty" tf:"tags_all,omitempty"` }
func (*EndpointObservation) DeepCopy ¶
func (in *EndpointObservation) DeepCopy() *EndpointObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointObservation.
func (*EndpointObservation) DeepCopyInto ¶
func (in *EndpointObservation) DeepCopyInto(out *EndpointObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EndpointParameters ¶
type EndpointParameters struct { // ARN for the certificate. // +kubebuilder:validation:Optional CertificateArn *string `json:"certificateArn,omitempty" tf:"certificate_arn,omitempty"` // Name of the endpoint database. // +kubebuilder:validation:Optional DatabaseName *string `json:"databaseName,omitempty" tf:"database_name,omitempty"` // Configuration block for OpenSearch settings. See below. // +kubebuilder:validation:Optional ElasticsearchSettings []ElasticsearchSettingsParameters `json:"elasticsearchSettings,omitempty" tf:"elasticsearch_settings,omitempty"` // Type of endpoint. Valid values are source, target. // +kubebuilder:validation:Required EndpointType *string `json:"endpointType" tf:"endpoint_type,omitempty"` // Type of engine for the endpoint. Valid values are aurora, aurora-postgresql, azuredb, db2, docdb, dynamodb, elasticsearch, kafka, kinesis, mariadb, mongodb, mysql, opensearch, oracle, postgres, redshift, s3, sqlserver, sybase. // +kubebuilder:validation:Required EngineName *string `json:"engineName" tf:"engine_name,omitempty"` // Additional attributes associated with the connection. For available attributes see Using Extra Connection Attributes with AWS Database Migration Service. // +kubebuilder:validation:Optional ExtraConnectionAttributes *string `json:"extraConnectionAttributes,omitempty" tf:"extra_connection_attributes,omitempty"` // ARN for the KMS key that will be used to encrypt the connection parameters. If you do not specify a value for kms_key_arn, then AWS DMS will use your default encryption key. AWS KMS creates the default encryption key for your AWS account. Your AWS account has a different default encryption key for each AWS region. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kms/v1beta1.Key // +kubebuilder:validation:Optional KMSKeyArn *string `json:"kmsKeyArn,omitempty" tf:"kms_key_arn,omitempty"` // Reference to a Key in kms to populate kmsKeyArn. // +kubebuilder:validation:Optional KMSKeyArnRef *v1.Reference `json:"kmsKeyArnRef,omitempty" tf:"-"` // Selector for a Key in kms to populate kmsKeyArn. // +kubebuilder:validation:Optional KMSKeyArnSelector *v1.Selector `json:"kmsKeyArnSelector,omitempty" tf:"-"` // Configuration block for Kafka settings. See below. // +kubebuilder:validation:Optional KafkaSettings []KafkaSettingsParameters `json:"kafkaSettings,omitempty" tf:"kafka_settings,omitempty"` // Configuration block for Kinesis settings. See below. // +kubebuilder:validation:Optional KinesisSettings []KinesisSettingsParameters `json:"kinesisSettings,omitempty" tf:"kinesis_settings,omitempty"` // Configuration block for MongoDB settings. See below. // +kubebuilder:validation:Optional MongodbSettings []MongodbSettingsParameters `json:"mongodbSettings,omitempty" tf:"mongodb_settings,omitempty"` // Password to be used to login to the endpoint database. // +kubebuilder:validation:Optional PasswordSecretRef *v1.SecretKeySelector `json:"passwordSecretRef,omitempty" tf:"-"` // Port used by the endpoint database. // +kubebuilder:validation:Optional Port *float64 `json:"port,omitempty" tf:"port,omitempty"` // Region is the region you'd like your resource to be created in. // +upjet:crd:field:TFTag=- // +kubebuilder:validation:Required Region *string `json:"region" tf:"-"` // Configuration block for S3 settings. See below. // +kubebuilder:validation:Optional S3Settings []S3SettingsParameters `json:"s3Settings,omitempty" tf:"s3_settings,omitempty"` // SSL mode to use for the connection. Valid values are none, require, verify-ca, verify-full // +kubebuilder:validation:Optional SSLMode *string `json:"sslMode,omitempty" tf:"ssl_mode,omitempty"` // ARN of the IAM role that specifies AWS DMS as the trusted entity and has the required permissions to access the value in SecretsManagerSecret. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/iam/v1beta1.Role // +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor() // +kubebuilder:validation:Optional SecretsManagerAccessRoleArn *string `json:"secretsManagerAccessRoleArn,omitempty" tf:"secrets_manager_access_role_arn,omitempty"` // Reference to a Role in iam to populate secretsManagerAccessRoleArn. // +kubebuilder:validation:Optional SecretsManagerAccessRoleArnRef *v1.Reference `json:"secretsManagerAccessRoleArnRef,omitempty" tf:"-"` // Selector for a Role in iam to populate secretsManagerAccessRoleArn. // +kubebuilder:validation:Optional SecretsManagerAccessRoleArnSelector *v1.Selector `json:"secretsManagerAccessRoleArnSelector,omitempty" tf:"-"` // Full ARN, partial ARN, or friendly name of the SecretsManagerSecret that contains the endpoint connection details. Supported only for engine_name as oracle and postgres. // +kubebuilder:validation:Optional SecretsManagerArn *string `json:"secretsManagerArn,omitempty" tf:"secrets_manager_arn,omitempty"` // Host name of the server. // +kubebuilder:validation:Optional ServerName *string `json:"serverName,omitempty" tf:"server_name,omitempty"` // ARN used by the service access IAM role for dynamodb endpoints. // +kubebuilder:validation:Optional ServiceAccessRole *string `json:"serviceAccessRole,omitempty" tf:"service_access_role,omitempty"` // Key-value map of resource tags. // +kubebuilder:validation:Optional Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"` // User name to be used to login to the endpoint database. // +kubebuilder:validation:Optional Username *string `json:"username,omitempty" tf:"username,omitempty"` }
func (*EndpointParameters) DeepCopy ¶
func (in *EndpointParameters) DeepCopy() *EndpointParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EndpointParameters.
func (*EndpointParameters) DeepCopyInto ¶
func (in *EndpointParameters) DeepCopyInto(out *EndpointParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EndpointSpec ¶
type EndpointSpec struct { v1.ResourceSpec `json:",inline"` ForProvider EndpointParameters `json:"forProvider"` }
EndpointSpec defines the desired state of Endpoint
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 EndpointStatus ¶
type EndpointStatus struct { v1.ResourceStatus `json:",inline"` AtProvider EndpointObservation `json:"atProvider,omitempty"` }
EndpointStatus defines the observed state of Endpoint.
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 KafkaSettingsObservation ¶
type KafkaSettingsObservation struct { }
func (*KafkaSettingsObservation) DeepCopy ¶
func (in *KafkaSettingsObservation) DeepCopy() *KafkaSettingsObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSettingsObservation.
func (*KafkaSettingsObservation) DeepCopyInto ¶
func (in *KafkaSettingsObservation) DeepCopyInto(out *KafkaSettingsObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KafkaSettingsParameters ¶
type KafkaSettingsParameters struct { // Kafka broker location. Specify in the form broker-hostname-or-ip:port. // +kubebuilder:validation:Required Broker *string `json:"broker" tf:"broker,omitempty"` // Shows detailed control information for table definition, column definition, and table and column changes in the Kafka message output. Default is false. // +kubebuilder:validation:Optional IncludeControlDetails *bool `json:"includeControlDetails,omitempty" tf:"include_control_details,omitempty"` // Include NULL and empty columns for records migrated to the endpoint. Default is false. // +kubebuilder:validation:Optional IncludeNullAndEmpty *bool `json:"includeNullAndEmpty,omitempty" tf:"include_null_and_empty,omitempty"` // Shows the partition value within the Kafka message output unless the partition type is schema-table-type. Default is false. // +kubebuilder:validation:Optional IncludePartitionValue *bool `json:"includePartitionValue,omitempty" tf:"include_partition_value,omitempty"` // Includes any data definition language (DDL) operations that change the table in the control data, such as rename-table, drop-table, add-column, drop-column, and rename-column. Default is false. // +kubebuilder:validation:Optional IncludeTableAlterOperations *bool `json:"includeTableAlterOperations,omitempty" tf:"include_table_alter_operations,omitempty"` // Provides detailed transaction information from the source database. This information includes a commit timestamp, a log position, and values for transaction_id, previous transaction_id, and transaction_record_id (the record offset within a transaction). Default is false. // +kubebuilder:validation:Optional IncludeTransactionDetails *bool `json:"includeTransactionDetails,omitempty" tf:"include_transaction_details,omitempty"` // Output format for the records created on the endpoint. Message format is JSON (default) or JSON_UNFORMATTED (a single line with no tab). // +kubebuilder:validation:Optional MessageFormat *string `json:"messageFormat,omitempty" tf:"message_format,omitempty"` // Maximum size in bytes for records created on the endpoint Default is 1,000,000. // +kubebuilder:validation:Optional MessageMaxBytes *float64 `json:"messageMaxBytes,omitempty" tf:"message_max_bytes,omitempty"` // Set this optional parameter to true to avoid adding a '0x' prefix to raw data in hexadecimal format. For example, by default, AWS DMS adds a '0x' prefix to the LOB column type in hexadecimal format moving from an Oracle source to a Kafka target. Use the no_hex_prefix endpoint setting to enable migration of RAW data type columns without adding the '0x' prefix. // +kubebuilder:validation:Optional NoHexPrefix *bool `json:"noHexPrefix,omitempty" tf:"no_hex_prefix,omitempty"` // Prefixes schema and table names to partition values, when the partition type is primary-key-type. Doing this increases data distribution among Kafka partitions. For example, suppose that a SysBench schema has thousands of tables and each table has only limited range for a primary key. In this case, the same primary key is sent from thousands of tables to the same partition, which causes throttling. Default is false. // +kubebuilder:validation:Optional PartitionIncludeSchemaTable *bool `json:"partitionIncludeSchemaTable,omitempty" tf:"partition_include_schema_table,omitempty"` // ARN for the private certificate authority (CA) cert that AWS DMS uses to securely connect to your Kafka target endpoint. // +kubebuilder:validation:Optional SSLCACertificateArn *string `json:"sslCaCertificateArn,omitempty" tf:"ssl_ca_certificate_arn,omitempty"` // ARN of the client certificate used to securely connect to a Kafka target endpoint. // +kubebuilder:validation:Optional SSLClientCertificateArn *string `json:"sslClientCertificateArn,omitempty" tf:"ssl_client_certificate_arn,omitempty"` // ARN for the client private key used to securely connect to a Kafka target endpoint. // +kubebuilder:validation:Optional SSLClientKeyArn *string `json:"sslClientKeyArn,omitempty" tf:"ssl_client_key_arn,omitempty"` // Password for the client private key used to securely connect to a Kafka target endpoint. // +kubebuilder:validation:Optional SSLClientKeyPasswordSecretRef *v1.SecretKeySelector `json:"sslClientKeyPasswordSecretRef,omitempty" tf:"-"` // Secure password you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication. // +kubebuilder:validation:Optional SaslPasswordSecretRef *v1.SecretKeySelector `json:"saslPasswordSecretRef,omitempty" tf:"-"` // Secure user name you created when you first set up your MSK cluster to validate a client identity and make an encrypted connection between server and client using SASL-SSL authentication. // +kubebuilder:validation:Optional SaslUsername *string `json:"saslUsername,omitempty" tf:"sasl_username,omitempty"` // Set secure connection to a Kafka target endpoint using Transport Layer Security (TLS). Options include ssl-encryption, ssl-authentication, and sasl-ssl. sasl-ssl requires sasl_username and sasl_password. // +kubebuilder:validation:Optional SecurityProtocol *string `json:"securityProtocol,omitempty" tf:"security_protocol,omitempty"` // Kafka topic for migration. Default is kafka-default-topic. // +kubebuilder:validation:Optional Topic *string `json:"topic,omitempty" tf:"topic,omitempty"` }
func (*KafkaSettingsParameters) DeepCopy ¶
func (in *KafkaSettingsParameters) DeepCopy() *KafkaSettingsParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KafkaSettingsParameters.
func (*KafkaSettingsParameters) DeepCopyInto ¶
func (in *KafkaSettingsParameters) DeepCopyInto(out *KafkaSettingsParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KinesisSettingsObservation ¶
type KinesisSettingsObservation struct { }
func (*KinesisSettingsObservation) DeepCopy ¶
func (in *KinesisSettingsObservation) DeepCopy() *KinesisSettingsObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KinesisSettingsObservation.
func (*KinesisSettingsObservation) DeepCopyInto ¶
func (in *KinesisSettingsObservation) DeepCopyInto(out *KinesisSettingsObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type KinesisSettingsParameters ¶
type KinesisSettingsParameters struct { // Shows detailed control information for table definition, column definition, and table and column changes in the Kinesis message output. Default is false. // +kubebuilder:validation:Optional IncludeControlDetails *bool `json:"includeControlDetails,omitempty" tf:"include_control_details,omitempty"` // Include NULL and empty columns in the target. Default is false. // +kubebuilder:validation:Optional IncludeNullAndEmpty *bool `json:"includeNullAndEmpty,omitempty" tf:"include_null_and_empty,omitempty"` // Shows the partition value within the Kinesis message output, unless the partition type is schema-table-type. Default is false. // +kubebuilder:validation:Optional IncludePartitionValue *bool `json:"includePartitionValue,omitempty" tf:"include_partition_value,omitempty"` // Includes any data definition language (DDL) operations that change the table in the control data. Default is false. // +kubebuilder:validation:Optional IncludeTableAlterOperations *bool `json:"includeTableAlterOperations,omitempty" tf:"include_table_alter_operations,omitempty"` // Provides detailed transaction information from the source database. Default is false. // +kubebuilder:validation:Optional IncludeTransactionDetails *bool `json:"includeTransactionDetails,omitempty" tf:"include_transaction_details,omitempty"` // Output format for the records created. Default is json. Valid values are json and json-unformatted (a single line with no tab). // +kubebuilder:validation:Optional MessageFormat *string `json:"messageFormat,omitempty" tf:"message_format,omitempty"` // Prefixes schema and table names to partition values, when the partition type is primary-key-type. Default is false. // +kubebuilder:validation:Optional PartitionIncludeSchemaTable *bool `json:"partitionIncludeSchemaTable,omitempty" tf:"partition_include_schema_table,omitempty"` // ARN of the IAM Role with permissions to write to the Kinesis data stream. // +kubebuilder:validation:Optional ServiceAccessRoleArn *string `json:"serviceAccessRoleArn,omitempty" tf:"service_access_role_arn,omitempty"` // ARN of the Kinesis data stream. // +kubebuilder:validation:Optional StreamArn *string `json:"streamArn,omitempty" tf:"stream_arn,omitempty"` }
func (*KinesisSettingsParameters) DeepCopy ¶
func (in *KinesisSettingsParameters) DeepCopy() *KinesisSettingsParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new KinesisSettingsParameters.
func (*KinesisSettingsParameters) DeepCopyInto ¶
func (in *KinesisSettingsParameters) DeepCopyInto(out *KinesisSettingsParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MongodbSettingsObservation ¶
type MongodbSettingsObservation struct { }
func (*MongodbSettingsObservation) DeepCopy ¶
func (in *MongodbSettingsObservation) DeepCopy() *MongodbSettingsObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MongodbSettingsObservation.
func (*MongodbSettingsObservation) DeepCopyInto ¶
func (in *MongodbSettingsObservation) DeepCopyInto(out *MongodbSettingsObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MongodbSettingsParameters ¶
type MongodbSettingsParameters struct { // Authentication mechanism to access the MongoDB source endpoint. Default is default. // +kubebuilder:validation:Optional AuthMechanism *string `json:"authMechanism,omitempty" tf:"auth_mechanism,omitempty"` // Authentication database name. Not used when auth_type is no. Default is admin. // +kubebuilder:validation:Optional AuthSource *string `json:"authSource,omitempty" tf:"auth_source,omitempty"` // Authentication type to access the MongoDB source endpoint. Default is password. // +kubebuilder:validation:Optional AuthType *string `json:"authType,omitempty" tf:"auth_type,omitempty"` // Number of documents to preview to determine the document organization. Use this setting when nesting_level is set to one. Default is 1000. // +kubebuilder:validation:Optional DocsToInvestigate *string `json:"docsToInvestigate,omitempty" tf:"docs_to_investigate,omitempty"` // Document ID. Use this setting when nesting_level is set to none. Default is false. // +kubebuilder:validation:Optional ExtractDocID *string `json:"extractDocId,omitempty" tf:"extract_doc_id,omitempty"` // Specifies either document or table mode. Default is none. Valid values are one (table mode) and none (document mode). // +kubebuilder:validation:Optional NestingLevel *string `json:"nestingLevel,omitempty" tf:"nesting_level,omitempty"` }
func (*MongodbSettingsParameters) DeepCopy ¶
func (in *MongodbSettingsParameters) DeepCopy() *MongodbSettingsParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MongodbSettingsParameters.
func (*MongodbSettingsParameters) DeepCopyInto ¶
func (in *MongodbSettingsParameters) DeepCopyInto(out *MongodbSettingsParameters)
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"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ReplicationSubnetGroupSpec `json:"spec"` Status ReplicationSubnetGroupStatus `json:"status,omitempty"` }
ReplicationSubnetGroup is the Schema for the ReplicationSubnetGroups API. Provides a DMS (Data Migration Service) subnet group resource. +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}
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) GetCondition ¶
func (mg *ReplicationSubnetGroup) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this ReplicationSubnetGroup.
func (*ReplicationSubnetGroup) GetConnectionDetailsMapping ¶
func (tr *ReplicationSubnetGroup) GetConnectionDetailsMapping() map[string]string
GetConnectionDetailsMapping for this ReplicationSubnetGroup
func (*ReplicationSubnetGroup) GetDeletionPolicy ¶
func (mg *ReplicationSubnetGroup) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this ReplicationSubnetGroup.
func (*ReplicationSubnetGroup) GetID ¶
func (tr *ReplicationSubnetGroup) GetID() string
GetID returns ID of underlying Terraform resource of this ReplicationSubnetGroup
func (*ReplicationSubnetGroup) GetObservation ¶
func (tr *ReplicationSubnetGroup) GetObservation() (map[string]any, error)
GetObservation of this ReplicationSubnetGroup
func (*ReplicationSubnetGroup) GetParameters ¶
func (tr *ReplicationSubnetGroup) GetParameters() (map[string]any, error)
GetParameters of this ReplicationSubnetGroup
func (*ReplicationSubnetGroup) GetProviderConfigReference ¶
func (mg *ReplicationSubnetGroup) GetProviderConfigReference() *xpv1.Reference
GetProviderConfigReference of this ReplicationSubnetGroup.
func (*ReplicationSubnetGroup) GetProviderReference ¶
func (mg *ReplicationSubnetGroup) GetProviderReference() *xpv1.Reference
GetProviderReference of this ReplicationSubnetGroup. Deprecated: Use GetProviderConfigReference.
func (*ReplicationSubnetGroup) GetPublishConnectionDetailsTo ¶
func (mg *ReplicationSubnetGroup) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this ReplicationSubnetGroup.
func (*ReplicationSubnetGroup) GetTerraformResourceType ¶
func (mg *ReplicationSubnetGroup) GetTerraformResourceType() string
GetTerraformResourceType returns Terraform resource type for this ReplicationSubnetGroup
func (*ReplicationSubnetGroup) GetTerraformSchemaVersion ¶
func (tr *ReplicationSubnetGroup) GetTerraformSchemaVersion() int
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*ReplicationSubnetGroup) GetWriteConnectionSecretToReference ¶
func (mg *ReplicationSubnetGroup) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this ReplicationSubnetGroup.
func (*ReplicationSubnetGroup) LateInitialize ¶
func (tr *ReplicationSubnetGroup) LateInitialize(attrs []byte) (bool, error)
LateInitialize this ReplicationSubnetGroup using its observed tfState. returns True if there are any spec changes for the resource.
func (*ReplicationSubnetGroup) ResolveReferences ¶
ResolveReferences of this ReplicationSubnetGroup.
func (*ReplicationSubnetGroup) SetConditions ¶
func (mg *ReplicationSubnetGroup) SetConditions(c ...xpv1.Condition)
SetConditions of this ReplicationSubnetGroup.
func (*ReplicationSubnetGroup) SetDeletionPolicy ¶
func (mg *ReplicationSubnetGroup) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this ReplicationSubnetGroup.
func (*ReplicationSubnetGroup) SetObservation ¶
func (tr *ReplicationSubnetGroup) SetObservation(obs map[string]any) error
SetObservation for this ReplicationSubnetGroup
func (*ReplicationSubnetGroup) SetParameters ¶
func (tr *ReplicationSubnetGroup) SetParameters(params map[string]any) error
SetParameters for this ReplicationSubnetGroup
func (*ReplicationSubnetGroup) SetProviderConfigReference ¶
func (mg *ReplicationSubnetGroup) SetProviderConfigReference(r *xpv1.Reference)
SetProviderConfigReference of this ReplicationSubnetGroup.
func (*ReplicationSubnetGroup) SetProviderReference ¶
func (mg *ReplicationSubnetGroup) SetProviderReference(r *xpv1.Reference)
SetProviderReference of this ReplicationSubnetGroup. Deprecated: Use SetProviderConfigReference.
func (*ReplicationSubnetGroup) SetPublishConnectionDetailsTo ¶
func (mg *ReplicationSubnetGroup) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this ReplicationSubnetGroup.
func (*ReplicationSubnetGroup) SetWriteConnectionSecretToReference ¶
func (mg *ReplicationSubnetGroup) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this ReplicationSubnetGroup.
type ReplicationSubnetGroupList ¶
type ReplicationSubnetGroupList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []ReplicationSubnetGroup `json:"items"` }
ReplicationSubnetGroupList contains 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.
func (*ReplicationSubnetGroupList) GetItems ¶
func (l *ReplicationSubnetGroupList) GetItems() []resource.Managed
GetItems of this ReplicationSubnetGroupList.
type ReplicationSubnetGroupObservation ¶
type ReplicationSubnetGroupObservation struct { ID *string `json:"id,omitempty" tf:"id,omitempty"` ReplicationSubnetGroupArn *string `json:"replicationSubnetGroupArn,omitempty" tf:"replication_subnet_group_arn,omitempty"` // A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block. TagsAll map[string]*string `json:"tagsAll,omitempty" tf:"tags_all,omitempty"` // The ID of the VPC the subnet group is in. VPCID *string `json:"vpcId,omitempty" tf:"vpc_id,omitempty"` }
func (*ReplicationSubnetGroupObservation) DeepCopy ¶
func (in *ReplicationSubnetGroupObservation) DeepCopy() *ReplicationSubnetGroupObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationSubnetGroupObservation.
func (*ReplicationSubnetGroupObservation) DeepCopyInto ¶
func (in *ReplicationSubnetGroupObservation) DeepCopyInto(out *ReplicationSubnetGroupObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ReplicationSubnetGroupParameters ¶
type ReplicationSubnetGroupParameters struct { // Region is the region you'd like your resource to be created in. // +upjet:crd:field:TFTag=- // +kubebuilder:validation:Required Region *string `json:"region" tf:"-"` // The description for the subnet group. // +kubebuilder:validation:Required ReplicationSubnetGroupDescription *string `json:"replicationSubnetGroupDescription" tf:"replication_subnet_group_description,omitempty"` // References to Subnet in ec2 to populate subnetIds. // +kubebuilder:validation:Optional SubnetIDRefs []v1.Reference `json:"subnetIdRefs,omitempty" tf:"-"` // Selector for a list of Subnet in ec2 to populate subnetIds. // +kubebuilder:validation:Optional SubnetIDSelector *v1.Selector `json:"subnetIdSelector,omitempty" tf:"-"` // A list of the EC2 subnet IDs for the subnet group. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.Subnet // +crossplane:generate:reference:refFieldName=SubnetIDRefs // +crossplane:generate:reference:selectorFieldName=SubnetIDSelector // +kubebuilder:validation:Optional SubnetIds []*string `json:"subnetIds,omitempty" tf:"subnet_ids,omitempty"` // Key-value map of resource tags. // +kubebuilder:validation:Optional Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"` }
func (*ReplicationSubnetGroupParameters) DeepCopy ¶
func (in *ReplicationSubnetGroupParameters) DeepCopy() *ReplicationSubnetGroupParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ReplicationSubnetGroupParameters.
func (*ReplicationSubnetGroupParameters) DeepCopyInto ¶
func (in *ReplicationSubnetGroupParameters) DeepCopyInto(out *ReplicationSubnetGroupParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ReplicationSubnetGroupSpec ¶
type ReplicationSubnetGroupSpec struct { v1.ResourceSpec `json:",inline"` ForProvider ReplicationSubnetGroupParameters `json:"forProvider"` }
ReplicationSubnetGroupSpec defines the desired state of ReplicationSubnetGroup
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 ReplicationSubnetGroupStatus ¶
type ReplicationSubnetGroupStatus struct { v1.ResourceStatus `json:",inline"` AtProvider ReplicationSubnetGroupObservation `json:"atProvider,omitempty"` }
ReplicationSubnetGroupStatus defines the observed state of ReplicationSubnetGroup.
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 S3SettingsObservation ¶
type S3SettingsObservation struct { }
func (*S3SettingsObservation) DeepCopy ¶
func (in *S3SettingsObservation) DeepCopy() *S3SettingsObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3SettingsObservation.
func (*S3SettingsObservation) DeepCopyInto ¶
func (in *S3SettingsObservation) DeepCopyInto(out *S3SettingsObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type S3SettingsParameters ¶
type S3SettingsParameters struct { // Whether to add column name information to the .csv output file. Default is false. // +kubebuilder:validation:Optional AddColumnName *bool `json:"addColumnName,omitempty" tf:"add_column_name,omitempty"` // S3 object prefix. // +kubebuilder:validation:Optional BucketFolder *string `json:"bucketFolder,omitempty" tf:"bucket_folder,omitempty"` // S3 bucket name. // +kubebuilder:validation:Optional BucketName *string `json:"bucketName,omitempty" tf:"bucket_name,omitempty"` // Predefined (canned) access control list for objects created in an S3 bucket. Valid values include NONE, PRIVATE, PUBLIC_READ, PUBLIC_READ_WRITE, AUTHENTICATED_READ, AWS_EXEC_READ, BUCKET_OWNER_READ, and BUCKET_OWNER_FULL_CONTROL. Default is NONE. // +kubebuilder:validation:Optional CannedACLForObjects *string `json:"cannedAclForObjects,omitempty" tf:"canned_acl_for_objects,omitempty"` // Whether to write insert and update operations to .csv or .parquet output files. Default is false. // +kubebuilder:validation:Optional CdcInsertsAndUpdates *bool `json:"cdcInsertsAndUpdates,omitempty" tf:"cdc_inserts_and_updates,omitempty"` // Whether to write insert operations to .csv or .parquet output files. Default is false. // +kubebuilder:validation:Optional CdcInsertsOnly *bool `json:"cdcInsertsOnly,omitempty" tf:"cdc_inserts_only,omitempty"` // Maximum length of the interval, defined in seconds, after which to output a file to Amazon S3. Default is 60. // +kubebuilder:validation:Optional CdcMaxBatchInterval *float64 `json:"cdcMaxBatchInterval,omitempty" tf:"cdc_max_batch_interval,omitempty"` // Minimum file size, defined in megabytes, to reach for a file output. Default is 32. // +kubebuilder:validation:Optional CdcMinFileSize *float64 `json:"cdcMinFileSize,omitempty" tf:"cdc_min_file_size,omitempty"` // Folder path of CDC files. For an S3 source, this setting is required if a task captures change data; otherwise, it's optional. If cdc_path is set, AWS DMS reads CDC files from this path and replicates the data changes to the target endpoint. Supported in AWS DMS versions 3.4.2 and later. // +kubebuilder:validation:Optional CdcPath *string `json:"cdcPath,omitempty" tf:"cdc_path,omitempty"` // Set to compress target files. Default is NONE. Valid values are GZIP and NONE. // +kubebuilder:validation:Optional CompressionType *string `json:"compressionType,omitempty" tf:"compression_type,omitempty"` // Delimiter used to separate columns in the source files. Default is ,. // +kubebuilder:validation:Optional CsvDelimiter *string `json:"csvDelimiter,omitempty" tf:"csv_delimiter,omitempty"` // String to use for all columns not included in the supplemental log. // +kubebuilder:validation:Optional CsvNoSupValue *string `json:"csvNoSupValue,omitempty" tf:"csv_no_sup_value,omitempty"` // String to as null when writing to the target. // +kubebuilder:validation:Optional CsvNullValue *string `json:"csvNullValue,omitempty" tf:"csv_null_value,omitempty"` // Delimiter used to separate rows in the source files. Default is \n. // +kubebuilder:validation:Optional CsvRowDelimiter *string `json:"csvRowDelimiter,omitempty" tf:"csv_row_delimiter,omitempty"` // Output format for the files that AWS DMS uses to create S3 objects. Valid values are csv and parquet. Default is csv. // +kubebuilder:validation:Optional DataFormat *string `json:"dataFormat,omitempty" tf:"data_format,omitempty"` // Size of one data page in bytes. Default is 1048576 (1 MiB). // +kubebuilder:validation:Optional DataPageSize *float64 `json:"dataPageSize,omitempty" tf:"data_page_size,omitempty"` // Date separating delimiter to use during folder partitioning. Valid values are SLASH, UNDERSCORE, DASH, and NONE. Default is SLASH. // +kubebuilder:validation:Optional DatePartitionDelimiter *string `json:"datePartitionDelimiter,omitempty" tf:"date_partition_delimiter,omitempty"` // Partition S3 bucket folders based on transaction commit dates. Default is false. // +kubebuilder:validation:Optional DatePartitionEnabled *bool `json:"datePartitionEnabled,omitempty" tf:"date_partition_enabled,omitempty"` // Date format to use during folder partitioning. Use this parameter when date_partition_enabled is set to true. Valid values are YYYYMMDD, YYYYMMDDHH, YYYYMM, MMYYYYDD, and DDMMYYYY. Default is YYYYMMDD. // +kubebuilder:validation:Optional DatePartitionSequence *string `json:"datePartitionSequence,omitempty" tf:"date_partition_sequence,omitempty"` // Maximum size in bytes of an encoded dictionary page of a column. Default is 1048576 (1 MiB). // +kubebuilder:validation:Optional DictPageSizeLimit *float64 `json:"dictPageSizeLimit,omitempty" tf:"dict_page_size_limit,omitempty"` // Whether to enable statistics for Parquet pages and row groups. Default is true. // +kubebuilder:validation:Optional EnableStatistics *bool `json:"enableStatistics,omitempty" tf:"enable_statistics,omitempty"` // Type of encoding to use. Value values are rle_dictionary, plain, and plain_dictionary. Default is rle_dictionary. // +kubebuilder:validation:Optional EncodingType *string `json:"encodingType,omitempty" tf:"encoding_type,omitempty"` // Server-side encryption mode that you want to encrypt your .csv or .parquet object files copied to S3. Valid values are SSE_S3 and SSE_KMS. Default is SSE_S3. // +kubebuilder:validation:Optional EncryptionMode *string `json:"encryptionMode,omitempty" tf:"encryption_mode,omitempty"` // JSON document that describes how AWS DMS should interpret the data. // +kubebuilder:validation:Optional ExternalTableDefinition *string `json:"externalTableDefinition,omitempty" tf:"external_table_definition,omitempty"` // When this value is set to 1, DMS ignores the first row header in a .csv file. Default is 0. // +kubebuilder:validation:Optional IgnoreHeadersRow *float64 `json:"ignoreHeadersRow,omitempty" tf:"ignore_headers_row,omitempty"` // Whether to enable a full load to write INSERT operations to the .csv output files only to indicate how the rows were added to the source database. Default is false. // +kubebuilder:validation:Optional IncludeOpForFullLoad *bool `json:"includeOpForFullLoad,omitempty" tf:"include_op_for_full_load,omitempty"` // Maximum size (in KB) of any .csv file to be created while migrating to an S3 target during full load. Valid values are from 1 to 1048576. Default is 1048576 (1 GB). // +kubebuilder:validation:Optional MaxFileSize *float64 `json:"maxFileSize,omitempty" tf:"max_file_size,omitempty"` // - Specifies the precision of any TIMESTAMP column values written to an S3 object file in .parquet format. Default is false. // +kubebuilder:validation:Optional ParquetTimestampInMillisecond *bool `json:"parquetTimestampInMillisecond,omitempty" tf:"parquet_timestamp_in_millisecond,omitempty"` // Version of the .parquet file format. Default is parquet-1-0. Valid values are parquet-1-0 and parquet-2-0. // +kubebuilder:validation:Optional ParquetVersion *string `json:"parquetVersion,omitempty" tf:"parquet_version,omitempty"` // Whether DMS saves the transaction order for a CDC load on the S3 target specified by cdc_path. Default is false. // +kubebuilder:validation:Optional PreserveTransactions *bool `json:"preserveTransactions,omitempty" tf:"preserve_transactions,omitempty"` // For an S3 source, whether each leading double quotation mark has to be followed by an ending double quotation mark. Default is true. // +kubebuilder:validation:Optional Rfc4180 *bool `json:"rfc4180,omitempty" tf:"rfc_4180,omitempty"` // Number of rows in a row group. Default is 10000. // +kubebuilder:validation:Optional RowGroupLength *float64 `json:"rowGroupLength,omitempty" tf:"row_group_length,omitempty"` // If you set encryptionMode to SSE_KMS, set this parameter to the ARN for the AWS KMS key. // +kubebuilder:validation:Optional ServerSideEncryptionKMSKeyID *string `json:"serverSideEncryptionKmsKeyId,omitempty" tf:"server_side_encryption_kms_key_id,omitempty"` // ARN of the IAM Role with permissions to read from or write to the S3 Bucket. // +kubebuilder:validation:Optional ServiceAccessRoleArn *string `json:"serviceAccessRoleArn,omitempty" tf:"service_access_role_arn,omitempty"` // Column to add with timestamp information to the endpoint data for an Amazon S3 target. // +kubebuilder:validation:Optional TimestampColumnName *string `json:"timestampColumnName,omitempty" tf:"timestamp_column_name,omitempty"` // Whether to use csv_no_sup_value for columns not included in the supplemental log. // +kubebuilder:validation:Optional UseCsvNoSupValue *bool `json:"useCsvNoSupValue,omitempty" tf:"use_csv_no_sup_value,omitempty"` }
func (*S3SettingsParameters) DeepCopy ¶
func (in *S3SettingsParameters) DeepCopy() *S3SettingsParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3SettingsParameters.
func (*S3SettingsParameters) DeepCopyInto ¶
func (in *S3SettingsParameters) DeepCopyInto(out *S3SettingsParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.