v1beta1

package
v1.16.0 Latest Latest
Warning

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

Go to latest
Published: Oct 23, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

+kubebuilder:object:generate=true +groupName=kafkaconnect.aws.upbound.io +versionName=v1beta1

Index

Constants

View Source
const (
	CRDGroup   = "kafkaconnect.aws.upbound.io"
	CRDVersion = "v1beta1"
)

Package type metadata.

Variables

View Source
var (
	Connector_Kind             = "Connector"
	Connector_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Connector_Kind}.String()
	Connector_KindAPIVersion   = Connector_Kind + "." + CRDGroupVersion.String()
	Connector_GroupVersionKind = CRDGroupVersion.WithKind(Connector_Kind)
)

Repository type metadata.

View Source
var (
	CustomPlugin_Kind             = "CustomPlugin"
	CustomPlugin_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: CustomPlugin_Kind}.String()
	CustomPlugin_KindAPIVersion   = CustomPlugin_Kind + "." + CRDGroupVersion.String()
	CustomPlugin_GroupVersionKind = CRDGroupVersion.WithKind(CustomPlugin_Kind)
)

Repository type metadata.

View Source
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
)
View Source
var (
	WorkerConfiguration_Kind             = "WorkerConfiguration"
	WorkerConfiguration_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: WorkerConfiguration_Kind}.String()
	WorkerConfiguration_KindAPIVersion   = WorkerConfiguration_Kind + "." + CRDGroupVersion.String()
	WorkerConfiguration_GroupVersionKind = CRDGroupVersion.WithKind(WorkerConfiguration_Kind)
)

Repository type metadata.

Functions

This section is empty.

Types

type ApacheKafkaClusterInitParameters

type ApacheKafkaClusterInitParameters struct {

	// The bootstrap servers of the cluster.
	BootstrapServers *string `json:"bootstrapServers,omitempty" tf:"bootstrap_servers,omitempty"`

	// Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.
	VPC []VPCInitParameters `json:"vpc,omitempty" tf:"vpc,omitempty"`
}

func (*ApacheKafkaClusterInitParameters) DeepCopy

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

func (*ApacheKafkaClusterInitParameters) DeepCopyInto

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

type ApacheKafkaClusterObservation

type ApacheKafkaClusterObservation struct {

	// The bootstrap servers of the cluster.
	BootstrapServers *string `json:"bootstrapServers,omitempty" tf:"bootstrap_servers,omitempty"`

	// Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.
	VPC []VPCObservation `json:"vpc,omitempty" tf:"vpc,omitempty"`
}

func (*ApacheKafkaClusterObservation) DeepCopy

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

func (*ApacheKafkaClusterObservation) DeepCopyInto

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

type ApacheKafkaClusterParameters

type ApacheKafkaClusterParameters struct {

	// The bootstrap servers of the cluster.
	// +kubebuilder:validation:Optional
	BootstrapServers *string `json:"bootstrapServers" tf:"bootstrap_servers,omitempty"`

	// Details of an Amazon VPC which has network connectivity to the Apache Kafka cluster.
	// +kubebuilder:validation:Optional
	VPC []VPCParameters `json:"vpc" tf:"vpc,omitempty"`
}

func (*ApacheKafkaClusterParameters) DeepCopy

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

func (*ApacheKafkaClusterParameters) DeepCopyInto

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

type AutoscalingInitParameters

type AutoscalingInitParameters struct {

	// The maximum number of workers allocated to the connector.
	MaxWorkerCount *float64 `json:"maxWorkerCount,omitempty" tf:"max_worker_count,omitempty"`

	// The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
	McuCount *float64 `json:"mcuCount,omitempty" tf:"mcu_count,omitempty"`

	// The minimum number of workers allocated to the connector.
	MinWorkerCount *float64 `json:"minWorkerCount,omitempty" tf:"min_worker_count,omitempty"`

	// The scale-in policy for the connector. See below.
	ScaleInPolicy []ScaleInPolicyInitParameters `json:"scaleInPolicy,omitempty" tf:"scale_in_policy,omitempty"`

	// The scale-out policy for the connector. See below.
	ScaleOutPolicy []ScaleOutPolicyInitParameters `json:"scaleOutPolicy,omitempty" tf:"scale_out_policy,omitempty"`
}

func (*AutoscalingInitParameters) DeepCopy

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

func (*AutoscalingInitParameters) DeepCopyInto

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

type AutoscalingObservation

type AutoscalingObservation struct {

	// The maximum number of workers allocated to the connector.
	MaxWorkerCount *float64 `json:"maxWorkerCount,omitempty" tf:"max_worker_count,omitempty"`

	// The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
	McuCount *float64 `json:"mcuCount,omitempty" tf:"mcu_count,omitempty"`

	// The minimum number of workers allocated to the connector.
	MinWorkerCount *float64 `json:"minWorkerCount,omitempty" tf:"min_worker_count,omitempty"`

	// The scale-in policy for the connector. See below.
	ScaleInPolicy []ScaleInPolicyObservation `json:"scaleInPolicy,omitempty" tf:"scale_in_policy,omitempty"`

	// The scale-out policy for the connector. See below.
	ScaleOutPolicy []ScaleOutPolicyObservation `json:"scaleOutPolicy,omitempty" tf:"scale_out_policy,omitempty"`
}

func (*AutoscalingObservation) DeepCopy

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

func (*AutoscalingObservation) DeepCopyInto

func (in *AutoscalingObservation) DeepCopyInto(out *AutoscalingObservation)

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

type AutoscalingParameters

type AutoscalingParameters struct {

	// The maximum number of workers allocated to the connector.
	// +kubebuilder:validation:Optional
	MaxWorkerCount *float64 `json:"maxWorkerCount" tf:"max_worker_count,omitempty"`

	// The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
	// +kubebuilder:validation:Optional
	McuCount *float64 `json:"mcuCount,omitempty" tf:"mcu_count,omitempty"`

	// The minimum number of workers allocated to the connector.
	// +kubebuilder:validation:Optional
	MinWorkerCount *float64 `json:"minWorkerCount" tf:"min_worker_count,omitempty"`

	// The scale-in policy for the connector. See below.
	// +kubebuilder:validation:Optional
	ScaleInPolicy []ScaleInPolicyParameters `json:"scaleInPolicy,omitempty" tf:"scale_in_policy,omitempty"`

	// The scale-out policy for the connector. See below.
	// +kubebuilder:validation:Optional
	ScaleOutPolicy []ScaleOutPolicyParameters `json:"scaleOutPolicy,omitempty" tf:"scale_out_policy,omitempty"`
}

func (*AutoscalingParameters) DeepCopy

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

func (*AutoscalingParameters) DeepCopyInto

func (in *AutoscalingParameters) DeepCopyInto(out *AutoscalingParameters)

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

type CapacityInitParameters

type CapacityInitParameters struct {

	// Information about the auto scaling parameters for the connector. See below.
	Autoscaling []AutoscalingInitParameters `json:"autoscaling,omitempty" tf:"autoscaling,omitempty"`

	// Details about a fixed capacity allocated to a connector. See below.
	ProvisionedCapacity []ProvisionedCapacityInitParameters `json:"provisionedCapacity,omitempty" tf:"provisioned_capacity,omitempty"`
}

func (*CapacityInitParameters) DeepCopy

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

func (*CapacityInitParameters) DeepCopyInto

func (in *CapacityInitParameters) DeepCopyInto(out *CapacityInitParameters)

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

type CapacityObservation

type CapacityObservation struct {

	// Information about the auto scaling parameters for the connector. See below.
	Autoscaling []AutoscalingObservation `json:"autoscaling,omitempty" tf:"autoscaling,omitempty"`

	// Details about a fixed capacity allocated to a connector. See below.
	ProvisionedCapacity []ProvisionedCapacityObservation `json:"provisionedCapacity,omitempty" tf:"provisioned_capacity,omitempty"`
}

func (*CapacityObservation) DeepCopy

func (in *CapacityObservation) DeepCopy() *CapacityObservation

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

func (*CapacityObservation) DeepCopyInto

func (in *CapacityObservation) DeepCopyInto(out *CapacityObservation)

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

type CapacityParameters

type CapacityParameters struct {

	// Information about the auto scaling parameters for the connector. See below.
	// +kubebuilder:validation:Optional
	Autoscaling []AutoscalingParameters `json:"autoscaling,omitempty" tf:"autoscaling,omitempty"`

	// Details about a fixed capacity allocated to a connector. See below.
	// +kubebuilder:validation:Optional
	ProvisionedCapacity []ProvisionedCapacityParameters `json:"provisionedCapacity,omitempty" tf:"provisioned_capacity,omitempty"`
}

func (*CapacityParameters) DeepCopy

func (in *CapacityParameters) DeepCopy() *CapacityParameters

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

func (*CapacityParameters) DeepCopyInto

func (in *CapacityParameters) DeepCopyInto(out *CapacityParameters)

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

type CloudwatchLogsInitParameters

type CloudwatchLogsInitParameters struct {

	// Specifies whether connector logs get sent to the specified Amazon S3 destination.
	Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`

	// The name of the CloudWatch log group that is the destination for log delivery.
	// +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

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

func (*CloudwatchLogsInitParameters) DeepCopyInto

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

type CloudwatchLogsObservation

type CloudwatchLogsObservation struct {

	// Specifies whether connector logs get sent to the specified Amazon S3 destination.
	Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`

	// The name of the CloudWatch log group that is the destination for log delivery.
	LogGroup *string `json:"logGroup,omitempty" tf:"log_group,omitempty"`
}

func (*CloudwatchLogsObservation) DeepCopy

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

func (*CloudwatchLogsObservation) DeepCopyInto

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

type CloudwatchLogsParameters

type CloudwatchLogsParameters struct {

	// Specifies whether connector logs get sent to the specified Amazon S3 destination.
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled" tf:"enabled,omitempty"`

	// The name of the CloudWatch log group that is the destination for log delivery.
	// +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

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 Connector

type Connector 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.capacity) || (has(self.initProvider) && has(self.initProvider.capacity))",message="spec.forProvider.capacity is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.connectorConfiguration) || (has(self.initProvider) && has(self.initProvider.connectorConfiguration))",message="spec.forProvider.connectorConfiguration is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.kafkaCluster) || (has(self.initProvider) && has(self.initProvider.kafkaCluster))",message="spec.forProvider.kafkaCluster is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.kafkaClusterClientAuthentication) || (has(self.initProvider) && has(self.initProvider.kafkaClusterClientAuthentication))",message="spec.forProvider.kafkaClusterClientAuthentication is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.kafkaClusterEncryptionInTransit) || (has(self.initProvider) && has(self.initProvider.kafkaClusterEncryptionInTransit))",message="spec.forProvider.kafkaClusterEncryptionInTransit is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.kafkaconnectVersion) || (has(self.initProvider) && has(self.initProvider.kafkaconnectVersion))",message="spec.forProvider.kafkaconnectVersion is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.plugin) || (has(self.initProvider) && has(self.initProvider.plugin))",message="spec.forProvider.plugin is a required parameter"
	Spec   ConnectorSpec   `json:"spec"`
	Status ConnectorStatus `json:"status,omitempty"`
}

Connector is the Schema for the Connectors API. Provides an Amazon MSK Connect Connector resource. Changes to any parameter besides "scaling" will be rejected. Instead you must create a new resource. +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 (*Connector) ConvertFrom added in v1.7.0

func (tr *Connector) ConvertFrom(srcRaw conversion.Hub) error

ConvertFrom converts from the hub type to the Connector type.

func (*Connector) ConvertTo added in v1.7.0

func (tr *Connector) ConvertTo(dstRaw conversion.Hub) error

ConvertTo converts this Connector to the hub type.

func (*Connector) DeepCopy

func (in *Connector) DeepCopy() *Connector

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

func (*Connector) DeepCopyInto

func (in *Connector) DeepCopyInto(out *Connector)

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

func (*Connector) DeepCopyObject

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

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

func (*Connector) GetCondition

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

GetCondition of this Connector.

func (*Connector) GetConnectionDetailsMapping

func (tr *Connector) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this Connector

func (*Connector) GetDeletionPolicy

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

GetDeletionPolicy of this Connector.

func (*Connector) GetID

func (tr *Connector) GetID() string

GetID returns ID of underlying Terraform resource of this Connector

func (*Connector) GetInitParameters

func (tr *Connector) GetInitParameters() (map[string]any, error)

GetInitParameters of this Connector

func (*Connector) GetManagementPolicies

func (mg *Connector) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this Connector.

func (*Connector) GetMergedParameters

func (tr *Connector) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

GetInitParameters of this Connector

func (*Connector) GetObservation

func (tr *Connector) GetObservation() (map[string]any, error)

GetObservation of this Connector

func (*Connector) GetParameters

func (tr *Connector) GetParameters() (map[string]any, error)

GetParameters of this Connector

func (*Connector) GetProviderConfigReference

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

GetProviderConfigReference of this Connector.

func (*Connector) GetPublishConnectionDetailsTo

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

GetPublishConnectionDetailsTo of this Connector.

func (*Connector) GetTerraformResourceType

func (mg *Connector) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Connector

func (*Connector) GetTerraformSchemaVersion

func (tr *Connector) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Connector) GetWriteConnectionSecretToReference

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

GetWriteConnectionSecretToReference of this Connector.

func (*Connector) LateInitialize

func (tr *Connector) LateInitialize(attrs []byte) (bool, error)

LateInitialize this Connector using its observed tfState. returns True if there are any spec changes for the resource.

func (*Connector) ResolveReferences

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

func (*Connector) SetConditions

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

SetConditions of this Connector.

func (*Connector) SetDeletionPolicy

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

SetDeletionPolicy of this Connector.

func (*Connector) SetManagementPolicies

func (mg *Connector) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this Connector.

func (*Connector) SetObservation

func (tr *Connector) SetObservation(obs map[string]any) error

SetObservation for this Connector

func (*Connector) SetParameters

func (tr *Connector) SetParameters(params map[string]any) error

SetParameters for this Connector

func (*Connector) SetProviderConfigReference

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

SetProviderConfigReference of this Connector.

func (*Connector) SetPublishConnectionDetailsTo

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

SetPublishConnectionDetailsTo of this Connector.

func (*Connector) SetWriteConnectionSecretToReference

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

SetWriteConnectionSecretToReference of this Connector.

type ConnectorInitParameters

type ConnectorInitParameters struct {

	// Information about the capacity allocated to the connector. See below.
	Capacity []CapacityInitParameters `json:"capacity,omitempty" tf:"capacity,omitempty"`

	// A map of keys to values that represent the configuration for the connector.
	// +mapType=granular
	ConnectorConfiguration map[string]*string `json:"connectorConfiguration,omitempty" tf:"connector_configuration,omitempty"`

	// A summary description of the connector.
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// Specifies which Apache Kafka cluster to connect to. See below.
	KafkaCluster []KafkaClusterInitParameters `json:"kafkaCluster,omitempty" tf:"kafka_cluster,omitempty"`

	// Details of the client authentication used by the Apache Kafka cluster. See below.
	KafkaClusterClientAuthentication []KafkaClusterClientAuthenticationInitParameters `json:"kafkaClusterClientAuthentication,omitempty" tf:"kafka_cluster_client_authentication,omitempty"`

	// Details of encryption in transit to the Apache Kafka cluster. See below.
	KafkaClusterEncryptionInTransit []KafkaClusterEncryptionInTransitInitParameters `json:"kafkaClusterEncryptionInTransit,omitempty" tf:"kafka_cluster_encryption_in_transit,omitempty"`

	// The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
	KafkaconnectVersion *string `json:"kafkaconnectVersion,omitempty" tf:"kafkaconnect_version,omitempty"`

	// Details about log delivery. See below.
	LogDelivery []LogDeliveryInitParameters `json:"logDelivery,omitempty" tf:"log_delivery,omitempty"`

	// Specifies which plugins to use for the connector. See below.
	Plugin []PluginInitParameters `json:"plugin,omitempty" tf:"plugin,omitempty"`

	// The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/iam/v1beta1.Role
	// +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor()
	ServiceExecutionRoleArn *string `json:"serviceExecutionRoleArn,omitempty" tf:"service_execution_role_arn,omitempty"`

	// Reference to a Role in iam to populate serviceExecutionRoleArn.
	// +kubebuilder:validation:Optional
	ServiceExecutionRoleArnRef *v1.Reference `json:"serviceExecutionRoleArnRef,omitempty" tf:"-"`

	// Selector for a Role in iam to populate serviceExecutionRoleArn.
	// +kubebuilder:validation:Optional
	ServiceExecutionRoleArnSelector *v1.Selector `json:"serviceExecutionRoleArnSelector,omitempty" tf:"-"`

	// Key-value map of resource tags.
	// +mapType=granular
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`

	// Specifies which worker configuration to use with the connector. See below.
	WorkerConfiguration []WorkerConfigurationInitParameters `json:"workerConfiguration,omitempty" tf:"worker_configuration,omitempty"`
}

func (*ConnectorInitParameters) DeepCopy

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

func (*ConnectorInitParameters) DeepCopyInto

func (in *ConnectorInitParameters) DeepCopyInto(out *ConnectorInitParameters)

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

type ConnectorList

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

ConnectorList contains a list of Connectors

func (*ConnectorList) DeepCopy

func (in *ConnectorList) DeepCopy() *ConnectorList

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

func (*ConnectorList) DeepCopyInto

func (in *ConnectorList) DeepCopyInto(out *ConnectorList)

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

func (*ConnectorList) DeepCopyObject

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

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

func (*ConnectorList) GetItems

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

GetItems of this ConnectorList.

type ConnectorObservation

type ConnectorObservation struct {

	// The Amazon Resource Name (ARN) of the custom plugin.
	Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`

	// Information about the capacity allocated to the connector. See below.
	Capacity []CapacityObservation `json:"capacity,omitempty" tf:"capacity,omitempty"`

	// A map of keys to values that represent the configuration for the connector.
	// +mapType=granular
	ConnectorConfiguration map[string]*string `json:"connectorConfiguration,omitempty" tf:"connector_configuration,omitempty"`

	// A summary description of the connector.
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// Specifies which Apache Kafka cluster to connect to. See below.
	KafkaCluster []KafkaClusterObservation `json:"kafkaCluster,omitempty" tf:"kafka_cluster,omitempty"`

	// Details of the client authentication used by the Apache Kafka cluster. See below.
	KafkaClusterClientAuthentication []KafkaClusterClientAuthenticationObservation `json:"kafkaClusterClientAuthentication,omitempty" tf:"kafka_cluster_client_authentication,omitempty"`

	// Details of encryption in transit to the Apache Kafka cluster. See below.
	KafkaClusterEncryptionInTransit []KafkaClusterEncryptionInTransitObservation `json:"kafkaClusterEncryptionInTransit,omitempty" tf:"kafka_cluster_encryption_in_transit,omitempty"`

	// The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
	KafkaconnectVersion *string `json:"kafkaconnectVersion,omitempty" tf:"kafkaconnect_version,omitempty"`

	// Details about log delivery. See below.
	LogDelivery []LogDeliveryObservation `json:"logDelivery,omitempty" tf:"log_delivery,omitempty"`

	// The name of the connector.
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// Specifies which plugins to use for the connector. See below.
	Plugin []PluginObservation `json:"plugin,omitempty" tf:"plugin,omitempty"`

	// The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
	ServiceExecutionRoleArn *string `json:"serviceExecutionRoleArn,omitempty" tf:"service_execution_role_arn,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"`

	// The current version of the connector.
	Version *string `json:"version,omitempty" tf:"version,omitempty"`

	// Specifies which worker configuration to use with the connector. See below.
	WorkerConfiguration []WorkerConfigurationObservation `json:"workerConfiguration,omitempty" tf:"worker_configuration,omitempty"`
}

func (*ConnectorObservation) DeepCopy

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

func (*ConnectorObservation) DeepCopyInto

func (in *ConnectorObservation) DeepCopyInto(out *ConnectorObservation)

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

type ConnectorParameters

type ConnectorParameters struct {

	// Information about the capacity allocated to the connector. See below.
	// +kubebuilder:validation:Optional
	Capacity []CapacityParameters `json:"capacity,omitempty" tf:"capacity,omitempty"`

	// A map of keys to values that represent the configuration for the connector.
	// +kubebuilder:validation:Optional
	// +mapType=granular
	ConnectorConfiguration map[string]*string `json:"connectorConfiguration,omitempty" tf:"connector_configuration,omitempty"`

	// A summary description of the connector.
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// Specifies which Apache Kafka cluster to connect to. See below.
	// +kubebuilder:validation:Optional
	KafkaCluster []KafkaClusterParameters `json:"kafkaCluster,omitempty" tf:"kafka_cluster,omitempty"`

	// Details of the client authentication used by the Apache Kafka cluster. See below.
	// +kubebuilder:validation:Optional
	KafkaClusterClientAuthentication []KafkaClusterClientAuthenticationParameters `json:"kafkaClusterClientAuthentication,omitempty" tf:"kafka_cluster_client_authentication,omitempty"`

	// Details of encryption in transit to the Apache Kafka cluster. See below.
	// +kubebuilder:validation:Optional
	KafkaClusterEncryptionInTransit []KafkaClusterEncryptionInTransitParameters `json:"kafkaClusterEncryptionInTransit,omitempty" tf:"kafka_cluster_encryption_in_transit,omitempty"`

	// The version of Kafka Connect. It has to be compatible with both the Apache Kafka cluster's version and the plugins.
	// +kubebuilder:validation:Optional
	KafkaconnectVersion *string `json:"kafkaconnectVersion,omitempty" tf:"kafkaconnect_version,omitempty"`

	// Details about log delivery. See below.
	// +kubebuilder:validation:Optional
	LogDelivery []LogDeliveryParameters `json:"logDelivery,omitempty" tf:"log_delivery,omitempty"`

	// The name of the connector.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Specifies which plugins to use for the connector. See below.
	// +kubebuilder:validation:Optional
	Plugin []PluginParameters `json:"plugin,omitempty" tf:"plugin,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:"-"`

	// The Amazon Resource Name (ARN) of the IAM role used by the connector to access the Amazon Web Services resources that it needs. The types of resources depends on the logic of the connector. For example, a connector that has Amazon S3 as a destination must have permissions that allow it to write to the S3 destination bucket.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/iam/v1beta1.Role
	// +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor()
	// +kubebuilder:validation:Optional
	ServiceExecutionRoleArn *string `json:"serviceExecutionRoleArn,omitempty" tf:"service_execution_role_arn,omitempty"`

	// Reference to a Role in iam to populate serviceExecutionRoleArn.
	// +kubebuilder:validation:Optional
	ServiceExecutionRoleArnRef *v1.Reference `json:"serviceExecutionRoleArnRef,omitempty" tf:"-"`

	// Selector for a Role in iam to populate serviceExecutionRoleArn.
	// +kubebuilder:validation:Optional
	ServiceExecutionRoleArnSelector *v1.Selector `json:"serviceExecutionRoleArnSelector,omitempty" tf:"-"`

	// Key-value map of resource tags.
	// +kubebuilder:validation:Optional
	// +mapType=granular
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`

	// Specifies which worker configuration to use with the connector. See below.
	// +kubebuilder:validation:Optional
	WorkerConfiguration []WorkerConfigurationParameters `json:"workerConfiguration,omitempty" tf:"worker_configuration,omitempty"`
}

func (*ConnectorParameters) DeepCopy

func (in *ConnectorParameters) DeepCopy() *ConnectorParameters

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

func (*ConnectorParameters) DeepCopyInto

func (in *ConnectorParameters) DeepCopyInto(out *ConnectorParameters)

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

type ConnectorSpec

type ConnectorSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     ConnectorParameters `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 ConnectorInitParameters `json:"initProvider,omitempty"`
}

ConnectorSpec defines the desired state of Connector

func (*ConnectorSpec) DeepCopy

func (in *ConnectorSpec) DeepCopy() *ConnectorSpec

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

func (*ConnectorSpec) DeepCopyInto

func (in *ConnectorSpec) DeepCopyInto(out *ConnectorSpec)

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

type ConnectorStatus

type ConnectorStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        ConnectorObservation `json:"atProvider,omitempty"`
}

ConnectorStatus defines the observed state of Connector.

func (*ConnectorStatus) DeepCopy

func (in *ConnectorStatus) DeepCopy() *ConnectorStatus

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

func (*ConnectorStatus) DeepCopyInto

func (in *ConnectorStatus) DeepCopyInto(out *ConnectorStatus)

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

type CustomPlugin

type CustomPlugin 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.contentType) || (has(self.initProvider) && has(self.initProvider.contentType))",message="spec.forProvider.contentType is a required parameter"
	// +kubebuilder:validation:XValidation:rule="!('*' in self.managementPolicies || 'Create' in self.managementPolicies || 'Update' in self.managementPolicies) || has(self.forProvider.location) || (has(self.initProvider) && has(self.initProvider.location))",message="spec.forProvider.location is a required parameter"
	Spec   CustomPluginSpec   `json:"spec"`
	Status CustomPluginStatus `json:"status,omitempty"`
}

CustomPlugin is the Schema for the CustomPlugins API. Provides an Amazon MSK Connect custom plugin resource. This resource can be Created, Observed and Deleted, but not Updated. AWS does not currently provide update APIs. +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 (*CustomPlugin) ConvertFrom added in v1.7.0

func (tr *CustomPlugin) ConvertFrom(srcRaw conversion.Hub) error

ConvertFrom converts from the hub type to the CustomPlugin type.

func (*CustomPlugin) ConvertTo added in v1.7.0

func (tr *CustomPlugin) ConvertTo(dstRaw conversion.Hub) error

ConvertTo converts this CustomPlugin to the hub type.

func (*CustomPlugin) DeepCopy

func (in *CustomPlugin) DeepCopy() *CustomPlugin

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

func (*CustomPlugin) DeepCopyInto

func (in *CustomPlugin) DeepCopyInto(out *CustomPlugin)

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

func (*CustomPlugin) DeepCopyObject

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

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

func (*CustomPlugin) GetCondition

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

GetCondition of this CustomPlugin.

func (*CustomPlugin) GetConnectionDetailsMapping

func (tr *CustomPlugin) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this CustomPlugin

func (*CustomPlugin) GetDeletionPolicy

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

GetDeletionPolicy of this CustomPlugin.

func (*CustomPlugin) GetID

func (tr *CustomPlugin) GetID() string

GetID returns ID of underlying Terraform resource of this CustomPlugin

func (*CustomPlugin) GetInitParameters

func (tr *CustomPlugin) GetInitParameters() (map[string]any, error)

GetInitParameters of this CustomPlugin

func (*CustomPlugin) GetManagementPolicies

func (mg *CustomPlugin) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this CustomPlugin.

func (*CustomPlugin) GetMergedParameters

func (tr *CustomPlugin) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

GetInitParameters of this CustomPlugin

func (*CustomPlugin) GetObservation

func (tr *CustomPlugin) GetObservation() (map[string]any, error)

GetObservation of this CustomPlugin

func (*CustomPlugin) GetParameters

func (tr *CustomPlugin) GetParameters() (map[string]any, error)

GetParameters of this CustomPlugin

func (*CustomPlugin) GetProviderConfigReference

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

GetProviderConfigReference of this CustomPlugin.

func (*CustomPlugin) GetPublishConnectionDetailsTo

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

GetPublishConnectionDetailsTo of this CustomPlugin.

func (*CustomPlugin) GetTerraformResourceType

func (mg *CustomPlugin) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this CustomPlugin

func (*CustomPlugin) GetTerraformSchemaVersion

func (tr *CustomPlugin) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*CustomPlugin) GetWriteConnectionSecretToReference

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

GetWriteConnectionSecretToReference of this CustomPlugin.

func (*CustomPlugin) LateInitialize

func (tr *CustomPlugin) LateInitialize(attrs []byte) (bool, error)

LateInitialize this CustomPlugin using its observed tfState. returns True if there are any spec changes for the resource.

func (*CustomPlugin) ResolveReferences

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

ResolveReferences of this CustomPlugin.

func (*CustomPlugin) SetConditions

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

SetConditions of this CustomPlugin.

func (*CustomPlugin) SetDeletionPolicy

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

SetDeletionPolicy of this CustomPlugin.

func (*CustomPlugin) SetManagementPolicies

func (mg *CustomPlugin) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this CustomPlugin.

func (*CustomPlugin) SetObservation

func (tr *CustomPlugin) SetObservation(obs map[string]any) error

SetObservation for this CustomPlugin

func (*CustomPlugin) SetParameters

func (tr *CustomPlugin) SetParameters(params map[string]any) error

SetParameters for this CustomPlugin

func (*CustomPlugin) SetProviderConfigReference

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

SetProviderConfigReference of this CustomPlugin.

func (*CustomPlugin) SetPublishConnectionDetailsTo

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

SetPublishConnectionDetailsTo of this CustomPlugin.

func (*CustomPlugin) SetWriteConnectionSecretToReference

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

SetWriteConnectionSecretToReference of this CustomPlugin.

type CustomPluginInitParameters

type CustomPluginInitParameters struct {

	// The Amazon Resource Name (ARN) of the worker configuration.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kafkaconnect/v1beta1.CustomPlugin
	// +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor()
	Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`

	// Reference to a CustomPlugin in kafkaconnect to populate arn.
	// +kubebuilder:validation:Optional
	ArnRef *v1.Reference `json:"arnRef,omitempty" tf:"-"`

	// Selector for a CustomPlugin in kafkaconnect to populate arn.
	// +kubebuilder:validation:Optional
	ArnSelector *v1.Selector `json:"arnSelector,omitempty" tf:"-"`

	// The revision of the worker configuration.
	Revision *float64 `json:"revision,omitempty" tf:"revision,omitempty"`
}

func (*CustomPluginInitParameters) DeepCopy

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

func (*CustomPluginInitParameters) DeepCopyInto

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

type CustomPluginInitParameters_2

type CustomPluginInitParameters_2 struct {

	// The type of the plugin file. Allowed values are ZIP and JAR.
	ContentType *string `json:"contentType,omitempty" tf:"content_type,omitempty"`

	// A summary description of the custom plugin.
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// Information about the location of a custom plugin. See below.
	Location []LocationInitParameters `json:"location,omitempty" tf:"location,omitempty"`

	// Key-value map of resource tags.
	// +mapType=granular
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
}

func (*CustomPluginInitParameters_2) DeepCopy

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

func (*CustomPluginInitParameters_2) DeepCopyInto

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

type CustomPluginList

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

CustomPluginList contains a list of CustomPlugins

func (*CustomPluginList) DeepCopy

func (in *CustomPluginList) DeepCopy() *CustomPluginList

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

func (*CustomPluginList) DeepCopyInto

func (in *CustomPluginList) DeepCopyInto(out *CustomPluginList)

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

func (*CustomPluginList) DeepCopyObject

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

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

func (*CustomPluginList) GetItems

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

GetItems of this CustomPluginList.

type CustomPluginObservation

type CustomPluginObservation struct {

	// The Amazon Resource Name (ARN) of the worker configuration.
	Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`

	// The revision of the worker configuration.
	Revision *float64 `json:"revision,omitempty" tf:"revision,omitempty"`
}

func (*CustomPluginObservation) DeepCopy

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

func (*CustomPluginObservation) DeepCopyInto

func (in *CustomPluginObservation) DeepCopyInto(out *CustomPluginObservation)

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

type CustomPluginObservation_2

type CustomPluginObservation_2 struct {

	// the Amazon Resource Name (ARN) of the custom plugin.
	Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`

	// The type of the plugin file. Allowed values are ZIP and JAR.
	ContentType *string `json:"contentType,omitempty" tf:"content_type,omitempty"`

	// A summary description of the custom plugin.
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// an ID of the latest successfully created revision of the custom plugin.
	LatestRevision *float64 `json:"latestRevision,omitempty" tf:"latest_revision,omitempty"`

	// Information about the location of a custom plugin. See below.
	Location []LocationObservation `json:"location,omitempty" tf:"location,omitempty"`

	// The name of the custom plugin..
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// the state of the custom plugin.
	State *string `json:"state,omitempty" tf:"state,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"`
}

func (*CustomPluginObservation_2) DeepCopy

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

func (*CustomPluginObservation_2) DeepCopyInto

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

type CustomPluginParameters

type CustomPluginParameters struct {

	// The Amazon Resource Name (ARN) of the worker configuration.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kafkaconnect/v1beta1.CustomPlugin
	// +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 CustomPlugin in kafkaconnect to populate arn.
	// +kubebuilder:validation:Optional
	ArnRef *v1.Reference `json:"arnRef,omitempty" tf:"-"`

	// Selector for a CustomPlugin in kafkaconnect to populate arn.
	// +kubebuilder:validation:Optional
	ArnSelector *v1.Selector `json:"arnSelector,omitempty" tf:"-"`

	// The revision of the worker configuration.
	// +kubebuilder:validation:Optional
	Revision *float64 `json:"revision" tf:"revision,omitempty"`
}

func (*CustomPluginParameters) DeepCopy

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

func (*CustomPluginParameters) DeepCopyInto

func (in *CustomPluginParameters) DeepCopyInto(out *CustomPluginParameters)

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

type CustomPluginParameters_2

type CustomPluginParameters_2 struct {

	// The type of the plugin file. Allowed values are ZIP and JAR.
	// +kubebuilder:validation:Optional
	ContentType *string `json:"contentType,omitempty" tf:"content_type,omitempty"`

	// A summary description of the custom plugin.
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// Information about the location of a custom plugin. See below.
	// +kubebuilder:validation:Optional
	Location []LocationParameters `json:"location,omitempty" tf:"location,omitempty"`

	// The name of the custom plugin..
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Region is the region you'd like your resource to be created in.
	// +upjet:crd:field:TFTag=-
	// +kubebuilder:validation:Required
	Region *string `json:"region" tf:"-"`

	// Key-value map of resource tags.
	// +kubebuilder:validation:Optional
	// +mapType=granular
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
}

func (*CustomPluginParameters_2) DeepCopy

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

func (*CustomPluginParameters_2) DeepCopyInto

func (in *CustomPluginParameters_2) DeepCopyInto(out *CustomPluginParameters_2)

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

type CustomPluginSpec

type CustomPluginSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     CustomPluginParameters_2 `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 CustomPluginInitParameters_2 `json:"initProvider,omitempty"`
}

CustomPluginSpec defines the desired state of CustomPlugin

func (*CustomPluginSpec) DeepCopy

func (in *CustomPluginSpec) DeepCopy() *CustomPluginSpec

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

func (*CustomPluginSpec) DeepCopyInto

func (in *CustomPluginSpec) DeepCopyInto(out *CustomPluginSpec)

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

type CustomPluginStatus

type CustomPluginStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        CustomPluginObservation_2 `json:"atProvider,omitempty"`
}

CustomPluginStatus defines the observed state of CustomPlugin.

func (*CustomPluginStatus) DeepCopy

func (in *CustomPluginStatus) DeepCopy() *CustomPluginStatus

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

func (*CustomPluginStatus) DeepCopyInto

func (in *CustomPluginStatus) DeepCopyInto(out *CustomPluginStatus)

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

type FirehoseInitParameters

type FirehoseInitParameters struct {

	// The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery.
	// +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",true)
	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:"-"`

	// Specifies whether connector logs get sent to the specified Amazon S3 destination.
	Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`
}

func (*FirehoseInitParameters) DeepCopy

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 {

	// The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery.
	DeliveryStream *string `json:"deliveryStream,omitempty" tf:"delivery_stream,omitempty"`

	// Specifies whether connector logs get sent to the specified Amazon S3 destination.
	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 {

	// The name of the Kinesis Data Firehose delivery stream that is the destination for log delivery.
	// +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",true)
	// +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:"-"`

	// Specifies whether connector logs get sent to the specified Amazon S3 destination.
	// +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 KafkaClusterClientAuthenticationInitParameters

type KafkaClusterClientAuthenticationInitParameters struct {

	// The type of client authentication used to connect to the Apache Kafka cluster. Valid values: IAM, NONE. A value of NONE means that no client authentication is used. The default value is NONE.
	AuthenticationType *string `json:"authenticationType,omitempty" tf:"authentication_type,omitempty"`
}

func (*KafkaClusterClientAuthenticationInitParameters) DeepCopy

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

func (*KafkaClusterClientAuthenticationInitParameters) DeepCopyInto

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

type KafkaClusterClientAuthenticationObservation

type KafkaClusterClientAuthenticationObservation struct {

	// The type of client authentication used to connect to the Apache Kafka cluster. Valid values: IAM, NONE. A value of NONE means that no client authentication is used. The default value is NONE.
	AuthenticationType *string `json:"authenticationType,omitempty" tf:"authentication_type,omitempty"`
}

func (*KafkaClusterClientAuthenticationObservation) DeepCopy

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

func (*KafkaClusterClientAuthenticationObservation) DeepCopyInto

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

type KafkaClusterClientAuthenticationParameters

type KafkaClusterClientAuthenticationParameters struct {

	// The type of client authentication used to connect to the Apache Kafka cluster. Valid values: IAM, NONE. A value of NONE means that no client authentication is used. The default value is NONE.
	// +kubebuilder:validation:Optional
	AuthenticationType *string `json:"authenticationType,omitempty" tf:"authentication_type,omitempty"`
}

func (*KafkaClusterClientAuthenticationParameters) DeepCopy

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

func (*KafkaClusterClientAuthenticationParameters) DeepCopyInto

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

type KafkaClusterEncryptionInTransitInitParameters

type KafkaClusterEncryptionInTransitInitParameters struct {

	// The type of encryption in transit to the Apache Kafka cluster. Valid values: PLAINTEXT, TLS. The default values is PLAINTEXT.
	EncryptionType *string `json:"encryptionType,omitempty" tf:"encryption_type,omitempty"`
}

func (*KafkaClusterEncryptionInTransitInitParameters) DeepCopy

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

func (*KafkaClusterEncryptionInTransitInitParameters) DeepCopyInto

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

type KafkaClusterEncryptionInTransitObservation

type KafkaClusterEncryptionInTransitObservation struct {

	// The type of encryption in transit to the Apache Kafka cluster. Valid values: PLAINTEXT, TLS. The default values is PLAINTEXT.
	EncryptionType *string `json:"encryptionType,omitempty" tf:"encryption_type,omitempty"`
}

func (*KafkaClusterEncryptionInTransitObservation) DeepCopy

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

func (*KafkaClusterEncryptionInTransitObservation) DeepCopyInto

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

type KafkaClusterEncryptionInTransitParameters

type KafkaClusterEncryptionInTransitParameters struct {

	// The type of encryption in transit to the Apache Kafka cluster. Valid values: PLAINTEXT, TLS. The default values is PLAINTEXT.
	// +kubebuilder:validation:Optional
	EncryptionType *string `json:"encryptionType,omitempty" tf:"encryption_type,omitempty"`
}

func (*KafkaClusterEncryptionInTransitParameters) DeepCopy

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

func (*KafkaClusterEncryptionInTransitParameters) DeepCopyInto

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

type KafkaClusterInitParameters

type KafkaClusterInitParameters struct {

	// The Apache Kafka cluster to which the connector is connected.
	ApacheKafkaCluster []ApacheKafkaClusterInitParameters `json:"apacheKafkaCluster,omitempty" tf:"apache_kafka_cluster,omitempty"`
}

func (*KafkaClusterInitParameters) DeepCopy

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

func (*KafkaClusterInitParameters) DeepCopyInto

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

type KafkaClusterObservation

type KafkaClusterObservation struct {

	// The Apache Kafka cluster to which the connector is connected.
	ApacheKafkaCluster []ApacheKafkaClusterObservation `json:"apacheKafkaCluster,omitempty" tf:"apache_kafka_cluster,omitempty"`
}

func (*KafkaClusterObservation) DeepCopy

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

func (*KafkaClusterObservation) DeepCopyInto

func (in *KafkaClusterObservation) DeepCopyInto(out *KafkaClusterObservation)

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

type KafkaClusterParameters

type KafkaClusterParameters struct {

	// The Apache Kafka cluster to which the connector is connected.
	// +kubebuilder:validation:Optional
	ApacheKafkaCluster []ApacheKafkaClusterParameters `json:"apacheKafkaCluster" tf:"apache_kafka_cluster,omitempty"`
}

func (*KafkaClusterParameters) DeepCopy

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

func (*KafkaClusterParameters) DeepCopyInto

func (in *KafkaClusterParameters) DeepCopyInto(out *KafkaClusterParameters)

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

type LocationInitParameters

type LocationInitParameters struct {

	// Information of the plugin file stored in Amazon S3. See below.
	S3 []LocationS3InitParameters `json:"s3,omitempty" tf:"s3,omitempty"`
}

func (*LocationInitParameters) DeepCopy

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

func (*LocationInitParameters) DeepCopyInto

func (in *LocationInitParameters) DeepCopyInto(out *LocationInitParameters)

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

type LocationObservation

type LocationObservation struct {

	// Information of the plugin file stored in Amazon S3. See below.
	S3 []LocationS3Observation `json:"s3,omitempty" tf:"s3,omitempty"`
}

func (*LocationObservation) DeepCopy

func (in *LocationObservation) DeepCopy() *LocationObservation

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

func (*LocationObservation) DeepCopyInto

func (in *LocationObservation) DeepCopyInto(out *LocationObservation)

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

type LocationParameters

type LocationParameters struct {

	// Information of the plugin file stored in Amazon S3. See below.
	// +kubebuilder:validation:Optional
	S3 []LocationS3Parameters `json:"s3" tf:"s3,omitempty"`
}

func (*LocationParameters) DeepCopy

func (in *LocationParameters) DeepCopy() *LocationParameters

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

func (*LocationParameters) DeepCopyInto

func (in *LocationParameters) DeepCopyInto(out *LocationParameters)

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

type LocationS3InitParameters

type LocationS3InitParameters struct {

	// The Amazon Resource Name (ARN) of an S3 bucket.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta1.Bucket
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("arn",true)
	BucketArn *string `json:"bucketArn,omitempty" tf:"bucket_arn,omitempty"`

	// Reference to a Bucket in s3 to populate bucketArn.
	// +kubebuilder:validation:Optional
	BucketArnRef *v1.Reference `json:"bucketArnRef,omitempty" tf:"-"`

	// Selector for a Bucket in s3 to populate bucketArn.
	// +kubebuilder:validation:Optional
	BucketArnSelector *v1.Selector `json:"bucketArnSelector,omitempty" tf:"-"`

	// The file key for an object in an S3 bucket.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta1.Object
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("key",false)
	FileKey *string `json:"fileKey,omitempty" tf:"file_key,omitempty"`

	// Reference to a Object in s3 to populate fileKey.
	// +kubebuilder:validation:Optional
	FileKeyRef *v1.Reference `json:"fileKeyRef,omitempty" tf:"-"`

	// Selector for a Object in s3 to populate fileKey.
	// +kubebuilder:validation:Optional
	FileKeySelector *v1.Selector `json:"fileKeySelector,omitempty" tf:"-"`

	// The version of an object in an S3 bucket.
	ObjectVersion *string `json:"objectVersion,omitempty" tf:"object_version,omitempty"`
}

func (*LocationS3InitParameters) DeepCopy

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

func (*LocationS3InitParameters) DeepCopyInto

func (in *LocationS3InitParameters) DeepCopyInto(out *LocationS3InitParameters)

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

type LocationS3Observation

type LocationS3Observation struct {

	// The Amazon Resource Name (ARN) of an S3 bucket.
	BucketArn *string `json:"bucketArn,omitempty" tf:"bucket_arn,omitempty"`

	// The file key for an object in an S3 bucket.
	FileKey *string `json:"fileKey,omitempty" tf:"file_key,omitempty"`

	// The version of an object in an S3 bucket.
	ObjectVersion *string `json:"objectVersion,omitempty" tf:"object_version,omitempty"`
}

func (*LocationS3Observation) DeepCopy

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

func (*LocationS3Observation) DeepCopyInto

func (in *LocationS3Observation) DeepCopyInto(out *LocationS3Observation)

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

type LocationS3Parameters

type LocationS3Parameters struct {

	// The Amazon Resource Name (ARN) of an S3 bucket.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta1.Bucket
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("arn",true)
	// +kubebuilder:validation:Optional
	BucketArn *string `json:"bucketArn,omitempty" tf:"bucket_arn,omitempty"`

	// Reference to a Bucket in s3 to populate bucketArn.
	// +kubebuilder:validation:Optional
	BucketArnRef *v1.Reference `json:"bucketArnRef,omitempty" tf:"-"`

	// Selector for a Bucket in s3 to populate bucketArn.
	// +kubebuilder:validation:Optional
	BucketArnSelector *v1.Selector `json:"bucketArnSelector,omitempty" tf:"-"`

	// The file key for an object in an S3 bucket.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta1.Object
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("key",false)
	// +kubebuilder:validation:Optional
	FileKey *string `json:"fileKey,omitempty" tf:"file_key,omitempty"`

	// Reference to a Object in s3 to populate fileKey.
	// +kubebuilder:validation:Optional
	FileKeyRef *v1.Reference `json:"fileKeyRef,omitempty" tf:"-"`

	// Selector for a Object in s3 to populate fileKey.
	// +kubebuilder:validation:Optional
	FileKeySelector *v1.Selector `json:"fileKeySelector,omitempty" tf:"-"`

	// The version of an object in an S3 bucket.
	// +kubebuilder:validation:Optional
	ObjectVersion *string `json:"objectVersion,omitempty" tf:"object_version,omitempty"`
}

func (*LocationS3Parameters) DeepCopy

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

func (*LocationS3Parameters) DeepCopyInto

func (in *LocationS3Parameters) DeepCopyInto(out *LocationS3Parameters)

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

type LogDeliveryInitParameters

type LogDeliveryInitParameters struct {

	// The workers can send worker logs to different destination types. This configuration specifies the details of these destinations. See below.
	WorkerLogDelivery []WorkerLogDeliveryInitParameters `json:"workerLogDelivery,omitempty" tf:"worker_log_delivery,omitempty"`
}

func (*LogDeliveryInitParameters) DeepCopy

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

func (*LogDeliveryInitParameters) DeepCopyInto

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

type LogDeliveryObservation

type LogDeliveryObservation struct {

	// The workers can send worker logs to different destination types. This configuration specifies the details of these destinations. See below.
	WorkerLogDelivery []WorkerLogDeliveryObservation `json:"workerLogDelivery,omitempty" tf:"worker_log_delivery,omitempty"`
}

func (*LogDeliveryObservation) DeepCopy

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

func (*LogDeliveryObservation) DeepCopyInto

func (in *LogDeliveryObservation) DeepCopyInto(out *LogDeliveryObservation)

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

type LogDeliveryParameters

type LogDeliveryParameters struct {

	// The workers can send worker logs to different destination types. This configuration specifies the details of these destinations. See below.
	// +kubebuilder:validation:Optional
	WorkerLogDelivery []WorkerLogDeliveryParameters `json:"workerLogDelivery" tf:"worker_log_delivery,omitempty"`
}

func (*LogDeliveryParameters) DeepCopy

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

func (*LogDeliveryParameters) DeepCopyInto

func (in *LogDeliveryParameters) DeepCopyInto(out *LogDeliveryParameters)

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

type PluginInitParameters

type PluginInitParameters struct {

	// Details about a custom plugin. See below.
	CustomPlugin []CustomPluginInitParameters `json:"customPlugin,omitempty" tf:"custom_plugin,omitempty"`
}

func (*PluginInitParameters) DeepCopy

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

func (*PluginInitParameters) DeepCopyInto

func (in *PluginInitParameters) DeepCopyInto(out *PluginInitParameters)

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

type PluginObservation

type PluginObservation struct {

	// Details about a custom plugin. See below.
	CustomPlugin []CustomPluginObservation `json:"customPlugin,omitempty" tf:"custom_plugin,omitempty"`
}

func (*PluginObservation) DeepCopy

func (in *PluginObservation) DeepCopy() *PluginObservation

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

func (*PluginObservation) DeepCopyInto

func (in *PluginObservation) DeepCopyInto(out *PluginObservation)

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

type PluginParameters

type PluginParameters struct {

	// Details about a custom plugin. See below.
	// +kubebuilder:validation:Optional
	CustomPlugin []CustomPluginParameters `json:"customPlugin" tf:"custom_plugin,omitempty"`
}

func (*PluginParameters) DeepCopy

func (in *PluginParameters) DeepCopy() *PluginParameters

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

func (*PluginParameters) DeepCopyInto

func (in *PluginParameters) DeepCopyInto(out *PluginParameters)

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

type ProvisionedCapacityInitParameters

type ProvisionedCapacityInitParameters struct {

	// The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
	McuCount *float64 `json:"mcuCount,omitempty" tf:"mcu_count,omitempty"`

	// The number of workers that are allocated to the connector.
	WorkerCount *float64 `json:"workerCount,omitempty" tf:"worker_count,omitempty"`
}

func (*ProvisionedCapacityInitParameters) DeepCopy

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

func (*ProvisionedCapacityInitParameters) DeepCopyInto

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

type ProvisionedCapacityObservation

type ProvisionedCapacityObservation struct {

	// The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
	McuCount *float64 `json:"mcuCount,omitempty" tf:"mcu_count,omitempty"`

	// The number of workers that are allocated to the connector.
	WorkerCount *float64 `json:"workerCount,omitempty" tf:"worker_count,omitempty"`
}

func (*ProvisionedCapacityObservation) DeepCopy

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

func (*ProvisionedCapacityObservation) DeepCopyInto

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

type ProvisionedCapacityParameters

type ProvisionedCapacityParameters struct {

	// The number of microcontroller units (MCUs) allocated to each connector worker. Valid values: 1, 2, 4, 8. The default value is 1.
	// +kubebuilder:validation:Optional
	McuCount *float64 `json:"mcuCount,omitempty" tf:"mcu_count,omitempty"`

	// The number of workers that are allocated to the connector.
	// +kubebuilder:validation:Optional
	WorkerCount *float64 `json:"workerCount" tf:"worker_count,omitempty"`
}

func (*ProvisionedCapacityParameters) DeepCopy

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

func (*ProvisionedCapacityParameters) DeepCopyInto

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

type S3InitParameters

type S3InitParameters struct {

	// The name of the S3 bucket that is the destination for log delivery.
	// +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:"-"`

	// Specifies whether connector logs get sent to the specified Amazon S3 destination.
	Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`

	// The S3 prefix that is the destination for log delivery.
	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 {

	// The name of the S3 bucket that is the destination for log delivery.
	Bucket *string `json:"bucket,omitempty" tf:"bucket,omitempty"`

	// Specifies whether connector logs get sent to the specified Amazon S3 destination.
	Enabled *bool `json:"enabled,omitempty" tf:"enabled,omitempty"`

	// The S3 prefix that is the destination for log delivery.
	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 {

	// The name of the S3 bucket that is the destination for log delivery.
	// +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:"-"`

	// Specifies whether connector logs get sent to the specified Amazon S3 destination.
	// +kubebuilder:validation:Optional
	Enabled *bool `json:"enabled" tf:"enabled,omitempty"`

	// The S3 prefix that is the destination for log delivery.
	// +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 ScaleInPolicyInitParameters

type ScaleInPolicyInitParameters struct {

	// The CPU utilization percentage threshold at which you want connector scale out to be triggered.
	CPUUtilizationPercentage *float64 `json:"cpuUtilizationPercentage,omitempty" tf:"cpu_utilization_percentage,omitempty"`
}

func (*ScaleInPolicyInitParameters) DeepCopy

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

func (*ScaleInPolicyInitParameters) DeepCopyInto

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

type ScaleInPolicyObservation

type ScaleInPolicyObservation struct {

	// The CPU utilization percentage threshold at which you want connector scale out to be triggered.
	CPUUtilizationPercentage *float64 `json:"cpuUtilizationPercentage,omitempty" tf:"cpu_utilization_percentage,omitempty"`
}

func (*ScaleInPolicyObservation) DeepCopy

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

func (*ScaleInPolicyObservation) DeepCopyInto

func (in *ScaleInPolicyObservation) DeepCopyInto(out *ScaleInPolicyObservation)

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

type ScaleInPolicyParameters

type ScaleInPolicyParameters struct {

	// The CPU utilization percentage threshold at which you want connector scale out to be triggered.
	// +kubebuilder:validation:Optional
	CPUUtilizationPercentage *float64 `json:"cpuUtilizationPercentage,omitempty" tf:"cpu_utilization_percentage,omitempty"`
}

func (*ScaleInPolicyParameters) DeepCopy

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

func (*ScaleInPolicyParameters) DeepCopyInto

func (in *ScaleInPolicyParameters) DeepCopyInto(out *ScaleInPolicyParameters)

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

type ScaleOutPolicyInitParameters

type ScaleOutPolicyInitParameters struct {

	// The CPU utilization percentage threshold at which you want connector scale out to be triggered.
	CPUUtilizationPercentage *float64 `json:"cpuUtilizationPercentage,omitempty" tf:"cpu_utilization_percentage,omitempty"`
}

func (*ScaleOutPolicyInitParameters) DeepCopy

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

func (*ScaleOutPolicyInitParameters) DeepCopyInto

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

type ScaleOutPolicyObservation

type ScaleOutPolicyObservation struct {

	// The CPU utilization percentage threshold at which you want connector scale out to be triggered.
	CPUUtilizationPercentage *float64 `json:"cpuUtilizationPercentage,omitempty" tf:"cpu_utilization_percentage,omitempty"`
}

func (*ScaleOutPolicyObservation) DeepCopy

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

func (*ScaleOutPolicyObservation) DeepCopyInto

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

type ScaleOutPolicyParameters

type ScaleOutPolicyParameters struct {

	// The CPU utilization percentage threshold at which you want connector scale out to be triggered.
	// +kubebuilder:validation:Optional
	CPUUtilizationPercentage *float64 `json:"cpuUtilizationPercentage,omitempty" tf:"cpu_utilization_percentage,omitempty"`
}

func (*ScaleOutPolicyParameters) DeepCopy

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

func (*ScaleOutPolicyParameters) DeepCopyInto

func (in *ScaleOutPolicyParameters) DeepCopyInto(out *ScaleOutPolicyParameters)

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

type VPCInitParameters

type VPCInitParameters struct {

	// References to SecurityGroup in ec2 to populate securityGroups.
	// +kubebuilder:validation:Optional
	SecurityGroupRefs []v1.Reference `json:"securityGroupRefs,omitempty" tf:"-"`

	// Selector for a list of SecurityGroup in ec2 to populate securityGroups.
	// +kubebuilder:validation:Optional
	SecurityGroupSelector *v1.Selector `json:"securityGroupSelector,omitempty" tf:"-"`

	// The security groups for the connector.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.SecurityGroup
	// +crossplane:generate:reference:refFieldName=SecurityGroupRefs
	// +crossplane:generate:reference:selectorFieldName=SecurityGroupSelector
	// +listType=set
	SecurityGroups []*string `json:"securityGroups,omitempty" tf:"security_groups,omitempty"`

	// References to Subnet in ec2 to populate subnets.
	// +kubebuilder:validation:Optional
	SubnetRefs []v1.Reference `json:"subnetRefs,omitempty" tf:"-"`

	// Selector for a list of Subnet in ec2 to populate subnets.
	// +kubebuilder:validation:Optional
	SubnetSelector *v1.Selector `json:"subnetSelector,omitempty" tf:"-"`

	// The subnets for the connector.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.Subnet
	// +crossplane:generate:reference:refFieldName=SubnetRefs
	// +crossplane:generate:reference:selectorFieldName=SubnetSelector
	// +listType=set
	Subnets []*string `json:"subnets,omitempty" tf:"subnets,omitempty"`
}

func (*VPCInitParameters) DeepCopy

func (in *VPCInitParameters) DeepCopy() *VPCInitParameters

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

func (*VPCInitParameters) DeepCopyInto

func (in *VPCInitParameters) DeepCopyInto(out *VPCInitParameters)

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

type VPCObservation

type VPCObservation struct {

	// The security groups for the connector.
	// +listType=set
	SecurityGroups []*string `json:"securityGroups,omitempty" tf:"security_groups,omitempty"`

	// The subnets for the connector.
	// +listType=set
	Subnets []*string `json:"subnets,omitempty" tf:"subnets,omitempty"`
}

func (*VPCObservation) DeepCopy

func (in *VPCObservation) DeepCopy() *VPCObservation

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

func (*VPCObservation) DeepCopyInto

func (in *VPCObservation) DeepCopyInto(out *VPCObservation)

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

type VPCParameters

type VPCParameters struct {

	// References to SecurityGroup in ec2 to populate securityGroups.
	// +kubebuilder:validation:Optional
	SecurityGroupRefs []v1.Reference `json:"securityGroupRefs,omitempty" tf:"-"`

	// Selector for a list of SecurityGroup in ec2 to populate securityGroups.
	// +kubebuilder:validation:Optional
	SecurityGroupSelector *v1.Selector `json:"securityGroupSelector,omitempty" tf:"-"`

	// The security groups for the connector.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.SecurityGroup
	// +crossplane:generate:reference:refFieldName=SecurityGroupRefs
	// +crossplane:generate:reference:selectorFieldName=SecurityGroupSelector
	// +kubebuilder:validation:Optional
	// +listType=set
	SecurityGroups []*string `json:"securityGroups,omitempty" tf:"security_groups,omitempty"`

	// References to Subnet in ec2 to populate subnets.
	// +kubebuilder:validation:Optional
	SubnetRefs []v1.Reference `json:"subnetRefs,omitempty" tf:"-"`

	// Selector for a list of Subnet in ec2 to populate subnets.
	// +kubebuilder:validation:Optional
	SubnetSelector *v1.Selector `json:"subnetSelector,omitempty" tf:"-"`

	// The subnets for the connector.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.Subnet
	// +crossplane:generate:reference:refFieldName=SubnetRefs
	// +crossplane:generate:reference:selectorFieldName=SubnetSelector
	// +kubebuilder:validation:Optional
	// +listType=set
	Subnets []*string `json:"subnets,omitempty" tf:"subnets,omitempty"`
}

func (*VPCParameters) DeepCopy

func (in *VPCParameters) DeepCopy() *VPCParameters

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

func (*VPCParameters) DeepCopyInto

func (in *VPCParameters) DeepCopyInto(out *VPCParameters)

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

type WorkerConfiguration

type WorkerConfiguration 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.propertiesFileContent) || (has(self.initProvider) && has(self.initProvider.propertiesFileContent))",message="spec.forProvider.propertiesFileContent is a required parameter"
	Spec   WorkerConfigurationSpec   `json:"spec"`
	Status WorkerConfigurationStatus `json:"status,omitempty"`
}

WorkerConfiguration is the Schema for the WorkerConfigurations API. Provides an Amazon MSK Connect worker configuration resource. This resource is create-only, and requires a unique "name" parameter. AWS does not currently provide update or delete APIs. +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 (*WorkerConfiguration) DeepCopy

func (in *WorkerConfiguration) DeepCopy() *WorkerConfiguration

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

func (*WorkerConfiguration) DeepCopyInto

func (in *WorkerConfiguration) DeepCopyInto(out *WorkerConfiguration)

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

func (*WorkerConfiguration) DeepCopyObject

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

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

func (*WorkerConfiguration) GetCondition

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

GetCondition of this WorkerConfiguration.

func (*WorkerConfiguration) GetConnectionDetailsMapping

func (tr *WorkerConfiguration) GetConnectionDetailsMapping() map[string]string

GetConnectionDetailsMapping for this WorkerConfiguration

func (*WorkerConfiguration) GetDeletionPolicy

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

GetDeletionPolicy of this WorkerConfiguration.

func (*WorkerConfiguration) GetID

func (tr *WorkerConfiguration) GetID() string

GetID returns ID of underlying Terraform resource of this WorkerConfiguration

func (*WorkerConfiguration) GetInitParameters

func (tr *WorkerConfiguration) GetInitParameters() (map[string]any, error)

GetInitParameters of this WorkerConfiguration

func (*WorkerConfiguration) GetManagementPolicies

func (mg *WorkerConfiguration) GetManagementPolicies() xpv1.ManagementPolicies

GetManagementPolicies of this WorkerConfiguration.

func (*WorkerConfiguration) GetMergedParameters

func (tr *WorkerConfiguration) GetMergedParameters(shouldMergeInitProvider bool) (map[string]any, error)

GetInitParameters of this WorkerConfiguration

func (*WorkerConfiguration) GetObservation

func (tr *WorkerConfiguration) GetObservation() (map[string]any, error)

GetObservation of this WorkerConfiguration

func (*WorkerConfiguration) GetParameters

func (tr *WorkerConfiguration) GetParameters() (map[string]any, error)

GetParameters of this WorkerConfiguration

func (*WorkerConfiguration) GetProviderConfigReference

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

GetProviderConfigReference of this WorkerConfiguration.

func (*WorkerConfiguration) GetPublishConnectionDetailsTo

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

GetPublishConnectionDetailsTo of this WorkerConfiguration.

func (*WorkerConfiguration) GetTerraformResourceType

func (mg *WorkerConfiguration) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this WorkerConfiguration

func (*WorkerConfiguration) GetTerraformSchemaVersion

func (tr *WorkerConfiguration) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*WorkerConfiguration) GetWriteConnectionSecretToReference

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

GetWriteConnectionSecretToReference of this WorkerConfiguration.

func (*WorkerConfiguration) Hub

func (tr *WorkerConfiguration) Hub()

Hub marks this type as a conversion hub.

func (*WorkerConfiguration) LateInitialize

func (tr *WorkerConfiguration) LateInitialize(attrs []byte) (bool, error)

LateInitialize this WorkerConfiguration using its observed tfState. returns True if there are any spec changes for the resource.

func (*WorkerConfiguration) SetConditions

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

SetConditions of this WorkerConfiguration.

func (*WorkerConfiguration) SetDeletionPolicy

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

SetDeletionPolicy of this WorkerConfiguration.

func (*WorkerConfiguration) SetManagementPolicies

func (mg *WorkerConfiguration) SetManagementPolicies(r xpv1.ManagementPolicies)

SetManagementPolicies of this WorkerConfiguration.

func (*WorkerConfiguration) SetObservation

func (tr *WorkerConfiguration) SetObservation(obs map[string]any) error

SetObservation for this WorkerConfiguration

func (*WorkerConfiguration) SetParameters

func (tr *WorkerConfiguration) SetParameters(params map[string]any) error

SetParameters for this WorkerConfiguration

func (*WorkerConfiguration) SetProviderConfigReference

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

SetProviderConfigReference of this WorkerConfiguration.

func (*WorkerConfiguration) SetPublishConnectionDetailsTo

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

SetPublishConnectionDetailsTo of this WorkerConfiguration.

func (*WorkerConfiguration) SetWriteConnectionSecretToReference

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

SetWriteConnectionSecretToReference of this WorkerConfiguration.

type WorkerConfigurationInitParameters

type WorkerConfigurationInitParameters struct {

	// The Amazon Resource Name (ARN) of the worker configuration.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kafkaconnect/v1beta1.WorkerConfiguration
	// +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor()
	Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`

	// Reference to a WorkerConfiguration in kafkaconnect to populate arn.
	// +kubebuilder:validation:Optional
	ArnRef *v1.Reference `json:"arnRef,omitempty" tf:"-"`

	// Selector for a WorkerConfiguration in kafkaconnect to populate arn.
	// +kubebuilder:validation:Optional
	ArnSelector *v1.Selector `json:"arnSelector,omitempty" tf:"-"`

	// The revision of the worker configuration.
	Revision *float64 `json:"revision,omitempty" tf:"revision,omitempty"`
}

func (*WorkerConfigurationInitParameters) DeepCopy

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

func (*WorkerConfigurationInitParameters) DeepCopyInto

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

type WorkerConfigurationInitParameters_2

type WorkerConfigurationInitParameters_2 struct {

	// A summary description of the worker configuration.
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// Contents of connect-distributed.properties file. The value can be either base64 encoded or in raw format.
	PropertiesFileContent *string `json:"propertiesFileContent,omitempty" tf:"properties_file_content,omitempty"`

	// Key-value map of resource tags.
	// +mapType=granular
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
}

func (*WorkerConfigurationInitParameters_2) DeepCopy

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

func (*WorkerConfigurationInitParameters_2) DeepCopyInto

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

type WorkerConfigurationList

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

WorkerConfigurationList contains a list of WorkerConfigurations

func (*WorkerConfigurationList) DeepCopy

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

func (*WorkerConfigurationList) DeepCopyInto

func (in *WorkerConfigurationList) DeepCopyInto(out *WorkerConfigurationList)

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

func (*WorkerConfigurationList) DeepCopyObject

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

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

func (*WorkerConfigurationList) GetItems

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

GetItems of this WorkerConfigurationList.

type WorkerConfigurationObservation

type WorkerConfigurationObservation struct {

	// The Amazon Resource Name (ARN) of the worker configuration.
	Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`

	// The revision of the worker configuration.
	Revision *float64 `json:"revision,omitempty" tf:"revision,omitempty"`
}

func (*WorkerConfigurationObservation) DeepCopy

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

func (*WorkerConfigurationObservation) DeepCopyInto

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

type WorkerConfigurationObservation_2

type WorkerConfigurationObservation_2 struct {

	// the Amazon Resource Name (ARN) of the worker configuration.
	Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`

	// A summary description of the worker configuration.
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// an ID of the latest successfully created revision of the worker configuration.
	LatestRevision *float64 `json:"latestRevision,omitempty" tf:"latest_revision,omitempty"`

	// The name of the worker configuration.
	Name *string `json:"name,omitempty" tf:"name,omitempty"`

	// Contents of connect-distributed.properties file. The value can be either base64 encoded or in raw format.
	PropertiesFileContent *string `json:"propertiesFileContent,omitempty" tf:"properties_file_content,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"`
}

func (*WorkerConfigurationObservation_2) DeepCopy

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

func (*WorkerConfigurationObservation_2) DeepCopyInto

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

type WorkerConfigurationParameters

type WorkerConfigurationParameters struct {

	// The Amazon Resource Name (ARN) of the worker configuration.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kafkaconnect/v1beta1.WorkerConfiguration
	// +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 WorkerConfiguration in kafkaconnect to populate arn.
	// +kubebuilder:validation:Optional
	ArnRef *v1.Reference `json:"arnRef,omitempty" tf:"-"`

	// Selector for a WorkerConfiguration in kafkaconnect to populate arn.
	// +kubebuilder:validation:Optional
	ArnSelector *v1.Selector `json:"arnSelector,omitempty" tf:"-"`

	// The revision of the worker configuration.
	// +kubebuilder:validation:Optional
	Revision *float64 `json:"revision" tf:"revision,omitempty"`
}

func (*WorkerConfigurationParameters) DeepCopy

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

func (*WorkerConfigurationParameters) DeepCopyInto

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

type WorkerConfigurationParameters_2

type WorkerConfigurationParameters_2 struct {

	// A summary description of the worker configuration.
	// +kubebuilder:validation:Optional
	Description *string `json:"description,omitempty" tf:"description,omitempty"`

	// The name of the worker configuration.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// Contents of connect-distributed.properties file. The value can be either base64 encoded or in raw format.
	// +kubebuilder:validation:Optional
	PropertiesFileContent *string `json:"propertiesFileContent,omitempty" tf:"properties_file_content,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"`
}

func (*WorkerConfigurationParameters_2) DeepCopy

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

func (*WorkerConfigurationParameters_2) DeepCopyInto

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

type WorkerConfigurationSpec

type WorkerConfigurationSpec struct {
	v1.ResourceSpec `json:",inline"`
	ForProvider     WorkerConfigurationParameters_2 `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 WorkerConfigurationInitParameters_2 `json:"initProvider,omitempty"`
}

WorkerConfigurationSpec defines the desired state of WorkerConfiguration

func (*WorkerConfigurationSpec) DeepCopy

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

func (*WorkerConfigurationSpec) DeepCopyInto

func (in *WorkerConfigurationSpec) DeepCopyInto(out *WorkerConfigurationSpec)

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

type WorkerConfigurationStatus

type WorkerConfigurationStatus struct {
	v1.ResourceStatus `json:",inline"`
	AtProvider        WorkerConfigurationObservation_2 `json:"atProvider,omitempty"`
}

WorkerConfigurationStatus defines the observed state of WorkerConfiguration.

func (*WorkerConfigurationStatus) DeepCopy

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

func (*WorkerConfigurationStatus) DeepCopyInto

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

type WorkerLogDeliveryInitParameters

type WorkerLogDeliveryInitParameters struct {

	// Details about delivering logs to Amazon CloudWatch Logs. See below.
	CloudwatchLogs []CloudwatchLogsInitParameters `json:"cloudwatchLogs,omitempty" tf:"cloudwatch_logs,omitempty"`

	// Details about delivering logs to Amazon Kinesis Data Firehose. See below.
	Firehose []FirehoseInitParameters `json:"firehose,omitempty" tf:"firehose,omitempty"`

	// Details about delivering logs to Amazon S3. See below.
	S3 []S3InitParameters `json:"s3,omitempty" tf:"s3,omitempty"`
}

func (*WorkerLogDeliveryInitParameters) DeepCopy

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

func (*WorkerLogDeliveryInitParameters) DeepCopyInto

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

type WorkerLogDeliveryObservation

type WorkerLogDeliveryObservation struct {

	// Details about delivering logs to Amazon CloudWatch Logs. See below.
	CloudwatchLogs []CloudwatchLogsObservation `json:"cloudwatchLogs,omitempty" tf:"cloudwatch_logs,omitempty"`

	// Details about delivering logs to Amazon Kinesis Data Firehose. See below.
	Firehose []FirehoseObservation `json:"firehose,omitempty" tf:"firehose,omitempty"`

	// Details about delivering logs to Amazon S3. See below.
	S3 []S3Observation `json:"s3,omitempty" tf:"s3,omitempty"`
}

func (*WorkerLogDeliveryObservation) DeepCopy

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

func (*WorkerLogDeliveryObservation) DeepCopyInto

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

type WorkerLogDeliveryParameters

type WorkerLogDeliveryParameters struct {

	// Details about delivering logs to Amazon CloudWatch Logs. See below.
	// +kubebuilder:validation:Optional
	CloudwatchLogs []CloudwatchLogsParameters `json:"cloudwatchLogs,omitempty" tf:"cloudwatch_logs,omitempty"`

	// Details about delivering logs to Amazon Kinesis Data Firehose. See below.
	// +kubebuilder:validation:Optional
	Firehose []FirehoseParameters `json:"firehose,omitempty" tf:"firehose,omitempty"`

	// Details about delivering logs to Amazon S3. See below.
	// +kubebuilder:validation:Optional
	S3 []S3Parameters `json:"s3,omitempty" tf:"s3,omitempty"`
}

func (*WorkerLogDeliveryParameters) DeepCopy

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

func (*WorkerLogDeliveryParameters) DeepCopyInto

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL