Documentation
¶
Overview ¶
+kubebuilder:object:generate=true +groupName=kafka.aws.upbound.io +versionName=v1beta1
Index ¶
- Constants
- Variables
- type BrokerLogsInitParameters
- type BrokerLogsObservation
- type BrokerLogsParameters
- type BrokerNodeGroupInfoInitParameters
- type BrokerNodeGroupInfoObservation
- type BrokerNodeGroupInfoParameters
- type ClientAuthenticationInitParameters
- type ClientAuthenticationObservation
- type ClientAuthenticationParameters
- type ClientAuthenticationSaslInitParameters
- type ClientAuthenticationSaslObservation
- type ClientAuthenticationSaslParameters
- type CloudwatchLogsInitParameters
- type CloudwatchLogsObservation
- type CloudwatchLogsParameters
- type Cluster
- func (tr *Cluster) ConvertFrom(srcRaw conversion.Hub) error
- func (tr *Cluster) ConvertTo(dstRaw conversion.Hub) error
- func (in *Cluster) DeepCopy() *Cluster
- func (in *Cluster) DeepCopyInto(out *Cluster)
- func (in *Cluster) DeepCopyObject() runtime.Object
- func (mg *Cluster) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (tr *Cluster) GetConnectionDetailsMapping() map[string]string
- func (mg *Cluster) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *Cluster) GetID() string
- func (tr *Cluster) GetInitParameters() (map[string]any, error)
- func (mg *Cluster) GetManagementPolicies() xpv1.ManagementPolicies
- func (tr *Cluster) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
- func (tr *Cluster) GetObservation() (map[string]any, error)
- func (tr *Cluster) GetParameters() (map[string]any, error)
- func (mg *Cluster) GetProviderConfigReference() *xpv1.Reference
- func (mg *Cluster) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Cluster) GetTerraformResourceType() string
- func (tr *Cluster) GetTerraformSchemaVersion() int
- func (mg *Cluster) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *Cluster) LateInitialize(attrs []byte) (bool, error)
- func (mg *Cluster) ResolveReferences(ctx context.Context, c client.Reader) error
- func (mg *Cluster) SetConditions(c ...xpv1.Condition)
- func (mg *Cluster) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (mg *Cluster) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *Cluster) SetObservation(obs map[string]any) error
- func (tr *Cluster) SetParameters(params map[string]any) error
- func (mg *Cluster) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *Cluster) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *Cluster) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type ClusterInitParameters
- type ClusterList
- type ClusterObservation
- type ClusterParameters
- type ClusterSpec
- type ClusterStatus
- type Configuration
- func (in *Configuration) DeepCopy() *Configuration
- func (in *Configuration) DeepCopyInto(out *Configuration)
- func (in *Configuration) DeepCopyObject() runtime.Object
- func (mg *Configuration) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (tr *Configuration) GetConnectionDetailsMapping() map[string]string
- func (mg *Configuration) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *Configuration) GetID() string
- func (tr *Configuration) GetInitParameters() (map[string]any, error)
- func (mg *Configuration) GetManagementPolicies() xpv1.ManagementPolicies
- func (tr *Configuration) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
- func (tr *Configuration) GetObservation() (map[string]any, error)
- func (tr *Configuration) GetParameters() (map[string]any, error)
- func (mg *Configuration) GetProviderConfigReference() *xpv1.Reference
- func (mg *Configuration) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Configuration) GetTerraformResourceType() string
- func (tr *Configuration) GetTerraformSchemaVersion() int
- func (mg *Configuration) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *Configuration) Hub()
- func (tr *Configuration) LateInitialize(attrs []byte) (bool, error)
- func (mg *Configuration) SetConditions(c ...xpv1.Condition)
- func (mg *Configuration) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (mg *Configuration) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *Configuration) SetObservation(obs map[string]any) error
- func (tr *Configuration) SetParameters(params map[string]any) error
- func (mg *Configuration) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *Configuration) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *Configuration) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type ConfigurationInfoInitParameters
- type ConfigurationInfoObservation
- type ConfigurationInfoParameters
- type ConfigurationInitParameters
- type ConfigurationList
- type ConfigurationObservation
- type ConfigurationParameters
- type ConfigurationSpec
- type ConfigurationStatus
- type ConnectivityInfoInitParameters
- type ConnectivityInfoObservation
- type ConnectivityInfoParameters
- type EBSStorageInfoInitParameters
- type EBSStorageInfoObservation
- type EBSStorageInfoParameters
- type EncryptionInTransitInitParameters
- type EncryptionInTransitObservation
- type EncryptionInTransitParameters
- type EncryptionInfoInitParameters
- type EncryptionInfoObservation
- type EncryptionInfoParameters
- type FirehoseInitParameters
- type FirehoseObservation
- type FirehoseParameters
- type IAMInitParameters
- type IAMObservation
- type IAMParameters
- type JmxExporterInitParameters
- type JmxExporterObservation
- type JmxExporterParameters
- type LoggingInfoInitParameters
- type LoggingInfoObservation
- type LoggingInfoParameters
- type NodeExporterInitParameters
- type NodeExporterObservation
- type NodeExporterParameters
- type OpenMonitoringInitParameters
- type OpenMonitoringObservation
- type OpenMonitoringParameters
- type PrometheusInitParameters
- type PrometheusObservation
- type PrometheusParameters
- type ProvisionedThroughputInitParameters
- type ProvisionedThroughputObservation
- type ProvisionedThroughputParameters
- type PublicAccessInitParameters
- type PublicAccessObservation
- type PublicAccessParameters
- type S3InitParameters
- type S3Observation
- type S3Parameters
- type SaslInitParameters
- type SaslObservation
- type SaslParameters
- type ScramSecretAssociation
- func (in *ScramSecretAssociation) DeepCopy() *ScramSecretAssociation
- func (in *ScramSecretAssociation) DeepCopyInto(out *ScramSecretAssociation)
- func (in *ScramSecretAssociation) DeepCopyObject() runtime.Object
- func (mg *ScramSecretAssociation) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (tr *ScramSecretAssociation) GetConnectionDetailsMapping() map[string]string
- func (mg *ScramSecretAssociation) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *ScramSecretAssociation) GetID() string
- func (tr *ScramSecretAssociation) GetInitParameters() (map[string]any, error)
- func (mg *ScramSecretAssociation) GetManagementPolicies() xpv1.ManagementPolicies
- func (tr *ScramSecretAssociation) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
- func (tr *ScramSecretAssociation) GetObservation() (map[string]any, error)
- func (tr *ScramSecretAssociation) GetParameters() (map[string]any, error)
- func (mg *ScramSecretAssociation) GetProviderConfigReference() *xpv1.Reference
- func (mg *ScramSecretAssociation) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *ScramSecretAssociation) GetTerraformResourceType() string
- func (tr *ScramSecretAssociation) GetTerraformSchemaVersion() int
- func (mg *ScramSecretAssociation) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *ScramSecretAssociation) Hub()
- func (tr *ScramSecretAssociation) LateInitialize(attrs []byte) (bool, error)
- func (mg *ScramSecretAssociation) ResolveReferences(ctx context.Context, c client.Reader) error
- func (mg *ScramSecretAssociation) SetConditions(c ...xpv1.Condition)
- func (mg *ScramSecretAssociation) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (mg *ScramSecretAssociation) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *ScramSecretAssociation) SetObservation(obs map[string]any) error
- func (tr *ScramSecretAssociation) SetParameters(params map[string]any) error
- func (mg *ScramSecretAssociation) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *ScramSecretAssociation) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *ScramSecretAssociation) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type ScramSecretAssociationInitParameters
- type ScramSecretAssociationList
- type ScramSecretAssociationObservation
- type ScramSecretAssociationParameters
- type ScramSecretAssociationSpec
- type ScramSecretAssociationStatus
- type ServerlessCluster
- func (tr *ServerlessCluster) ConvertFrom(srcRaw conversion.Hub) error
- func (tr *ServerlessCluster) ConvertTo(dstRaw conversion.Hub) error
- func (in *ServerlessCluster) DeepCopy() *ServerlessCluster
- func (in *ServerlessCluster) DeepCopyInto(out *ServerlessCluster)
- func (in *ServerlessCluster) DeepCopyObject() runtime.Object
- func (mg *ServerlessCluster) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (tr *ServerlessCluster) GetConnectionDetailsMapping() map[string]string
- func (mg *ServerlessCluster) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *ServerlessCluster) GetID() string
- func (tr *ServerlessCluster) GetInitParameters() (map[string]any, error)
- func (mg *ServerlessCluster) GetManagementPolicies() xpv1.ManagementPolicies
- func (tr *ServerlessCluster) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
- func (tr *ServerlessCluster) GetObservation() (map[string]any, error)
- func (tr *ServerlessCluster) GetParameters() (map[string]any, error)
- func (mg *ServerlessCluster) GetProviderConfigReference() *xpv1.Reference
- func (mg *ServerlessCluster) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *ServerlessCluster) GetTerraformResourceType() string
- func (tr *ServerlessCluster) GetTerraformSchemaVersion() int
- func (mg *ServerlessCluster) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *ServerlessCluster) LateInitialize(attrs []byte) (bool, error)
- func (mg *ServerlessCluster) ResolveReferences(ctx context.Context, c client.Reader) error
- func (mg *ServerlessCluster) SetConditions(c ...xpv1.Condition)
- func (mg *ServerlessCluster) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (mg *ServerlessCluster) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *ServerlessCluster) SetObservation(obs map[string]any) error
- func (tr *ServerlessCluster) SetParameters(params map[string]any) error
- func (mg *ServerlessCluster) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *ServerlessCluster) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *ServerlessCluster) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type ServerlessClusterClientAuthenticationInitParameters
- type ServerlessClusterClientAuthenticationObservation
- type ServerlessClusterClientAuthenticationParameters
- type ServerlessClusterInitParameters
- type ServerlessClusterList
- type ServerlessClusterObservation
- type ServerlessClusterParameters
- type ServerlessClusterSpec
- type ServerlessClusterStatus
- type StorageInfoInitParameters
- type StorageInfoObservation
- type StorageInfoParameters
- type TLSInitParameters
- type TLSObservation
- type TLSParameters
- type VPCConfigInitParameters
- type VPCConfigObservation
- type VPCConfigParameters
Constants ¶
const ( CRDGroup = "kafka.aws.upbound.io" CRDVersion = "v1beta1" )
Package type metadata.
Variables ¶
var ( Cluster_Kind = "Cluster" Cluster_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Cluster_Kind}.String() Cluster_KindAPIVersion = Cluster_Kind + "." + CRDGroupVersion.String() Cluster_GroupVersionKind = CRDGroupVersion.WithKind(Cluster_Kind) )
Repository type metadata.
var ( Configuration_Kind = "Configuration" Configuration_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Configuration_Kind}.String() Configuration_KindAPIVersion = Configuration_Kind + "." + CRDGroupVersion.String() Configuration_GroupVersionKind = CRDGroupVersion.WithKind(Configuration_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 ( ScramSecretAssociation_Kind = "ScramSecretAssociation" ScramSecretAssociation_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: ScramSecretAssociation_Kind}.String() ScramSecretAssociation_KindAPIVersion = ScramSecretAssociation_Kind + "." + CRDGroupVersion.String() ScramSecretAssociation_GroupVersionKind = CRDGroupVersion.WithKind(ScramSecretAssociation_Kind) )
Repository type metadata.
var ( ServerlessCluster_Kind = "ServerlessCluster" ServerlessCluster_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: ServerlessCluster_Kind}.String() ServerlessCluster_KindAPIVersion = ServerlessCluster_Kind + "." + CRDGroupVersion.String() ServerlessCluster_GroupVersionKind = CRDGroupVersion.WithKind(ServerlessCluster_Kind) )
Repository type metadata.
Functions ¶
This section is empty.
Types ¶
type BrokerLogsInitParameters ¶ added in v0.38.0
type BrokerLogsInitParameters struct { CloudwatchLogs []CloudwatchLogsInitParameters `json:"cloudwatchLogs,omitempty" tf:"cloudwatch_logs,omitempty"` Firehose []FirehoseInitParameters `json:"firehose,omitempty" tf:"firehose,omitempty"` S3 []S3InitParameters `json:"s3,omitempty" tf:"s3,omitempty"` }
func (*BrokerLogsInitParameters) DeepCopy ¶ added in v0.38.0
func (in *BrokerLogsInitParameters) DeepCopy() *BrokerLogsInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerLogsInitParameters.
func (*BrokerLogsInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *BrokerLogsInitParameters) DeepCopyInto(out *BrokerLogsInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerLogsObservation ¶
type BrokerLogsObservation struct { CloudwatchLogs []CloudwatchLogsObservation `json:"cloudwatchLogs,omitempty" tf:"cloudwatch_logs,omitempty"` Firehose []FirehoseObservation `json:"firehose,omitempty" tf:"firehose,omitempty"` S3 []S3Observation `json:"s3,omitempty" tf:"s3,omitempty"` }
func (*BrokerLogsObservation) DeepCopy ¶
func (in *BrokerLogsObservation) DeepCopy() *BrokerLogsObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerLogsObservation.
func (*BrokerLogsObservation) DeepCopyInto ¶
func (in *BrokerLogsObservation) DeepCopyInto(out *BrokerLogsObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerLogsParameters ¶
type BrokerLogsParameters struct { // +kubebuilder:validation:Optional CloudwatchLogs []CloudwatchLogsParameters `json:"cloudwatchLogs,omitempty" tf:"cloudwatch_logs,omitempty"` // +kubebuilder:validation:Optional Firehose []FirehoseParameters `json:"firehose,omitempty" tf:"firehose,omitempty"` // +kubebuilder:validation:Optional S3 []S3Parameters `json:"s3,omitempty" tf:"s3,omitempty"` }
func (*BrokerLogsParameters) DeepCopy ¶
func (in *BrokerLogsParameters) DeepCopy() *BrokerLogsParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerLogsParameters.
func (*BrokerLogsParameters) DeepCopyInto ¶
func (in *BrokerLogsParameters) DeepCopyInto(out *BrokerLogsParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerNodeGroupInfoInitParameters ¶ added in v0.38.0
type BrokerNodeGroupInfoInitParameters struct { // The distribution of broker nodes across availability zones (documentation). Currently the only valid value is DEFAULT. AzDistribution *string `json:"azDistribution,omitempty" tf:"az_distribution,omitempty"` // A list of subnets to connect to in client VPC (documentation). // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.Subnet // +listType=set ClientSubnets []*string `json:"clientSubnets,omitempty" tf:"client_subnets,omitempty"` // References to Subnet in ec2 to populate clientSubnets. // +kubebuilder:validation:Optional ClientSubnetsRefs []v1.Reference `json:"clientSubnetsRefs,omitempty" tf:"-"` // Selector for a list of Subnet in ec2 to populate clientSubnets. // +kubebuilder:validation:Optional ClientSubnetsSelector *v1.Selector `json:"clientSubnetsSelector,omitempty" tf:"-"` // Information about the cluster access configuration. See below. For security reasons, you can't turn on public access while creating an MSK cluster. However, you can update an existing cluster to make it publicly accessible. You can also create a new cluster and then update it to make it publicly accessible (documentation). ConnectivityInfo []ConnectivityInfoInitParameters `json:"connectivityInfo,omitempty" tf:"connectivity_info,omitempty"` // The size in GiB of the EBS volume for the data drive on each broker node. EBSVolumeSize *float64 `json:"ebsVolumeSize,omitempty" tf:"ebs_volume_size,omitempty"` // Specify the instance type to use for the kafka brokersE.g., kafka.m5.large. (Pricing info) InstanceType *string `json:"instanceType,omitempty" tf:"instance_type,omitempty"` // A list of the security groups to associate with the elastic network interfaces to control who can communicate with the cluster. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.SecurityGroup // +listType=set SecurityGroups []*string `json:"securityGroups,omitempty" tf:"security_groups,omitempty"` // References to SecurityGroup in ec2 to populate securityGroups. // +kubebuilder:validation:Optional SecurityGroupsRefs []v1.Reference `json:"securityGroupsRefs,omitempty" tf:"-"` // Selector for a list of SecurityGroup in ec2 to populate securityGroups. // +kubebuilder:validation:Optional SecurityGroupsSelector *v1.Selector `json:"securityGroupsSelector,omitempty" tf:"-"` // A block that contains information about storage volumes attached to MSK broker nodes. See below. StorageInfo []StorageInfoInitParameters `json:"storageInfo,omitempty" tf:"storage_info,omitempty"` }
func (*BrokerNodeGroupInfoInitParameters) DeepCopy ¶ added in v0.38.0
func (in *BrokerNodeGroupInfoInitParameters) DeepCopy() *BrokerNodeGroupInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerNodeGroupInfoInitParameters.
func (*BrokerNodeGroupInfoInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *BrokerNodeGroupInfoInitParameters) DeepCopyInto(out *BrokerNodeGroupInfoInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerNodeGroupInfoObservation ¶
type BrokerNodeGroupInfoObservation struct { // The distribution of broker nodes across availability zones (documentation). Currently the only valid value is DEFAULT. AzDistribution *string `json:"azDistribution,omitempty" tf:"az_distribution,omitempty"` // A list of subnets to connect to in client VPC (documentation). // +listType=set ClientSubnets []*string `json:"clientSubnets,omitempty" tf:"client_subnets,omitempty"` // Information about the cluster access configuration. See below. For security reasons, you can't turn on public access while creating an MSK cluster. However, you can update an existing cluster to make it publicly accessible. You can also create a new cluster and then update it to make it publicly accessible (documentation). ConnectivityInfo []ConnectivityInfoObservation `json:"connectivityInfo,omitempty" tf:"connectivity_info,omitempty"` // The size in GiB of the EBS volume for the data drive on each broker node. EBSVolumeSize *float64 `json:"ebsVolumeSize,omitempty" tf:"ebs_volume_size,omitempty"` // Specify the instance type to use for the kafka brokersE.g., kafka.m5.large. (Pricing info) InstanceType *string `json:"instanceType,omitempty" tf:"instance_type,omitempty"` // A list of the security groups to associate with the elastic network interfaces to control who can communicate with the cluster. // +listType=set SecurityGroups []*string `json:"securityGroups,omitempty" tf:"security_groups,omitempty"` // A block that contains information about storage volumes attached to MSK broker nodes. See below. StorageInfo []StorageInfoObservation `json:"storageInfo,omitempty" tf:"storage_info,omitempty"` }
func (*BrokerNodeGroupInfoObservation) DeepCopy ¶
func (in *BrokerNodeGroupInfoObservation) DeepCopy() *BrokerNodeGroupInfoObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerNodeGroupInfoObservation.
func (*BrokerNodeGroupInfoObservation) DeepCopyInto ¶
func (in *BrokerNodeGroupInfoObservation) DeepCopyInto(out *BrokerNodeGroupInfoObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerNodeGroupInfoParameters ¶
type BrokerNodeGroupInfoParameters struct { // The distribution of broker nodes across availability zones (documentation). Currently the only valid value is DEFAULT. // +kubebuilder:validation:Optional AzDistribution *string `json:"azDistribution,omitempty" tf:"az_distribution,omitempty"` // A list of subnets to connect to in client VPC (documentation). // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.Subnet // +kubebuilder:validation:Optional // +listType=set ClientSubnets []*string `json:"clientSubnets,omitempty" tf:"client_subnets,omitempty"` // References to Subnet in ec2 to populate clientSubnets. // +kubebuilder:validation:Optional ClientSubnetsRefs []v1.Reference `json:"clientSubnetsRefs,omitempty" tf:"-"` // Selector for a list of Subnet in ec2 to populate clientSubnets. // +kubebuilder:validation:Optional ClientSubnetsSelector *v1.Selector `json:"clientSubnetsSelector,omitempty" tf:"-"` // Information about the cluster access configuration. See below. For security reasons, you can't turn on public access while creating an MSK cluster. However, you can update an existing cluster to make it publicly accessible. You can also create a new cluster and then update it to make it publicly accessible (documentation). // +kubebuilder:validation:Optional ConnectivityInfo []ConnectivityInfoParameters `json:"connectivityInfo,omitempty" tf:"connectivity_info,omitempty"` // The size in GiB of the EBS volume for the data drive on each broker node. // +kubebuilder:validation:Optional EBSVolumeSize *float64 `json:"ebsVolumeSize,omitempty" tf:"ebs_volume_size,omitempty"` // Specify the instance type to use for the kafka brokersE.g., kafka.m5.large. (Pricing info) // +kubebuilder:validation:Optional InstanceType *string `json:"instanceType" tf:"instance_type,omitempty"` // A list of the security groups to associate with the elastic network interfaces to control who can communicate with the cluster. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.SecurityGroup // +kubebuilder:validation:Optional // +listType=set SecurityGroups []*string `json:"securityGroups,omitempty" tf:"security_groups,omitempty"` // References to SecurityGroup in ec2 to populate securityGroups. // +kubebuilder:validation:Optional SecurityGroupsRefs []v1.Reference `json:"securityGroupsRefs,omitempty" tf:"-"` // Selector for a list of SecurityGroup in ec2 to populate securityGroups. // +kubebuilder:validation:Optional SecurityGroupsSelector *v1.Selector `json:"securityGroupsSelector,omitempty" tf:"-"` // A block that contains information about storage volumes attached to MSK broker nodes. See below. // +kubebuilder:validation:Optional StorageInfo []StorageInfoParameters `json:"storageInfo,omitempty" tf:"storage_info,omitempty"` }
func (*BrokerNodeGroupInfoParameters) DeepCopy ¶
func (in *BrokerNodeGroupInfoParameters) DeepCopy() *BrokerNodeGroupInfoParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerNodeGroupInfoParameters.
func (*BrokerNodeGroupInfoParameters) DeepCopyInto ¶
func (in *BrokerNodeGroupInfoParameters) DeepCopyInto(out *BrokerNodeGroupInfoParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClientAuthenticationInitParameters ¶ added in v0.38.0
type ClientAuthenticationInitParameters struct { // Configuration block for specifying SASL client authentication. See below. Sasl []SaslInitParameters `json:"sasl,omitempty" tf:"sasl,omitempty"` // Configuration block for specifying TLS client authentication. See below. TLS []TLSInitParameters `json:"tls,omitempty" tf:"tls,omitempty"` // Enables unauthenticated access. Unauthenticated *bool `json:"unauthenticated,omitempty" tf:"unauthenticated,omitempty"` }
func (*ClientAuthenticationInitParameters) DeepCopy ¶ added in v0.38.0
func (in *ClientAuthenticationInitParameters) DeepCopy() *ClientAuthenticationInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientAuthenticationInitParameters.
func (*ClientAuthenticationInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *ClientAuthenticationInitParameters) DeepCopyInto(out *ClientAuthenticationInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClientAuthenticationObservation ¶
type ClientAuthenticationObservation struct { // Configuration block for specifying SASL client authentication. See below. Sasl []SaslObservation `json:"sasl,omitempty" tf:"sasl,omitempty"` // Configuration block for specifying TLS client authentication. See below. TLS []TLSObservation `json:"tls,omitempty" tf:"tls,omitempty"` // Enables unauthenticated access. Unauthenticated *bool `json:"unauthenticated,omitempty" tf:"unauthenticated,omitempty"` }
func (*ClientAuthenticationObservation) DeepCopy ¶
func (in *ClientAuthenticationObservation) DeepCopy() *ClientAuthenticationObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientAuthenticationObservation.
func (*ClientAuthenticationObservation) DeepCopyInto ¶
func (in *ClientAuthenticationObservation) DeepCopyInto(out *ClientAuthenticationObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClientAuthenticationParameters ¶
type ClientAuthenticationParameters struct { // Configuration block for specifying SASL client authentication. See below. // +kubebuilder:validation:Optional Sasl []SaslParameters `json:"sasl,omitempty" tf:"sasl,omitempty"` // Configuration block for specifying TLS client authentication. See below. // +kubebuilder:validation:Optional TLS []TLSParameters `json:"tls,omitempty" tf:"tls,omitempty"` // Enables unauthenticated access. // +kubebuilder:validation:Optional Unauthenticated *bool `json:"unauthenticated,omitempty" tf:"unauthenticated,omitempty"` }
func (*ClientAuthenticationParameters) DeepCopy ¶
func (in *ClientAuthenticationParameters) DeepCopy() *ClientAuthenticationParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientAuthenticationParameters.
func (*ClientAuthenticationParameters) DeepCopyInto ¶
func (in *ClientAuthenticationParameters) DeepCopyInto(out *ClientAuthenticationParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClientAuthenticationSaslInitParameters ¶ added in v0.43.0
type ClientAuthenticationSaslInitParameters struct { // Details for client authentication using IAM. See below. IAM []IAMInitParameters `json:"iam,omitempty" tf:"iam,omitempty"` }
func (*ClientAuthenticationSaslInitParameters) DeepCopy ¶ added in v0.43.0
func (in *ClientAuthenticationSaslInitParameters) DeepCopy() *ClientAuthenticationSaslInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientAuthenticationSaslInitParameters.
func (*ClientAuthenticationSaslInitParameters) DeepCopyInto ¶ added in v0.43.0
func (in *ClientAuthenticationSaslInitParameters) DeepCopyInto(out *ClientAuthenticationSaslInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClientAuthenticationSaslObservation ¶ added in v0.43.0
type ClientAuthenticationSaslObservation struct { // Details for client authentication using IAM. See below. IAM []IAMObservation `json:"iam,omitempty" tf:"iam,omitempty"` }
func (*ClientAuthenticationSaslObservation) DeepCopy ¶ added in v0.43.0
func (in *ClientAuthenticationSaslObservation) DeepCopy() *ClientAuthenticationSaslObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientAuthenticationSaslObservation.
func (*ClientAuthenticationSaslObservation) DeepCopyInto ¶ added in v0.43.0
func (in *ClientAuthenticationSaslObservation) DeepCopyInto(out *ClientAuthenticationSaslObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClientAuthenticationSaslParameters ¶ added in v0.43.0
type ClientAuthenticationSaslParameters struct { // Details for client authentication using IAM. See below. // +kubebuilder:validation:Optional IAM []IAMParameters `json:"iam" tf:"iam,omitempty"` }
func (*ClientAuthenticationSaslParameters) DeepCopy ¶ added in v0.43.0
func (in *ClientAuthenticationSaslParameters) DeepCopy() *ClientAuthenticationSaslParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientAuthenticationSaslParameters.
func (*ClientAuthenticationSaslParameters) DeepCopyInto ¶ added in v0.43.0
func (in *ClientAuthenticationSaslParameters) DeepCopyInto(out *ClientAuthenticationSaslParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CloudwatchLogsInitParameters ¶ added in v0.38.0
type CloudwatchLogsInitParameters struct { // Controls whether provisioned throughput is enabled or not. Default value: false. Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"` // Name of the Cloudwatch Log Group to deliver logs to. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/cloudwatchlogs/v1beta1.Group LogGroup *string `json:"logGroup,omitempty" tf:"log_group,omitempty"` // Reference to a Group in cloudwatchlogs to populate logGroup. // +kubebuilder:validation:Optional LogGroupRef *v1.Reference `json:"logGroupRef,omitempty" tf:"-"` // Selector for a Group in cloudwatchlogs to populate logGroup. // +kubebuilder:validation:Optional LogGroupSelector *v1.Selector `json:"logGroupSelector,omitempty" tf:"-"` }
func (*CloudwatchLogsInitParameters) DeepCopy ¶ added in v0.38.0
func (in *CloudwatchLogsInitParameters) DeepCopy() *CloudwatchLogsInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudwatchLogsInitParameters.
func (*CloudwatchLogsInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *CloudwatchLogsInitParameters) DeepCopyInto(out *CloudwatchLogsInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CloudwatchLogsObservation ¶
type CloudwatchLogsObservation struct { // Controls whether provisioned throughput is enabled or not. Default value: false. Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"` // Name of the Cloudwatch Log Group to deliver logs to. LogGroup *string `json:"logGroup,omitempty" tf:"log_group,omitempty"` }
func (*CloudwatchLogsObservation) DeepCopy ¶
func (in *CloudwatchLogsObservation) DeepCopy() *CloudwatchLogsObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudwatchLogsObservation.
func (*CloudwatchLogsObservation) DeepCopyInto ¶
func (in *CloudwatchLogsObservation) DeepCopyInto(out *CloudwatchLogsObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CloudwatchLogsParameters ¶
type CloudwatchLogsParameters struct { // Controls whether provisioned throughput is enabled or not. Default value: false. // +kubebuilder:validation:Optional Enabled *bool `json:"enabled" tf:"enabled,omitempty"` // Name of the Cloudwatch Log Group to deliver logs to. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/cloudwatchlogs/v1beta1.Group // +kubebuilder:validation:Optional LogGroup *string `json:"logGroup,omitempty" tf:"log_group,omitempty"` // Reference to a Group in cloudwatchlogs to populate logGroup. // +kubebuilder:validation:Optional LogGroupRef *v1.Reference `json:"logGroupRef,omitempty" tf:"-"` // Selector for a Group in cloudwatchlogs to populate logGroup. // +kubebuilder:validation:Optional LogGroupSelector *v1.Selector `json:"logGroupSelector,omitempty" tf:"-"` }
func (*CloudwatchLogsParameters) DeepCopy ¶
func (in *CloudwatchLogsParameters) DeepCopy() *CloudwatchLogsParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudwatchLogsParameters.
func (*CloudwatchLogsParameters) DeepCopyInto ¶
func (in *CloudwatchLogsParameters) DeepCopyInto(out *CloudwatchLogsParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Cluster ¶
type Cluster struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.brokerNodeGroupInfo) || (has(self.initProvider) && has(self.initProvider.brokerNodeGroupInfo))",message="spec.forProvider.brokerNodeGroupInfo is a required parameter" // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.clusterName) || (has(self.initProvider) && has(self.initProvider.clusterName))",message="spec.forProvider.clusterName is a required parameter" // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.kafkaVersion) || (has(self.initProvider) && has(self.initProvider.kafkaVersion))",message="spec.forProvider.kafkaVersion is a required parameter" // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.numberOfBrokerNodes) || (has(self.initProvider) && has(self.initProvider.numberOfBrokerNodes))",message="spec.forProvider.numberOfBrokerNodes is a required parameter" Spec ClusterSpec `json:"spec"` Status ClusterStatus `json:"status,omitempty"` }
Cluster is the Schema for the Clusters API. +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:resource:scope=Cluster,categories={crossplane,managed,aws}
func (*Cluster) ConvertFrom ¶ added in v1.0.0
func (tr *Cluster) ConvertFrom(srcRaw conversion.Hub) error
ConvertFrom converts from the hub type to the Cluster type.
func (*Cluster) ConvertTo ¶ added in v1.0.0
func (tr *Cluster) ConvertTo(dstRaw conversion.Hub) error
ConvertTo converts this Cluster to the hub type.
func (*Cluster) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Cluster.
func (*Cluster) DeepCopyInto ¶
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Cluster) DeepCopyObject ¶
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Cluster) GetCondition ¶
func (mg *Cluster) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this Cluster.
func (*Cluster) GetConnectionDetailsMapping ¶
GetConnectionDetailsMapping for this Cluster
func (*Cluster) GetDeletionPolicy ¶
func (mg *Cluster) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this Cluster.
func (*Cluster) GetInitParameters ¶ added in v0.38.0
GetInitParameters of this Cluster
func (*Cluster) GetManagementPolicies ¶ added in v0.38.0
func (mg *Cluster) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this Cluster.
func (*Cluster) GetMergedParameters ¶ added in v0.44.0
GetInitParameters of this Cluster
func (*Cluster) GetObservation ¶
GetObservation of this Cluster
func (*Cluster) GetParameters ¶
GetParameters of this Cluster
func (*Cluster) GetProviderConfigReference ¶
GetProviderConfigReference of this Cluster.
func (*Cluster) GetPublishConnectionDetailsTo ¶
func (mg *Cluster) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Cluster.
func (*Cluster) GetTerraformResourceType ¶
GetTerraformResourceType returns Terraform resource type for this Cluster
func (*Cluster) GetTerraformSchemaVersion ¶
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*Cluster) GetWriteConnectionSecretToReference ¶
func (mg *Cluster) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this Cluster.
func (*Cluster) LateInitialize ¶
LateInitialize this Cluster using its observed tfState. returns True if there are any spec changes for the resource.
func (*Cluster) ResolveReferences ¶
func (*Cluster) SetConditions ¶
SetConditions of this Cluster.
func (*Cluster) SetDeletionPolicy ¶
func (mg *Cluster) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Cluster.
func (*Cluster) SetManagementPolicies ¶ added in v0.38.0
func (mg *Cluster) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this Cluster.
func (*Cluster) SetObservation ¶
SetObservation for this Cluster
func (*Cluster) SetParameters ¶
SetParameters for this Cluster
func (*Cluster) SetProviderConfigReference ¶
SetProviderConfigReference of this Cluster.
func (*Cluster) SetPublishConnectionDetailsTo ¶
func (mg *Cluster) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this Cluster.
func (*Cluster) SetWriteConnectionSecretToReference ¶
func (mg *Cluster) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this Cluster.
type ClusterInitParameters ¶ added in v0.38.0
type ClusterInitParameters struct { // Configuration block for the broker nodes of the Kafka cluster. BrokerNodeGroupInfo []BrokerNodeGroupInfoInitParameters `json:"brokerNodeGroupInfo,omitempty" tf:"broker_node_group_info,omitempty"` // Configuration block for specifying a client authentication. See below. ClientAuthentication []ClientAuthenticationInitParameters `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"` // Name of the MSK cluster. ClusterName *string `json:"clusterName,omitempty" tf:"cluster_name,omitempty"` // Configuration block for specifying a MSK Configuration to attach to Kafka brokers. See below. ConfigurationInfo []ConfigurationInfoInitParameters `json:"configurationInfo,omitempty" tf:"configuration_info,omitempty"` // Configuration block for specifying encryption. See below. EncryptionInfo []EncryptionInfoInitParameters `json:"encryptionInfo,omitempty" tf:"encryption_info,omitempty"` // Specify the desired enhanced MSK CloudWatch monitoring level. See Monitoring Amazon MSK with Amazon CloudWatch EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty" tf:"enhanced_monitoring,omitempty"` // Specify the desired Kafka software version. KafkaVersion *string `json:"kafkaVersion,omitempty" tf:"kafka_version,omitempty"` // Configuration block for streaming broker logs to Cloudwatch/S3/Kinesis Firehose. See below. LoggingInfo []LoggingInfoInitParameters `json:"loggingInfo,omitempty" tf:"logging_info,omitempty"` // The desired total number of broker nodes in the kafka cluster. It must be a multiple of the number of specified client subnets. NumberOfBrokerNodes *float64 `json:"numberOfBrokerNodes,omitempty" tf:"number_of_broker_nodes,omitempty"` // Configuration block for JMX and Node monitoring for the MSK cluster. See below. OpenMonitoring []OpenMonitoringInitParameters `json:"openMonitoring,omitempty" tf:"open_monitoring,omitempty"` // Controls storage mode for supported storage tiers. Valid values are: LOCAL or TIERED. StorageMode *string `json:"storageMode,omitempty" tf:"storage_mode,omitempty"` // Key-value map of resource tags. // +mapType=granular Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"` }
func (*ClusterInitParameters) DeepCopy ¶ added in v0.38.0
func (in *ClusterInitParameters) DeepCopy() *ClusterInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterInitParameters.
func (*ClusterInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *ClusterInitParameters) DeepCopyInto(out *ClusterInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterList ¶
type ClusterList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Cluster `json:"items"` }
ClusterList contains a list of Clusters
func (*ClusterList) DeepCopy ¶
func (in *ClusterList) DeepCopy() *ClusterList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterList.
func (*ClusterList) DeepCopyInto ¶
func (in *ClusterList) DeepCopyInto(out *ClusterList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ClusterList) DeepCopyObject ¶
func (in *ClusterList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ClusterList) GetItems ¶
func (l *ClusterList) GetItems() []resource.Managed
GetItems of this ClusterList.
type ClusterObservation ¶
type ClusterObservation struct { // Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster. Arn *string `json:"arn,omitempty" tf:"arn,omitempty"` // Comma separated list of one or more hostname:port pairs of kafka brokers suitable to bootstrap connectivity to the kafka cluster. Contains a value if encryption_info.0.encryption_in_transit.0.client_broker is set to PLAINTEXT or TLS_PLAINTEXT. The resource sorts values alphabetically. AWS may not always return all endpoints so this value is not guaranteed to be stable across applies. BootstrapBrokers *string `json:"bootstrapBrokers,omitempty" tf:"bootstrap_brokers,omitempty"` // One or more DNS names (or IP addresses) and SASL IAM port pairs. For example, b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9198. This attribute will have a value if encryption_info.0.encryption_in_transit.0.client_broker is set to TLS_PLAINTEXT or TLS and client_authentication.0.sasl.0.iam is set to true and broker_node_group_info.0.connectivity_info.0.public_access.0.type is set to SERVICE_PROVIDED_EIPS and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies. BootstrapBrokersPublicSaslIAM *string `json:"bootstrapBrokersPublicSaslIam,omitempty" tf:"bootstrap_brokers_public_sasl_iam,omitempty"` // One or more DNS names (or IP addresses) and SASL SCRAM port pairs. For example, b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9196. This attribute will have a value if encryption_info.0.encryption_in_transit.0.client_broker is set to TLS_PLAINTEXT or TLS and client_authentication.0.sasl.0.scram is set to true and broker_node_group_info.0.connectivity_info.0.public_access.0.type is set to SERVICE_PROVIDED_EIPS and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies. BootstrapBrokersPublicSaslScram *string `json:"bootstrapBrokersPublicSaslScram,omitempty" tf:"bootstrap_brokers_public_sasl_scram,omitempty"` // One or more DNS names (or IP addresses) and TLS port pairs. For example, b-1-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194,b-2-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194,b-3-public.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9194. This attribute will have a value if encryption_info.0.encryption_in_transit.0.client_broker is set to TLS_PLAINTEXT or TLS and broker_node_group_info.0.connectivity_info.0.public_access.0.type is set to SERVICE_PROVIDED_EIPS and the cluster fulfill all other requirements for public access. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies. BootstrapBrokersPublicTLS *string `json:"bootstrapBrokersPublicTls,omitempty" tf:"bootstrap_brokers_public_tls,omitempty"` // One or more DNS names (or IP addresses) and SASL IAM port pairs. For example, b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9098. This attribute will have a value if encryption_info.0.encryption_in_transit.0.client_broker is set to TLS_PLAINTEXT or TLS and client_authentication.0.sasl.0.iam is set to true. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies. BootstrapBrokersSaslIAM *string `json:"bootstrapBrokersSaslIam,omitempty" tf:"bootstrap_brokers_sasl_iam,omitempty"` // One or more DNS names (or IP addresses) and SASL SCRAM port pairs. For example, b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9096. This attribute will have a value if encryption_info.0.encryption_in_transit.0.client_broker is set to TLS_PLAINTEXT or TLS and client_authentication.0.sasl.0.scram is set to true. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies. BootstrapBrokersSaslScram *string `json:"bootstrapBrokersSaslScram,omitempty" tf:"bootstrap_brokers_sasl_scram,omitempty"` // One or more DNS names (or IP addresses) and TLS port pairs. For example, b-1.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094,b-2.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094,b-3.exampleClusterName.abcde.c2.kafka.us-east-1.amazonaws.com:9094. This attribute will have a value if encryption_info.0.encryption_in_transit.0.client_broker is set to TLS_PLAINTEXT or TLS. The resource sorts the list alphabetically. AWS may not always return all endpoints so the values may not be stable across applies. BootstrapBrokersTLS *string `json:"bootstrapBrokersTls,omitempty" tf:"bootstrap_brokers_tls,omitempty"` // Configuration block for the broker nodes of the Kafka cluster. BrokerNodeGroupInfo []BrokerNodeGroupInfoObservation `json:"brokerNodeGroupInfo,omitempty" tf:"broker_node_group_info,omitempty"` // Configuration block for specifying a client authentication. See below. ClientAuthentication []ClientAuthenticationObservation `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"` // Name of the MSK cluster. ClusterName *string `json:"clusterName,omitempty" tf:"cluster_name,omitempty"` // Configuration block for specifying a MSK Configuration to attach to Kafka brokers. See below. ConfigurationInfo []ConfigurationInfoObservation `json:"configurationInfo,omitempty" tf:"configuration_info,omitempty"` // Current version of the MSK Cluster used for updates, e.g., K13V1IB3VIYZZH CurrentVersion *string `json:"currentVersion,omitempty" tf:"current_version,omitempty"` // Configuration block for specifying encryption. See below. EncryptionInfo []EncryptionInfoObservation `json:"encryptionInfo,omitempty" tf:"encryption_info,omitempty"` // Specify the desired enhanced MSK CloudWatch monitoring level. See Monitoring Amazon MSK with Amazon CloudWatch EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty" tf:"enhanced_monitoring,omitempty"` ID *string `json:"id,omitempty" tf:"id,omitempty"` // Specify the desired Kafka software version. KafkaVersion *string `json:"kafkaVersion,omitempty" tf:"kafka_version,omitempty"` // Configuration block for streaming broker logs to Cloudwatch/S3/Kinesis Firehose. See below. LoggingInfo []LoggingInfoObservation `json:"loggingInfo,omitempty" tf:"logging_info,omitempty"` // The desired total number of broker nodes in the kafka cluster. It must be a multiple of the number of specified client subnets. NumberOfBrokerNodes *float64 `json:"numberOfBrokerNodes,omitempty" tf:"number_of_broker_nodes,omitempty"` // Configuration block for JMX and Node monitoring for the MSK cluster. See below. OpenMonitoring []OpenMonitoringObservation `json:"openMonitoring,omitempty" tf:"open_monitoring,omitempty"` // Controls storage mode for supported storage tiers. Valid values are: LOCAL or TIERED. StorageMode *string `json:"storageMode,omitempty" tf:"storage_mode,omitempty"` // Key-value map of resource tags. // +mapType=granular Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"` // A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block. // +mapType=granular TagsAll map[string]*string `json:"tagsAll,omitempty" tf:"tags_all,omitempty"` // A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster. The returned values are sorted alphabetically. The AWS API may not return all endpoints, so this value is not guaranteed to be stable across applies. ZookeeperConnectString *string `json:"zookeeperConnectString,omitempty" tf:"zookeeper_connect_string,omitempty"` // A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster via TLS. The returned values are sorted alphabetically. The AWS API may not return all endpoints, so this value is not guaranteed to be stable across applies. ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTls,omitempty" tf:"zookeeper_connect_string_tls,omitempty"` }
func (*ClusterObservation) DeepCopy ¶
func (in *ClusterObservation) DeepCopy() *ClusterObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterObservation.
func (*ClusterObservation) DeepCopyInto ¶
func (in *ClusterObservation) DeepCopyInto(out *ClusterObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterParameters ¶
type ClusterParameters struct { // Configuration block for the broker nodes of the Kafka cluster. // +kubebuilder:validation:Optional BrokerNodeGroupInfo []BrokerNodeGroupInfoParameters `json:"brokerNodeGroupInfo,omitempty" tf:"broker_node_group_info,omitempty"` // Configuration block for specifying a client authentication. See below. // +kubebuilder:validation:Optional ClientAuthentication []ClientAuthenticationParameters `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"` // Name of the MSK cluster. // +kubebuilder:validation:Optional ClusterName *string `json:"clusterName,omitempty" tf:"cluster_name,omitempty"` // Configuration block for specifying a MSK Configuration to attach to Kafka brokers. See below. // +kubebuilder:validation:Optional ConfigurationInfo []ConfigurationInfoParameters `json:"configurationInfo,omitempty" tf:"configuration_info,omitempty"` // Configuration block for specifying encryption. See below. // +kubebuilder:validation:Optional EncryptionInfo []EncryptionInfoParameters `json:"encryptionInfo,omitempty" tf:"encryption_info,omitempty"` // Specify the desired enhanced MSK CloudWatch monitoring level. See Monitoring Amazon MSK with Amazon CloudWatch // +kubebuilder:validation:Optional EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty" tf:"enhanced_monitoring,omitempty"` // Specify the desired Kafka software version. // +kubebuilder:validation:Optional KafkaVersion *string `json:"kafkaVersion,omitempty" tf:"kafka_version,omitempty"` // Configuration block for streaming broker logs to Cloudwatch/S3/Kinesis Firehose. See below. // +kubebuilder:validation:Optional LoggingInfo []LoggingInfoParameters `json:"loggingInfo,omitempty" tf:"logging_info,omitempty"` // The desired total number of broker nodes in the kafka cluster. It must be a multiple of the number of specified client subnets. // +kubebuilder:validation:Optional NumberOfBrokerNodes *float64 `json:"numberOfBrokerNodes,omitempty" tf:"number_of_broker_nodes,omitempty"` // Configuration block for JMX and Node monitoring for the MSK cluster. See below. // +kubebuilder:validation:Optional OpenMonitoring []OpenMonitoringParameters `json:"openMonitoring,omitempty" tf:"open_monitoring,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:"-"` // Controls storage mode for supported storage tiers. Valid values are: LOCAL or TIERED. // +kubebuilder:validation:Optional StorageMode *string `json:"storageMode,omitempty" tf:"storage_mode,omitempty"` // Key-value map of resource tags. // +kubebuilder:validation:Optional // +mapType=granular Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"` }
func (*ClusterParameters) DeepCopy ¶
func (in *ClusterParameters) DeepCopy() *ClusterParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterParameters.
func (*ClusterParameters) DeepCopyInto ¶
func (in *ClusterParameters) DeepCopyInto(out *ClusterParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpec ¶
type ClusterSpec struct { v1.ResourceSpec `json:",inline"` ForProvider ClusterParameters `json:"forProvider"` // THIS IS A BETA FIELD. It will be honored // unless the Management Policies feature flag is disabled. // InitProvider holds the same fields as ForProvider, with the exception // of Identifier and other resource reference fields. The fields that are // in InitProvider are merged into ForProvider when the resource is created. // The same fields are also added to the terraform ignore_changes hook, to // avoid updating them after creation. This is useful for fields that are // required on creation, but we do not desire to update them after creation, // for example because of an external controller is managing them, like an // autoscaler. InitProvider ClusterInitParameters `json:"initProvider,omitempty"` }
ClusterSpec defines the desired state of Cluster
func (*ClusterSpec) DeepCopy ¶
func (in *ClusterSpec) DeepCopy() *ClusterSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpec.
func (*ClusterSpec) DeepCopyInto ¶
func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterStatus ¶
type ClusterStatus struct { v1.ResourceStatus `json:",inline"` AtProvider ClusterObservation `json:"atProvider,omitempty"` }
ClusterStatus defines the observed state of Cluster.
func (*ClusterStatus) DeepCopy ¶
func (in *ClusterStatus) DeepCopy() *ClusterStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterStatus.
func (*ClusterStatus) DeepCopyInto ¶
func (in *ClusterStatus) DeepCopyInto(out *ClusterStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Configuration ¶
type Configuration struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.name) || (has(self.initProvider) && has(self.initProvider.name))",message="spec.forProvider.name is a required parameter" // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.serverProperties) || (has(self.initProvider) && has(self.initProvider.serverProperties))",message="spec.forProvider.serverProperties is a required parameter" Spec ConfigurationSpec `json:"spec"` Status ConfigurationStatus `json:"status,omitempty"` }
Configuration is the Schema for the Configurations API. provider resource for managing an amazon managed streaming for kafka configuration +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].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:resource:scope=Cluster,categories={crossplane,managed,aws}
func (*Configuration) DeepCopy ¶
func (in *Configuration) DeepCopy() *Configuration
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Configuration.
func (*Configuration) DeepCopyInto ¶
func (in *Configuration) DeepCopyInto(out *Configuration)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*Configuration) DeepCopyObject ¶
func (in *Configuration) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*Configuration) GetCondition ¶
func (mg *Configuration) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this Configuration.
func (*Configuration) GetConnectionDetailsMapping ¶
func (tr *Configuration) GetConnectionDetailsMapping() map[string]string
GetConnectionDetailsMapping for this Configuration
func (*Configuration) GetDeletionPolicy ¶
func (mg *Configuration) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this Configuration.
func (*Configuration) GetID ¶
func (tr *Configuration) GetID() string
GetID returns ID of underlying Terraform resource of this Configuration
func (*Configuration) GetInitParameters ¶ added in v0.38.0
func (tr *Configuration) GetInitParameters() (map[string]any, error)
GetInitParameters of this Configuration
func (*Configuration) GetManagementPolicies ¶ added in v0.38.0
func (mg *Configuration) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this Configuration.
func (*Configuration) GetMergedParameters ¶ added in v0.44.0
func (tr *Configuration) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
GetInitParameters of this Configuration
func (*Configuration) GetObservation ¶
func (tr *Configuration) GetObservation() (map[string]any, error)
GetObservation of this Configuration
func (*Configuration) GetParameters ¶
func (tr *Configuration) GetParameters() (map[string]any, error)
GetParameters of this Configuration
func (*Configuration) GetProviderConfigReference ¶
func (mg *Configuration) GetProviderConfigReference() *xpv1.Reference
GetProviderConfigReference of this Configuration.
func (*Configuration) GetPublishConnectionDetailsTo ¶
func (mg *Configuration) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Configuration.
func (*Configuration) GetTerraformResourceType ¶
func (mg *Configuration) GetTerraformResourceType() string
GetTerraformResourceType returns Terraform resource type for this Configuration
func (*Configuration) GetTerraformSchemaVersion ¶
func (tr *Configuration) GetTerraformSchemaVersion() int
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*Configuration) GetWriteConnectionSecretToReference ¶
func (mg *Configuration) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this Configuration.
func (*Configuration) Hub ¶ added in v0.47.2
func (tr *Configuration) Hub()
Hub marks this type as a conversion hub.
func (*Configuration) LateInitialize ¶
func (tr *Configuration) LateInitialize(attrs []byte) (bool, error)
LateInitialize this Configuration using its observed tfState. returns True if there are any spec changes for the resource.
func (*Configuration) SetConditions ¶
func (mg *Configuration) SetConditions(c ...xpv1.Condition)
SetConditions of this Configuration.
func (*Configuration) SetDeletionPolicy ¶
func (mg *Configuration) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Configuration.
func (*Configuration) SetManagementPolicies ¶ added in v0.38.0
func (mg *Configuration) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this Configuration.
func (*Configuration) SetObservation ¶
func (tr *Configuration) SetObservation(obs map[string]any) error
SetObservation for this Configuration
func (*Configuration) SetParameters ¶
func (tr *Configuration) SetParameters(params map[string]any) error
SetParameters for this Configuration
func (*Configuration) SetProviderConfigReference ¶
func (mg *Configuration) SetProviderConfigReference(r *xpv1.Reference)
SetProviderConfigReference of this Configuration.
func (*Configuration) SetPublishConnectionDetailsTo ¶
func (mg *Configuration) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this Configuration.
func (*Configuration) SetWriteConnectionSecretToReference ¶
func (mg *Configuration) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this Configuration.
type ConfigurationInfoInitParameters ¶ added in v0.38.0
type ConfigurationInfoInitParameters struct { // Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster. // +crossplane:generate:reference:type=Configuration // +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor() Arn *string `json:"arn,omitempty" tf:"arn,omitempty"` // Reference to a Configuration to populate arn. // +kubebuilder:validation:Optional ArnRef *v1.Reference `json:"arnRef,omitempty" tf:"-"` // Selector for a Configuration to populate arn. // +kubebuilder:validation:Optional ArnSelector *v1.Selector `json:"arnSelector,omitempty" tf:"-"` // Revision of the MSK Configuration to use in the cluster. Revision *float64 `json:"revision,omitempty" tf:"revision,omitempty"` }
func (*ConfigurationInfoInitParameters) DeepCopy ¶ added in v0.38.0
func (in *ConfigurationInfoInitParameters) DeepCopy() *ConfigurationInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationInfoInitParameters.
func (*ConfigurationInfoInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *ConfigurationInfoInitParameters) DeepCopyInto(out *ConfigurationInfoInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationInfoObservation ¶
type ConfigurationInfoObservation struct { // Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster. Arn *string `json:"arn,omitempty" tf:"arn,omitempty"` // Revision of the MSK Configuration to use in the cluster. Revision *float64 `json:"revision,omitempty" tf:"revision,omitempty"` }
func (*ConfigurationInfoObservation) DeepCopy ¶
func (in *ConfigurationInfoObservation) DeepCopy() *ConfigurationInfoObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationInfoObservation.
func (*ConfigurationInfoObservation) DeepCopyInto ¶
func (in *ConfigurationInfoObservation) DeepCopyInto(out *ConfigurationInfoObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationInfoParameters ¶
type ConfigurationInfoParameters struct { // Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster. // +crossplane:generate:reference:type=Configuration // +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor() // +kubebuilder:validation:Optional Arn *string `json:"arn,omitempty" tf:"arn,omitempty"` // Reference to a Configuration to populate arn. // +kubebuilder:validation:Optional ArnRef *v1.Reference `json:"arnRef,omitempty" tf:"-"` // Selector for a Configuration to populate arn. // +kubebuilder:validation:Optional ArnSelector *v1.Selector `json:"arnSelector,omitempty" tf:"-"` // Revision of the MSK Configuration to use in the cluster. // +kubebuilder:validation:Optional Revision *float64 `json:"revision" tf:"revision,omitempty"` }
func (*ConfigurationInfoParameters) DeepCopy ¶
func (in *ConfigurationInfoParameters) DeepCopy() *ConfigurationInfoParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationInfoParameters.
func (*ConfigurationInfoParameters) DeepCopyInto ¶
func (in *ConfigurationInfoParameters) DeepCopyInto(out *ConfigurationInfoParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationInitParameters ¶ added in v0.38.0
type ConfigurationInitParameters struct { // Description of the configuration. Description *string `json:"description,omitempty" tf:"description,omitempty"` // List of Apache Kafka versions which can use this configuration. // +listType=set KafkaVersions []*string `json:"kafkaVersions,omitempty" tf:"kafka_versions,omitempty"` // Name of the configuration. Name *string `json:"name,omitempty" tf:"name,omitempty"` // Contents of the server.properties file. Supported properties are documented in the MSK Developer Guide. ServerProperties *string `json:"serverProperties,omitempty" tf:"server_properties,omitempty"` }
func (*ConfigurationInitParameters) DeepCopy ¶ added in v0.38.0
func (in *ConfigurationInitParameters) DeepCopy() *ConfigurationInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationInitParameters.
func (*ConfigurationInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *ConfigurationInitParameters) DeepCopyInto(out *ConfigurationInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationList ¶
type ConfigurationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []Configuration `json:"items"` }
ConfigurationList contains a list of Configurations
func (*ConfigurationList) DeepCopy ¶
func (in *ConfigurationList) DeepCopy() *ConfigurationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationList.
func (*ConfigurationList) DeepCopyInto ¶
func (in *ConfigurationList) DeepCopyInto(out *ConfigurationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ConfigurationList) DeepCopyObject ¶
func (in *ConfigurationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ConfigurationList) GetItems ¶
func (l *ConfigurationList) GetItems() []resource.Managed
GetItems of this ConfigurationList.
type ConfigurationObservation ¶
type ConfigurationObservation struct { // Amazon Resource Name (ARN) of the configuration. Arn *string `json:"arn,omitempty" tf:"arn,omitempty"` // Description of the configuration. Description *string `json:"description,omitempty" tf:"description,omitempty"` ID *string `json:"id,omitempty" tf:"id,omitempty"` // List of Apache Kafka versions which can use this configuration. // +listType=set KafkaVersions []*string `json:"kafkaVersions,omitempty" tf:"kafka_versions,omitempty"` // Latest revision of the configuration. LatestRevision *float64 `json:"latestRevision,omitempty" tf:"latest_revision,omitempty"` // Name of the configuration. Name *string `json:"name,omitempty" tf:"name,omitempty"` // Contents of the server.properties file. Supported properties are documented in the MSK Developer Guide. ServerProperties *string `json:"serverProperties,omitempty" tf:"server_properties,omitempty"` }
func (*ConfigurationObservation) DeepCopy ¶
func (in *ConfigurationObservation) DeepCopy() *ConfigurationObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationObservation.
func (*ConfigurationObservation) DeepCopyInto ¶
func (in *ConfigurationObservation) DeepCopyInto(out *ConfigurationObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationParameters ¶
type ConfigurationParameters struct { // Description of the configuration. // +kubebuilder:validation:Optional Description *string `json:"description,omitempty" tf:"description,omitempty"` // List of Apache Kafka versions which can use this configuration. // +kubebuilder:validation:Optional // +listType=set KafkaVersions []*string `json:"kafkaVersions,omitempty" tf:"kafka_versions,omitempty"` // Name of the configuration. // +kubebuilder:validation:Optional Name *string `json:"name,omitempty" tf:"name,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:"-"` // Contents of the server.properties file. Supported properties are documented in the MSK Developer Guide. // +kubebuilder:validation:Optional ServerProperties *string `json:"serverProperties,omitempty" tf:"server_properties,omitempty"` }
func (*ConfigurationParameters) DeepCopy ¶
func (in *ConfigurationParameters) DeepCopy() *ConfigurationParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationParameters.
func (*ConfigurationParameters) DeepCopyInto ¶
func (in *ConfigurationParameters) DeepCopyInto(out *ConfigurationParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationSpec ¶
type ConfigurationSpec struct { v1.ResourceSpec `json:",inline"` ForProvider ConfigurationParameters `json:"forProvider"` // THIS IS A BETA FIELD. It will be honored // unless the Management Policies feature flag is disabled. // InitProvider holds the same fields as ForProvider, with the exception // of Identifier and other resource reference fields. The fields that are // in InitProvider are merged into ForProvider when the resource is created. // The same fields are also added to the terraform ignore_changes hook, to // avoid updating them after creation. This is useful for fields that are // required on creation, but we do not desire to update them after creation, // for example because of an external controller is managing them, like an // autoscaler. InitProvider ConfigurationInitParameters `json:"initProvider,omitempty"` }
ConfigurationSpec defines the desired state of Configuration
func (*ConfigurationSpec) DeepCopy ¶
func (in *ConfigurationSpec) DeepCopy() *ConfigurationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationSpec.
func (*ConfigurationSpec) DeepCopyInto ¶
func (in *ConfigurationSpec) DeepCopyInto(out *ConfigurationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationStatus ¶
type ConfigurationStatus struct { v1.ResourceStatus `json:",inline"` AtProvider ConfigurationObservation `json:"atProvider,omitempty"` }
ConfigurationStatus defines the observed state of Configuration.
func (*ConfigurationStatus) DeepCopy ¶
func (in *ConfigurationStatus) DeepCopy() *ConfigurationStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationStatus.
func (*ConfigurationStatus) DeepCopyInto ¶
func (in *ConfigurationStatus) DeepCopyInto(out *ConfigurationStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConnectivityInfoInitParameters ¶ added in v0.38.0
type ConnectivityInfoInitParameters struct { // Access control settings for brokers. See below. PublicAccess []PublicAccessInitParameters `json:"publicAccess,omitempty" tf:"public_access,omitempty"` }
func (*ConnectivityInfoInitParameters) DeepCopy ¶ added in v0.38.0
func (in *ConnectivityInfoInitParameters) DeepCopy() *ConnectivityInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectivityInfoInitParameters.
func (*ConnectivityInfoInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *ConnectivityInfoInitParameters) DeepCopyInto(out *ConnectivityInfoInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConnectivityInfoObservation ¶
type ConnectivityInfoObservation struct { // Access control settings for brokers. See below. PublicAccess []PublicAccessObservation `json:"publicAccess,omitempty" tf:"public_access,omitempty"` }
func (*ConnectivityInfoObservation) DeepCopy ¶
func (in *ConnectivityInfoObservation) DeepCopy() *ConnectivityInfoObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectivityInfoObservation.
func (*ConnectivityInfoObservation) DeepCopyInto ¶
func (in *ConnectivityInfoObservation) DeepCopyInto(out *ConnectivityInfoObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConnectivityInfoParameters ¶
type ConnectivityInfoParameters struct { // Access control settings for brokers. See below. // +kubebuilder:validation:Optional PublicAccess []PublicAccessParameters `json:"publicAccess,omitempty" tf:"public_access,omitempty"` }
func (*ConnectivityInfoParameters) DeepCopy ¶
func (in *ConnectivityInfoParameters) DeepCopy() *ConnectivityInfoParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectivityInfoParameters.
func (*ConnectivityInfoParameters) DeepCopyInto ¶
func (in *ConnectivityInfoParameters) DeepCopyInto(out *ConnectivityInfoParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EBSStorageInfoInitParameters ¶ added in v0.38.0
type EBSStorageInfoInitParameters struct { // A block that contains EBS volume provisioned throughput information. To provision storage throughput, you must choose broker type kafka.m5.4xlarge or larger. See below. ProvisionedThroughput []ProvisionedThroughputInitParameters `json:"provisionedThroughput,omitempty" tf:"provisioned_throughput,omitempty"` // The size in GiB of the EBS volume for the data drive on each broker node. Minimum value of 1 and maximum value of 16384. VolumeSize *float64 `json:"volumeSize,omitempty" tf:"volume_size,omitempty"` }
func (*EBSStorageInfoInitParameters) DeepCopy ¶ added in v0.38.0
func (in *EBSStorageInfoInitParameters) DeepCopy() *EBSStorageInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EBSStorageInfoInitParameters.
func (*EBSStorageInfoInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *EBSStorageInfoInitParameters) DeepCopyInto(out *EBSStorageInfoInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EBSStorageInfoObservation ¶
type EBSStorageInfoObservation struct { // A block that contains EBS volume provisioned throughput information. To provision storage throughput, you must choose broker type kafka.m5.4xlarge or larger. See below. ProvisionedThroughput []ProvisionedThroughputObservation `json:"provisionedThroughput,omitempty" tf:"provisioned_throughput,omitempty"` // The size in GiB of the EBS volume for the data drive on each broker node. Minimum value of 1 and maximum value of 16384. VolumeSize *float64 `json:"volumeSize,omitempty" tf:"volume_size,omitempty"` }
func (*EBSStorageInfoObservation) DeepCopy ¶
func (in *EBSStorageInfoObservation) DeepCopy() *EBSStorageInfoObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EBSStorageInfoObservation.
func (*EBSStorageInfoObservation) DeepCopyInto ¶
func (in *EBSStorageInfoObservation) DeepCopyInto(out *EBSStorageInfoObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EBSStorageInfoParameters ¶
type EBSStorageInfoParameters struct { // A block that contains EBS volume provisioned throughput information. To provision storage throughput, you must choose broker type kafka.m5.4xlarge or larger. See below. // +kubebuilder:validation:Optional ProvisionedThroughput []ProvisionedThroughputParameters `json:"provisionedThroughput,omitempty" tf:"provisioned_throughput,omitempty"` // The size in GiB of the EBS volume for the data drive on each broker node. Minimum value of 1 and maximum value of 16384. // +kubebuilder:validation:Optional VolumeSize *float64 `json:"volumeSize,omitempty" tf:"volume_size,omitempty"` }
func (*EBSStorageInfoParameters) DeepCopy ¶
func (in *EBSStorageInfoParameters) DeepCopy() *EBSStorageInfoParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EBSStorageInfoParameters.
func (*EBSStorageInfoParameters) DeepCopyInto ¶
func (in *EBSStorageInfoParameters) DeepCopyInto(out *EBSStorageInfoParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionInTransitInitParameters ¶ added in v0.38.0
type EncryptionInTransitInitParameters struct { // Encryption setting for data in transit between clients and brokers. Valid values: TLS, TLS_PLAINTEXT, and PLAINTEXT. Default value is TLS. ClientBroker *string `json:"clientBroker,omitempty" tf:"client_broker,omitempty"` // Whether data communication among broker nodes is encrypted. Default value: true. InCluster *bool `json:"inCluster,omitempty" tf:"in_cluster,omitempty"` }
func (*EncryptionInTransitInitParameters) DeepCopy ¶ added in v0.38.0
func (in *EncryptionInTransitInitParameters) DeepCopy() *EncryptionInTransitInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInTransitInitParameters.
func (*EncryptionInTransitInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *EncryptionInTransitInitParameters) DeepCopyInto(out *EncryptionInTransitInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionInTransitObservation ¶
type EncryptionInTransitObservation struct { // Encryption setting for data in transit between clients and brokers. Valid values: TLS, TLS_PLAINTEXT, and PLAINTEXT. Default value is TLS. ClientBroker *string `json:"clientBroker,omitempty" tf:"client_broker,omitempty"` // Whether data communication among broker nodes is encrypted. Default value: true. InCluster *bool `json:"inCluster,omitempty" tf:"in_cluster,omitempty"` }
func (*EncryptionInTransitObservation) DeepCopy ¶
func (in *EncryptionInTransitObservation) DeepCopy() *EncryptionInTransitObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInTransitObservation.
func (*EncryptionInTransitObservation) DeepCopyInto ¶
func (in *EncryptionInTransitObservation) DeepCopyInto(out *EncryptionInTransitObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionInTransitParameters ¶
type EncryptionInTransitParameters struct { // Encryption setting for data in transit between clients and brokers. Valid values: TLS, TLS_PLAINTEXT, and PLAINTEXT. Default value is TLS. // +kubebuilder:validation:Optional ClientBroker *string `json:"clientBroker,omitempty" tf:"client_broker,omitempty"` // Whether data communication among broker nodes is encrypted. Default value: true. // +kubebuilder:validation:Optional InCluster *bool `json:"inCluster,omitempty" tf:"in_cluster,omitempty"` }
func (*EncryptionInTransitParameters) DeepCopy ¶
func (in *EncryptionInTransitParameters) DeepCopy() *EncryptionInTransitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInTransitParameters.
func (*EncryptionInTransitParameters) DeepCopyInto ¶
func (in *EncryptionInTransitParameters) DeepCopyInto(out *EncryptionInTransitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionInfoInitParameters ¶ added in v0.38.0
type EncryptionInfoInitParameters struct { // The ARN of the KMS key used for encryption at rest of the broker data volumes. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kms/v1beta1.Key // +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor() EncryptionAtRestKMSKeyArn *string `json:"encryptionAtRestKmsKeyArn,omitempty" tf:"encryption_at_rest_kms_key_arn,omitempty"` // Reference to a Key in kms to populate encryptionAtRestKmsKeyArn. // +kubebuilder:validation:Optional EncryptionAtRestKMSKeyArnRef *v1.Reference `json:"encryptionAtRestKmsKeyArnRef,omitempty" tf:"-"` // Selector for a Key in kms to populate encryptionAtRestKmsKeyArn. // +kubebuilder:validation:Optional EncryptionAtRestKMSKeyArnSelector *v1.Selector `json:"encryptionAtRestKmsKeyArnSelector,omitempty" tf:"-"` // Configuration block to specify encryption in transit. See below. EncryptionInTransit []EncryptionInTransitInitParameters `json:"encryptionInTransit,omitempty" tf:"encryption_in_transit,omitempty"` }
func (*EncryptionInfoInitParameters) DeepCopy ¶ added in v0.38.0
func (in *EncryptionInfoInitParameters) DeepCopy() *EncryptionInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInfoInitParameters.
func (*EncryptionInfoInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *EncryptionInfoInitParameters) DeepCopyInto(out *EncryptionInfoInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionInfoObservation ¶
type EncryptionInfoObservation struct { // The ARN of the KMS key used for encryption at rest of the broker data volumes. EncryptionAtRestKMSKeyArn *string `json:"encryptionAtRestKmsKeyArn,omitempty" tf:"encryption_at_rest_kms_key_arn,omitempty"` // Configuration block to specify encryption in transit. See below. EncryptionInTransit []EncryptionInTransitObservation `json:"encryptionInTransit,omitempty" tf:"encryption_in_transit,omitempty"` }
func (*EncryptionInfoObservation) DeepCopy ¶
func (in *EncryptionInfoObservation) DeepCopy() *EncryptionInfoObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInfoObservation.
func (*EncryptionInfoObservation) DeepCopyInto ¶
func (in *EncryptionInfoObservation) DeepCopyInto(out *EncryptionInfoObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionInfoParameters ¶
type EncryptionInfoParameters struct { // The ARN of the KMS key used for encryption at rest of the broker data volumes. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kms/v1beta1.Key // +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor() // +kubebuilder:validation:Optional EncryptionAtRestKMSKeyArn *string `json:"encryptionAtRestKmsKeyArn,omitempty" tf:"encryption_at_rest_kms_key_arn,omitempty"` // Reference to a Key in kms to populate encryptionAtRestKmsKeyArn. // +kubebuilder:validation:Optional EncryptionAtRestKMSKeyArnRef *v1.Reference `json:"encryptionAtRestKmsKeyArnRef,omitempty" tf:"-"` // Selector for a Key in kms to populate encryptionAtRestKmsKeyArn. // +kubebuilder:validation:Optional EncryptionAtRestKMSKeyArnSelector *v1.Selector `json:"encryptionAtRestKmsKeyArnSelector,omitempty" tf:"-"` // Configuration block to specify encryption in transit. See below. // +kubebuilder:validation:Optional EncryptionInTransit []EncryptionInTransitParameters `json:"encryptionInTransit,omitempty" tf:"encryption_in_transit,omitempty"` }
func (*EncryptionInfoParameters) DeepCopy ¶
func (in *EncryptionInfoParameters) DeepCopy() *EncryptionInfoParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInfoParameters.
func (*EncryptionInfoParameters) DeepCopyInto ¶
func (in *EncryptionInfoParameters) DeepCopyInto(out *EncryptionInfoParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type FirehoseInitParameters ¶ added in v0.38.0
type FirehoseInitParameters struct { // Name of the Kinesis Data Firehose delivery stream to deliver logs to. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/firehose/v1beta1.DeliveryStream // +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("name",false) DeliveryStream *string `json:"deliveryStream,omitempty" tf:"delivery_stream,omitempty"` // Reference to a DeliveryStream in firehose to populate deliveryStream. // +kubebuilder:validation:Optional DeliveryStreamRef *v1.Reference `json:"deliveryStreamRef,omitempty" tf:"-"` // Selector for a DeliveryStream in firehose to populate deliveryStream. // +kubebuilder:validation:Optional DeliveryStreamSelector *v1.Selector `json:"deliveryStreamSelector,omitempty" tf:"-"` // Controls whether provisioned throughput is enabled or not. Default value: false. Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"` }
func (*FirehoseInitParameters) DeepCopy ¶ added in v0.38.0
func (in *FirehoseInitParameters) DeepCopy() *FirehoseInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FirehoseInitParameters.
func (*FirehoseInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *FirehoseInitParameters) DeepCopyInto(out *FirehoseInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type FirehoseObservation ¶
type FirehoseObservation struct { // Name of the Kinesis Data Firehose delivery stream to deliver logs to. DeliveryStream *string `json:"deliveryStream,omitempty" tf:"delivery_stream,omitempty"` // Controls whether provisioned throughput is enabled or not. Default value: false. Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"` }
func (*FirehoseObservation) DeepCopy ¶
func (in *FirehoseObservation) DeepCopy() *FirehoseObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FirehoseObservation.
func (*FirehoseObservation) DeepCopyInto ¶
func (in *FirehoseObservation) DeepCopyInto(out *FirehoseObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type FirehoseParameters ¶
type FirehoseParameters struct { // Name of the Kinesis Data Firehose delivery stream to deliver logs to. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/firehose/v1beta1.DeliveryStream // +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("name",false) // +kubebuilder:validation:Optional DeliveryStream *string `json:"deliveryStream,omitempty" tf:"delivery_stream,omitempty"` // Reference to a DeliveryStream in firehose to populate deliveryStream. // +kubebuilder:validation:Optional DeliveryStreamRef *v1.Reference `json:"deliveryStreamRef,omitempty" tf:"-"` // Selector for a DeliveryStream in firehose to populate deliveryStream. // +kubebuilder:validation:Optional DeliveryStreamSelector *v1.Selector `json:"deliveryStreamSelector,omitempty" tf:"-"` // Controls whether provisioned throughput is enabled or not. Default value: false. // +kubebuilder:validation:Optional Enabled *bool `json:"enabled" tf:"enabled,omitempty"` }
func (*FirehoseParameters) DeepCopy ¶
func (in *FirehoseParameters) DeepCopy() *FirehoseParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FirehoseParameters.
func (*FirehoseParameters) DeepCopyInto ¶
func (in *FirehoseParameters) DeepCopyInto(out *FirehoseParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type IAMInitParameters ¶ added in v0.43.0
type IAMInitParameters struct { // Whether SASL/IAM authentication is enabled or not. Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"` }
func (*IAMInitParameters) DeepCopy ¶ added in v0.43.0
func (in *IAMInitParameters) DeepCopy() *IAMInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IAMInitParameters.
func (*IAMInitParameters) DeepCopyInto ¶ added in v0.43.0
func (in *IAMInitParameters) DeepCopyInto(out *IAMInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type IAMObservation ¶ added in v0.43.0
type IAMObservation struct { // Whether SASL/IAM authentication is enabled or not. Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"` }
func (*IAMObservation) DeepCopy ¶ added in v0.43.0
func (in *IAMObservation) DeepCopy() *IAMObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IAMObservation.
func (*IAMObservation) DeepCopyInto ¶ added in v0.43.0
func (in *IAMObservation) DeepCopyInto(out *IAMObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type IAMParameters ¶ added in v0.43.0
type IAMParameters struct { // Whether SASL/IAM authentication is enabled or not. // +kubebuilder:validation:Optional Enabled *bool `json:"enabled" tf:"enabled,omitempty"` }
func (*IAMParameters) DeepCopy ¶ added in v0.43.0
func (in *IAMParameters) DeepCopy() *IAMParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IAMParameters.
func (*IAMParameters) DeepCopyInto ¶ added in v0.43.0
func (in *IAMParameters) DeepCopyInto(out *IAMParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JmxExporterInitParameters ¶ added in v0.38.0
type JmxExporterInitParameters struct { // Indicates whether you want to enable or disable the JMX Exporter. EnabledInBroker *bool `json:"enabledInBroker,omitempty" tf:"enabled_in_broker,omitempty"` }
func (*JmxExporterInitParameters) DeepCopy ¶ added in v0.38.0
func (in *JmxExporterInitParameters) DeepCopy() *JmxExporterInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JmxExporterInitParameters.
func (*JmxExporterInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *JmxExporterInitParameters) DeepCopyInto(out *JmxExporterInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JmxExporterObservation ¶
type JmxExporterObservation struct { // Indicates whether you want to enable or disable the JMX Exporter. EnabledInBroker *bool `json:"enabledInBroker,omitempty" tf:"enabled_in_broker,omitempty"` }
func (*JmxExporterObservation) DeepCopy ¶
func (in *JmxExporterObservation) DeepCopy() *JmxExporterObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JmxExporterObservation.
func (*JmxExporterObservation) DeepCopyInto ¶
func (in *JmxExporterObservation) DeepCopyInto(out *JmxExporterObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JmxExporterParameters ¶
type JmxExporterParameters struct { // Indicates whether you want to enable or disable the JMX Exporter. // +kubebuilder:validation:Optional EnabledInBroker *bool `json:"enabledInBroker" tf:"enabled_in_broker,omitempty"` }
func (*JmxExporterParameters) DeepCopy ¶
func (in *JmxExporterParameters) DeepCopy() *JmxExporterParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JmxExporterParameters.
func (*JmxExporterParameters) DeepCopyInto ¶
func (in *JmxExporterParameters) DeepCopyInto(out *JmxExporterParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LoggingInfoInitParameters ¶ added in v0.38.0
type LoggingInfoInitParameters struct { // Configuration block for Broker Logs settings for logging info. See below. BrokerLogs []BrokerLogsInitParameters `json:"brokerLogs,omitempty" tf:"broker_logs,omitempty"` }
func (*LoggingInfoInitParameters) DeepCopy ¶ added in v0.38.0
func (in *LoggingInfoInitParameters) DeepCopy() *LoggingInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoggingInfoInitParameters.
func (*LoggingInfoInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *LoggingInfoInitParameters) DeepCopyInto(out *LoggingInfoInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LoggingInfoObservation ¶
type LoggingInfoObservation struct { // Configuration block for Broker Logs settings for logging info. See below. BrokerLogs []BrokerLogsObservation `json:"brokerLogs,omitempty" tf:"broker_logs,omitempty"` }
func (*LoggingInfoObservation) DeepCopy ¶
func (in *LoggingInfoObservation) DeepCopy() *LoggingInfoObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoggingInfoObservation.
func (*LoggingInfoObservation) DeepCopyInto ¶
func (in *LoggingInfoObservation) DeepCopyInto(out *LoggingInfoObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type LoggingInfoParameters ¶
type LoggingInfoParameters struct { // Configuration block for Broker Logs settings for logging info. See below. // +kubebuilder:validation:Optional BrokerLogs []BrokerLogsParameters `json:"brokerLogs" tf:"broker_logs,omitempty"` }
func (*LoggingInfoParameters) DeepCopy ¶
func (in *LoggingInfoParameters) DeepCopy() *LoggingInfoParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoggingInfoParameters.
func (*LoggingInfoParameters) DeepCopyInto ¶
func (in *LoggingInfoParameters) DeepCopyInto(out *LoggingInfoParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NodeExporterInitParameters ¶ added in v0.38.0
type NodeExporterInitParameters struct { // Indicates whether you want to enable or disable the JMX Exporter. EnabledInBroker *bool `json:"enabledInBroker,omitempty" tf:"enabled_in_broker,omitempty"` }
func (*NodeExporterInitParameters) DeepCopy ¶ added in v0.38.0
func (in *NodeExporterInitParameters) DeepCopy() *NodeExporterInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeExporterInitParameters.
func (*NodeExporterInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *NodeExporterInitParameters) DeepCopyInto(out *NodeExporterInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NodeExporterObservation ¶
type NodeExporterObservation struct { // Indicates whether you want to enable or disable the JMX Exporter. EnabledInBroker *bool `json:"enabledInBroker,omitempty" tf:"enabled_in_broker,omitempty"` }
func (*NodeExporterObservation) DeepCopy ¶
func (in *NodeExporterObservation) DeepCopy() *NodeExporterObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeExporterObservation.
func (*NodeExporterObservation) DeepCopyInto ¶
func (in *NodeExporterObservation) DeepCopyInto(out *NodeExporterObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type NodeExporterParameters ¶
type NodeExporterParameters struct { // Indicates whether you want to enable or disable the JMX Exporter. // +kubebuilder:validation:Optional EnabledInBroker *bool `json:"enabledInBroker" tf:"enabled_in_broker,omitempty"` }
func (*NodeExporterParameters) DeepCopy ¶
func (in *NodeExporterParameters) DeepCopy() *NodeExporterParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeExporterParameters.
func (*NodeExporterParameters) DeepCopyInto ¶
func (in *NodeExporterParameters) DeepCopyInto(out *NodeExporterParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OpenMonitoringInitParameters ¶ added in v0.38.0
type OpenMonitoringInitParameters struct { // Configuration block for Prometheus settings for open monitoring. See below. Prometheus []PrometheusInitParameters `json:"prometheus,omitempty" tf:"prometheus,omitempty"` }
func (*OpenMonitoringInitParameters) DeepCopy ¶ added in v0.38.0
func (in *OpenMonitoringInitParameters) DeepCopy() *OpenMonitoringInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenMonitoringInitParameters.
func (*OpenMonitoringInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *OpenMonitoringInitParameters) DeepCopyInto(out *OpenMonitoringInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OpenMonitoringObservation ¶
type OpenMonitoringObservation struct { // Configuration block for Prometheus settings for open monitoring. See below. Prometheus []PrometheusObservation `json:"prometheus,omitempty" tf:"prometheus,omitempty"` }
func (*OpenMonitoringObservation) DeepCopy ¶
func (in *OpenMonitoringObservation) DeepCopy() *OpenMonitoringObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenMonitoringObservation.
func (*OpenMonitoringObservation) DeepCopyInto ¶
func (in *OpenMonitoringObservation) DeepCopyInto(out *OpenMonitoringObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type OpenMonitoringParameters ¶
type OpenMonitoringParameters struct { // Configuration block for Prometheus settings for open monitoring. See below. // +kubebuilder:validation:Optional Prometheus []PrometheusParameters `json:"prometheus" tf:"prometheus,omitempty"` }
func (*OpenMonitoringParameters) DeepCopy ¶
func (in *OpenMonitoringParameters) DeepCopy() *OpenMonitoringParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenMonitoringParameters.
func (*OpenMonitoringParameters) DeepCopyInto ¶
func (in *OpenMonitoringParameters) DeepCopyInto(out *OpenMonitoringParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PrometheusInitParameters ¶ added in v0.38.0
type PrometheusInitParameters struct { // Configuration block for JMX Exporter. See below. JmxExporter []JmxExporterInitParameters `json:"jmxExporter,omitempty" tf:"jmx_exporter,omitempty"` // Configuration block for Node Exporter. See below. NodeExporter []NodeExporterInitParameters `json:"nodeExporter,omitempty" tf:"node_exporter,omitempty"` }
func (*PrometheusInitParameters) DeepCopy ¶ added in v0.38.0
func (in *PrometheusInitParameters) DeepCopy() *PrometheusInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrometheusInitParameters.
func (*PrometheusInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *PrometheusInitParameters) DeepCopyInto(out *PrometheusInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PrometheusObservation ¶
type PrometheusObservation struct { // Configuration block for JMX Exporter. See below. JmxExporter []JmxExporterObservation `json:"jmxExporter,omitempty" tf:"jmx_exporter,omitempty"` // Configuration block for Node Exporter. See below. NodeExporter []NodeExporterObservation `json:"nodeExporter,omitempty" tf:"node_exporter,omitempty"` }
func (*PrometheusObservation) DeepCopy ¶
func (in *PrometheusObservation) DeepCopy() *PrometheusObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrometheusObservation.
func (*PrometheusObservation) DeepCopyInto ¶
func (in *PrometheusObservation) DeepCopyInto(out *PrometheusObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PrometheusParameters ¶
type PrometheusParameters struct { // Configuration block for JMX Exporter. See below. // +kubebuilder:validation:Optional JmxExporter []JmxExporterParameters `json:"jmxExporter,omitempty" tf:"jmx_exporter,omitempty"` // Configuration block for Node Exporter. See below. // +kubebuilder:validation:Optional NodeExporter []NodeExporterParameters `json:"nodeExporter,omitempty" tf:"node_exporter,omitempty"` }
func (*PrometheusParameters) DeepCopy ¶
func (in *PrometheusParameters) DeepCopy() *PrometheusParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrometheusParameters.
func (*PrometheusParameters) DeepCopyInto ¶
func (in *PrometheusParameters) DeepCopyInto(out *PrometheusParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ProvisionedThroughputInitParameters ¶ added in v0.38.0
type ProvisionedThroughputInitParameters struct { // Controls whether provisioned throughput is enabled or not. Default value: false. Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"` // Throughput value of the EBS volumes for the data drive on each kafka broker node in MiB per second. The minimum value is 250. The maximum value varies between broker type. You can refer to the valid values for the maximum volume throughput at the following documentation on throughput bottlenecks VolumeThroughput *float64 `json:"volumeThroughput,omitempty" tf:"volume_throughput,omitempty"` }
func (*ProvisionedThroughputInitParameters) DeepCopy ¶ added in v0.38.0
func (in *ProvisionedThroughputInitParameters) DeepCopy() *ProvisionedThroughputInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProvisionedThroughputInitParameters.
func (*ProvisionedThroughputInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *ProvisionedThroughputInitParameters) DeepCopyInto(out *ProvisionedThroughputInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ProvisionedThroughputObservation ¶
type ProvisionedThroughputObservation struct { // Controls whether provisioned throughput is enabled or not. Default value: false. Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"` // Throughput value of the EBS volumes for the data drive on each kafka broker node in MiB per second. The minimum value is 250. The maximum value varies between broker type. You can refer to the valid values for the maximum volume throughput at the following documentation on throughput bottlenecks VolumeThroughput *float64 `json:"volumeThroughput,omitempty" tf:"volume_throughput,omitempty"` }
func (*ProvisionedThroughputObservation) DeepCopy ¶
func (in *ProvisionedThroughputObservation) DeepCopy() *ProvisionedThroughputObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProvisionedThroughputObservation.
func (*ProvisionedThroughputObservation) DeepCopyInto ¶
func (in *ProvisionedThroughputObservation) DeepCopyInto(out *ProvisionedThroughputObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ProvisionedThroughputParameters ¶
type ProvisionedThroughputParameters struct { // Controls whether provisioned throughput is enabled or not. Default value: false. // +kubebuilder:validation:Optional Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"` // Throughput value of the EBS volumes for the data drive on each kafka broker node in MiB per second. The minimum value is 250. The maximum value varies between broker type. You can refer to the valid values for the maximum volume throughput at the following documentation on throughput bottlenecks // +kubebuilder:validation:Optional VolumeThroughput *float64 `json:"volumeThroughput,omitempty" tf:"volume_throughput,omitempty"` }
func (*ProvisionedThroughputParameters) DeepCopy ¶
func (in *ProvisionedThroughputParameters) DeepCopy() *ProvisionedThroughputParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProvisionedThroughputParameters.
func (*ProvisionedThroughputParameters) DeepCopyInto ¶
func (in *ProvisionedThroughputParameters) DeepCopyInto(out *ProvisionedThroughputParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PublicAccessInitParameters ¶ added in v0.38.0
type PublicAccessInitParameters struct { // Public access type. Valida values: DISABLED, SERVICE_PROVIDED_EIPS. Type *string `json:"type,omitempty" tf:"type,omitempty"` }
func (*PublicAccessInitParameters) DeepCopy ¶ added in v0.38.0
func (in *PublicAccessInitParameters) DeepCopy() *PublicAccessInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PublicAccessInitParameters.
func (*PublicAccessInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *PublicAccessInitParameters) DeepCopyInto(out *PublicAccessInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PublicAccessObservation ¶
type PublicAccessObservation struct { // Public access type. Valida values: DISABLED, SERVICE_PROVIDED_EIPS. Type *string `json:"type,omitempty" tf:"type,omitempty"` }
func (*PublicAccessObservation) DeepCopy ¶
func (in *PublicAccessObservation) DeepCopy() *PublicAccessObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PublicAccessObservation.
func (*PublicAccessObservation) DeepCopyInto ¶
func (in *PublicAccessObservation) DeepCopyInto(out *PublicAccessObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type PublicAccessParameters ¶
type PublicAccessParameters struct { // Public access type. Valida values: DISABLED, SERVICE_PROVIDED_EIPS. // +kubebuilder:validation:Optional Type *string `json:"type,omitempty" tf:"type,omitempty"` }
func (*PublicAccessParameters) DeepCopy ¶
func (in *PublicAccessParameters) DeepCopy() *PublicAccessParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PublicAccessParameters.
func (*PublicAccessParameters) DeepCopyInto ¶
func (in *PublicAccessParameters) DeepCopyInto(out *PublicAccessParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type S3InitParameters ¶ added in v0.38.0
type S3InitParameters struct { // Name of the S3 bucket to deliver logs to. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta1.Bucket Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"` // Reference to a Bucket in s3 to populate bucket. // +kubebuilder:validation:Optional BucketRef *v1.Reference `json:"bucketRef,omitempty" tf:"-"` // Selector for a Bucket in s3 to populate bucket. // +kubebuilder:validation:Optional BucketSelector *v1.Selector `json:"bucketSelector,omitempty" tf:"-"` // Controls whether provisioned throughput is enabled or not. Default value: false. Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"` // Prefix to append to the folder name. Prefix *string `json:"prefix,omitempty" tf:"prefix,omitempty"` }
func (*S3InitParameters) DeepCopy ¶ added in v0.38.0
func (in *S3InitParameters) DeepCopy() *S3InitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3InitParameters.
func (*S3InitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *S3InitParameters) DeepCopyInto(out *S3InitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type S3Observation ¶
type S3Observation struct { // Name of the S3 bucket to deliver logs to. Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"` // Controls whether provisioned throughput is enabled or not. Default value: false. Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"` // Prefix to append to the folder name. Prefix *string `json:"prefix,omitempty" tf:"prefix,omitempty"` }
func (*S3Observation) DeepCopy ¶
func (in *S3Observation) DeepCopy() *S3Observation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3Observation.
func (*S3Observation) DeepCopyInto ¶
func (in *S3Observation) DeepCopyInto(out *S3Observation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type S3Parameters ¶
type S3Parameters struct { // Name of the S3 bucket to deliver logs to. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta1.Bucket // +kubebuilder:validation:Optional Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"` // Reference to a Bucket in s3 to populate bucket. // +kubebuilder:validation:Optional BucketRef *v1.Reference `json:"bucketRef,omitempty" tf:"-"` // Selector for a Bucket in s3 to populate bucket. // +kubebuilder:validation:Optional BucketSelector *v1.Selector `json:"bucketSelector,omitempty" tf:"-"` // Controls whether provisioned throughput is enabled or not. Default value: false. // +kubebuilder:validation:Optional Enabled *bool `json:"enabled" tf:"enabled,omitempty"` // Prefix to append to the folder name. // +kubebuilder:validation:Optional Prefix *string `json:"prefix,omitempty" tf:"prefix,omitempty"` }
func (*S3Parameters) DeepCopy ¶
func (in *S3Parameters) DeepCopy() *S3Parameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3Parameters.
func (*S3Parameters) DeepCopyInto ¶
func (in *S3Parameters) DeepCopyInto(out *S3Parameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SaslInitParameters ¶ added in v0.38.0
type SaslInitParameters struct { // Enables IAM client authentication. Defaults to false. IAM *bool `json:"iam,omitempty" tf:"iam,omitempty"` // Enables SCRAM client authentication via AWS Secrets Manager. Defaults to false. Scram *bool `json:"scram,omitempty" tf:"scram,omitempty"` }
func (*SaslInitParameters) DeepCopy ¶ added in v0.38.0
func (in *SaslInitParameters) DeepCopy() *SaslInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SaslInitParameters.
func (*SaslInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *SaslInitParameters) DeepCopyInto(out *SaslInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SaslObservation ¶
type SaslObservation struct { // Enables IAM client authentication. Defaults to false. IAM *bool `json:"iam,omitempty" tf:"iam,omitempty"` // Enables SCRAM client authentication via AWS Secrets Manager. Defaults to false. Scram *bool `json:"scram,omitempty" tf:"scram,omitempty"` }
func (*SaslObservation) DeepCopy ¶
func (in *SaslObservation) DeepCopy() *SaslObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SaslObservation.
func (*SaslObservation) DeepCopyInto ¶
func (in *SaslObservation) DeepCopyInto(out *SaslObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SaslParameters ¶
type SaslParameters struct { // Enables IAM client authentication. Defaults to false. // +kubebuilder:validation:Optional IAM *bool `json:"iam,omitempty" tf:"iam,omitempty"` // Enables SCRAM client authentication via AWS Secrets Manager. Defaults to false. // +kubebuilder:validation:Optional Scram *bool `json:"scram,omitempty" tf:"scram,omitempty"` }
func (*SaslParameters) DeepCopy ¶
func (in *SaslParameters) DeepCopy() *SaslParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SaslParameters.
func (*SaslParameters) DeepCopyInto ¶
func (in *SaslParameters) DeepCopyInto(out *SaslParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ScramSecretAssociation ¶ added in v0.41.0
type ScramSecretAssociation struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` Spec ScramSecretAssociationSpec `json:"spec"` Status ScramSecretAssociationStatus `json:"status,omitempty"` }
ScramSecretAssociation is the Schema for the ScramSecretAssociations API. Associates SCRAM secrets with a Managed Streaming for Kafka (MSK) cluster. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].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:resource:scope=Cluster,categories={crossplane,managed,aws}
func (*ScramSecretAssociation) DeepCopy ¶ added in v0.41.0
func (in *ScramSecretAssociation) DeepCopy() *ScramSecretAssociation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScramSecretAssociation.
func (*ScramSecretAssociation) DeepCopyInto ¶ added in v0.41.0
func (in *ScramSecretAssociation) DeepCopyInto(out *ScramSecretAssociation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ScramSecretAssociation) DeepCopyObject ¶ added in v0.41.0
func (in *ScramSecretAssociation) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ScramSecretAssociation) GetCondition ¶ added in v0.41.0
func (mg *ScramSecretAssociation) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this ScramSecretAssociation.
func (*ScramSecretAssociation) GetConnectionDetailsMapping ¶ added in v0.41.0
func (tr *ScramSecretAssociation) GetConnectionDetailsMapping() map[string]string
GetConnectionDetailsMapping for this ScramSecretAssociation
func (*ScramSecretAssociation) GetDeletionPolicy ¶ added in v0.41.0
func (mg *ScramSecretAssociation) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this ScramSecretAssociation.
func (*ScramSecretAssociation) GetID ¶ added in v0.41.0
func (tr *ScramSecretAssociation) GetID() string
GetID returns ID of underlying Terraform resource of this ScramSecretAssociation
func (*ScramSecretAssociation) GetInitParameters ¶ added in v0.41.0
func (tr *ScramSecretAssociation) GetInitParameters() (map[string]any, error)
GetInitParameters of this ScramSecretAssociation
func (*ScramSecretAssociation) GetManagementPolicies ¶ added in v0.41.0
func (mg *ScramSecretAssociation) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this ScramSecretAssociation.
func (*ScramSecretAssociation) GetMergedParameters ¶ added in v0.44.0
func (tr *ScramSecretAssociation) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
GetInitParameters of this ScramSecretAssociation
func (*ScramSecretAssociation) GetObservation ¶ added in v0.41.0
func (tr *ScramSecretAssociation) GetObservation() (map[string]any, error)
GetObservation of this ScramSecretAssociation
func (*ScramSecretAssociation) GetParameters ¶ added in v0.41.0
func (tr *ScramSecretAssociation) GetParameters() (map[string]any, error)
GetParameters of this ScramSecretAssociation
func (*ScramSecretAssociation) GetProviderConfigReference ¶ added in v0.41.0
func (mg *ScramSecretAssociation) GetProviderConfigReference() *xpv1.Reference
GetProviderConfigReference of this ScramSecretAssociation.
func (*ScramSecretAssociation) GetPublishConnectionDetailsTo ¶ added in v0.41.0
func (mg *ScramSecretAssociation) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this ScramSecretAssociation.
func (*ScramSecretAssociation) GetTerraformResourceType ¶ added in v0.41.0
func (mg *ScramSecretAssociation) GetTerraformResourceType() string
GetTerraformResourceType returns Terraform resource type for this ScramSecretAssociation
func (*ScramSecretAssociation) GetTerraformSchemaVersion ¶ added in v0.41.0
func (tr *ScramSecretAssociation) GetTerraformSchemaVersion() int
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*ScramSecretAssociation) GetWriteConnectionSecretToReference ¶ added in v0.41.0
func (mg *ScramSecretAssociation) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this ScramSecretAssociation.
func (*ScramSecretAssociation) Hub ¶ added in v0.47.2
func (tr *ScramSecretAssociation) Hub()
Hub marks this type as a conversion hub.
func (*ScramSecretAssociation) LateInitialize ¶ added in v0.41.0
func (tr *ScramSecretAssociation) LateInitialize(attrs []byte) (bool, error)
LateInitialize this ScramSecretAssociation using its observed tfState. returns True if there are any spec changes for the resource.
func (*ScramSecretAssociation) ResolveReferences ¶ added in v0.41.0
ResolveReferences of this ScramSecretAssociation.
func (*ScramSecretAssociation) SetConditions ¶ added in v0.41.0
func (mg *ScramSecretAssociation) SetConditions(c ...xpv1.Condition)
SetConditions of this ScramSecretAssociation.
func (*ScramSecretAssociation) SetDeletionPolicy ¶ added in v0.41.0
func (mg *ScramSecretAssociation) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this ScramSecretAssociation.
func (*ScramSecretAssociation) SetManagementPolicies ¶ added in v0.41.0
func (mg *ScramSecretAssociation) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this ScramSecretAssociation.
func (*ScramSecretAssociation) SetObservation ¶ added in v0.41.0
func (tr *ScramSecretAssociation) SetObservation(obs map[string]any) error
SetObservation for this ScramSecretAssociation
func (*ScramSecretAssociation) SetParameters ¶ added in v0.41.0
func (tr *ScramSecretAssociation) SetParameters(params map[string]any) error
SetParameters for this ScramSecretAssociation
func (*ScramSecretAssociation) SetProviderConfigReference ¶ added in v0.41.0
func (mg *ScramSecretAssociation) SetProviderConfigReference(r *xpv1.Reference)
SetProviderConfigReference of this ScramSecretAssociation.
func (*ScramSecretAssociation) SetPublishConnectionDetailsTo ¶ added in v0.41.0
func (mg *ScramSecretAssociation) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this ScramSecretAssociation.
func (*ScramSecretAssociation) SetWriteConnectionSecretToReference ¶ added in v0.41.0
func (mg *ScramSecretAssociation) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this ScramSecretAssociation.
type ScramSecretAssociationInitParameters ¶ added in v0.41.0
type ScramSecretAssociationInitParameters struct { // Amazon Resource Name (ARN) of the MSK cluster. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kafka/v1beta3.Cluster // +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("arn",true) ClusterArn *string `json:"clusterArn,omitempty" tf:"cluster_arn,omitempty"` // Reference to a Cluster in kafka to populate clusterArn. // +kubebuilder:validation:Optional ClusterArnRef *v1.Reference `json:"clusterArnRef,omitempty" tf:"-"` // Selector for a Cluster in kafka to populate clusterArn. // +kubebuilder:validation:Optional ClusterArnSelector *v1.Selector `json:"clusterArnSelector,omitempty" tf:"-"` // List of all AWS Secrets Manager secret ARNs to associate with the cluster. Secrets not referenced, selected or listed here will be disassociated from the cluster. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/secretsmanager/v1beta1.Secret // +crossplane:generate:reference:refFieldName=SecretArnRefs // +crossplane:generate:reference:selectorFieldName=SecretArnSelector // +listType=set SecretArnList []*string `json:"secretArnList,omitempty" tf:"secret_arn_list,omitempty"` // References to Secret in secretsmanager to populate secretArnList. // +kubebuilder:validation:Optional SecretArnRefs []v1.Reference `json:"secretArnRefs,omitempty" tf:"-"` // Selector for a list of Secret in secretsmanager to populate secretArnList. // +kubebuilder:validation:Optional SecretArnSelector *v1.Selector `json:"secretArnSelector,omitempty" tf:"-"` }
func (*ScramSecretAssociationInitParameters) DeepCopy ¶ added in v0.41.0
func (in *ScramSecretAssociationInitParameters) DeepCopy() *ScramSecretAssociationInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScramSecretAssociationInitParameters.
func (*ScramSecretAssociationInitParameters) DeepCopyInto ¶ added in v0.41.0
func (in *ScramSecretAssociationInitParameters) DeepCopyInto(out *ScramSecretAssociationInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ScramSecretAssociationList ¶ added in v0.41.0
type ScramSecretAssociationList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []ScramSecretAssociation `json:"items"` }
ScramSecretAssociationList contains a list of ScramSecretAssociations
func (*ScramSecretAssociationList) DeepCopy ¶ added in v0.41.0
func (in *ScramSecretAssociationList) DeepCopy() *ScramSecretAssociationList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScramSecretAssociationList.
func (*ScramSecretAssociationList) DeepCopyInto ¶ added in v0.41.0
func (in *ScramSecretAssociationList) DeepCopyInto(out *ScramSecretAssociationList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ScramSecretAssociationList) DeepCopyObject ¶ added in v0.41.0
func (in *ScramSecretAssociationList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ScramSecretAssociationList) GetItems ¶ added in v0.41.0
func (l *ScramSecretAssociationList) GetItems() []resource.Managed
GetItems of this ScramSecretAssociationList.
type ScramSecretAssociationObservation ¶ added in v0.41.0
type ScramSecretAssociationObservation struct { // Amazon Resource Name (ARN) of the MSK cluster. ClusterArn *string `json:"clusterArn,omitempty" tf:"cluster_arn,omitempty"` // Amazon Resource Name (ARN) of the MSK cluster. ID *string `json:"id,omitempty" tf:"id,omitempty"` // List of all AWS Secrets Manager secret ARNs to associate with the cluster. Secrets not referenced, selected or listed here will be disassociated from the cluster. // +listType=set SecretArnList []*string `json:"secretArnList,omitempty" tf:"secret_arn_list,omitempty"` }
func (*ScramSecretAssociationObservation) DeepCopy ¶ added in v0.41.0
func (in *ScramSecretAssociationObservation) DeepCopy() *ScramSecretAssociationObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScramSecretAssociationObservation.
func (*ScramSecretAssociationObservation) DeepCopyInto ¶ added in v0.41.0
func (in *ScramSecretAssociationObservation) DeepCopyInto(out *ScramSecretAssociationObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ScramSecretAssociationParameters ¶ added in v0.41.0
type ScramSecretAssociationParameters struct { // Amazon Resource Name (ARN) of the MSK cluster. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kafka/v1beta3.Cluster // +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("arn",true) // +kubebuilder:validation:Optional ClusterArn *string `json:"clusterArn,omitempty" tf:"cluster_arn,omitempty"` // Reference to a Cluster in kafka to populate clusterArn. // +kubebuilder:validation:Optional ClusterArnRef *v1.Reference `json:"clusterArnRef,omitempty" tf:"-"` // Selector for a Cluster in kafka to populate clusterArn. // +kubebuilder:validation:Optional ClusterArnSelector *v1.Selector `json:"clusterArnSelector,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:"-"` // List of all AWS Secrets Manager secret ARNs to associate with the cluster. Secrets not referenced, selected or listed here will be disassociated from the cluster. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/secretsmanager/v1beta1.Secret // +crossplane:generate:reference:refFieldName=SecretArnRefs // +crossplane:generate:reference:selectorFieldName=SecretArnSelector // +kubebuilder:validation:Optional // +listType=set SecretArnList []*string `json:"secretArnList,omitempty" tf:"secret_arn_list,omitempty"` // References to Secret in secretsmanager to populate secretArnList. // +kubebuilder:validation:Optional SecretArnRefs []v1.Reference `json:"secretArnRefs,omitempty" tf:"-"` // Selector for a list of Secret in secretsmanager to populate secretArnList. // +kubebuilder:validation:Optional SecretArnSelector *v1.Selector `json:"secretArnSelector,omitempty" tf:"-"` }
func (*ScramSecretAssociationParameters) DeepCopy ¶ added in v0.41.0
func (in *ScramSecretAssociationParameters) DeepCopy() *ScramSecretAssociationParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScramSecretAssociationParameters.
func (*ScramSecretAssociationParameters) DeepCopyInto ¶ added in v0.41.0
func (in *ScramSecretAssociationParameters) DeepCopyInto(out *ScramSecretAssociationParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ScramSecretAssociationSpec ¶ added in v0.41.0
type ScramSecretAssociationSpec struct { v1.ResourceSpec `json:",inline"` ForProvider ScramSecretAssociationParameters `json:"forProvider"` // THIS IS A BETA FIELD. It will be honored // unless the Management Policies feature flag is disabled. // InitProvider holds the same fields as ForProvider, with the exception // of Identifier and other resource reference fields. The fields that are // in InitProvider are merged into ForProvider when the resource is created. // The same fields are also added to the terraform ignore_changes hook, to // avoid updating them after creation. This is useful for fields that are // required on creation, but we do not desire to update them after creation, // for example because of an external controller is managing them, like an // autoscaler. InitProvider ScramSecretAssociationInitParameters `json:"initProvider,omitempty"` }
ScramSecretAssociationSpec defines the desired state of ScramSecretAssociation
func (*ScramSecretAssociationSpec) DeepCopy ¶ added in v0.41.0
func (in *ScramSecretAssociationSpec) DeepCopy() *ScramSecretAssociationSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScramSecretAssociationSpec.
func (*ScramSecretAssociationSpec) DeepCopyInto ¶ added in v0.41.0
func (in *ScramSecretAssociationSpec) DeepCopyInto(out *ScramSecretAssociationSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ScramSecretAssociationStatus ¶ added in v0.41.0
type ScramSecretAssociationStatus struct { v1.ResourceStatus `json:",inline"` AtProvider ScramSecretAssociationObservation `json:"atProvider,omitempty"` }
ScramSecretAssociationStatus defines the observed state of ScramSecretAssociation.
func (*ScramSecretAssociationStatus) DeepCopy ¶ added in v0.41.0
func (in *ScramSecretAssociationStatus) DeepCopy() *ScramSecretAssociationStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ScramSecretAssociationStatus.
func (*ScramSecretAssociationStatus) DeepCopyInto ¶ added in v0.41.0
func (in *ScramSecretAssociationStatus) DeepCopyInto(out *ScramSecretAssociationStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessCluster ¶ added in v0.43.0
type ServerlessCluster struct { metav1.TypeMeta `json:",inline"` metav1.ObjectMeta `json:"metadata,omitempty"` // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.clientAuthentication) || (has(self.initProvider) && has(self.initProvider.clientAuthentication))",message="spec.forProvider.clientAuthentication is a required parameter" // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.clusterName) || (has(self.initProvider) && has(self.initProvider.clusterName))",message="spec.forProvider.clusterName is a required parameter" // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.vpcConfig) || (has(self.initProvider) && has(self.initProvider.vpcConfig))",message="spec.forProvider.vpcConfig is a required parameter" Spec ServerlessClusterSpec `json:"spec"` Status ServerlessClusterStatus `json:"status,omitempty"` }
ServerlessCluster is the Schema for the ServerlessClusters API. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].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:resource:scope=Cluster,categories={crossplane,managed,aws}
func (*ServerlessCluster) ConvertFrom ¶ added in v1.7.0
func (tr *ServerlessCluster) ConvertFrom(srcRaw conversion.Hub) error
ConvertFrom converts from the hub type to the ServerlessCluster type.
func (*ServerlessCluster) ConvertTo ¶ added in v1.7.0
func (tr *ServerlessCluster) ConvertTo(dstRaw conversion.Hub) error
ConvertTo converts this ServerlessCluster to the hub type.
func (*ServerlessCluster) DeepCopy ¶ added in v0.43.0
func (in *ServerlessCluster) DeepCopy() *ServerlessCluster
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessCluster.
func (*ServerlessCluster) DeepCopyInto ¶ added in v0.43.0
func (in *ServerlessCluster) DeepCopyInto(out *ServerlessCluster)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ServerlessCluster) DeepCopyObject ¶ added in v0.43.0
func (in *ServerlessCluster) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ServerlessCluster) GetCondition ¶ added in v0.43.0
func (mg *ServerlessCluster) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this ServerlessCluster.
func (*ServerlessCluster) GetConnectionDetailsMapping ¶ added in v0.43.0
func (tr *ServerlessCluster) GetConnectionDetailsMapping() map[string]string
GetConnectionDetailsMapping for this ServerlessCluster
func (*ServerlessCluster) GetDeletionPolicy ¶ added in v0.43.0
func (mg *ServerlessCluster) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this ServerlessCluster.
func (*ServerlessCluster) GetID ¶ added in v0.43.0
func (tr *ServerlessCluster) GetID() string
GetID returns ID of underlying Terraform resource of this ServerlessCluster
func (*ServerlessCluster) GetInitParameters ¶ added in v0.43.0
func (tr *ServerlessCluster) GetInitParameters() (map[string]any, error)
GetInitParameters of this ServerlessCluster
func (*ServerlessCluster) GetManagementPolicies ¶ added in v0.43.0
func (mg *ServerlessCluster) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this ServerlessCluster.
func (*ServerlessCluster) GetMergedParameters ¶ added in v0.44.0
func (tr *ServerlessCluster) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
GetInitParameters of this ServerlessCluster
func (*ServerlessCluster) GetObservation ¶ added in v0.43.0
func (tr *ServerlessCluster) GetObservation() (map[string]any, error)
GetObservation of this ServerlessCluster
func (*ServerlessCluster) GetParameters ¶ added in v0.43.0
func (tr *ServerlessCluster) GetParameters() (map[string]any, error)
GetParameters of this ServerlessCluster
func (*ServerlessCluster) GetProviderConfigReference ¶ added in v0.43.0
func (mg *ServerlessCluster) GetProviderConfigReference() *xpv1.Reference
GetProviderConfigReference of this ServerlessCluster.
func (*ServerlessCluster) GetPublishConnectionDetailsTo ¶ added in v0.43.0
func (mg *ServerlessCluster) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this ServerlessCluster.
func (*ServerlessCluster) GetTerraformResourceType ¶ added in v0.43.0
func (mg *ServerlessCluster) GetTerraformResourceType() string
GetTerraformResourceType returns Terraform resource type for this ServerlessCluster
func (*ServerlessCluster) GetTerraformSchemaVersion ¶ added in v0.43.0
func (tr *ServerlessCluster) GetTerraformSchemaVersion() int
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*ServerlessCluster) GetWriteConnectionSecretToReference ¶ added in v0.43.0
func (mg *ServerlessCluster) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this ServerlessCluster.
func (*ServerlessCluster) LateInitialize ¶ added in v0.43.0
func (tr *ServerlessCluster) LateInitialize(attrs []byte) (bool, error)
LateInitialize this ServerlessCluster using its observed tfState. returns True if there are any spec changes for the resource.
func (*ServerlessCluster) ResolveReferences ¶ added in v0.43.0
ResolveReferences of this ServerlessCluster.
func (*ServerlessCluster) SetConditions ¶ added in v0.43.0
func (mg *ServerlessCluster) SetConditions(c ...xpv1.Condition)
SetConditions of this ServerlessCluster.
func (*ServerlessCluster) SetDeletionPolicy ¶ added in v0.43.0
func (mg *ServerlessCluster) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this ServerlessCluster.
func (*ServerlessCluster) SetManagementPolicies ¶ added in v0.43.0
func (mg *ServerlessCluster) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this ServerlessCluster.
func (*ServerlessCluster) SetObservation ¶ added in v0.43.0
func (tr *ServerlessCluster) SetObservation(obs map[string]any) error
SetObservation for this ServerlessCluster
func (*ServerlessCluster) SetParameters ¶ added in v0.43.0
func (tr *ServerlessCluster) SetParameters(params map[string]any) error
SetParameters for this ServerlessCluster
func (*ServerlessCluster) SetProviderConfigReference ¶ added in v0.43.0
func (mg *ServerlessCluster) SetProviderConfigReference(r *xpv1.Reference)
SetProviderConfigReference of this ServerlessCluster.
func (*ServerlessCluster) SetPublishConnectionDetailsTo ¶ added in v0.43.0
func (mg *ServerlessCluster) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this ServerlessCluster.
func (*ServerlessCluster) SetWriteConnectionSecretToReference ¶ added in v0.43.0
func (mg *ServerlessCluster) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this ServerlessCluster.
type ServerlessClusterClientAuthenticationInitParameters ¶ added in v0.43.0
type ServerlessClusterClientAuthenticationInitParameters struct { // Details for client authentication using SASL. See below. Sasl []ClientAuthenticationSaslInitParameters `json:"sasl,omitempty" tf:"sasl,omitempty"` }
func (*ServerlessClusterClientAuthenticationInitParameters) DeepCopy ¶ added in v0.43.0
func (in *ServerlessClusterClientAuthenticationInitParameters) DeepCopy() *ServerlessClusterClientAuthenticationInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterClientAuthenticationInitParameters.
func (*ServerlessClusterClientAuthenticationInitParameters) DeepCopyInto ¶ added in v0.43.0
func (in *ServerlessClusterClientAuthenticationInitParameters) DeepCopyInto(out *ServerlessClusterClientAuthenticationInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterClientAuthenticationObservation ¶ added in v0.43.0
type ServerlessClusterClientAuthenticationObservation struct { // Details for client authentication using SASL. See below. Sasl []ClientAuthenticationSaslObservation `json:"sasl,omitempty" tf:"sasl,omitempty"` }
func (*ServerlessClusterClientAuthenticationObservation) DeepCopy ¶ added in v0.43.0
func (in *ServerlessClusterClientAuthenticationObservation) DeepCopy() *ServerlessClusterClientAuthenticationObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterClientAuthenticationObservation.
func (*ServerlessClusterClientAuthenticationObservation) DeepCopyInto ¶ added in v0.43.0
func (in *ServerlessClusterClientAuthenticationObservation) DeepCopyInto(out *ServerlessClusterClientAuthenticationObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterClientAuthenticationParameters ¶ added in v0.43.0
type ServerlessClusterClientAuthenticationParameters struct { // Details for client authentication using SASL. See below. // +kubebuilder:validation:Optional Sasl []ClientAuthenticationSaslParameters `json:"sasl" tf:"sasl,omitempty"` }
func (*ServerlessClusterClientAuthenticationParameters) DeepCopy ¶ added in v0.43.0
func (in *ServerlessClusterClientAuthenticationParameters) DeepCopy() *ServerlessClusterClientAuthenticationParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterClientAuthenticationParameters.
func (*ServerlessClusterClientAuthenticationParameters) DeepCopyInto ¶ added in v0.43.0
func (in *ServerlessClusterClientAuthenticationParameters) DeepCopyInto(out *ServerlessClusterClientAuthenticationParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterInitParameters ¶ added in v0.43.0
type ServerlessClusterInitParameters struct { // Specifies client authentication information for the serverless cluster. See below. ClientAuthentication []ServerlessClusterClientAuthenticationInitParameters `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"` // The name of the serverless cluster. ClusterName *string `json:"clusterName,omitempty" tf:"cluster_name,omitempty"` // Key-value map of resource tags. // +mapType=granular Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"` // VPC configuration information. See below. VPCConfig []VPCConfigInitParameters `json:"vpcConfig,omitempty" tf:"vpc_config,omitempty"` }
func (*ServerlessClusterInitParameters) DeepCopy ¶ added in v0.43.0
func (in *ServerlessClusterInitParameters) DeepCopy() *ServerlessClusterInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterInitParameters.
func (*ServerlessClusterInitParameters) DeepCopyInto ¶ added in v0.43.0
func (in *ServerlessClusterInitParameters) DeepCopyInto(out *ServerlessClusterInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterList ¶ added in v0.43.0
type ServerlessClusterList struct { metav1.TypeMeta `json:",inline"` metav1.ListMeta `json:"metadata,omitempty"` Items []ServerlessCluster `json:"items"` }
ServerlessClusterList contains a list of ServerlessClusters
func (*ServerlessClusterList) DeepCopy ¶ added in v0.43.0
func (in *ServerlessClusterList) DeepCopy() *ServerlessClusterList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterList.
func (*ServerlessClusterList) DeepCopyInto ¶ added in v0.43.0
func (in *ServerlessClusterList) DeepCopyInto(out *ServerlessClusterList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ServerlessClusterList) DeepCopyObject ¶ added in v0.43.0
func (in *ServerlessClusterList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ServerlessClusterList) GetItems ¶ added in v0.43.0
func (l *ServerlessClusterList) GetItems() []resource.Managed
GetItems of this ServerlessClusterList.
type ServerlessClusterObservation ¶ added in v0.43.0
type ServerlessClusterObservation struct { // The ARN of the serverless cluster. Arn *string `json:"arn,omitempty" tf:"arn,omitempty"` // Specifies client authentication information for the serverless cluster. See below. ClientAuthentication []ServerlessClusterClientAuthenticationObservation `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"` // The name of the serverless cluster. ClusterName *string `json:"clusterName,omitempty" tf:"cluster_name,omitempty"` // UUID of the serverless cluster, for use in IAM policies. ClusterUUID *string `json:"clusterUuid,omitempty" tf:"cluster_uuid,omitempty"` ID *string `json:"id,omitempty" tf:"id,omitempty"` // Key-value map of resource tags. // +mapType=granular Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"` // A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block. // +mapType=granular TagsAll map[string]*string `json:"tagsAll,omitempty" tf:"tags_all,omitempty"` // VPC configuration information. See below. VPCConfig []VPCConfigObservation `json:"vpcConfig,omitempty" tf:"vpc_config,omitempty"` }
func (*ServerlessClusterObservation) DeepCopy ¶ added in v0.43.0
func (in *ServerlessClusterObservation) DeepCopy() *ServerlessClusterObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterObservation.
func (*ServerlessClusterObservation) DeepCopyInto ¶ added in v0.43.0
func (in *ServerlessClusterObservation) DeepCopyInto(out *ServerlessClusterObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterParameters ¶ added in v0.43.0
type ServerlessClusterParameters struct { // Specifies client authentication information for the serverless cluster. See below. // +kubebuilder:validation:Optional ClientAuthentication []ServerlessClusterClientAuthenticationParameters `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"` // The name of the serverless cluster. // +kubebuilder:validation:Optional ClusterName *string `json:"clusterName,omitempty" tf:"cluster_name,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:"-"` // Key-value map of resource tags. // +kubebuilder:validation:Optional // +mapType=granular Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"` // VPC configuration information. See below. // +kubebuilder:validation:Optional VPCConfig []VPCConfigParameters `json:"vpcConfig,omitempty" tf:"vpc_config,omitempty"` }
func (*ServerlessClusterParameters) DeepCopy ¶ added in v0.43.0
func (in *ServerlessClusterParameters) DeepCopy() *ServerlessClusterParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterParameters.
func (*ServerlessClusterParameters) DeepCopyInto ¶ added in v0.43.0
func (in *ServerlessClusterParameters) DeepCopyInto(out *ServerlessClusterParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterSpec ¶ added in v0.43.0
type ServerlessClusterSpec struct { v1.ResourceSpec `json:",inline"` ForProvider ServerlessClusterParameters `json:"forProvider"` // THIS IS A BETA FIELD. It will be honored // unless the Management Policies feature flag is disabled. // InitProvider holds the same fields as ForProvider, with the exception // of Identifier and other resource reference fields. The fields that are // in InitProvider are merged into ForProvider when the resource is created. // The same fields are also added to the terraform ignore_changes hook, to // avoid updating them after creation. This is useful for fields that are // required on creation, but we do not desire to update them after creation, // for example because of an external controller is managing them, like an // autoscaler. InitProvider ServerlessClusterInitParameters `json:"initProvider,omitempty"` }
ServerlessClusterSpec defines the desired state of ServerlessCluster
func (*ServerlessClusterSpec) DeepCopy ¶ added in v0.43.0
func (in *ServerlessClusterSpec) DeepCopy() *ServerlessClusterSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterSpec.
func (*ServerlessClusterSpec) DeepCopyInto ¶ added in v0.43.0
func (in *ServerlessClusterSpec) DeepCopyInto(out *ServerlessClusterSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterStatus ¶ added in v0.43.0
type ServerlessClusterStatus struct { v1.ResourceStatus `json:",inline"` AtProvider ServerlessClusterObservation `json:"atProvider,omitempty"` }
ServerlessClusterStatus defines the observed state of ServerlessCluster.
func (*ServerlessClusterStatus) DeepCopy ¶ added in v0.43.0
func (in *ServerlessClusterStatus) DeepCopy() *ServerlessClusterStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterStatus.
func (*ServerlessClusterStatus) DeepCopyInto ¶ added in v0.43.0
func (in *ServerlessClusterStatus) DeepCopyInto(out *ServerlessClusterStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StorageInfoInitParameters ¶ added in v0.38.0
type StorageInfoInitParameters struct { // A block that contains EBS volume information. See below. EBSStorageInfo []EBSStorageInfoInitParameters `json:"ebsStorageInfo,omitempty" tf:"ebs_storage_info,omitempty"` }
func (*StorageInfoInitParameters) DeepCopy ¶ added in v0.38.0
func (in *StorageInfoInitParameters) DeepCopy() *StorageInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageInfoInitParameters.
func (*StorageInfoInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *StorageInfoInitParameters) DeepCopyInto(out *StorageInfoInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StorageInfoObservation ¶
type StorageInfoObservation struct { // A block that contains EBS volume information. See below. EBSStorageInfo []EBSStorageInfoObservation `json:"ebsStorageInfo,omitempty" tf:"ebs_storage_info,omitempty"` }
func (*StorageInfoObservation) DeepCopy ¶
func (in *StorageInfoObservation) DeepCopy() *StorageInfoObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageInfoObservation.
func (*StorageInfoObservation) DeepCopyInto ¶
func (in *StorageInfoObservation) DeepCopyInto(out *StorageInfoObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StorageInfoParameters ¶
type StorageInfoParameters struct { // A block that contains EBS volume information. See below. // +kubebuilder:validation:Optional EBSStorageInfo []EBSStorageInfoParameters `json:"ebsStorageInfo,omitempty" tf:"ebs_storage_info,omitempty"` }
func (*StorageInfoParameters) DeepCopy ¶
func (in *StorageInfoParameters) DeepCopy() *StorageInfoParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageInfoParameters.
func (*StorageInfoParameters) DeepCopyInto ¶
func (in *StorageInfoParameters) DeepCopyInto(out *StorageInfoParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TLSInitParameters ¶ added in v0.38.0
type TLSInitParameters struct { // List of ACM Certificate Authority Amazon Resource Names (ARNs). // +listType=set CertificateAuthorityArns []*string `json:"certificateAuthorityArns,omitempty" tf:"certificate_authority_arns,omitempty"` }
func (*TLSInitParameters) DeepCopy ¶ added in v0.38.0
func (in *TLSInitParameters) DeepCopy() *TLSInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLSInitParameters.
func (*TLSInitParameters) DeepCopyInto ¶ added in v0.38.0
func (in *TLSInitParameters) DeepCopyInto(out *TLSInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TLSObservation ¶
type TLSObservation struct { // List of ACM Certificate Authority Amazon Resource Names (ARNs). // +listType=set CertificateAuthorityArns []*string `json:"certificateAuthorityArns,omitempty" tf:"certificate_authority_arns,omitempty"` }
func (*TLSObservation) DeepCopy ¶
func (in *TLSObservation) DeepCopy() *TLSObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLSObservation.
func (*TLSObservation) DeepCopyInto ¶
func (in *TLSObservation) DeepCopyInto(out *TLSObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TLSParameters ¶
type TLSParameters struct { // List of ACM Certificate Authority Amazon Resource Names (ARNs). // +kubebuilder:validation:Optional // +listType=set CertificateAuthorityArns []*string `json:"certificateAuthorityArns,omitempty" tf:"certificate_authority_arns,omitempty"` }
func (*TLSParameters) DeepCopy ¶
func (in *TLSParameters) DeepCopy() *TLSParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLSParameters.
func (*TLSParameters) DeepCopyInto ¶
func (in *TLSParameters) DeepCopyInto(out *TLSParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConfigInitParameters ¶ added in v0.43.0
type VPCConfigInitParameters struct { // References to SecurityGroup in ec2 to populate securityGroupIds. // +kubebuilder:validation:Optional SecurityGroupIDRefs []v1.Reference `json:"securityGroupIdRefs,omitempty" tf:"-"` // Selector for a list of SecurityGroup in ec2 to populate securityGroupIds. // +kubebuilder:validation:Optional SecurityGroupIDSelector *v1.Selector `json:"securityGroupIdSelector,omitempty" tf:"-"` // Specifies up to five security groups that control inbound and outbound traffic for the serverless cluster. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.SecurityGroup // +crossplane:generate:reference:refFieldName=SecurityGroupIDRefs // +crossplane:generate:reference:selectorFieldName=SecurityGroupIDSelector // +listType=set SecurityGroupIds []*string `json:"securityGroupIds,omitempty" tf:"security_group_ids,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 subnets in at least two different Availability Zones that host your client applications. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.Subnet // +crossplane:generate:reference:refFieldName=SubnetIDRefs // +crossplane:generate:reference:selectorFieldName=SubnetIDSelector // +listType=set SubnetIds []*string `json:"subnetIds,omitempty" tf:"subnet_ids,omitempty"` }
func (*VPCConfigInitParameters) DeepCopy ¶ added in v0.43.0
func (in *VPCConfigInitParameters) DeepCopy() *VPCConfigInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConfigInitParameters.
func (*VPCConfigInitParameters) DeepCopyInto ¶ added in v0.43.0
func (in *VPCConfigInitParameters) DeepCopyInto(out *VPCConfigInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConfigObservation ¶ added in v0.43.0
type VPCConfigObservation struct { // Specifies up to five security groups that control inbound and outbound traffic for the serverless cluster. // +listType=set SecurityGroupIds []*string `json:"securityGroupIds,omitempty" tf:"security_group_ids,omitempty"` // A list of subnets in at least two different Availability Zones that host your client applications. // +listType=set SubnetIds []*string `json:"subnetIds,omitempty" tf:"subnet_ids,omitempty"` }
func (*VPCConfigObservation) DeepCopy ¶ added in v0.43.0
func (in *VPCConfigObservation) DeepCopy() *VPCConfigObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConfigObservation.
func (*VPCConfigObservation) DeepCopyInto ¶ added in v0.43.0
func (in *VPCConfigObservation) DeepCopyInto(out *VPCConfigObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConfigParameters ¶ added in v0.43.0
type VPCConfigParameters struct { // References to SecurityGroup in ec2 to populate securityGroupIds. // +kubebuilder:validation:Optional SecurityGroupIDRefs []v1.Reference `json:"securityGroupIdRefs,omitempty" tf:"-"` // Selector for a list of SecurityGroup in ec2 to populate securityGroupIds. // +kubebuilder:validation:Optional SecurityGroupIDSelector *v1.Selector `json:"securityGroupIdSelector,omitempty" tf:"-"` // Specifies up to five security groups that control inbound and outbound traffic for the serverless cluster. // +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.SecurityGroup // +crossplane:generate:reference:refFieldName=SecurityGroupIDRefs // +crossplane:generate:reference:selectorFieldName=SecurityGroupIDSelector // +kubebuilder:validation:Optional // +listType=set SecurityGroupIds []*string `json:"securityGroupIds,omitempty" tf:"security_group_ids,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 subnets in at least two different Availability Zones that host your client applications. // +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 // +listType=set SubnetIds []*string `json:"subnetIds,omitempty" tf:"subnet_ids,omitempty"` }
func (*VPCConfigParameters) DeepCopy ¶ added in v0.43.0
func (in *VPCConfigParameters) DeepCopy() *VPCConfigParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConfigParameters.
func (*VPCConfigParameters) DeepCopyInto ¶ added in v0.43.0
func (in *VPCConfigParameters) DeepCopyInto(out *VPCConfigParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
Source Files
¶
- zz_cluster_terraformed.go
- zz_cluster_types.go
- zz_configuration_terraformed.go
- zz_configuration_types.go
- zz_generated.conversion_hubs.go
- zz_generated.conversion_spokes.go
- zz_generated.deepcopy.go
- zz_generated.managed.go
- zz_generated.managedlist.go
- zz_generated.resolvers.go
- zz_groupversion_info.go
- zz_scramsecretassociation_terraformed.go
- zz_scramsecretassociation_types.go
- zz_serverlesscluster_terraformed.go
- zz_serverlesscluster_types.go