Documentation ¶
Overview ¶
+kubebuilder:object:generate=true +groupName=kafka.aws.kubedb.com +versionName=v1alpha1
Index ¶
- Constants
- Variables
- type BrokerLogsInitParameters
- type BrokerLogsObservation
- type BrokerLogsParameters
- type BrokerNodeGroupInfoInitParameters
- type BrokerNodeGroupInfoObservation
- type BrokerNodeGroupInfoParameters
- type ClientAuthenticationInitParameters
- type ClientAuthenticationObservation
- type ClientAuthenticationParameters
- type CloudwatchLogsInitParameters
- type CloudwatchLogsObservation
- type CloudwatchLogsParameters
- type Cluster
- 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) 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 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 StorageInfoInitParameters
- type StorageInfoObservation
- type StorageInfoParameters
- type TLSInitParameters
- type TLSObservation
- type TLSParameters
Constants ¶
const ( CRDGroup = "kafka.aws.kubedb.com" CRDVersion = "v1alpha1" )
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 )
Functions ¶
This section is empty.
Types ¶
type BrokerLogsInitParameters ¶ added in v0.0.2
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.0.2
func (in *BrokerLogsInitParameters) DeepCopy() *BrokerLogsInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerLogsInitParameters.
func (*BrokerLogsInitParameters) DeepCopyInto ¶ added in v0.0.2
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.0.2
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"` // 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"` // 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 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.0.2
func (in *BrokerNodeGroupInfoInitParameters) DeepCopy() *BrokerNodeGroupInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerNodeGroupInfoInitParameters.
func (*BrokerNodeGroupInfoInitParameters) DeepCopyInto ¶ added in v0.0.2
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). 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"` // 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. 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=kubedb.dev/provider-aws/apis/ec2/v1alpha1.Subnet // +kubebuilder:validation:Optional 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"` // 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=kubedb.dev/provider-aws/apis/ec2/v1alpha1.SecurityGroup // +kubebuilder:validation:Optional 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.0.2
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.0.2
func (in *ClientAuthenticationInitParameters) DeepCopy() *ClientAuthenticationInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientAuthenticationInitParameters.
func (*ClientAuthenticationInitParameters) DeepCopyInto ¶ added in v0.0.2
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 CloudwatchLogsInitParameters ¶ added in v0.0.2
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. LogGroup *string `json:"logGroup,omitempty" tf:"log_group,omitempty"` }
func (*CloudwatchLogsInitParameters) DeepCopy ¶ added in v0.0.2
func (in *CloudwatchLogsInitParameters) DeepCopy() *CloudwatchLogsInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudwatchLogsInitParameters.
func (*CloudwatchLogsInitParameters) DeepCopyInto ¶ added in v0.0.2
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. // +kubebuilder:validation:Optional LogGroup *string `json:"logGroup,omitempty" tf:"log_group,omitempty"` }
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" // +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.region)",message="spec.forProvider.region 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:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}
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.0.2
GetInitParameters of this Cluster
func (*Cluster) GetManagementPolicies ¶ added in v0.0.2
func (mg *Cluster) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this Cluster.
func (*Cluster) GetMergedParameters ¶ added in v0.0.2
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 ¶
ResolveReferences of this Cluster.
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.0.2
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.0.2
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"` // A map of tags to assign to the resource. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level. 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. TagsAll map[string]*string `json:"tagsAll,omitempty" tf:"tags_all,omitempty"` }
func (*ClusterInitParameters) DeepCopy ¶ added in v0.0.2
func (in *ClusterInitParameters) DeepCopy() *ClusterInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterInitParameters.
func (*ClusterInitParameters) DeepCopyInto ¶ added in v0.0.2
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"` // A map of tags to assign to the resource. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level. 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. 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:Optional Region *string `json:"region,omitempty" 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"` // A map of tags to assign to the resource. If configured with a provider default_tags configuration block present, tags with matching keys will overwrite those defined at the provider-level. // +kubebuilder:validation:Optional 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. // +kubebuilder:validation:Optional TagsAll map[string]*string `json:"tagsAll,omitempty" tf:"tags_all,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.region)",message="spec.forProvider.region 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="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}
func (*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.0.2
func (tr *Configuration) GetInitParameters() (map[string]any, error)
GetInitParameters of this Configuration
func (*Configuration) GetManagementPolicies ¶ added in v0.0.2
func (mg *Configuration) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this Configuration.
func (*Configuration) GetMergedParameters ¶ added in v0.0.2
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) 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.0.2
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.0.2
type ConfigurationInfoInitParameters 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 (*ConfigurationInfoInitParameters) DeepCopy ¶ added in v0.0.2
func (in *ConfigurationInfoInitParameters) DeepCopy() *ConfigurationInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationInfoInitParameters.
func (*ConfigurationInfoInitParameters) DeepCopyInto ¶ added in v0.0.2
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. // +kubebuilder:validation:Optional Arn *string `json:"arn" tf:"arn,omitempty"` // 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.0.2
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. 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.0.2
func (in *ConfigurationInitParameters) DeepCopy() *ConfigurationInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationInitParameters.
func (*ConfigurationInitParameters) DeepCopyInto ¶ added in v0.0.2
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. 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 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:Optional Region *string `json:"region,omitempty" 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.0.2
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.0.2
func (in *ConnectivityInfoInitParameters) DeepCopy() *ConnectivityInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectivityInfoInitParameters.
func (*ConnectivityInfoInitParameters) DeepCopyInto ¶ added in v0.0.2
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.0.2
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.0.2
func (in *EBSStorageInfoInitParameters) DeepCopy() *EBSStorageInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EBSStorageInfoInitParameters.
func (*EBSStorageInfoInitParameters) DeepCopyInto ¶ added in v0.0.2
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.0.2
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.0.2
func (in *EncryptionInTransitInitParameters) DeepCopy() *EncryptionInTransitInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInTransitInitParameters.
func (*EncryptionInTransitInitParameters) DeepCopyInto ¶ added in v0.0.2
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.0.2
type EncryptionInfoInitParameters struct { // 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.0.2
func (in *EncryptionInfoInitParameters) DeepCopy() *EncryptionInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInfoInitParameters.
func (*EncryptionInfoInitParameters) DeepCopyInto ¶ added in v0.0.2
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=kubedb.dev/provider-aws/apis/kms/v1alpha1.Key // +crossplane:generate:reference:extractor=kubedb.dev/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.0.2
type FirehoseInitParameters 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 (*FirehoseInitParameters) DeepCopy ¶ added in v0.0.2
func (in *FirehoseInitParameters) DeepCopy() *FirehoseInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FirehoseInitParameters.
func (*FirehoseInitParameters) DeepCopyInto ¶ added in v0.0.2
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. // +kubebuilder:validation:Optional DeliveryStream *string `json:"deliveryStream,omitempty" tf:"delivery_stream,omitempty"` // 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 JmxExporterInitParameters ¶ added in v0.0.2
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.0.2
func (in *JmxExporterInitParameters) DeepCopy() *JmxExporterInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JmxExporterInitParameters.
func (*JmxExporterInitParameters) DeepCopyInto ¶ added in v0.0.2
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.0.2
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.0.2
func (in *LoggingInfoInitParameters) DeepCopy() *LoggingInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoggingInfoInitParameters.
func (*LoggingInfoInitParameters) DeepCopyInto ¶ added in v0.0.2
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.0.2
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.0.2
func (in *NodeExporterInitParameters) DeepCopy() *NodeExporterInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeExporterInitParameters.
func (*NodeExporterInitParameters) DeepCopyInto ¶ added in v0.0.2
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.0.2
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.0.2
func (in *OpenMonitoringInitParameters) DeepCopy() *OpenMonitoringInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenMonitoringInitParameters.
func (*OpenMonitoringInitParameters) DeepCopyInto ¶ added in v0.0.2
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.0.2
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.0.2
func (in *PrometheusInitParameters) DeepCopy() *PrometheusInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrometheusInitParameters.
func (*PrometheusInitParameters) DeepCopyInto ¶ added in v0.0.2
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.0.2
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.0.2
func (in *ProvisionedThroughputInitParameters) DeepCopy() *ProvisionedThroughputInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProvisionedThroughputInitParameters.
func (*ProvisionedThroughputInitParameters) DeepCopyInto ¶ added in v0.0.2
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.0.2
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.0.2
func (in *PublicAccessInitParameters) DeepCopy() *PublicAccessInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PublicAccessInitParameters.
func (*PublicAccessInitParameters) DeepCopyInto ¶ added in v0.0.2
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.0.2
type S3InitParameters 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 (*S3InitParameters) DeepCopy ¶ added in v0.0.2
func (in *S3InitParameters) DeepCopy() *S3InitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3InitParameters.
func (*S3InitParameters) DeepCopyInto ¶ added in v0.0.2
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. // +kubebuilder:validation:Optional Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"` // 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.0.2
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.0.2
func (in *SaslInitParameters) DeepCopy() *SaslInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SaslInitParameters.
func (*SaslInitParameters) DeepCopyInto ¶ added in v0.0.2
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 StorageInfoInitParameters ¶ added in v0.0.2
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.0.2
func (in *StorageInfoInitParameters) DeepCopy() *StorageInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageInfoInitParameters.
func (*StorageInfoInitParameters) DeepCopyInto ¶ added in v0.0.2
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.0.2
type TLSInitParameters struct { // List of ACM Certificate Authority Amazon Resource Names (ARNs). CertificateAuthorityArns []*string `json:"certificateAuthorityArns,omitempty" tf:"certificate_authority_arns,omitempty"` }
func (*TLSInitParameters) DeepCopy ¶ added in v0.0.2
func (in *TLSInitParameters) DeepCopy() *TLSInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLSInitParameters.
func (*TLSInitParameters) DeepCopyInto ¶ added in v0.0.2
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). 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 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.