Documentation
¶
Overview ¶
+kubebuilder:object:generate=true +groupName=kafka.aws.upbound.io +versionName=v1beta2
Index ¶
- Constants
- Variables
- type BrokerLogsInitParameters
- type BrokerLogsObservation
- type BrokerLogsParameters
- type BrokerNodeGroupInfoInitParameters
- type BrokerNodeGroupInfoObservation
- type BrokerNodeGroupInfoParameters
- type ClientAuthenticationInitParameters
- type ClientAuthenticationObservation
- type ClientAuthenticationParameters
- type ClientAuthenticationSaslInitParameters
- type ClientAuthenticationSaslObservation
- type ClientAuthenticationSaslParameters
- type CloudwatchLogsInitParameters
- type CloudwatchLogsObservation
- type CloudwatchLogsParameters
- type Cluster
- func (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 ClusterClientAuthenticationInitParameters
- type ClusterClientAuthenticationObservation
- type ClusterClientAuthenticationParameters
- type ClusterInitParameters
- type ClusterList
- type ClusterObservation
- type ClusterParameters
- type ClusterSpec
- type ClusterStatus
- type ConfigurationInfoInitParameters
- type ConfigurationInfoObservation
- type ConfigurationInfoParameters
- type ConnectivityInfoInitParameters
- type ConnectivityInfoObservation
- type ConnectivityInfoParameters
- type EBSStorageInfoInitParameters
- type EBSStorageInfoObservation
- type EBSStorageInfoParameters
- type EncryptionInTransitInitParameters
- type EncryptionInTransitObservation
- type EncryptionInTransitParameters
- type EncryptionInfoInitParameters
- type EncryptionInfoObservation
- type EncryptionInfoParameters
- type FirehoseInitParameters
- type FirehoseObservation
- type FirehoseParameters
- type IAMInitParameters
- type IAMObservation
- type IAMParameters
- type JmxExporterInitParameters
- type JmxExporterObservation
- type JmxExporterParameters
- type LoggingInfoInitParameters
- type LoggingInfoObservation
- type LoggingInfoParameters
- type NodeExporterInitParameters
- type NodeExporterObservation
- type NodeExporterParameters
- type OpenMonitoringInitParameters
- type OpenMonitoringObservation
- type OpenMonitoringParameters
- type PrometheusInitParameters
- type PrometheusObservation
- type PrometheusParameters
- type ProvisionedThroughputInitParameters
- type ProvisionedThroughputObservation
- type ProvisionedThroughputParameters
- type PublicAccessInitParameters
- type PublicAccessObservation
- type PublicAccessParameters
- type S3InitParameters
- type S3Observation
- type S3Parameters
- type SaslInitParameters
- type SaslObservation
- type SaslParameters
- type ServerlessCluster
- func (in *ServerlessCluster) DeepCopy() *ServerlessCluster
- func (in *ServerlessCluster) DeepCopyInto(out *ServerlessCluster)
- func (in *ServerlessCluster) DeepCopyObject() runtime.Object
- func (mg *ServerlessCluster) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (tr *ServerlessCluster) GetConnectionDetailsMapping() map[string]string
- func (mg *ServerlessCluster) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *ServerlessCluster) GetID() string
- func (tr *ServerlessCluster) GetInitParameters() (map[string]any, error)
- func (mg *ServerlessCluster) GetManagementPolicies() xpv1.ManagementPolicies
- func (tr *ServerlessCluster) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
- func (tr *ServerlessCluster) GetObservation() (map[string]any, error)
- func (tr *ServerlessCluster) GetParameters() (map[string]any, error)
- func (mg *ServerlessCluster) GetProviderConfigReference() *xpv1.Reference
- func (mg *ServerlessCluster) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *ServerlessCluster) GetTerraformResourceType() string
- func (tr *ServerlessCluster) GetTerraformSchemaVersion() int
- func (mg *ServerlessCluster) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *ServerlessCluster) LateInitialize(attrs []byte) (bool, error)
- func (mg *ServerlessCluster) ResolveReferences(ctx context.Context, c client.Reader) error
- func (mg *ServerlessCluster) SetConditions(c ...xpv1.Condition)
- func (mg *ServerlessCluster) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (mg *ServerlessCluster) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (tr *ServerlessCluster) SetObservation(obs map[string]any) error
- func (tr *ServerlessCluster) SetParameters(params map[string]any) error
- func (mg *ServerlessCluster) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *ServerlessCluster) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *ServerlessCluster) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type ServerlessClusterClientAuthenticationInitParameters
- type ServerlessClusterClientAuthenticationObservation
- type ServerlessClusterClientAuthenticationParameters
- type ServerlessClusterClientAuthenticationSaslInitParameters
- type ServerlessClusterClientAuthenticationSaslObservation
- type ServerlessClusterClientAuthenticationSaslParameters
- type ServerlessClusterInitParameters
- type ServerlessClusterList
- type ServerlessClusterObservation
- type ServerlessClusterParameters
- type ServerlessClusterSpec
- type ServerlessClusterStatus
- type StorageInfoInitParameters
- type StorageInfoObservation
- type StorageInfoParameters
- type TLSInitParameters
- type TLSObservation
- type TLSParameters
- type VPCConfigInitParameters
- type VPCConfigObservation
- type VPCConfigParameters
- type VPCConnectivityInitParameters
- type VPCConnectivityObservation
- type VPCConnectivityParameters
Constants ¶
const ( CRDGroup = "kafka.aws.upbound.io" CRDVersion = "v1beta2" )
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 ( // CRDGroupVersion is the API Group Version used to register the objects CRDGroupVersion = schema.GroupVersion{Group: CRDGroup, Version: CRDVersion} // SchemeBuilder is used to add go types to the GroupVersionKind scheme SchemeBuilder = &scheme.Builder{GroupVersion: CRDGroupVersion} // AddToScheme adds the types in this group-version to the given scheme. AddToScheme = SchemeBuilder.AddToScheme )
var ( ServerlessCluster_Kind = "ServerlessCluster" ServerlessCluster_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: ServerlessCluster_Kind}.String() ServerlessCluster_KindAPIVersion = ServerlessCluster_Kind + "." + CRDGroupVersion.String() ServerlessCluster_GroupVersionKind = CRDGroupVersion.WithKind(ServerlessCluster_Kind) )
Repository type metadata.
Functions ¶
This section is empty.
Types ¶
type BrokerLogsInitParameters ¶
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 ¶
func (in *BrokerLogsInitParameters) DeepCopy() *BrokerLogsInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerLogsInitParameters.
func (*BrokerLogsInitParameters) DeepCopyInto ¶
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 ¶
type BrokerNodeGroupInfoInitParameters struct {
// The distribution of broker nodes across availability zones (documentation). Currently the only valid value is DEFAULT.
AzDistribution *string `json:"azDistribution,omitempty" tf:"az_distribution,omitempty"`
// A list of subnets to connect to in client VPC (documentation).
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.Subnet
// +listType=set
ClientSubnets []*string `json:"clientSubnets,omitempty" tf:"client_subnets,omitempty"`
// References to Subnet in ec2 to populate clientSubnets.
// +kubebuilder:validation:Optional
ClientSubnetsRefs []v1.Reference `json:"clientSubnetsRefs,omitempty" tf:"-"`
// Selector for a list of Subnet in ec2 to populate clientSubnets.
// +kubebuilder:validation:Optional
ClientSubnetsSelector *v1.Selector `json:"clientSubnetsSelector,omitempty" tf:"-"`
// Information about the cluster access configuration. See below. For security reasons, you can't turn on public access while creating an MSK cluster. However, you can update an existing cluster to make it publicly accessible. You can also create a new cluster and then update it to make it publicly accessible (documentation).
ConnectivityInfo []ConnectivityInfoInitParameters `json:"connectivityInfo,omitempty" tf:"connectivity_info,omitempty"`
// Specify the instance type to use for the kafka brokersE.g., kafka.m5.large. (Pricing info)
InstanceType *string `json:"instanceType,omitempty" tf:"instance_type,omitempty"`
// A list of the security groups to associate with the elastic network interfaces to control who can communicate with the cluster.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.SecurityGroup
// +listType=set
SecurityGroups []*string `json:"securityGroups,omitempty" tf:"security_groups,omitempty"`
// References to SecurityGroup in ec2 to populate securityGroups.
// +kubebuilder:validation:Optional
SecurityGroupsRefs []v1.Reference `json:"securityGroupsRefs,omitempty" tf:"-"`
// Selector for a list of SecurityGroup in ec2 to populate securityGroups.
// +kubebuilder:validation:Optional
SecurityGroupsSelector *v1.Selector `json:"securityGroupsSelector,omitempty" tf:"-"`
// A block that contains information about storage volumes attached to MSK broker nodes. See below.
StorageInfo []StorageInfoInitParameters `json:"storageInfo,omitempty" tf:"storage_info,omitempty"`
}
func (*BrokerNodeGroupInfoInitParameters) DeepCopy ¶
func (in *BrokerNodeGroupInfoInitParameters) DeepCopy() *BrokerNodeGroupInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerNodeGroupInfoInitParameters.
func (*BrokerNodeGroupInfoInitParameters) DeepCopyInto ¶
func (in *BrokerNodeGroupInfoInitParameters) DeepCopyInto(out *BrokerNodeGroupInfoInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerNodeGroupInfoObservation ¶
type BrokerNodeGroupInfoObservation struct {
// The distribution of broker nodes across availability zones (documentation). Currently the only valid value is DEFAULT.
AzDistribution *string `json:"azDistribution,omitempty" tf:"az_distribution,omitempty"`
// A list of subnets to connect to in client VPC (documentation).
// +listType=set
ClientSubnets []*string `json:"clientSubnets,omitempty" tf:"client_subnets,omitempty"`
// Information about the cluster access configuration. See below. For security reasons, you can't turn on public access while creating an MSK cluster. However, you can update an existing cluster to make it publicly accessible. You can also create a new cluster and then update it to make it publicly accessible (documentation).
ConnectivityInfo []ConnectivityInfoObservation `json:"connectivityInfo,omitempty" tf:"connectivity_info,omitempty"`
// Specify the instance type to use for the kafka brokersE.g., kafka.m5.large. (Pricing info)
InstanceType *string `json:"instanceType,omitempty" tf:"instance_type,omitempty"`
// A list of the security groups to associate with the elastic network interfaces to control who can communicate with the cluster.
// +listType=set
SecurityGroups []*string `json:"securityGroups,omitempty" tf:"security_groups,omitempty"`
// A block that contains information about storage volumes attached to MSK broker nodes. See below.
StorageInfo []StorageInfoObservation `json:"storageInfo,omitempty" tf:"storage_info,omitempty"`
}
func (*BrokerNodeGroupInfoObservation) DeepCopy ¶
func (in *BrokerNodeGroupInfoObservation) DeepCopy() *BrokerNodeGroupInfoObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerNodeGroupInfoObservation.
func (*BrokerNodeGroupInfoObservation) DeepCopyInto ¶
func (in *BrokerNodeGroupInfoObservation) DeepCopyInto(out *BrokerNodeGroupInfoObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type BrokerNodeGroupInfoParameters ¶
type BrokerNodeGroupInfoParameters struct {
// The distribution of broker nodes across availability zones (documentation). Currently the only valid value is DEFAULT.
// +kubebuilder:validation:Optional
AzDistribution *string `json:"azDistribution,omitempty" tf:"az_distribution,omitempty"`
// A list of subnets to connect to in client VPC (documentation).
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.Subnet
// +kubebuilder:validation:Optional
// +listType=set
ClientSubnets []*string `json:"clientSubnets,omitempty" tf:"client_subnets,omitempty"`
// References to Subnet in ec2 to populate clientSubnets.
// +kubebuilder:validation:Optional
ClientSubnetsRefs []v1.Reference `json:"clientSubnetsRefs,omitempty" tf:"-"`
// Selector for a list of Subnet in ec2 to populate clientSubnets.
// +kubebuilder:validation:Optional
ClientSubnetsSelector *v1.Selector `json:"clientSubnetsSelector,omitempty" tf:"-"`
// Information about the cluster access configuration. See below. For security reasons, you can't turn on public access while creating an MSK cluster. However, you can update an existing cluster to make it publicly accessible. You can also create a new cluster and then update it to make it publicly accessible (documentation).
// +kubebuilder:validation:Optional
ConnectivityInfo []ConnectivityInfoParameters `json:"connectivityInfo,omitempty" tf:"connectivity_info,omitempty"`
// Specify the instance type to use for the kafka brokersE.g., kafka.m5.large. (Pricing info)
// +kubebuilder:validation:Optional
InstanceType *string `json:"instanceType" tf:"instance_type,omitempty"`
// A list of the security groups to associate with the elastic network interfaces to control who can communicate with the cluster.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.SecurityGroup
// +kubebuilder:validation:Optional
// +listType=set
SecurityGroups []*string `json:"securityGroups,omitempty" tf:"security_groups,omitempty"`
// References to SecurityGroup in ec2 to populate securityGroups.
// +kubebuilder:validation:Optional
SecurityGroupsRefs []v1.Reference `json:"securityGroupsRefs,omitempty" tf:"-"`
// Selector for a list of SecurityGroup in ec2 to populate securityGroups.
// +kubebuilder:validation:Optional
SecurityGroupsSelector *v1.Selector `json:"securityGroupsSelector,omitempty" tf:"-"`
// A block that contains information about storage volumes attached to MSK broker nodes. See below.
// +kubebuilder:validation:Optional
StorageInfo []StorageInfoParameters `json:"storageInfo,omitempty" tf:"storage_info,omitempty"`
}
func (*BrokerNodeGroupInfoParameters) DeepCopy ¶
func (in *BrokerNodeGroupInfoParameters) DeepCopy() *BrokerNodeGroupInfoParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new BrokerNodeGroupInfoParameters.
func (*BrokerNodeGroupInfoParameters) DeepCopyInto ¶
func (in *BrokerNodeGroupInfoParameters) DeepCopyInto(out *BrokerNodeGroupInfoParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClientAuthenticationInitParameters ¶
type ClientAuthenticationInitParameters struct {
// SASL authentication type details for VPC connectivity. See below.
Sasl []SaslInitParameters `json:"sasl,omitempty" tf:"sasl,omitempty"`
// Enables TLS authentication for VPC connectivity.
TLS *bool `json:"tls,omitempty" tf:"tls,omitempty"`
}
func (*ClientAuthenticationInitParameters) DeepCopy ¶
func (in *ClientAuthenticationInitParameters) DeepCopy() *ClientAuthenticationInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientAuthenticationInitParameters.
func (*ClientAuthenticationInitParameters) DeepCopyInto ¶
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 {
// SASL authentication type details for VPC connectivity. See below.
Sasl []SaslObservation `json:"sasl,omitempty" tf:"sasl,omitempty"`
// Enables TLS authentication for VPC connectivity.
TLS *bool `json:"tls,omitempty" tf:"tls,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 {
// SASL authentication type details for VPC connectivity. See below.
// +kubebuilder:validation:Optional
Sasl []SaslParameters `json:"sasl,omitempty" tf:"sasl,omitempty"`
// Enables TLS authentication for VPC connectivity.
// +kubebuilder:validation:Optional
TLS *bool `json:"tls,omitempty" tf:"tls,omitempty"`
}
func (*ClientAuthenticationParameters) DeepCopy ¶
func (in *ClientAuthenticationParameters) DeepCopy() *ClientAuthenticationParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientAuthenticationParameters.
func (*ClientAuthenticationParameters) DeepCopyInto ¶
func (in *ClientAuthenticationParameters) DeepCopyInto(out *ClientAuthenticationParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClientAuthenticationSaslInitParameters ¶
type ClientAuthenticationSaslInitParameters struct {
// Enables SASL/IAM authentication for VPC connectivity.
IAM *bool `json:"iam,omitempty" tf:"iam,omitempty"`
// Enables SASL/SCRAM authentication for VPC connectivity.
Scram *bool `json:"scram,omitempty" tf:"scram,omitempty"`
}
func (*ClientAuthenticationSaslInitParameters) DeepCopy ¶
func (in *ClientAuthenticationSaslInitParameters) DeepCopy() *ClientAuthenticationSaslInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientAuthenticationSaslInitParameters.
func (*ClientAuthenticationSaslInitParameters) DeepCopyInto ¶
func (in *ClientAuthenticationSaslInitParameters) DeepCopyInto(out *ClientAuthenticationSaslInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClientAuthenticationSaslObservation ¶
type ClientAuthenticationSaslObservation struct {
// Enables SASL/IAM authentication for VPC connectivity.
IAM *bool `json:"iam,omitempty" tf:"iam,omitempty"`
// Enables SASL/SCRAM authentication for VPC connectivity.
Scram *bool `json:"scram,omitempty" tf:"scram,omitempty"`
}
func (*ClientAuthenticationSaslObservation) DeepCopy ¶
func (in *ClientAuthenticationSaslObservation) DeepCopy() *ClientAuthenticationSaslObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientAuthenticationSaslObservation.
func (*ClientAuthenticationSaslObservation) DeepCopyInto ¶
func (in *ClientAuthenticationSaslObservation) DeepCopyInto(out *ClientAuthenticationSaslObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClientAuthenticationSaslParameters ¶
type ClientAuthenticationSaslParameters struct {
// Enables SASL/IAM authentication for VPC connectivity.
// +kubebuilder:validation:Optional
IAM *bool `json:"iam,omitempty" tf:"iam,omitempty"`
// Enables SASL/SCRAM authentication for VPC connectivity.
// +kubebuilder:validation:Optional
Scram *bool `json:"scram,omitempty" tf:"scram,omitempty"`
}
func (*ClientAuthenticationSaslParameters) DeepCopy ¶
func (in *ClientAuthenticationSaslParameters) DeepCopy() *ClientAuthenticationSaslParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClientAuthenticationSaslParameters.
func (*ClientAuthenticationSaslParameters) DeepCopyInto ¶
func (in *ClientAuthenticationSaslParameters) DeepCopyInto(out *ClientAuthenticationSaslParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CloudwatchLogsInitParameters ¶
type CloudwatchLogsInitParameters struct {
// Controls whether provisioned throughput is enabled or not. Default value: false.
Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`
// Name of the Cloudwatch Log Group to deliver logs to.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/cloudwatchlogs/v1beta1.Group
LogGroup *string `json:"logGroup,omitempty" tf:"log_group,omitempty"`
// Reference to a Group in cloudwatchlogs to populate logGroup.
// +kubebuilder:validation:Optional
LogGroupRef *v1.Reference `json:"logGroupRef,omitempty" tf:"-"`
// Selector for a Group in cloudwatchlogs to populate logGroup.
// +kubebuilder:validation:Optional
LogGroupSelector *v1.Selector `json:"logGroupSelector,omitempty" tf:"-"`
}
func (*CloudwatchLogsInitParameters) DeepCopy ¶
func (in *CloudwatchLogsInitParameters) DeepCopy() *CloudwatchLogsInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudwatchLogsInitParameters.
func (*CloudwatchLogsInitParameters) DeepCopyInto ¶
func (in *CloudwatchLogsInitParameters) DeepCopyInto(out *CloudwatchLogsInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CloudwatchLogsObservation ¶
type CloudwatchLogsObservation struct {
// Controls whether provisioned throughput is enabled or not. Default value: false.
Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`
// Name of the Cloudwatch Log Group to deliver logs to.
LogGroup *string `json:"logGroup,omitempty" tf:"log_group,omitempty"`
}
func (*CloudwatchLogsObservation) DeepCopy ¶
func (in *CloudwatchLogsObservation) DeepCopy() *CloudwatchLogsObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudwatchLogsObservation.
func (*CloudwatchLogsObservation) DeepCopyInto ¶
func (in *CloudwatchLogsObservation) DeepCopyInto(out *CloudwatchLogsObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type CloudwatchLogsParameters ¶
type CloudwatchLogsParameters struct {
// Controls whether provisioned throughput is enabled or not. Default value: false.
// +kubebuilder:validation:Optional
Enabled *bool `json:"enabled" tf:"enabled,omitempty"`
// Name of the Cloudwatch Log Group to deliver logs to.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/cloudwatchlogs/v1beta1.Group
// +kubebuilder:validation:Optional
LogGroup *string `json:"logGroup,omitempty" tf:"log_group,omitempty"`
// Reference to a Group in cloudwatchlogs to populate logGroup.
// +kubebuilder:validation:Optional
LogGroupRef *v1.Reference `json:"logGroupRef,omitempty" tf:"-"`
// Selector for a Group in cloudwatchlogs to populate logGroup.
// +kubebuilder:validation:Optional
LogGroupSelector *v1.Selector `json:"logGroupSelector,omitempty" tf:"-"`
}
func (*CloudwatchLogsParameters) DeepCopy ¶
func (in *CloudwatchLogsParameters) DeepCopy() *CloudwatchLogsParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new CloudwatchLogsParameters.
func (*CloudwatchLogsParameters) DeepCopyInto ¶
func (in *CloudwatchLogsParameters) DeepCopyInto(out *CloudwatchLogsParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type Cluster ¶
type Cluster struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.brokerNodeGroupInfo) || (has(self.initProvider) && has(self.initProvider.brokerNodeGroupInfo))",message="spec.forProvider.brokerNodeGroupInfo is a required parameter"
// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.clusterName) || (has(self.initProvider) && has(self.initProvider.clusterName))",message="spec.forProvider.clusterName is a required parameter"
// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.kafkaVersion) || (has(self.initProvider) && has(self.initProvider.kafkaVersion))",message="spec.forProvider.kafkaVersion is a required parameter"
// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.numberOfBrokerNodes) || (has(self.initProvider) && has(self.initProvider.numberOfBrokerNodes))",message="spec.forProvider.numberOfBrokerNodes is a required parameter"
Spec ClusterSpec `json:"spec"`
Status ClusterStatus `json:"status,omitempty"`
}
Cluster is the Schema for the Clusters API. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}
func (*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 ¶
GetInitParameters of this Cluster
func (*Cluster) GetManagementPolicies ¶
func (mg *Cluster) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this Cluster.
func (*Cluster) GetMergedParameters ¶
GetInitParameters of this Cluster
func (*Cluster) GetObservation ¶
GetObservation of this Cluster
func (*Cluster) GetParameters ¶
GetParameters of this Cluster
func (*Cluster) GetProviderConfigReference ¶
GetProviderConfigReference of this Cluster.
func (*Cluster) GetPublishConnectionDetailsTo ¶
func (mg *Cluster) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this Cluster.
func (*Cluster) GetTerraformResourceType ¶
GetTerraformResourceType returns Terraform resource type for this Cluster
func (*Cluster) GetTerraformSchemaVersion ¶
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*Cluster) GetWriteConnectionSecretToReference ¶
func (mg *Cluster) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this Cluster.
func (*Cluster) LateInitialize ¶
LateInitialize this Cluster using its observed tfState. returns True if there are any spec changes for the resource.
func (*Cluster) ResolveReferences ¶
func (*Cluster) SetConditions ¶
SetConditions of this Cluster.
func (*Cluster) SetDeletionPolicy ¶
func (mg *Cluster) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this Cluster.
func (*Cluster) SetManagementPolicies ¶
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 ClusterClientAuthenticationInitParameters ¶
type ClusterClientAuthenticationInitParameters struct {
// SASL authentication type details for VPC connectivity. See below.
Sasl []ClientAuthenticationSaslInitParameters `json:"sasl,omitempty" tf:"sasl,omitempty"`
// Enables TLS authentication for VPC connectivity.
TLS []TLSInitParameters `json:"tls,omitempty" tf:"tls,omitempty"`
// Enables unauthenticated access.
Unauthenticated *bool `json:"unauthenticated,omitempty" tf:"unauthenticated,omitempty"`
}
func (*ClusterClientAuthenticationInitParameters) DeepCopy ¶
func (in *ClusterClientAuthenticationInitParameters) DeepCopy() *ClusterClientAuthenticationInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterClientAuthenticationInitParameters.
func (*ClusterClientAuthenticationInitParameters) DeepCopyInto ¶
func (in *ClusterClientAuthenticationInitParameters) DeepCopyInto(out *ClusterClientAuthenticationInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterClientAuthenticationObservation ¶
type ClusterClientAuthenticationObservation struct {
// SASL authentication type details for VPC connectivity. See below.
Sasl []ClientAuthenticationSaslObservation `json:"sasl,omitempty" tf:"sasl,omitempty"`
// Enables TLS authentication for VPC connectivity.
TLS []TLSObservation `json:"tls,omitempty" tf:"tls,omitempty"`
// Enables unauthenticated access.
Unauthenticated *bool `json:"unauthenticated,omitempty" tf:"unauthenticated,omitempty"`
}
func (*ClusterClientAuthenticationObservation) DeepCopy ¶
func (in *ClusterClientAuthenticationObservation) DeepCopy() *ClusterClientAuthenticationObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterClientAuthenticationObservation.
func (*ClusterClientAuthenticationObservation) DeepCopyInto ¶
func (in *ClusterClientAuthenticationObservation) DeepCopyInto(out *ClusterClientAuthenticationObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterClientAuthenticationParameters ¶
type ClusterClientAuthenticationParameters struct {
// SASL authentication type details for VPC connectivity. See below.
// +kubebuilder:validation:Optional
Sasl []ClientAuthenticationSaslParameters `json:"sasl,omitempty" tf:"sasl,omitempty"`
// Enables TLS authentication for VPC connectivity.
// +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 (*ClusterClientAuthenticationParameters) DeepCopy ¶
func (in *ClusterClientAuthenticationParameters) DeepCopy() *ClusterClientAuthenticationParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterClientAuthenticationParameters.
func (*ClusterClientAuthenticationParameters) DeepCopyInto ¶
func (in *ClusterClientAuthenticationParameters) DeepCopyInto(out *ClusterClientAuthenticationParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterInitParameters ¶
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 []ClusterClientAuthenticationInitParameters `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"`
// Name of the MSK cluster.
ClusterName *string `json:"clusterName,omitempty" tf:"cluster_name,omitempty"`
// Configuration block for specifying a MSK Configuration to attach to Kafka brokers. See below.
ConfigurationInfo []ConfigurationInfoInitParameters `json:"configurationInfo,omitempty" tf:"configuration_info,omitempty"`
// Configuration block for specifying encryption. See below.
EncryptionInfo []EncryptionInfoInitParameters `json:"encryptionInfo,omitempty" tf:"encryption_info,omitempty"`
// Specify the desired enhanced MSK CloudWatch monitoring level. See Monitoring Amazon MSK with Amazon CloudWatch
EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty" tf:"enhanced_monitoring,omitempty"`
// Specify the desired Kafka software version.
KafkaVersion *string `json:"kafkaVersion,omitempty" tf:"kafka_version,omitempty"`
// Configuration block for streaming broker logs to Cloudwatch/S3/Kinesis Firehose. See below.
LoggingInfo []LoggingInfoInitParameters `json:"loggingInfo,omitempty" tf:"logging_info,omitempty"`
// The desired total number of broker nodes in the kafka cluster. It must be a multiple of the number of specified client subnets.
NumberOfBrokerNodes *float64 `json:"numberOfBrokerNodes,omitempty" tf:"number_of_broker_nodes,omitempty"`
// Configuration block for JMX and Node monitoring for the MSK cluster. See below.
OpenMonitoring []OpenMonitoringInitParameters `json:"openMonitoring,omitempty" tf:"open_monitoring,omitempty"`
// Controls storage mode for supported storage tiers. Valid values are: LOCAL or TIERED.
StorageMode *string `json:"storageMode,omitempty" tf:"storage_mode,omitempty"`
// Key-value map of resource tags.
// +mapType=granular
Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
}
func (*ClusterInitParameters) DeepCopy ¶
func (in *ClusterInitParameters) DeepCopy() *ClusterInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterInitParameters.
func (*ClusterInitParameters) DeepCopyInto ¶
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"`
// A string containing one or more DNS names (or IP addresses) and SASL IAM port pairs for VPC connectivity. AWS may not always return all endpoints so the values may not be stable across applies.
BootstrapBrokersVPCConnectivitySaslIAM *string `json:"bootstrapBrokersVpcConnectivitySaslIam,omitempty" tf:"bootstrap_brokers_vpc_connectivity_sasl_iam,omitempty"`
// A string containing one or more DNS names (or IP addresses) and SASL SCRAM port pairs for VPC connectivity. AWS may not always return all endpoints so the values may not be stable across applies.
BootstrapBrokersVPCConnectivitySaslScram *string `json:"bootstrapBrokersVpcConnectivitySaslScram,omitempty" tf:"bootstrap_brokers_vpc_connectivity_sasl_scram,omitempty"`
// A string containing one or more DNS names (or IP addresses) and TLS port pairs for VPC connectivity. AWS may not always return all endpoints so the values may not be stable across applies.
BootstrapBrokersVPCConnectivityTLS *string `json:"bootstrapBrokersVpcConnectivityTls,omitempty" tf:"bootstrap_brokers_vpc_connectivity_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 []ClusterClientAuthenticationObservation `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"`
// Name of the MSK cluster.
ClusterName *string `json:"clusterName,omitempty" tf:"cluster_name,omitempty"`
// UUID of the MSK cluster, for use in IAM policies.
ClusterUUID *string `json:"clusterUuid,omitempty" tf:"cluster_uuid,omitempty"`
// Configuration block for specifying a MSK Configuration to attach to Kafka brokers. See below.
ConfigurationInfo []ConfigurationInfoObservation `json:"configurationInfo,omitempty" tf:"configuration_info,omitempty"`
// Current version of the MSK Cluster used for updates, e.g., K13V1IB3VIYZZH
CurrentVersion *string `json:"currentVersion,omitempty" tf:"current_version,omitempty"`
// Configuration block for specifying encryption. See below.
EncryptionInfo []EncryptionInfoObservation `json:"encryptionInfo,omitempty" tf:"encryption_info,omitempty"`
// Specify the desired enhanced MSK CloudWatch monitoring level. See Monitoring Amazon MSK with Amazon CloudWatch
EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty" tf:"enhanced_monitoring,omitempty"`
ID *string `json:"id,omitempty" tf:"id,omitempty"`
// Specify the desired Kafka software version.
KafkaVersion *string `json:"kafkaVersion,omitempty" tf:"kafka_version,omitempty"`
// Configuration block for streaming broker logs to Cloudwatch/S3/Kinesis Firehose. See below.
LoggingInfo []LoggingInfoObservation `json:"loggingInfo,omitempty" tf:"logging_info,omitempty"`
// The desired total number of broker nodes in the kafka cluster. It must be a multiple of the number of specified client subnets.
NumberOfBrokerNodes *float64 `json:"numberOfBrokerNodes,omitempty" tf:"number_of_broker_nodes,omitempty"`
// Configuration block for JMX and Node monitoring for the MSK cluster. See below.
OpenMonitoring []OpenMonitoringObservation `json:"openMonitoring,omitempty" tf:"open_monitoring,omitempty"`
// Controls storage mode for supported storage tiers. Valid values are: LOCAL or TIERED.
StorageMode *string `json:"storageMode,omitempty" tf:"storage_mode,omitempty"`
// Key-value map of resource tags.
// +mapType=granular
Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
// A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.
// +mapType=granular
TagsAll map[string]*string `json:"tagsAll,omitempty" tf:"tags_all,omitempty"`
// A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster. The returned values are sorted alphabetically. The AWS API may not return all endpoints, so this value is not guaranteed to be stable across applies.
ZookeeperConnectString *string `json:"zookeeperConnectString,omitempty" tf:"zookeeper_connect_string,omitempty"`
// A comma separated list of one or more hostname:port pairs to use to connect to the Apache Zookeeper cluster via TLS. The returned values are sorted alphabetically. The AWS API may not return all endpoints, so this value is not guaranteed to be stable across applies.
ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTls,omitempty" tf:"zookeeper_connect_string_tls,omitempty"`
}
func (*ClusterObservation) DeepCopy ¶
func (in *ClusterObservation) DeepCopy() *ClusterObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterObservation.
func (*ClusterObservation) DeepCopyInto ¶
func (in *ClusterObservation) DeepCopyInto(out *ClusterObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterParameters ¶
type ClusterParameters struct {
// Configuration block for the broker nodes of the Kafka cluster.
// +kubebuilder:validation:Optional
BrokerNodeGroupInfo []BrokerNodeGroupInfoParameters `json:"brokerNodeGroupInfo,omitempty" tf:"broker_node_group_info,omitempty"`
// Configuration block for specifying a client authentication. See below.
// +kubebuilder:validation:Optional
ClientAuthentication []ClusterClientAuthenticationParameters `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"`
// Name of the MSK cluster.
// +kubebuilder:validation:Optional
ClusterName *string `json:"clusterName,omitempty" tf:"cluster_name,omitempty"`
// Configuration block for specifying a MSK Configuration to attach to Kafka brokers. See below.
// +kubebuilder:validation:Optional
ConfigurationInfo []ConfigurationInfoParameters `json:"configurationInfo,omitempty" tf:"configuration_info,omitempty"`
// Configuration block for specifying encryption. See below.
// +kubebuilder:validation:Optional
EncryptionInfo []EncryptionInfoParameters `json:"encryptionInfo,omitempty" tf:"encryption_info,omitempty"`
// Specify the desired enhanced MSK CloudWatch monitoring level. See Monitoring Amazon MSK with Amazon CloudWatch
// +kubebuilder:validation:Optional
EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty" tf:"enhanced_monitoring,omitempty"`
// Specify the desired Kafka software version.
// +kubebuilder:validation:Optional
KafkaVersion *string `json:"kafkaVersion,omitempty" tf:"kafka_version,omitempty"`
// Configuration block for streaming broker logs to Cloudwatch/S3/Kinesis Firehose. See below.
// +kubebuilder:validation:Optional
LoggingInfo []LoggingInfoParameters `json:"loggingInfo,omitempty" tf:"logging_info,omitempty"`
// The desired total number of broker nodes in the kafka cluster. It must be a multiple of the number of specified client subnets.
// +kubebuilder:validation:Optional
NumberOfBrokerNodes *float64 `json:"numberOfBrokerNodes,omitempty" tf:"number_of_broker_nodes,omitempty"`
// Configuration block for JMX and Node monitoring for the MSK cluster. See below.
// +kubebuilder:validation:Optional
OpenMonitoring []OpenMonitoringParameters `json:"openMonitoring,omitempty" tf:"open_monitoring,omitempty"`
// Region is the region you'd like your resource to be created in.
// +upjet:crd:field:TFTag=-
// +kubebuilder:validation:Required
Region *string `json:"region" tf:"-"`
// Controls storage mode for supported storage tiers. Valid values are: LOCAL or TIERED.
// +kubebuilder:validation:Optional
StorageMode *string `json:"storageMode,omitempty" tf:"storage_mode,omitempty"`
// Key-value map of resource tags.
// +kubebuilder:validation:Optional
// +mapType=granular
Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
}
func (*ClusterParameters) DeepCopy ¶
func (in *ClusterParameters) DeepCopy() *ClusterParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterParameters.
func (*ClusterParameters) DeepCopyInto ¶
func (in *ClusterParameters) DeepCopyInto(out *ClusterParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterSpec ¶
type ClusterSpec struct {
v1.ResourceSpec `json:",inline"`
ForProvider ClusterParameters `json:"forProvider"`
// THIS IS A BETA FIELD. It will be honored
// unless the Management Policies feature flag is disabled.
// InitProvider holds the same fields as ForProvider, with the exception
// of Identifier and other resource reference fields. The fields that are
// in InitProvider are merged into ForProvider when the resource is created.
// The same fields are also added to the terraform ignore_changes hook, to
// avoid updating them after creation. This is useful for fields that are
// required on creation, but we do not desire to update them after creation,
// for example because of an external controller is managing them, like an
// autoscaler.
InitProvider ClusterInitParameters `json:"initProvider,omitempty"`
}
ClusterSpec defines the desired state of Cluster
func (*ClusterSpec) DeepCopy ¶
func (in *ClusterSpec) DeepCopy() *ClusterSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterSpec.
func (*ClusterSpec) DeepCopyInto ¶
func (in *ClusterSpec) DeepCopyInto(out *ClusterSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ClusterStatus ¶
type ClusterStatus struct {
v1.ResourceStatus `json:",inline"`
AtProvider ClusterObservation `json:"atProvider,omitempty"`
}
ClusterStatus defines the observed state of Cluster.
func (*ClusterStatus) DeepCopy ¶
func (in *ClusterStatus) DeepCopy() *ClusterStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ClusterStatus.
func (*ClusterStatus) DeepCopyInto ¶
func (in *ClusterStatus) DeepCopyInto(out *ClusterStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationInfoInitParameters ¶
type ConfigurationInfoInitParameters struct {
// Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kafka/v1beta1.Configuration
// +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor()
Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`
// Reference to a Configuration in kafka to populate arn.
// +kubebuilder:validation:Optional
ArnRef *v1.Reference `json:"arnRef,omitempty" tf:"-"`
// Selector for a Configuration in kafka to populate arn.
// +kubebuilder:validation:Optional
ArnSelector *v1.Selector `json:"arnSelector,omitempty" tf:"-"`
// Revision of the MSK Configuration to use in the cluster.
Revision *float64 `json:"revision,omitempty" tf:"revision,omitempty"`
}
func (*ConfigurationInfoInitParameters) DeepCopy ¶
func (in *ConfigurationInfoInitParameters) DeepCopy() *ConfigurationInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationInfoInitParameters.
func (*ConfigurationInfoInitParameters) DeepCopyInto ¶
func (in *ConfigurationInfoInitParameters) DeepCopyInto(out *ConfigurationInfoInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationInfoObservation ¶
type ConfigurationInfoObservation struct {
// Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.
Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`
// Revision of the MSK Configuration to use in the cluster.
Revision *float64 `json:"revision,omitempty" tf:"revision,omitempty"`
}
func (*ConfigurationInfoObservation) DeepCopy ¶
func (in *ConfigurationInfoObservation) DeepCopy() *ConfigurationInfoObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationInfoObservation.
func (*ConfigurationInfoObservation) DeepCopyInto ¶
func (in *ConfigurationInfoObservation) DeepCopyInto(out *ConfigurationInfoObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConfigurationInfoParameters ¶
type ConfigurationInfoParameters struct {
// Amazon Resource Name (ARN) of the MSK Configuration to use in the cluster.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kafka/v1beta1.Configuration
// +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor()
// +kubebuilder:validation:Optional
Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`
// Reference to a Configuration in kafka to populate arn.
// +kubebuilder:validation:Optional
ArnRef *v1.Reference `json:"arnRef,omitempty" tf:"-"`
// Selector for a Configuration in kafka to populate arn.
// +kubebuilder:validation:Optional
ArnSelector *v1.Selector `json:"arnSelector,omitempty" tf:"-"`
// Revision of the MSK Configuration to use in the cluster.
// +kubebuilder:validation:Optional
Revision *float64 `json:"revision" tf:"revision,omitempty"`
}
func (*ConfigurationInfoParameters) DeepCopy ¶
func (in *ConfigurationInfoParameters) DeepCopy() *ConfigurationInfoParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConfigurationInfoParameters.
func (*ConfigurationInfoParameters) DeepCopyInto ¶
func (in *ConfigurationInfoParameters) DeepCopyInto(out *ConfigurationInfoParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ConnectivityInfoInitParameters ¶
type ConnectivityInfoInitParameters struct {
// Access control settings for brokers. See below.
PublicAccess []PublicAccessInitParameters `json:"publicAccess,omitempty" tf:"public_access,omitempty"`
// VPC connectivity access control for brokers. See below.
VPCConnectivity []VPCConnectivityInitParameters `json:"vpcConnectivity,omitempty" tf:"vpc_connectivity,omitempty"`
}
func (*ConnectivityInfoInitParameters) DeepCopy ¶
func (in *ConnectivityInfoInitParameters) DeepCopy() *ConnectivityInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ConnectivityInfoInitParameters.
func (*ConnectivityInfoInitParameters) DeepCopyInto ¶
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"`
// VPC connectivity access control for brokers. See below.
VPCConnectivity []VPCConnectivityObservation `json:"vpcConnectivity,omitempty" tf:"vpc_connectivity,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"`
// VPC connectivity access control for brokers. See below.
// +kubebuilder:validation:Optional
VPCConnectivity []VPCConnectivityParameters `json:"vpcConnectivity,omitempty" tf:"vpc_connectivity,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 ¶
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 ¶
func (in *EBSStorageInfoInitParameters) DeepCopy() *EBSStorageInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EBSStorageInfoInitParameters.
func (*EBSStorageInfoInitParameters) DeepCopyInto ¶
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 ¶
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 ¶
func (in *EncryptionInTransitInitParameters) DeepCopy() *EncryptionInTransitInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInTransitInitParameters.
func (*EncryptionInTransitInitParameters) DeepCopyInto ¶
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 ¶
type EncryptionInfoInitParameters struct {
// The ARN of the KMS key used for encryption at rest of the broker data volumes.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kms/v1beta1.Key
// +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor()
EncryptionAtRestKMSKeyArn *string `json:"encryptionAtRestKmsKeyArn,omitempty" tf:"encryption_at_rest_kms_key_arn,omitempty"`
// Reference to a Key in kms to populate encryptionAtRestKmsKeyArn.
// +kubebuilder:validation:Optional
EncryptionAtRestKMSKeyArnRef *v1.Reference `json:"encryptionAtRestKmsKeyArnRef,omitempty" tf:"-"`
// Selector for a Key in kms to populate encryptionAtRestKmsKeyArn.
// +kubebuilder:validation:Optional
EncryptionAtRestKMSKeyArnSelector *v1.Selector `json:"encryptionAtRestKmsKeyArnSelector,omitempty" tf:"-"`
// Configuration block to specify encryption in transit. See below.
EncryptionInTransit []EncryptionInTransitInitParameters `json:"encryptionInTransit,omitempty" tf:"encryption_in_transit,omitempty"`
}
func (*EncryptionInfoInitParameters) DeepCopy ¶
func (in *EncryptionInfoInitParameters) DeepCopy() *EncryptionInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInfoInitParameters.
func (*EncryptionInfoInitParameters) DeepCopyInto ¶
func (in *EncryptionInfoInitParameters) DeepCopyInto(out *EncryptionInfoInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionInfoObservation ¶
type EncryptionInfoObservation struct {
// The ARN of the KMS key used for encryption at rest of the broker data volumes.
EncryptionAtRestKMSKeyArn *string `json:"encryptionAtRestKmsKeyArn,omitempty" tf:"encryption_at_rest_kms_key_arn,omitempty"`
// Configuration block to specify encryption in transit. See below.
EncryptionInTransit []EncryptionInTransitObservation `json:"encryptionInTransit,omitempty" tf:"encryption_in_transit,omitempty"`
}
func (*EncryptionInfoObservation) DeepCopy ¶
func (in *EncryptionInfoObservation) DeepCopy() *EncryptionInfoObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInfoObservation.
func (*EncryptionInfoObservation) DeepCopyInto ¶
func (in *EncryptionInfoObservation) DeepCopyInto(out *EncryptionInfoObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type EncryptionInfoParameters ¶
type EncryptionInfoParameters struct {
// The ARN of the KMS key used for encryption at rest of the broker data volumes.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kms/v1beta1.Key
// +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor()
// +kubebuilder:validation:Optional
EncryptionAtRestKMSKeyArn *string `json:"encryptionAtRestKmsKeyArn,omitempty" tf:"encryption_at_rest_kms_key_arn,omitempty"`
// Reference to a Key in kms to populate encryptionAtRestKmsKeyArn.
// +kubebuilder:validation:Optional
EncryptionAtRestKMSKeyArnRef *v1.Reference `json:"encryptionAtRestKmsKeyArnRef,omitempty" tf:"-"`
// Selector for a Key in kms to populate encryptionAtRestKmsKeyArn.
// +kubebuilder:validation:Optional
EncryptionAtRestKMSKeyArnSelector *v1.Selector `json:"encryptionAtRestKmsKeyArnSelector,omitempty" tf:"-"`
// Configuration block to specify encryption in transit. See below.
// +kubebuilder:validation:Optional
EncryptionInTransit []EncryptionInTransitParameters `json:"encryptionInTransit,omitempty" tf:"encryption_in_transit,omitempty"`
}
func (*EncryptionInfoParameters) DeepCopy ¶
func (in *EncryptionInfoParameters) DeepCopy() *EncryptionInfoParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EncryptionInfoParameters.
func (*EncryptionInfoParameters) DeepCopyInto ¶
func (in *EncryptionInfoParameters) DeepCopyInto(out *EncryptionInfoParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type FirehoseInitParameters ¶
type FirehoseInitParameters struct {
// Name of the Kinesis Data Firehose delivery stream to deliver logs to.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/firehose/v1beta1.DeliveryStream
// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("name",false)
DeliveryStream *string `json:"deliveryStream,omitempty" tf:"delivery_stream,omitempty"`
// Reference to a DeliveryStream in firehose to populate deliveryStream.
// +kubebuilder:validation:Optional
DeliveryStreamRef *v1.Reference `json:"deliveryStreamRef,omitempty" tf:"-"`
// Selector for a DeliveryStream in firehose to populate deliveryStream.
// +kubebuilder:validation:Optional
DeliveryStreamSelector *v1.Selector `json:"deliveryStreamSelector,omitempty" tf:"-"`
// Controls whether provisioned throughput is enabled or not. Default value: false.
Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`
}
func (*FirehoseInitParameters) DeepCopy ¶
func (in *FirehoseInitParameters) DeepCopy() *FirehoseInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FirehoseInitParameters.
func (*FirehoseInitParameters) DeepCopyInto ¶
func (in *FirehoseInitParameters) DeepCopyInto(out *FirehoseInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type FirehoseObservation ¶
type FirehoseObservation struct {
// Name of the Kinesis Data Firehose delivery stream to deliver logs to.
DeliveryStream *string `json:"deliveryStream,omitempty" tf:"delivery_stream,omitempty"`
// Controls whether provisioned throughput is enabled or not. Default value: false.
Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`
}
func (*FirehoseObservation) DeepCopy ¶
func (in *FirehoseObservation) DeepCopy() *FirehoseObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FirehoseObservation.
func (*FirehoseObservation) DeepCopyInto ¶
func (in *FirehoseObservation) DeepCopyInto(out *FirehoseObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type FirehoseParameters ¶
type FirehoseParameters struct {
// Name of the Kinesis Data Firehose delivery stream to deliver logs to.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/firehose/v1beta1.DeliveryStream
// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("name",false)
// +kubebuilder:validation:Optional
DeliveryStream *string `json:"deliveryStream,omitempty" tf:"delivery_stream,omitempty"`
// Reference to a DeliveryStream in firehose to populate deliveryStream.
// +kubebuilder:validation:Optional
DeliveryStreamRef *v1.Reference `json:"deliveryStreamRef,omitempty" tf:"-"`
// Selector for a DeliveryStream in firehose to populate deliveryStream.
// +kubebuilder:validation:Optional
DeliveryStreamSelector *v1.Selector `json:"deliveryStreamSelector,omitempty" tf:"-"`
// Controls whether provisioned throughput is enabled or not. Default value: false.
// +kubebuilder:validation:Optional
Enabled *bool `json:"enabled" tf:"enabled,omitempty"`
}
func (*FirehoseParameters) DeepCopy ¶
func (in *FirehoseParameters) DeepCopy() *FirehoseParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new FirehoseParameters.
func (*FirehoseParameters) DeepCopyInto ¶
func (in *FirehoseParameters) DeepCopyInto(out *FirehoseParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type IAMInitParameters ¶
type IAMInitParameters struct {
// Whether SASL/IAM authentication is enabled or not.
Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`
}
func (*IAMInitParameters) DeepCopy ¶
func (in *IAMInitParameters) DeepCopy() *IAMInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IAMInitParameters.
func (*IAMInitParameters) DeepCopyInto ¶
func (in *IAMInitParameters) DeepCopyInto(out *IAMInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type IAMObservation ¶
type IAMObservation struct {
// Whether SASL/IAM authentication is enabled or not.
Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`
}
func (*IAMObservation) DeepCopy ¶
func (in *IAMObservation) DeepCopy() *IAMObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IAMObservation.
func (*IAMObservation) DeepCopyInto ¶
func (in *IAMObservation) DeepCopyInto(out *IAMObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type IAMParameters ¶
type IAMParameters struct {
// Whether SASL/IAM authentication is enabled or not.
// +kubebuilder:validation:Optional
Enabled *bool `json:"enabled" tf:"enabled,omitempty"`
}
func (*IAMParameters) DeepCopy ¶
func (in *IAMParameters) DeepCopy() *IAMParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new IAMParameters.
func (*IAMParameters) DeepCopyInto ¶
func (in *IAMParameters) DeepCopyInto(out *IAMParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type JmxExporterInitParameters ¶
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 ¶
func (in *JmxExporterInitParameters) DeepCopy() *JmxExporterInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new JmxExporterInitParameters.
func (*JmxExporterInitParameters) DeepCopyInto ¶
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 ¶
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 ¶
func (in *LoggingInfoInitParameters) DeepCopy() *LoggingInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new LoggingInfoInitParameters.
func (*LoggingInfoInitParameters) DeepCopyInto ¶
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 ¶
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 ¶
func (in *NodeExporterInitParameters) DeepCopy() *NodeExporterInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new NodeExporterInitParameters.
func (*NodeExporterInitParameters) DeepCopyInto ¶
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 ¶
type OpenMonitoringInitParameters struct {
// Configuration block for Prometheus settings for open monitoring. See below.
Prometheus []PrometheusInitParameters `json:"prometheus,omitempty" tf:"prometheus,omitempty"`
}
func (*OpenMonitoringInitParameters) DeepCopy ¶
func (in *OpenMonitoringInitParameters) DeepCopy() *OpenMonitoringInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OpenMonitoringInitParameters.
func (*OpenMonitoringInitParameters) DeepCopyInto ¶
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 ¶
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 ¶
func (in *PrometheusInitParameters) DeepCopy() *PrometheusInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PrometheusInitParameters.
func (*PrometheusInitParameters) DeepCopyInto ¶
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 ¶
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 ¶
func (in *ProvisionedThroughputInitParameters) DeepCopy() *ProvisionedThroughputInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ProvisionedThroughputInitParameters.
func (*ProvisionedThroughputInitParameters) DeepCopyInto ¶
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 ¶
type PublicAccessInitParameters struct {
// Public access type. Valid values: DISABLED, SERVICE_PROVIDED_EIPS.
Type *string `json:"type,omitempty" tf:"type,omitempty"`
}
func (*PublicAccessInitParameters) DeepCopy ¶
func (in *PublicAccessInitParameters) DeepCopy() *PublicAccessInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PublicAccessInitParameters.
func (*PublicAccessInitParameters) DeepCopyInto ¶
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. Valid 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. Valid 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 ¶
type S3InitParameters struct {
// Name of the S3 bucket to deliver logs to.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta1.Bucket
Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"`
// Reference to a Bucket in s3 to populate bucket.
// +kubebuilder:validation:Optional
BucketRef *v1.Reference `json:"bucketRef,omitempty" tf:"-"`
// Selector for a Bucket in s3 to populate bucket.
// +kubebuilder:validation:Optional
BucketSelector *v1.Selector `json:"bucketSelector,omitempty" tf:"-"`
// Controls whether provisioned throughput is enabled or not. Default value: false.
Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`
// Prefix to append to the folder name.
Prefix *string `json:"prefix,omitempty" tf:"prefix,omitempty"`
}
func (*S3InitParameters) DeepCopy ¶
func (in *S3InitParameters) DeepCopy() *S3InitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3InitParameters.
func (*S3InitParameters) DeepCopyInto ¶
func (in *S3InitParameters) DeepCopyInto(out *S3InitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type S3Observation ¶
type S3Observation struct {
// Name of the S3 bucket to deliver logs to.
Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"`
// Controls whether provisioned throughput is enabled or not. Default value: false.
Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`
// Prefix to append to the folder name.
Prefix *string `json:"prefix,omitempty" tf:"prefix,omitempty"`
}
func (*S3Observation) DeepCopy ¶
func (in *S3Observation) DeepCopy() *S3Observation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3Observation.
func (*S3Observation) DeepCopyInto ¶
func (in *S3Observation) DeepCopyInto(out *S3Observation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type S3Parameters ¶
type S3Parameters struct {
// Name of the S3 bucket to deliver logs to.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta1.Bucket
// +kubebuilder:validation:Optional
Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"`
// Reference to a Bucket in s3 to populate bucket.
// +kubebuilder:validation:Optional
BucketRef *v1.Reference `json:"bucketRef,omitempty" tf:"-"`
// Selector for a Bucket in s3 to populate bucket.
// +kubebuilder:validation:Optional
BucketSelector *v1.Selector `json:"bucketSelector,omitempty" tf:"-"`
// Controls whether provisioned throughput is enabled or not. Default value: false.
// +kubebuilder:validation:Optional
Enabled *bool `json:"enabled" tf:"enabled,omitempty"`
// Prefix to append to the folder name.
// +kubebuilder:validation:Optional
Prefix *string `json:"prefix,omitempty" tf:"prefix,omitempty"`
}
func (*S3Parameters) DeepCopy ¶
func (in *S3Parameters) DeepCopy() *S3Parameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new S3Parameters.
func (*S3Parameters) DeepCopyInto ¶
func (in *S3Parameters) DeepCopyInto(out *S3Parameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type SaslInitParameters ¶
type SaslInitParameters struct {
// Enables SASL/IAM authentication for VPC connectivity.
IAM *bool `json:"iam,omitempty" tf:"iam,omitempty"`
// Enables SASL/SCRAM authentication for VPC connectivity.
Scram *bool `json:"scram,omitempty" tf:"scram,omitempty"`
}
func (*SaslInitParameters) DeepCopy ¶
func (in *SaslInitParameters) DeepCopy() *SaslInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new SaslInitParameters.
func (*SaslInitParameters) DeepCopyInto ¶
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 SASL/IAM authentication for VPC connectivity.
IAM *bool `json:"iam,omitempty" tf:"iam,omitempty"`
// Enables SASL/SCRAM authentication for VPC connectivity.
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 SASL/IAM authentication for VPC connectivity.
// +kubebuilder:validation:Optional
IAM *bool `json:"iam,omitempty" tf:"iam,omitempty"`
// Enables SASL/SCRAM authentication for VPC connectivity.
// +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 ServerlessCluster ¶
type ServerlessCluster struct {
metav1.TypeMeta `json:",inline"`
metav1.ObjectMeta `json:"metadata,omitempty"`
// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.clientAuthentication) || (has(self.initProvider) && has(self.initProvider.clientAuthentication))",message="spec.forProvider.clientAuthentication is a required parameter"
// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.clusterName) || (has(self.initProvider) && has(self.initProvider.clusterName))",message="spec.forProvider.clusterName is a required parameter"
// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.vpcConfig) || (has(self.initProvider) && has(self.initProvider.vpcConfig))",message="spec.forProvider.vpcConfig is a required parameter"
Spec ServerlessClusterSpec `json:"spec"`
Status ServerlessClusterStatus `json:"status,omitempty"`
}
ServerlessCluster is the Schema for the ServerlessClusters API. +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}
func (*ServerlessCluster) DeepCopy ¶
func (in *ServerlessCluster) DeepCopy() *ServerlessCluster
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessCluster.
func (*ServerlessCluster) DeepCopyInto ¶
func (in *ServerlessCluster) DeepCopyInto(out *ServerlessCluster)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ServerlessCluster) DeepCopyObject ¶
func (in *ServerlessCluster) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ServerlessCluster) GetCondition ¶
func (mg *ServerlessCluster) GetCondition(ct xpv1.ConditionType) xpv1.Condition
GetCondition of this ServerlessCluster.
func (*ServerlessCluster) GetConnectionDetailsMapping ¶
func (tr *ServerlessCluster) GetConnectionDetailsMapping() map[string]string
GetConnectionDetailsMapping for this ServerlessCluster
func (*ServerlessCluster) GetDeletionPolicy ¶
func (mg *ServerlessCluster) GetDeletionPolicy() xpv1.DeletionPolicy
GetDeletionPolicy of this ServerlessCluster.
func (*ServerlessCluster) GetID ¶
func (tr *ServerlessCluster) GetID() string
GetID returns ID of underlying Terraform resource of this ServerlessCluster
func (*ServerlessCluster) GetInitParameters ¶
func (tr *ServerlessCluster) GetInitParameters() (map[string]any, error)
GetInitParameters of this ServerlessCluster
func (*ServerlessCluster) GetManagementPolicies ¶
func (mg *ServerlessCluster) GetManagementPolicies() xpv1.ManagementPolicies
GetManagementPolicies of this ServerlessCluster.
func (*ServerlessCluster) GetMergedParameters ¶
func (tr *ServerlessCluster) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)
GetInitParameters of this ServerlessCluster
func (*ServerlessCluster) GetObservation ¶
func (tr *ServerlessCluster) GetObservation() (map[string]any, error)
GetObservation of this ServerlessCluster
func (*ServerlessCluster) GetParameters ¶
func (tr *ServerlessCluster) GetParameters() (map[string]any, error)
GetParameters of this ServerlessCluster
func (*ServerlessCluster) GetProviderConfigReference ¶
func (mg *ServerlessCluster) GetProviderConfigReference() *xpv1.Reference
GetProviderConfigReference of this ServerlessCluster.
func (*ServerlessCluster) GetPublishConnectionDetailsTo ¶
func (mg *ServerlessCluster) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
GetPublishConnectionDetailsTo of this ServerlessCluster.
func (*ServerlessCluster) GetTerraformResourceType ¶
func (mg *ServerlessCluster) GetTerraformResourceType() string
GetTerraformResourceType returns Terraform resource type for this ServerlessCluster
func (*ServerlessCluster) GetTerraformSchemaVersion ¶
func (tr *ServerlessCluster) GetTerraformSchemaVersion() int
GetTerraformSchemaVersion returns the associated Terraform schema version
func (*ServerlessCluster) GetWriteConnectionSecretToReference ¶
func (mg *ServerlessCluster) GetWriteConnectionSecretToReference() *xpv1.SecretReference
GetWriteConnectionSecretToReference of this ServerlessCluster.
func (*ServerlessCluster) LateInitialize ¶
func (tr *ServerlessCluster) LateInitialize(attrs []byte) (bool, error)
LateInitialize this ServerlessCluster using its observed tfState. returns True if there are any spec changes for the resource.
func (*ServerlessCluster) ResolveReferences ¶
ResolveReferences of this ServerlessCluster.
func (*ServerlessCluster) SetConditions ¶
func (mg *ServerlessCluster) SetConditions(c ...xpv1.Condition)
SetConditions of this ServerlessCluster.
func (*ServerlessCluster) SetDeletionPolicy ¶
func (mg *ServerlessCluster) SetDeletionPolicy(r xpv1.DeletionPolicy)
SetDeletionPolicy of this ServerlessCluster.
func (*ServerlessCluster) SetManagementPolicies ¶
func (mg *ServerlessCluster) SetManagementPolicies(r xpv1.ManagementPolicies)
SetManagementPolicies of this ServerlessCluster.
func (*ServerlessCluster) SetObservation ¶
func (tr *ServerlessCluster) SetObservation(obs map[string]any) error
SetObservation for this ServerlessCluster
func (*ServerlessCluster) SetParameters ¶
func (tr *ServerlessCluster) SetParameters(params map[string]any) error
SetParameters for this ServerlessCluster
func (*ServerlessCluster) SetProviderConfigReference ¶
func (mg *ServerlessCluster) SetProviderConfigReference(r *xpv1.Reference)
SetProviderConfigReference of this ServerlessCluster.
func (*ServerlessCluster) SetPublishConnectionDetailsTo ¶
func (mg *ServerlessCluster) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
SetPublishConnectionDetailsTo of this ServerlessCluster.
func (*ServerlessCluster) SetWriteConnectionSecretToReference ¶
func (mg *ServerlessCluster) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
SetWriteConnectionSecretToReference of this ServerlessCluster.
type ServerlessClusterClientAuthenticationInitParameters ¶
type ServerlessClusterClientAuthenticationInitParameters struct {
// Details for client authentication using SASL. See below.
Sasl *ServerlessClusterClientAuthenticationSaslInitParameters `json:"sasl,omitempty" tf:"sasl,omitempty"`
}
func (*ServerlessClusterClientAuthenticationInitParameters) DeepCopy ¶
func (in *ServerlessClusterClientAuthenticationInitParameters) DeepCopy() *ServerlessClusterClientAuthenticationInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterClientAuthenticationInitParameters.
func (*ServerlessClusterClientAuthenticationInitParameters) DeepCopyInto ¶
func (in *ServerlessClusterClientAuthenticationInitParameters) DeepCopyInto(out *ServerlessClusterClientAuthenticationInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterClientAuthenticationObservation ¶
type ServerlessClusterClientAuthenticationObservation struct {
// Details for client authentication using SASL. See below.
Sasl *ServerlessClusterClientAuthenticationSaslObservation `json:"sasl,omitempty" tf:"sasl,omitempty"`
}
func (*ServerlessClusterClientAuthenticationObservation) DeepCopy ¶
func (in *ServerlessClusterClientAuthenticationObservation) DeepCopy() *ServerlessClusterClientAuthenticationObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterClientAuthenticationObservation.
func (*ServerlessClusterClientAuthenticationObservation) DeepCopyInto ¶
func (in *ServerlessClusterClientAuthenticationObservation) DeepCopyInto(out *ServerlessClusterClientAuthenticationObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterClientAuthenticationParameters ¶
type ServerlessClusterClientAuthenticationParameters struct {
// Details for client authentication using SASL. See below.
// +kubebuilder:validation:Optional
Sasl *ServerlessClusterClientAuthenticationSaslParameters `json:"sasl" tf:"sasl,omitempty"`
}
func (*ServerlessClusterClientAuthenticationParameters) DeepCopy ¶
func (in *ServerlessClusterClientAuthenticationParameters) DeepCopy() *ServerlessClusterClientAuthenticationParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterClientAuthenticationParameters.
func (*ServerlessClusterClientAuthenticationParameters) DeepCopyInto ¶
func (in *ServerlessClusterClientAuthenticationParameters) DeepCopyInto(out *ServerlessClusterClientAuthenticationParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterClientAuthenticationSaslInitParameters ¶
type ServerlessClusterClientAuthenticationSaslInitParameters struct {
// Details for client authentication using IAM. See below.
IAM *IAMInitParameters `json:"iam,omitempty" tf:"iam,omitempty"`
}
func (*ServerlessClusterClientAuthenticationSaslInitParameters) DeepCopy ¶
func (in *ServerlessClusterClientAuthenticationSaslInitParameters) DeepCopy() *ServerlessClusterClientAuthenticationSaslInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterClientAuthenticationSaslInitParameters.
func (*ServerlessClusterClientAuthenticationSaslInitParameters) DeepCopyInto ¶
func (in *ServerlessClusterClientAuthenticationSaslInitParameters) DeepCopyInto(out *ServerlessClusterClientAuthenticationSaslInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterClientAuthenticationSaslObservation ¶
type ServerlessClusterClientAuthenticationSaslObservation struct {
// Details for client authentication using IAM. See below.
IAM *IAMObservation `json:"iam,omitempty" tf:"iam,omitempty"`
}
func (*ServerlessClusterClientAuthenticationSaslObservation) DeepCopy ¶
func (in *ServerlessClusterClientAuthenticationSaslObservation) DeepCopy() *ServerlessClusterClientAuthenticationSaslObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterClientAuthenticationSaslObservation.
func (*ServerlessClusterClientAuthenticationSaslObservation) DeepCopyInto ¶
func (in *ServerlessClusterClientAuthenticationSaslObservation) DeepCopyInto(out *ServerlessClusterClientAuthenticationSaslObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterClientAuthenticationSaslParameters ¶
type ServerlessClusterClientAuthenticationSaslParameters struct {
// Details for client authentication using IAM. See below.
// +kubebuilder:validation:Optional
IAM *IAMParameters `json:"iam" tf:"iam,omitempty"`
}
func (*ServerlessClusterClientAuthenticationSaslParameters) DeepCopy ¶
func (in *ServerlessClusterClientAuthenticationSaslParameters) DeepCopy() *ServerlessClusterClientAuthenticationSaslParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterClientAuthenticationSaslParameters.
func (*ServerlessClusterClientAuthenticationSaslParameters) DeepCopyInto ¶
func (in *ServerlessClusterClientAuthenticationSaslParameters) DeepCopyInto(out *ServerlessClusterClientAuthenticationSaslParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterInitParameters ¶
type ServerlessClusterInitParameters struct {
// Specifies client authentication information for the serverless cluster. See below.
ClientAuthentication *ServerlessClusterClientAuthenticationInitParameters `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"`
// The name of the serverless cluster.
ClusterName *string `json:"clusterName,omitempty" tf:"cluster_name,omitempty"`
// Key-value map of resource tags.
// +mapType=granular
Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
// VPC configuration information. See below.
VPCConfig []VPCConfigInitParameters `json:"vpcConfig,omitempty" tf:"vpc_config,omitempty"`
}
func (*ServerlessClusterInitParameters) DeepCopy ¶
func (in *ServerlessClusterInitParameters) DeepCopy() *ServerlessClusterInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterInitParameters.
func (*ServerlessClusterInitParameters) DeepCopyInto ¶
func (in *ServerlessClusterInitParameters) DeepCopyInto(out *ServerlessClusterInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterList ¶
type ServerlessClusterList struct {
metav1.TypeMeta `json:",inline"`
metav1.ListMeta `json:"metadata,omitempty"`
Items []ServerlessCluster `json:"items"`
}
ServerlessClusterList contains a list of ServerlessClusters
func (*ServerlessClusterList) DeepCopy ¶
func (in *ServerlessClusterList) DeepCopy() *ServerlessClusterList
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterList.
func (*ServerlessClusterList) DeepCopyInto ¶
func (in *ServerlessClusterList) DeepCopyInto(out *ServerlessClusterList)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
func (*ServerlessClusterList) DeepCopyObject ¶
func (in *ServerlessClusterList) DeepCopyObject() runtime.Object
DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
func (*ServerlessClusterList) GetItems ¶
func (l *ServerlessClusterList) GetItems() []resource.Managed
GetItems of this ServerlessClusterList.
type ServerlessClusterObservation ¶
type ServerlessClusterObservation struct {
// The ARN of the serverless cluster.
Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`
// Specifies client authentication information for the serverless cluster. See below.
ClientAuthentication *ServerlessClusterClientAuthenticationObservation `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"`
// The name of the serverless cluster.
ClusterName *string `json:"clusterName,omitempty" tf:"cluster_name,omitempty"`
// UUID of the serverless cluster, for use in IAM policies.
ClusterUUID *string `json:"clusterUuid,omitempty" tf:"cluster_uuid,omitempty"`
ID *string `json:"id,omitempty" tf:"id,omitempty"`
// Key-value map of resource tags.
// +mapType=granular
Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
// A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.
// +mapType=granular
TagsAll map[string]*string `json:"tagsAll,omitempty" tf:"tags_all,omitempty"`
// VPC configuration information. See below.
VPCConfig []VPCConfigObservation `json:"vpcConfig,omitempty" tf:"vpc_config,omitempty"`
}
func (*ServerlessClusterObservation) DeepCopy ¶
func (in *ServerlessClusterObservation) DeepCopy() *ServerlessClusterObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterObservation.
func (*ServerlessClusterObservation) DeepCopyInto ¶
func (in *ServerlessClusterObservation) DeepCopyInto(out *ServerlessClusterObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterParameters ¶
type ServerlessClusterParameters struct {
// Specifies client authentication information for the serverless cluster. See below.
// +kubebuilder:validation:Optional
ClientAuthentication *ServerlessClusterClientAuthenticationParameters `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"`
// The name of the serverless cluster.
// +kubebuilder:validation:Optional
ClusterName *string `json:"clusterName,omitempty" tf:"cluster_name,omitempty"`
// Region is the region you'd like your resource to be created in.
// +upjet:crd:field:TFTag=-
// +kubebuilder:validation:Required
Region *string `json:"region" tf:"-"`
// Key-value map of resource tags.
// +kubebuilder:validation:Optional
// +mapType=granular
Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
// VPC configuration information. See below.
// +kubebuilder:validation:Optional
VPCConfig []VPCConfigParameters `json:"vpcConfig,omitempty" tf:"vpc_config,omitempty"`
}
func (*ServerlessClusterParameters) DeepCopy ¶
func (in *ServerlessClusterParameters) DeepCopy() *ServerlessClusterParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterParameters.
func (*ServerlessClusterParameters) DeepCopyInto ¶
func (in *ServerlessClusterParameters) DeepCopyInto(out *ServerlessClusterParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterSpec ¶
type ServerlessClusterSpec struct {
v1.ResourceSpec `json:",inline"`
ForProvider ServerlessClusterParameters `json:"forProvider"`
// THIS IS A BETA FIELD. It will be honored
// unless the Management Policies feature flag is disabled.
// InitProvider holds the same fields as ForProvider, with the exception
// of Identifier and other resource reference fields. The fields that are
// in InitProvider are merged into ForProvider when the resource is created.
// The same fields are also added to the terraform ignore_changes hook, to
// avoid updating them after creation. This is useful for fields that are
// required on creation, but we do not desire to update them after creation,
// for example because of an external controller is managing them, like an
// autoscaler.
InitProvider ServerlessClusterInitParameters `json:"initProvider,omitempty"`
}
ServerlessClusterSpec defines the desired state of ServerlessCluster
func (*ServerlessClusterSpec) DeepCopy ¶
func (in *ServerlessClusterSpec) DeepCopy() *ServerlessClusterSpec
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterSpec.
func (*ServerlessClusterSpec) DeepCopyInto ¶
func (in *ServerlessClusterSpec) DeepCopyInto(out *ServerlessClusterSpec)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type ServerlessClusterStatus ¶
type ServerlessClusterStatus struct {
v1.ResourceStatus `json:",inline"`
AtProvider ServerlessClusterObservation `json:"atProvider,omitempty"`
}
ServerlessClusterStatus defines the observed state of ServerlessCluster.
func (*ServerlessClusterStatus) DeepCopy ¶
func (in *ServerlessClusterStatus) DeepCopy() *ServerlessClusterStatus
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new ServerlessClusterStatus.
func (*ServerlessClusterStatus) DeepCopyInto ¶
func (in *ServerlessClusterStatus) DeepCopyInto(out *ServerlessClusterStatus)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type StorageInfoInitParameters ¶
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 ¶
func (in *StorageInfoInitParameters) DeepCopy() *StorageInfoInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new StorageInfoInitParameters.
func (*StorageInfoInitParameters) DeepCopyInto ¶
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 ¶
type TLSInitParameters struct {
// List of ACM Certificate Authority Amazon Resource Names (ARNs).
// +listType=set
CertificateAuthorityArns []*string `json:"certificateAuthorityArns,omitempty" tf:"certificate_authority_arns,omitempty"`
}
func (*TLSInitParameters) DeepCopy ¶
func (in *TLSInitParameters) DeepCopy() *TLSInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLSInitParameters.
func (*TLSInitParameters) DeepCopyInto ¶
func (in *TLSInitParameters) DeepCopyInto(out *TLSInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TLSObservation ¶
type TLSObservation struct {
// List of ACM Certificate Authority Amazon Resource Names (ARNs).
// +listType=set
CertificateAuthorityArns []*string `json:"certificateAuthorityArns,omitempty" tf:"certificate_authority_arns,omitempty"`
}
func (*TLSObservation) DeepCopy ¶
func (in *TLSObservation) DeepCopy() *TLSObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLSObservation.
func (*TLSObservation) DeepCopyInto ¶
func (in *TLSObservation) DeepCopyInto(out *TLSObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type TLSParameters ¶
type TLSParameters struct {
// List of ACM Certificate Authority Amazon Resource Names (ARNs).
// +kubebuilder:validation:Optional
// +listType=set
CertificateAuthorityArns []*string `json:"certificateAuthorityArns,omitempty" tf:"certificate_authority_arns,omitempty"`
}
func (*TLSParameters) DeepCopy ¶
func (in *TLSParameters) DeepCopy() *TLSParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new TLSParameters.
func (*TLSParameters) DeepCopyInto ¶
func (in *TLSParameters) DeepCopyInto(out *TLSParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConfigInitParameters ¶
type VPCConfigInitParameters struct {
// References to SecurityGroup in ec2 to populate securityGroupIds.
// +kubebuilder:validation:Optional
SecurityGroupIDRefs []v1.Reference `json:"securityGroupIdRefs,omitempty" tf:"-"`
// Selector for a list of SecurityGroup in ec2 to populate securityGroupIds.
// +kubebuilder:validation:Optional
SecurityGroupIDSelector *v1.Selector `json:"securityGroupIdSelector,omitempty" tf:"-"`
// Specifies up to five security groups that control inbound and outbound traffic for the serverless cluster.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.SecurityGroup
// +crossplane:generate:reference:refFieldName=SecurityGroupIDRefs
// +crossplane:generate:reference:selectorFieldName=SecurityGroupIDSelector
// +listType=set
SecurityGroupIds []*string `json:"securityGroupIds,omitempty" tf:"security_group_ids,omitempty"`
// References to Subnet in ec2 to populate subnetIds.
// +kubebuilder:validation:Optional
SubnetIDRefs []v1.Reference `json:"subnetIdRefs,omitempty" tf:"-"`
// Selector for a list of Subnet in ec2 to populate subnetIds.
// +kubebuilder:validation:Optional
SubnetIDSelector *v1.Selector `json:"subnetIdSelector,omitempty" tf:"-"`
// A list of subnets in at least two different Availability Zones that host your client applications.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.Subnet
// +crossplane:generate:reference:refFieldName=SubnetIDRefs
// +crossplane:generate:reference:selectorFieldName=SubnetIDSelector
// +listType=set
SubnetIds []*string `json:"subnetIds,omitempty" tf:"subnet_ids,omitempty"`
}
func (*VPCConfigInitParameters) DeepCopy ¶
func (in *VPCConfigInitParameters) DeepCopy() *VPCConfigInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConfigInitParameters.
func (*VPCConfigInitParameters) DeepCopyInto ¶
func (in *VPCConfigInitParameters) DeepCopyInto(out *VPCConfigInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConfigObservation ¶
type VPCConfigObservation struct {
// Specifies up to five security groups that control inbound and outbound traffic for the serverless cluster.
// +listType=set
SecurityGroupIds []*string `json:"securityGroupIds,omitempty" tf:"security_group_ids,omitempty"`
// A list of subnets in at least two different Availability Zones that host your client applications.
// +listType=set
SubnetIds []*string `json:"subnetIds,omitempty" tf:"subnet_ids,omitempty"`
}
func (*VPCConfigObservation) DeepCopy ¶
func (in *VPCConfigObservation) DeepCopy() *VPCConfigObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConfigObservation.
func (*VPCConfigObservation) DeepCopyInto ¶
func (in *VPCConfigObservation) DeepCopyInto(out *VPCConfigObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConfigParameters ¶
type VPCConfigParameters struct {
// References to SecurityGroup in ec2 to populate securityGroupIds.
// +kubebuilder:validation:Optional
SecurityGroupIDRefs []v1.Reference `json:"securityGroupIdRefs,omitempty" tf:"-"`
// Selector for a list of SecurityGroup in ec2 to populate securityGroupIds.
// +kubebuilder:validation:Optional
SecurityGroupIDSelector *v1.Selector `json:"securityGroupIdSelector,omitempty" tf:"-"`
// Specifies up to five security groups that control inbound and outbound traffic for the serverless cluster.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.SecurityGroup
// +crossplane:generate:reference:refFieldName=SecurityGroupIDRefs
// +crossplane:generate:reference:selectorFieldName=SecurityGroupIDSelector
// +kubebuilder:validation:Optional
// +listType=set
SecurityGroupIds []*string `json:"securityGroupIds,omitempty" tf:"security_group_ids,omitempty"`
// References to Subnet in ec2 to populate subnetIds.
// +kubebuilder:validation:Optional
SubnetIDRefs []v1.Reference `json:"subnetIdRefs,omitempty" tf:"-"`
// Selector for a list of Subnet in ec2 to populate subnetIds.
// +kubebuilder:validation:Optional
SubnetIDSelector *v1.Selector `json:"subnetIdSelector,omitempty" tf:"-"`
// A list of subnets in at least two different Availability Zones that host your client applications.
// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.Subnet
// +crossplane:generate:reference:refFieldName=SubnetIDRefs
// +crossplane:generate:reference:selectorFieldName=SubnetIDSelector
// +kubebuilder:validation:Optional
// +listType=set
SubnetIds []*string `json:"subnetIds,omitempty" tf:"subnet_ids,omitempty"`
}
func (*VPCConfigParameters) DeepCopy ¶
func (in *VPCConfigParameters) DeepCopy() *VPCConfigParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConfigParameters.
func (*VPCConfigParameters) DeepCopyInto ¶
func (in *VPCConfigParameters) DeepCopyInto(out *VPCConfigParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConnectivityInitParameters ¶
type VPCConnectivityInitParameters struct {
// Configuration block for specifying a client authentication. See below.
ClientAuthentication []ClientAuthenticationInitParameters `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"`
}
func (*VPCConnectivityInitParameters) DeepCopy ¶
func (in *VPCConnectivityInitParameters) DeepCopy() *VPCConnectivityInitParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConnectivityInitParameters.
func (*VPCConnectivityInitParameters) DeepCopyInto ¶
func (in *VPCConnectivityInitParameters) DeepCopyInto(out *VPCConnectivityInitParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConnectivityObservation ¶
type VPCConnectivityObservation struct {
// Configuration block for specifying a client authentication. See below.
ClientAuthentication []ClientAuthenticationObservation `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"`
}
func (*VPCConnectivityObservation) DeepCopy ¶
func (in *VPCConnectivityObservation) DeepCopy() *VPCConnectivityObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConnectivityObservation.
func (*VPCConnectivityObservation) DeepCopyInto ¶
func (in *VPCConnectivityObservation) DeepCopyInto(out *VPCConnectivityObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConnectivityParameters ¶
type VPCConnectivityParameters struct {
// Configuration block for specifying a client authentication. See below.
// +kubebuilder:validation:Optional
ClientAuthentication []ClientAuthenticationParameters `json:"clientAuthentication,omitempty" tf:"client_authentication,omitempty"`
}
func (*VPCConnectivityParameters) DeepCopy ¶
func (in *VPCConnectivityParameters) DeepCopy() *VPCConnectivityParameters
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConnectivityParameters.
func (*VPCConnectivityParameters) DeepCopyInto ¶
func (in *VPCConnectivityParameters) DeepCopyInto(out *VPCConnectivityParameters)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.