v1alpha1

package
v0.27.1 Latest Latest
Warning

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

 Go to latest Published: Jun 10, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CRDGroup   = "kafka.aws.crossplane.io"
	CRDVersion = "v1alpha1"
)

Package type metadata.

Variables

View Source 
var (
	ClusterKind             = "Cluster"
	ClusterGroupKind        = schema.GroupKind{Group: CRDGroup, Kind: ClusterKind}.String()
	ClusterKindAPIVersion   = ClusterKind + "." + GroupVersion.String()
	ClusterGroupVersionKind = GroupVersion.WithKind(ClusterKind)
)

Repository type metadata.

View Source 
var (
	ConfigurationKind             = "Configuration"
	ConfigurationGroupKind        = schema.GroupKind{Group: CRDGroup, Kind: ConfigurationKind}.String()
	ConfigurationKindAPIVersion   = ConfigurationKind + "." + GroupVersion.String()
	ConfigurationGroupVersionKind = GroupVersion.WithKind(ConfigurationKind)
)

Repository type metadata.

View Source 
var (
	// GroupVersion is the API Group Version used to register the objects
	GroupVersion = schema.GroupVersion{Group: CRDGroup, Version: CRDVersion}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type BrokerAZDistribution 

type BrokerAZDistribution string
const (
	BrokerAZDistribution_DEFAULT BrokerAZDistribution = "DEFAULT"
)

type BrokerEBSVolumeInfo 

type BrokerEBSVolumeInfo struct {
	KafkaBrokerNodeID *string `json:"kafkaBrokerNodeID,omitempty"`

	VolumeSizeGB *int64 `json:"volumeSizeGB,omitempty"`
}

+kubebuilder:skipversion

func (*BrokerEBSVolumeInfo) DeepCopy 

func (in *BrokerEBSVolumeInfo) DeepCopy() *BrokerEBSVolumeInfo

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

func (*BrokerEBSVolumeInfo) DeepCopyInto 

func (in *BrokerEBSVolumeInfo) DeepCopyInto(out *BrokerEBSVolumeInfo)

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

type BrokerLogs 

type BrokerLogs struct {
	// Details of the CloudWatch Logs destination for broker logs.
	CloudWatchLogs *CloudWatchLogs `json:"cloudWatchLogs,omitempty"`
	// Firehose details for BrokerLogs.
	Firehose *Firehose `json:"firehose,omitempty"`
	// The details of the Amazon S3 destination for broker logs.
	S3 *S3 `json:"s3,omitempty"`
}

+kubebuilder:skipversion

func (*BrokerLogs) DeepCopy 

func (in *BrokerLogs) DeepCopy() *BrokerLogs

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

func (*BrokerLogs) DeepCopyInto 

func (in *BrokerLogs) DeepCopyInto(out *BrokerLogs)

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

type BrokerNodeGroupInfo 

type BrokerNodeGroupInfo struct {
	// The distribution of broker nodes across Availability Zones. By default, broker
	// nodes are distributed among the Availability Zones of your Region. Currently,
	// the only supported value is DEFAULT. You can either specify this value explicitly
	// or leave it out.
	BrokerAZDistribution *string `json:"brokerAZDistribution,omitempty"`

	ClientSubnets []*string `json:"clientSubnets,omitempty"`

	InstanceType *string `json:"instanceType,omitempty"`

	SecurityGroups []*string `json:"securityGroups,omitempty"`
	// Contains information about storage volumes attached to MSK broker nodes.
	StorageInfo *StorageInfo `json:"storageInfo,omitempty"`
}

+kubebuilder:skipversion

func (*BrokerNodeGroupInfo) DeepCopy 

func (in *BrokerNodeGroupInfo) DeepCopy() *BrokerNodeGroupInfo

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

func (*BrokerNodeGroupInfo) DeepCopyInto 

func (in *BrokerNodeGroupInfo) DeepCopyInto(out *BrokerNodeGroupInfo)

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

type BrokerNodeInfo 

type BrokerNodeInfo struct {
	AttachedENIID *string `json:"attachedENIID,omitempty"`

	ClientSubnet *string `json:"clientSubnet,omitempty"`

	ClientVPCIPAddress *string `json:"clientVPCIPAddress,omitempty"`
	// Information about the current software installed on the cluster.
	CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"`

	Endpoints []*string `json:"endpoints,omitempty"`
}

+kubebuilder:skipversion

func (*BrokerNodeInfo) DeepCopy 

func (in *BrokerNodeInfo) DeepCopy() *BrokerNodeInfo

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

func (*BrokerNodeInfo) DeepCopyInto 

func (in *BrokerNodeInfo) DeepCopyInto(out *BrokerNodeInfo)

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

type BrokerSoftwareInfo 

type BrokerSoftwareInfo struct {
	ConfigurationARN *string `json:"configurationARN,omitempty"`

	ConfigurationRevision *int64 `json:"configurationRevision,omitempty"`

	KafkaVersion *string `json:"kafkaVersion,omitempty"`
}

+kubebuilder:skipversion

func (*BrokerSoftwareInfo) DeepCopy 

func (in *BrokerSoftwareInfo) DeepCopy() *BrokerSoftwareInfo

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

func (*BrokerSoftwareInfo) DeepCopyInto 

func (in *BrokerSoftwareInfo) DeepCopyInto(out *BrokerSoftwareInfo)

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

type ClientAuthentication 

type ClientAuthentication struct {
	Sasl *Sasl `json:"sasl,omitempty"`
	// Details for client authentication using TLS.
	TLS *TLS `json:"tls,omitempty"`
	// Contains information about unauthenticated traffic to the cluster.
	Unauthenticated *Unauthenticated `json:"unauthenticated,omitempty"`
}

+kubebuilder:skipversion

func (*ClientAuthentication) DeepCopy 

func (in *ClientAuthentication) DeepCopy() *ClientAuthentication

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

func (*ClientAuthentication) DeepCopyInto 

func (in *ClientAuthentication) DeepCopyInto(out *ClientAuthentication)

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

type ClientBroker 

type ClientBroker string
const (
	ClientBroker_TLS           ClientBroker = "TLS"
	ClientBroker_TLS_PLAINTEXT ClientBroker = "TLS_PLAINTEXT"
	ClientBroker_PLAINTEXT     ClientBroker = "PLAINTEXT"
)

type CloudWatchLogs 

type CloudWatchLogs struct {
	Enabled *bool `json:"enabled,omitempty"`

	LogGroup *string `json:"logGroup,omitempty"`
}

+kubebuilder:skipversion

func (*CloudWatchLogs) DeepCopy 

func (in *CloudWatchLogs) DeepCopy() *CloudWatchLogs

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

func (*CloudWatchLogs) DeepCopyInto 

func (in *CloudWatchLogs) DeepCopyInto(out *CloudWatchLogs)

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"`
	Spec              ClusterSpec   `json:"spec"`
	Status            ClusterStatus `json:"status,omitempty"`
}

Cluster is the Schema for the Clusters API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}

func (*Cluster) DeepCopy 

func (in *Cluster) DeepCopy() *Cluster

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

func (*Cluster) DeepCopyInto 

func (in *Cluster) DeepCopyInto(out *Cluster)

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

func (*Cluster) DeepCopyObject 

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

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) GetDeletionPolicy 

func (mg *Cluster) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Cluster.

func (*Cluster) GetProviderConfigReference 

func (mg *Cluster) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Cluster.

func (*Cluster) GetProviderReference 

func (mg *Cluster) GetProviderReference() *xpv1.Reference

GetProviderReference of this Cluster. Deprecated: Use GetProviderConfigReference.

func (*Cluster) GetPublishConnectionDetailsTo added in v0.26.0 

func (mg *Cluster) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Cluster.

func (*Cluster) GetWriteConnectionSecretToReference 

func (mg *Cluster) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Cluster.

func (*Cluster) ResolveReferences added in v0.23.0 

func (mg *Cluster) ResolveReferences(ctx context.Context, c client.Reader) error

ResolveReferences of this Cluster.

func (*Cluster) SetConditions 

func (mg *Cluster) SetConditions(c ...xpv1.Condition)

SetConditions of this Cluster.

func (*Cluster) SetDeletionPolicy 

func (mg *Cluster) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Cluster.

func (*Cluster) SetProviderConfigReference 

func (mg *Cluster) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Cluster.

func (*Cluster) SetProviderReference 

func (mg *Cluster) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this Cluster. Deprecated: Use SetProviderConfigReference.

func (*Cluster) SetPublishConnectionDetailsTo added in v0.26.0 

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 ClusterInfo 

type ClusterInfo struct {
	ActiveOperationARN *string `json:"activeOperationARN,omitempty"`
	// Describes the setup to be used for Kafka broker nodes in the cluster.
	BrokerNodeGroupInfo *BrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"`
	// Includes all client authentication information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`

	ClusterARN *string `json:"clusterARN,omitempty"`

	ClusterName *string `json:"clusterName,omitempty"`

	CreationTime *metav1.Time `json:"creationTime,omitempty"`
	// Information about the current software installed on the cluster.
	CurrentBrokerSoftwareInfo *BrokerSoftwareInfo `json:"currentBrokerSoftwareInfo,omitempty"`

	CurrentVersion *string `json:"currentVersion,omitempty"`
	// Includes encryption-related information, such as the AWS KMS key used for
	// encrypting data at rest and whether you want MSK to encrypt your data in
	// transit.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies which metrics are gathered for the MSK cluster. This property has
	// the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER,
	// and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each
	// of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`
	// You can configure your MSK cluster to send broker logs to different destination
	// types. This is a container for the configuration details related to broker
	// logs.
	LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"`

	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoring `json:"openMonitoring,omitempty"`
	// The state of a Kafka cluster.
	State *string `json:"state,omitempty"`
	// Contains information about the state of the Amazon MSK cluster.
	StateInfo *StateInfo `json:"stateInfo,omitempty"`

	Tags map[string]*string `json:"tags,omitempty"`

	ZookeeperConnectString *string `json:"zookeeperConnectString,omitempty"`

	ZookeeperConnectStringTLS *string `json:"zookeeperConnectStringTLS,omitempty"`
}

+kubebuilder:skipversion

func (*ClusterInfo) DeepCopy 

func (in *ClusterInfo) DeepCopy() *ClusterInfo

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

func (*ClusterInfo) DeepCopyInto 

func (in *ClusterInfo) DeepCopyInto(out *ClusterInfo)

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 {
	// The Amazon Resource Name (ARN) of the cluster.
	ClusterARN *string `json:"clusterARN,omitempty"`
	// The name of the MSK cluster.
	ClusterName *string `json:"clusterName,omitempty"`
	// The state of the cluster. The possible states are ACTIVE, CREATING, DELETING,
	// FAILED, HEALING, MAINTENANCE, REBOOTING_BROKER, and UPDATING.
	State *string `json:"state,omitempty"`
}

ClusterObservation defines the observed state of Cluster

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 ClusterOperationInfo 

type ClusterOperationInfo struct {
	ClientRequestID *string `json:"clientRequestID,omitempty"`

	ClusterARN *string `json:"clusterARN,omitempty"`

	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	EndTime *metav1.Time `json:"endTime,omitempty"`

	OperationARN *string `json:"operationARN,omitempty"`

	OperationState *string `json:"operationState,omitempty"`

	OperationType *string `json:"operationType,omitempty"`
}

+kubebuilder:skipversion

func (*ClusterOperationInfo) DeepCopy 

func (in *ClusterOperationInfo) DeepCopy() *ClusterOperationInfo

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

func (*ClusterOperationInfo) DeepCopyInto 

func (in *ClusterOperationInfo) DeepCopyInto(out *ClusterOperationInfo)

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

type ClusterOperationStep 

type ClusterOperationStep struct {
	StepName *string `json:"stepName,omitempty"`
}

+kubebuilder:skipversion

func (*ClusterOperationStep) DeepCopy 

func (in *ClusterOperationStep) DeepCopy() *ClusterOperationStep

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

func (*ClusterOperationStep) DeepCopyInto 

func (in *ClusterOperationStep) DeepCopyInto(out *ClusterOperationStep)

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

type ClusterOperationStepInfo 

type ClusterOperationStepInfo struct {
	StepStatus *string `json:"stepStatus,omitempty"`
}

+kubebuilder:skipversion

func (*ClusterOperationStepInfo) DeepCopy 

func (in *ClusterOperationStepInfo) DeepCopy() *ClusterOperationStepInfo

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

func (*ClusterOperationStepInfo) DeepCopyInto 

func (in *ClusterOperationStepInfo) DeepCopyInto(out *ClusterOperationStepInfo)

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

type ClusterParameters 

type ClusterParameters struct {
	// Region is which region the Cluster will be created.
	// +kubebuilder:validation:Required
	Region string `json:"region"`
	// Includes all client authentication related information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`
	// Includes all encryption-related information.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies the level of monitoring for the MSK cluster. The possible values
	// are DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER, and PER_TOPIC_PER_PARTITION.
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`
	// The version of Apache Kafka.
	// +kubebuilder:validation:Required
	KafkaVersion *string `json:"kafkaVersion"`
	// LoggingInfo details.
	LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"`
	// The number of Kafka broker nodes in the Amazon MSK cluster.
	// +kubebuilder:validation:Required
	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes"`
	// The settings for open monitoring.
	OpenMonitoring *OpenMonitoringInfo `json:"openMonitoring,omitempty"`
	// Create tags when creating the cluster.
	Tags                    map[string]*string `json:"tags,omitempty"`
	CustomClusterParameters `json:",inline"`
}

ClusterParameters defines the desired state of Cluster

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 {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       ClusterParameters `json:"forProvider"`
}

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 ClusterState 

type ClusterState string
const (
	ClusterState_ACTIVE           ClusterState = "ACTIVE"
	ClusterState_CREATING         ClusterState = "CREATING"
	ClusterState_DELETING         ClusterState = "DELETING"
	ClusterState_FAILED           ClusterState = "FAILED"
	ClusterState_HEALING          ClusterState = "HEALING"
	ClusterState_MAINTENANCE      ClusterState = "MAINTENANCE"
	ClusterState_REBOOTING_BROKER ClusterState = "REBOOTING_BROKER"
	ClusterState_UPDATING         ClusterState = "UPDATING"
)

type ClusterStatus 

type ClusterStatus struct {
	xpv1.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 CompatibleKafkaVersion 

type CompatibleKafkaVersion struct {
	SourceVersion *string `json:"sourceVersion,omitempty"`

	TargetVersions []*string `json:"targetVersions,omitempty"`
}

+kubebuilder:skipversion

func (*CompatibleKafkaVersion) DeepCopy 

func (in *CompatibleKafkaVersion) DeepCopy() *CompatibleKafkaVersion

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

func (*CompatibleKafkaVersion) DeepCopyInto 

func (in *CompatibleKafkaVersion) DeepCopyInto(out *CompatibleKafkaVersion)

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

type Configuration 

type Configuration struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ConfigurationSpec   `json:"spec"`
	Status            ConfigurationStatus `json:"status,omitempty"`
}

Configuration is the Schema for the Configurations API +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:subresource:status +kubebuilder:storageversion +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}

func (*Configuration) DeepCopy 

func (in *Configuration) DeepCopy() *Configuration

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

func (*Configuration) DeepCopyInto 

func (in *Configuration) DeepCopyInto(out *Configuration)

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

func (*Configuration) DeepCopyObject added in v0.23.0 

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

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

func (*Configuration) GetCondition added in v0.23.0 

func (mg *Configuration) GetCondition(ct xpv1.ConditionType) xpv1.Condition

GetCondition of this Configuration.

func (*Configuration) GetDeletionPolicy added in v0.23.0 

func (mg *Configuration) GetDeletionPolicy() xpv1.DeletionPolicy

GetDeletionPolicy of this Configuration.

func (*Configuration) GetProviderConfigReference added in v0.23.0 

func (mg *Configuration) GetProviderConfigReference() *xpv1.Reference

GetProviderConfigReference of this Configuration.

func (*Configuration) GetProviderReference added in v0.23.0 

func (mg *Configuration) GetProviderReference() *xpv1.Reference

GetProviderReference of this Configuration. Deprecated: Use GetProviderConfigReference.

func (*Configuration) GetPublishConnectionDetailsTo added in v0.26.0 

func (mg *Configuration) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo

GetPublishConnectionDetailsTo of this Configuration.

func (*Configuration) GetWriteConnectionSecretToReference added in v0.23.0 

func (mg *Configuration) GetWriteConnectionSecretToReference() *xpv1.SecretReference

GetWriteConnectionSecretToReference of this Configuration.

func (*Configuration) SetConditions added in v0.23.0 

func (mg *Configuration) SetConditions(c ...xpv1.Condition)

SetConditions of this Configuration.

func (*Configuration) SetDeletionPolicy added in v0.23.0 

func (mg *Configuration) SetDeletionPolicy(r xpv1.DeletionPolicy)

SetDeletionPolicy of this Configuration.

func (*Configuration) SetProviderConfigReference added in v0.23.0 

func (mg *Configuration) SetProviderConfigReference(r *xpv1.Reference)

SetProviderConfigReference of this Configuration.

func (*Configuration) SetProviderReference added in v0.23.0 

func (mg *Configuration) SetProviderReference(r *xpv1.Reference)

SetProviderReference of this Configuration. Deprecated: Use SetProviderConfigReference.

func (*Configuration) SetPublishConnectionDetailsTo added in v0.26.0 

func (mg *Configuration) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)

SetPublishConnectionDetailsTo of this Configuration.

func (*Configuration) SetWriteConnectionSecretToReference added in v0.23.0 

func (mg *Configuration) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)

SetWriteConnectionSecretToReference of this Configuration.

type ConfigurationInfo 

type ConfigurationInfo struct {
	ARN *string `json:"arn,omitempty"`

	Revision *int64 `json:"revision,omitempty"`
}

+kubebuilder:skipversion

func (*ConfigurationInfo) DeepCopy 

func (in *ConfigurationInfo) DeepCopy() *ConfigurationInfo

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

func (*ConfigurationInfo) DeepCopyInto 

func (in *ConfigurationInfo) DeepCopyInto(out *ConfigurationInfo)

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

type ConfigurationList added in v0.23.0 

type ConfigurationList struct {
	metav1.TypeMeta `json:",inline"`
	metav1.ListMeta `json:"metadata,omitempty"`
	Items           []Configuration `json:"items"`
}

ConfigurationList contains a list of Configurations

func (*ConfigurationList) DeepCopy added in v0.23.0 

func (in *ConfigurationList) DeepCopy() *ConfigurationList

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

func (*ConfigurationList) DeepCopyInto added in v0.23.0 

func (in *ConfigurationList) DeepCopyInto(out *ConfigurationList)

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

func (*ConfigurationList) DeepCopyObject added in v0.23.0 

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

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

func (*ConfigurationList) GetItems added in v0.23.0 

func (l *ConfigurationList) GetItems() []resource.Managed

GetItems of this ConfigurationList.

type ConfigurationObservation added in v0.23.0 

type ConfigurationObservation struct {
	// The Amazon Resource Name (ARN) of the configuration.
	ARN *string `json:"arn,omitempty"`
	// The time when the configuration was created.
	CreationTime *metav1.Time `json:"creationTime,omitempty"`
	// Latest revision of the configuration.
	LatestRevision *ConfigurationRevision `json:"latestRevision,omitempty"`
	// The name of the configuration. Configuration names are strings that match
	// the regex "^[0-9A-Za-z-]+$".
	Name *string `json:"name,omitempty"`
	// The state of the configuration. The possible states are ACTIVE, DELETING
	// and DELETE_FAILED.
	State *string `json:"state,omitempty"`
}

ConfigurationObservation defines the observed state of Configuration

func (*ConfigurationObservation) DeepCopy added in v0.23.0 

func (in *ConfigurationObservation) DeepCopy() *ConfigurationObservation

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

func (*ConfigurationObservation) DeepCopyInto added in v0.23.0 

func (in *ConfigurationObservation) DeepCopyInto(out *ConfigurationObservation)

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

type ConfigurationParameters added in v0.23.0 

type ConfigurationParameters struct {
	// Region is which region the Configuration will be created.
	// +kubebuilder:validation:Required
	Region string `json:"region"`
	// The description of the configuration.
	Description *string `json:"description,omitempty"`
	// The versions of Apache Kafka with which you can use this MSK configuration.
	KafkaVersions                 []*string `json:"kafkaVersions,omitempty"`
	CustomConfigurationParameters `json:",inline"`
}

ConfigurationParameters defines the desired state of Configuration

func (*ConfigurationParameters) DeepCopy added in v0.23.0 

func (in *ConfigurationParameters) DeepCopy() *ConfigurationParameters

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

func (*ConfigurationParameters) DeepCopyInto added in v0.23.0 

func (in *ConfigurationParameters) DeepCopyInto(out *ConfigurationParameters)

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

type ConfigurationRevision 

type ConfigurationRevision struct {
	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	Description *string `json:"description,omitempty"`

	Revision *int64 `json:"revision,omitempty"`
}

+kubebuilder:skipversion

func (*ConfigurationRevision) DeepCopy 

func (in *ConfigurationRevision) DeepCopy() *ConfigurationRevision

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

func (*ConfigurationRevision) DeepCopyInto 

func (in *ConfigurationRevision) DeepCopyInto(out *ConfigurationRevision)

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

type ConfigurationSpec added in v0.23.0 

type ConfigurationSpec struct {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       ConfigurationParameters `json:"forProvider"`
}

ConfigurationSpec defines the desired state of Configuration

func (*ConfigurationSpec) DeepCopy added in v0.23.0 

func (in *ConfigurationSpec) DeepCopy() *ConfigurationSpec

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

func (*ConfigurationSpec) DeepCopyInto added in v0.23.0 

func (in *ConfigurationSpec) DeepCopyInto(out *ConfigurationSpec)

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

type ConfigurationState 

type ConfigurationState string
const (
	ConfigurationState_ACTIVE        ConfigurationState = "ACTIVE"
	ConfigurationState_DELETING      ConfigurationState = "DELETING"
	ConfigurationState_DELETE_FAILED ConfigurationState = "DELETE_FAILED"
)

type ConfigurationStatus added in v0.23.0 

type ConfigurationStatus struct {
	xpv1.ResourceStatus `json:",inline"`
	AtProvider          ConfigurationObservation `json:"atProvider,omitempty"`
}

ConfigurationStatus defines the observed state of Configuration.

func (*ConfigurationStatus) DeepCopy added in v0.23.0 

func (in *ConfigurationStatus) DeepCopy() *ConfigurationStatus

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

func (*ConfigurationStatus) DeepCopyInto added in v0.23.0 

func (in *ConfigurationStatus) DeepCopyInto(out *ConfigurationStatus)

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

type Configuration_SDK added in v0.23.0 

type Configuration_SDK struct {
	ARN *string `json:"arn,omitempty"`

	CreationTime *metav1.Time `json:"creationTime,omitempty"`

	Description *string `json:"description,omitempty"`

	KafkaVersions []*string `json:"kafkaVersions,omitempty"`
	// Describes a configuration revision.
	LatestRevision *ConfigurationRevision `json:"latestRevision,omitempty"`

	Name *string `json:"name,omitempty"`
	// The state of a configuration.
	State *string `json:"state,omitempty"`
}

+kubebuilder:skipversion

func (*Configuration_SDK) DeepCopy added in v0.23.0 

func (in *Configuration_SDK) DeepCopy() *Configuration_SDK

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

func (*Configuration_SDK) DeepCopyInto added in v0.23.0 

func (in *Configuration_SDK) DeepCopyInto(out *Configuration_SDK)

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

type CustomBrokerNodeGroupInfo added in v0.23.0 

type CustomBrokerNodeGroupInfo struct {
	// +optional
	// +crossplane:generate:reference:type=github.com/crossplane/provider-aws/apis/ec2/v1beta1.Subnet
	// +crossplane:generate:reference:refFieldName=ClientSubnetRefs
	// +crossplane:generate:reference:selectorFieldName=ClientSubnetSelector
	ClientSubnets []*string `json:"clientSubnets,omitempty"`

	// ClientSubnetRefs is a list of references to Subnets used to set
	// the ClientSubnets.
	// +optional
	ClientSubnetRefs []xpv1.Reference `json:"clientSubnetRefs,omitempty"`

	// ClientSubnetSelector selects references to Subnets used
	// to set the ClientSubnets.
	// +optional
	ClientSubnetSelector *xpv1.Selector `json:"clientSubnetSelector,omitempty"`

	InstanceType *string `json:"instanceType,omitempty"`

	// +optional
	// +crossplane:generate:reference:type=github.com/crossplane/provider-aws/apis/ec2/v1beta1.SecurityGroup
	// +crossplane:generate:reference:refFieldName=SecurityGroupRefs
	// +crossplane:generate:reference:selectorFieldName=SecurityGroupSelector
	SecurityGroups []*string `json:"securityGroups,omitempty"`

	// SecurityGroupRefs is a list of references to SecurityGroups used to set
	// the SecurityGroups.
	// +optional
	SecurityGroupRefs []xpv1.Reference `json:"securityGroupRefs,omitempty"`

	// SecurityGroupSelector selects references to SecurityGroup used
	// to set the SecurityGroups.
	// +optional
	SecurityGroupSelector *xpv1.Selector `json:"securityGroupSelector,omitempty"`

	// Contains information about storage volumes attached to MSK broker nodes.
	StorageInfo *StorageInfo `json:"storageInfo,omitempty"`
}

CustomBrokerNodeGroupInfo contains the additional fields for BrokerNodeGroupInfo.

func (*CustomBrokerNodeGroupInfo) DeepCopy added in v0.23.0 

func (in *CustomBrokerNodeGroupInfo) DeepCopy() *CustomBrokerNodeGroupInfo

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

func (*CustomBrokerNodeGroupInfo) DeepCopyInto added in v0.23.0 

func (in *CustomBrokerNodeGroupInfo) DeepCopyInto(out *CustomBrokerNodeGroupInfo)

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

type CustomClusterParameters 

type CustomClusterParameters struct {
	// Information about the brokers
	CustomBrokerNodeGroupInfo *CustomBrokerNodeGroupInfo `json:"brokerNodeGroupInfo,omitempty"`

	// Represents the configuration that you want MSK to use for the cluster.
	CustomConfigurationInfo *CustomConfigurationInfo `json:"configurationInfo,omitempty"`
}

CustomClusterParameters contains the additional fields for ClusterParameters.

func (*CustomClusterParameters) DeepCopy 

func (in *CustomClusterParameters) DeepCopy() *CustomClusterParameters

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

func (*CustomClusterParameters) DeepCopyInto 

func (in *CustomClusterParameters) DeepCopyInto(out *CustomClusterParameters)

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

type CustomConfigurationInfo added in v0.23.0 

type CustomConfigurationInfo struct {
	// ARN of the configuration to use.
	// +optional
	// +crossplane:generate:reference:type=Configuration
	ARN *string `json:"arn,omitempty"`

	// ARNRef is a reference to a Kafka Configuration used to set ARN.
	// +optional
	ARNRef *xpv1.Reference `json:"arnRef,omitempty"`

	// ARNSelector selects a reference to a Kafka Configuration used to set ARN.
	// +optional
	ARNSelector *xpv1.Selector `json:"arnSelector,omitempty"`

	Revision *int64 `json:"revision,omitempty"`
}

CustomConfigurationInfo contains the additional fields for ConfigurationInfo.

func (*CustomConfigurationInfo) DeepCopy added in v0.23.0 

func (in *CustomConfigurationInfo) DeepCopy() *CustomConfigurationInfo

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

func (*CustomConfigurationInfo) DeepCopyInto added in v0.23.0 

func (in *CustomConfigurationInfo) DeepCopyInto(out *CustomConfigurationInfo)

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

type CustomConfigurationParameters added in v0.23.0 

type CustomConfigurationParameters struct {
	// kafka server configurations
	Properties []string `json:"properties"`
}

CustomConfigurationParameters contains the additional fields for ConfigurationParameters.

func (*CustomConfigurationParameters) DeepCopy added in v0.23.0 

func (in *CustomConfigurationParameters) DeepCopy() *CustomConfigurationParameters

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

func (*CustomConfigurationParameters) DeepCopyInto added in v0.23.0 

func (in *CustomConfigurationParameters) DeepCopyInto(out *CustomConfigurationParameters)

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

type EBSStorageInfo 

type EBSStorageInfo struct {
	VolumeSize *int64 `json:"volumeSize,omitempty"`
}

+kubebuilder:skipversion

func (*EBSStorageInfo) DeepCopy 

func (in *EBSStorageInfo) DeepCopy() *EBSStorageInfo

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

func (*EBSStorageInfo) DeepCopyInto 

func (in *EBSStorageInfo) DeepCopyInto(out *EBSStorageInfo)

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

type EncryptionAtRest 

type EncryptionAtRest struct {
	DataVolumeKMSKeyID *string `json:"dataVolumeKMSKeyID,omitempty"`
}

+kubebuilder:skipversion

func (*EncryptionAtRest) DeepCopy 

func (in *EncryptionAtRest) DeepCopy() *EncryptionAtRest

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

func (*EncryptionAtRest) DeepCopyInto 

func (in *EncryptionAtRest) DeepCopyInto(out *EncryptionAtRest)

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

type EncryptionInTransit 

type EncryptionInTransit struct {
	// Client-broker encryption in transit setting.
	ClientBroker *string `json:"clientBroker,omitempty"`

	InCluster *bool `json:"inCluster,omitempty"`
}

+kubebuilder:skipversion

func (*EncryptionInTransit) DeepCopy 

func (in *EncryptionInTransit) DeepCopy() *EncryptionInTransit

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

func (*EncryptionInTransit) DeepCopyInto 

func (in *EncryptionInTransit) DeepCopyInto(out *EncryptionInTransit)

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

type EncryptionInfo 

type EncryptionInfo struct {
	// The data-volume encryption details.
	EncryptionAtRest *EncryptionAtRest `json:"encryptionAtRest,omitempty"`
	// The settings for encrypting data in transit.
	EncryptionInTransit *EncryptionInTransit `json:"encryptionInTransit,omitempty"`
}

+kubebuilder:skipversion

func (*EncryptionInfo) DeepCopy 

func (in *EncryptionInfo) DeepCopy() *EncryptionInfo

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

func (*EncryptionInfo) DeepCopyInto 

func (in *EncryptionInfo) DeepCopyInto(out *EncryptionInfo)

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

type EnhancedMonitoring 

type EnhancedMonitoring string
const (
	EnhancedMonitoring_DEFAULT                 EnhancedMonitoring = "DEFAULT"
	EnhancedMonitoring_PER_BROKER              EnhancedMonitoring = "PER_BROKER"
	EnhancedMonitoring_PER_TOPIC_PER_BROKER    EnhancedMonitoring = "PER_TOPIC_PER_BROKER"
	EnhancedMonitoring_PER_TOPIC_PER_PARTITION EnhancedMonitoring = "PER_TOPIC_PER_PARTITION"
)

type ErrorInfo 

type ErrorInfo struct {
	ErrorCode *string `json:"errorCode,omitempty"`

	ErrorString *string `json:"errorString,omitempty"`
}

+kubebuilder:skipversion

func (*ErrorInfo) DeepCopy 

func (in *ErrorInfo) DeepCopy() *ErrorInfo

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

func (*ErrorInfo) DeepCopyInto 

func (in *ErrorInfo) DeepCopyInto(out *ErrorInfo)

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

type Firehose 

type Firehose struct {
	DeliveryStream *string `json:"deliveryStream,omitempty"`

	Enabled *bool `json:"enabled,omitempty"`
}

+kubebuilder:skipversion

func (*Firehose) DeepCopy 

func (in *Firehose) DeepCopy() *Firehose

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

func (*Firehose) DeepCopyInto 

func (in *Firehose) DeepCopyInto(out *Firehose)

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

type IAM added in v0.25.0 

type IAM struct {
	Enabled *bool `json:"enabled,omitempty"`
}

+kubebuilder:skipversion

func (*IAM) DeepCopy added in v0.25.0 

func (in *IAM) DeepCopy() *IAM

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

func (*IAM) DeepCopyInto added in v0.25.0 

func (in *IAM) DeepCopyInto(out *IAM)

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

type JmxExporter 

type JmxExporter struct {
	EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}

+kubebuilder:skipversion

func (*JmxExporter) DeepCopy 

func (in *JmxExporter) DeepCopy() *JmxExporter

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

func (*JmxExporter) DeepCopyInto 

func (in *JmxExporter) DeepCopyInto(out *JmxExporter)

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

type JmxExporterInfo 

type JmxExporterInfo struct {
	EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}

+kubebuilder:skipversion

func (*JmxExporterInfo) DeepCopy 

func (in *JmxExporterInfo) DeepCopy() *JmxExporterInfo

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

func (*JmxExporterInfo) DeepCopyInto 

func (in *JmxExporterInfo) DeepCopyInto(out *JmxExporterInfo)

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

type KafkaVersion 

type KafkaVersion struct {
	Version *string `json:"version,omitempty"`
}

+kubebuilder:skipversion

func (*KafkaVersion) DeepCopy 

func (in *KafkaVersion) DeepCopy() *KafkaVersion

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

func (*KafkaVersion) DeepCopyInto 

func (in *KafkaVersion) DeepCopyInto(out *KafkaVersion)

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

type KafkaVersionStatus 

type KafkaVersionStatus string
const (
	KafkaVersionStatus_ACTIVE     KafkaVersionStatus = "ACTIVE"
	KafkaVersionStatus_DEPRECATED KafkaVersionStatus = "DEPRECATED"
)

type LoggingInfo 

type LoggingInfo struct {
	// The broker logs configuration for this MSK cluster.
	BrokerLogs *BrokerLogs `json:"brokerLogs,omitempty"`
}

+kubebuilder:skipversion

func (*LoggingInfo) DeepCopy 

func (in *LoggingInfo) DeepCopy() *LoggingInfo

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

func (*LoggingInfo) DeepCopyInto 

func (in *LoggingInfo) DeepCopyInto(out *LoggingInfo)

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

type MutableClusterInfo 

type MutableClusterInfo struct {
	// Includes all client authentication information.
	ClientAuthentication *ClientAuthentication `json:"clientAuthentication,omitempty"`
	// Includes encryption-related information, such as the AWS KMS key used for
	// encrypting data at rest and whether you want MSK to encrypt your data in
	// transit.
	EncryptionInfo *EncryptionInfo `json:"encryptionInfo,omitempty"`
	// Specifies which metrics are gathered for the MSK cluster. This property has
	// the following possible values: DEFAULT, PER_BROKER, PER_TOPIC_PER_BROKER,
	// and PER_TOPIC_PER_PARTITION. For a list of the metrics associated with each
	// of these levels of monitoring, see Monitoring (https://docs.aws.amazon.com/msk/latest/developerguide/monitoring.html).
	EnhancedMonitoring *string `json:"enhancedMonitoring,omitempty"`

	InstanceType *string `json:"instanceType,omitempty"`

	KafkaVersion *string `json:"kafkaVersion,omitempty"`
	// You can configure your MSK cluster to send broker logs to different destination
	// types. This is a container for the configuration details related to broker
	// logs.
	LoggingInfo *LoggingInfo `json:"loggingInfo,omitempty"`

	NumberOfBrokerNodes *int64 `json:"numberOfBrokerNodes,omitempty"`
	// JMX and Node monitoring for the MSK cluster.
	OpenMonitoring *OpenMonitoring `json:"openMonitoring,omitempty"`
}

+kubebuilder:skipversion

func (*MutableClusterInfo) DeepCopy 

func (in *MutableClusterInfo) DeepCopy() *MutableClusterInfo

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

func (*MutableClusterInfo) DeepCopyInto 

func (in *MutableClusterInfo) DeepCopyInto(out *MutableClusterInfo)

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

type NodeExporter 

type NodeExporter struct {
	EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}

+kubebuilder:skipversion

func (*NodeExporter) DeepCopy 

func (in *NodeExporter) DeepCopy() *NodeExporter

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

func (*NodeExporter) DeepCopyInto 

func (in *NodeExporter) DeepCopyInto(out *NodeExporter)

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

type NodeExporterInfo 

type NodeExporterInfo struct {
	EnabledInBroker *bool `json:"enabledInBroker,omitempty"`
}

+kubebuilder:skipversion

func (*NodeExporterInfo) DeepCopy 

func (in *NodeExporterInfo) DeepCopy() *NodeExporterInfo

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

func (*NodeExporterInfo) DeepCopyInto 

func (in *NodeExporterInfo) DeepCopyInto(out *NodeExporterInfo)

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

type NodeInfo 

type NodeInfo struct {
	AddedToClusterTime *string `json:"addedToClusterTime,omitempty"`

	InstanceType *string `json:"instanceType,omitempty"`

	NodeARN *string `json:"nodeARN,omitempty"`
}

+kubebuilder:skipversion

func (*NodeInfo) DeepCopy 

func (in *NodeInfo) DeepCopy() *NodeInfo

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

func (*NodeInfo) DeepCopyInto 

func (in *NodeInfo) DeepCopyInto(out *NodeInfo)

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

type NodeType 

type NodeType string
const (
	NodeType_BROKER NodeType = "BROKER"
)

type OpenMonitoring 

type OpenMonitoring struct {
	// Prometheus settings for open monitoring.
	Prometheus *Prometheus `json:"prometheus,omitempty"`
}

+kubebuilder:skipversion

func (*OpenMonitoring) DeepCopy 

func (in *OpenMonitoring) DeepCopy() *OpenMonitoring

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

func (*OpenMonitoring) DeepCopyInto 

func (in *OpenMonitoring) DeepCopyInto(out *OpenMonitoring)

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

type OpenMonitoringInfo 

type OpenMonitoringInfo struct {
	// Prometheus settings.
	Prometheus *PrometheusInfo `json:"prometheus,omitempty"`
}

+kubebuilder:skipversion

func (*OpenMonitoringInfo) DeepCopy 

func (in *OpenMonitoringInfo) DeepCopy() *OpenMonitoringInfo

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

func (*OpenMonitoringInfo) DeepCopyInto 

func (in *OpenMonitoringInfo) DeepCopyInto(out *OpenMonitoringInfo)

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

type Prometheus 

type Prometheus struct {
	// Indicates whether you want to enable or disable the JMX Exporter.
	JmxExporter *JmxExporter `json:"jmxExporter,omitempty"`
	// Indicates whether you want to enable or disable the Node Exporter.
	NodeExporter *NodeExporter `json:"nodeExporter,omitempty"`
}

+kubebuilder:skipversion

func (*Prometheus) DeepCopy 

func (in *Prometheus) DeepCopy() *Prometheus

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

func (*Prometheus) DeepCopyInto 

func (in *Prometheus) DeepCopyInto(out *Prometheus)

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

type PrometheusInfo 

type PrometheusInfo struct {
	// Indicates whether you want to enable or disable the JMX Exporter.
	JmxExporter *JmxExporterInfo `json:"jmxExporter,omitempty"`
	// Indicates whether you want to enable or disable the Node Exporter.
	NodeExporter *NodeExporterInfo `json:"nodeExporter,omitempty"`
}

+kubebuilder:skipversion

func (*PrometheusInfo) DeepCopy 

func (in *PrometheusInfo) DeepCopy() *PrometheusInfo

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

func (*PrometheusInfo) DeepCopyInto 

func (in *PrometheusInfo) DeepCopyInto(out *PrometheusInfo)

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

type S3 

type S3 struct {
	Bucket *string `json:"bucket,omitempty"`

	Enabled *bool `json:"enabled,omitempty"`

	Prefix *string `json:"prefix,omitempty"`
}

+kubebuilder:skipversion

func (*S3) DeepCopy 

func (in *S3) DeepCopy() *S3

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

func (*S3) DeepCopyInto 

func (in *S3) DeepCopyInto(out *S3)

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

type Sasl 

type Sasl struct {
	IAM *IAM `json:"iam,omitempty"`

	Scram *Scram `json:"scram,omitempty"`
}

+kubebuilder:skipversion

func (*Sasl) DeepCopy 

func (in *Sasl) DeepCopy() *Sasl

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

func (*Sasl) DeepCopyInto 

func (in *Sasl) DeepCopyInto(out *Sasl)

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

type Scram 

type Scram struct {
	Enabled *bool `json:"enabled,omitempty"`
}

+kubebuilder:skipversion

func (*Scram) DeepCopy 

func (in *Scram) DeepCopy() *Scram

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

func (*Scram) DeepCopyInto 

func (in *Scram) DeepCopyInto(out *Scram)

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

type StateInfo added in v0.25.0 

type StateInfo struct {
	Code *string `json:"code,omitempty"`

	Message *string `json:"message,omitempty"`
}

+kubebuilder:skipversion

func (*StateInfo) DeepCopy added in v0.25.0 

func (in *StateInfo) DeepCopy() *StateInfo

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

func (*StateInfo) DeepCopyInto added in v0.25.0 

func (in *StateInfo) DeepCopyInto(out *StateInfo)

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

type StorageInfo 

type StorageInfo struct {
	// Contains information about the EBS storage volumes attached to Kafka broker
	// nodes.
	EBSStorageInfo *EBSStorageInfo `json:"ebsStorageInfo,omitempty"`
}

+kubebuilder:skipversion

func (*StorageInfo) DeepCopy 

func (in *StorageInfo) DeepCopy() *StorageInfo

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

func (*StorageInfo) DeepCopyInto 

func (in *StorageInfo) DeepCopyInto(out *StorageInfo)

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

type TLS 

type TLS struct {
	CertificateAuthorityARNList []*string `json:"certificateAuthorityARNList,omitempty"`

	Enabled *bool `json:"enabled,omitempty"`
}

+kubebuilder:skipversion

func (*TLS) DeepCopy 

func (in *TLS) DeepCopy() *TLS

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

func (*TLS) DeepCopyInto 

func (in *TLS) DeepCopyInto(out *TLS)

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

type Unauthenticated added in v0.25.0 

type Unauthenticated struct {
	Enabled *bool `json:"enabled,omitempty"`
}

+kubebuilder:skipversion

func (*Unauthenticated) DeepCopy added in v0.25.0 

func (in *Unauthenticated) DeepCopy() *Unauthenticated

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

func (*Unauthenticated) DeepCopyInto added in v0.25.0 

func (in *Unauthenticated) DeepCopyInto(out *Unauthenticated)

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

type UnprocessedScramSecret 

type UnprocessedScramSecret struct {
	ErrorCode *string `json:"errorCode,omitempty"`

	ErrorMessage *string `json:"errorMessage,omitempty"`

	SecretARN *string `json:"secretARN,omitempty"`
}

+kubebuilder:skipversion

func (*UnprocessedScramSecret) DeepCopy 

func (in *UnprocessedScramSecret) DeepCopy() *UnprocessedScramSecret

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

func (*UnprocessedScramSecret) DeepCopyInto 

func (in *UnprocessedScramSecret) DeepCopyInto(out *UnprocessedScramSecret)

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

type ZookeeperNodeInfo 

type ZookeeperNodeInfo struct {
	AttachedENIID *string `json:"attachedENIID,omitempty"`

	ClientVPCIPAddress *string `json:"clientVPCIPAddress,omitempty"`

	Endpoints []*string `json:"endpoints,omitempty"`

	ZookeeperVersion *string `json:"zookeeperVersion,omitempty"`
}

+kubebuilder:skipversion

func (*ZookeeperNodeInfo) DeepCopy 

func (in *ZookeeperNodeInfo) DeepCopy() *ZookeeperNodeInfo

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

func (*ZookeeperNodeInfo) DeepCopyInto 

func (in *ZookeeperNodeInfo) DeepCopyInto(out *ZookeeperNodeInfo)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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