v1beta1

package
v1.4.0 Latest Latest
Warning

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

 Go to latest Published: Apr 2, 2024 License: Apache-2.0 Imports: 15 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 

func (in *ApacheKafkaClusterInitParameters) DeepCopy() *ApacheKafkaClusterInitParameters

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

func (*ApacheKafkaClusterInitParameters) DeepCopyInto 

func (in *ApacheKafkaClusterInitParameters) DeepCopyInto(out *ApacheKafkaClusterInitParameters)

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 

func (in *ApacheKafkaClusterObservation) DeepCopy() *ApacheKafkaClusterObservation

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

func (*ApacheKafkaClusterObservation) DeepCopyInto 

func (in *ApacheKafkaClusterObservation) DeepCopyInto(out *ApacheKafkaClusterObservation)

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 

func (in *ApacheKafkaClusterParameters) DeepCopy() *ApacheKafkaClusterParameters

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

func (*ApacheKafkaClusterParameters) DeepCopyInto 

func (in *ApacheKafkaClusterParameters) DeepCopyInto(out *ApacheKafkaClusterParameters)

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 

func (in *AutoscalingInitParameters) DeepCopy() *AutoscalingInitParameters

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

func (*AutoscalingInitParameters) DeepCopyInto 

func (in *AutoscalingInitParameters) DeepCopyInto(out *AutoscalingInitParameters)

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 

func (in *AutoscalingObservation) DeepCopy() *AutoscalingObservation

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 

func (in *AutoscalingParameters) DeepCopy() *AutoscalingParameters

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 

func (in *CapacityInitParameters) DeepCopy() *CapacityInitParameters

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 

func (in *CloudwatchLogsInitParameters) DeepCopy() *CloudwatchLogsInitParameters

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

func (*CloudwatchLogsInitParameters) DeepCopyInto 

func (in *CloudwatchLogsInitParameters) DeepCopyInto(out *CloudwatchLogsInitParameters)

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

type CloudwatchLogsObservation 

type CloudwatchLogsObservation struct {

	// 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 

func (in *CloudwatchLogsObservation) DeepCopy() *CloudwatchLogsObservation

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

func (*CloudwatchLogsObservation) DeepCopyInto 

func (in *CloudwatchLogsObservation) DeepCopyInto(out *CloudwatchLogsObservation)

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

type CloudwatchLogsParameters 

type CloudwatchLogsParameters struct {

	// 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 

func (in *CloudwatchLogsParameters) DeepCopy() *CloudwatchLogsParameters

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

func (*CloudwatchLogsParameters) DeepCopyInto 

func (in *CloudwatchLogsParameters) DeepCopyInto(out *CloudwatchLogsParameters)

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

type 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) 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) Hub 

func (tr *Connector) Hub()

Hub marks this type as a conversion hub.

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:"-"`

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

func (*ConnectorInitParameters) DeepCopy 

func (in *ConnectorInitParameters) DeepCopy() *ConnectorInitParameters

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"`

	// 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 

func (in *ConnectorObservation) DeepCopy() *ConnectorObservation

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:"-"`

	// 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) 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) Hub 

func (tr *CustomPlugin) Hub()

Hub marks this type as a conversion hub.

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 

func (in *CustomPluginInitParameters) DeepCopy() *CustomPluginInitParameters

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

func (*CustomPluginInitParameters) DeepCopyInto 

func (in *CustomPluginInitParameters) DeepCopyInto(out *CustomPluginInitParameters)

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"`
}

func (*CustomPluginInitParameters_2) DeepCopy 

func (in *CustomPluginInitParameters_2) DeepCopy() *CustomPluginInitParameters_2

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

func (*CustomPluginInitParameters_2) DeepCopyInto 

func (in *CustomPluginInitParameters_2) DeepCopyInto(out *CustomPluginInitParameters_2)

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 

func (in *CustomPluginObservation) DeepCopy() *CustomPluginObservation

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"`
}

func (*CustomPluginObservation_2) DeepCopy 

func (in *CustomPluginObservation_2) DeepCopy() *CustomPluginObservation_2

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

func (*CustomPluginObservation_2) DeepCopyInto 

func (in *CustomPluginObservation_2) DeepCopyInto(out *CustomPluginObservation_2)

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 

func (in *CustomPluginParameters) DeepCopy() *CustomPluginParameters

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:"-"`
}

func (*CustomPluginParameters_2) DeepCopy 

func (in *CustomPluginParameters_2) DeepCopy() *CustomPluginParameters_2

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 

func (in *FirehoseInitParameters) DeepCopy() *FirehoseInitParameters

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

func (*FirehoseInitParameters) DeepCopyInto 

func (in *FirehoseInitParameters) DeepCopyInto(out *FirehoseInitParameters)

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

type FirehoseObservation 

type FirehoseObservation struct {

	// 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 

func (in *KafkaClusterClientAuthenticationInitParameters) DeepCopy() *KafkaClusterClientAuthenticationInitParameters

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

func (*KafkaClusterClientAuthenticationInitParameters) DeepCopyInto 

func (in *KafkaClusterClientAuthenticationInitParameters) DeepCopyInto(out *KafkaClusterClientAuthenticationInitParameters)

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 

func (in *KafkaClusterClientAuthenticationObservation) DeepCopy() *KafkaClusterClientAuthenticationObservation

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

func (*KafkaClusterClientAuthenticationObservation) DeepCopyInto 

func (in *KafkaClusterClientAuthenticationObservation) DeepCopyInto(out *KafkaClusterClientAuthenticationObservation)

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 

func (in *KafkaClusterClientAuthenticationParameters) DeepCopy() *KafkaClusterClientAuthenticationParameters

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

func (*KafkaClusterClientAuthenticationParameters) DeepCopyInto 

func (in *KafkaClusterClientAuthenticationParameters) DeepCopyInto(out *KafkaClusterClientAuthenticationParameters)

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 

func (in *KafkaClusterEncryptionInTransitInitParameters) DeepCopy() *KafkaClusterEncryptionInTransitInitParameters

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

func (*KafkaClusterEncryptionInTransitInitParameters) DeepCopyInto 

func (in *KafkaClusterEncryptionInTransitInitParameters) DeepCopyInto(out *KafkaClusterEncryptionInTransitInitParameters)

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 

func (in *KafkaClusterEncryptionInTransitObservation) DeepCopy() *KafkaClusterEncryptionInTransitObservation

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

func (*KafkaClusterEncryptionInTransitObservation) DeepCopyInto 

func (in *KafkaClusterEncryptionInTransitObservation) DeepCopyInto(out *KafkaClusterEncryptionInTransitObservation)

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 

func (in *KafkaClusterEncryptionInTransitParameters) DeepCopy() *KafkaClusterEncryptionInTransitParameters

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

func (*KafkaClusterEncryptionInTransitParameters) DeepCopyInto 

func (in *KafkaClusterEncryptionInTransitParameters) DeepCopyInto(out *KafkaClusterEncryptionInTransitParameters)

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 

func (in *KafkaClusterInitParameters) DeepCopy() *KafkaClusterInitParameters

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

func (*KafkaClusterInitParameters) DeepCopyInto 

func (in *KafkaClusterInitParameters) DeepCopyInto(out *KafkaClusterInitParameters)

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 

func (in *KafkaClusterObservation) DeepCopy() *KafkaClusterObservation

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 

func (in *KafkaClusterParameters) DeepCopy() *KafkaClusterParameters

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 

func (in *LocationInitParameters) DeepCopy() *LocationInitParameters

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 

func (in *LocationS3InitParameters) DeepCopy() *LocationS3InitParameters

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 

func (in *LocationS3Observation) DeepCopy() *LocationS3Observation

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 

func (in *LocationS3Parameters) DeepCopy() *LocationS3Parameters

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 

func (in *LogDeliveryInitParameters) DeepCopy() *LogDeliveryInitParameters

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

func (*LogDeliveryInitParameters) DeepCopyInto 

func (in *LogDeliveryInitParameters) DeepCopyInto(out *LogDeliveryInitParameters)

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 

func (in *LogDeliveryObservation) DeepCopy() *LogDeliveryObservation

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 

func (in *LogDeliveryParameters) DeepCopy() *LogDeliveryParameters

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 

func (in *PluginInitParameters) DeepCopy() *PluginInitParameters

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 

func (in *ProvisionedCapacityInitParameters) DeepCopy() *ProvisionedCapacityInitParameters

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

func (*ProvisionedCapacityInitParameters) DeepCopyInto 

func (in *ProvisionedCapacityInitParameters) DeepCopyInto(out *ProvisionedCapacityInitParameters)

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 

func (in *ProvisionedCapacityObservation) DeepCopy() *ProvisionedCapacityObservation

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

func (*ProvisionedCapacityObservation) DeepCopyInto 

func (in *ProvisionedCapacityObservation) DeepCopyInto(out *ProvisionedCapacityObservation)

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 

func (in *ProvisionedCapacityParameters) DeepCopy() *ProvisionedCapacityParameters

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

func (*ProvisionedCapacityParameters) DeepCopyInto 

func (in *ProvisionedCapacityParameters) DeepCopyInto(out *ProvisionedCapacityParameters)

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 

func (in *ScaleInPolicyInitParameters) DeepCopy() *ScaleInPolicyInitParameters

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

func (*ScaleInPolicyInitParameters) DeepCopyInto 

func (in *ScaleInPolicyInitParameters) DeepCopyInto(out *ScaleInPolicyInitParameters)

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 

func (in *ScaleInPolicyObservation) DeepCopy() *ScaleInPolicyObservation

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 

func (in *ScaleInPolicyParameters) DeepCopy() *ScaleInPolicyParameters

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 

func (in *ScaleOutPolicyInitParameters) DeepCopy() *ScaleOutPolicyInitParameters

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

func (*ScaleOutPolicyInitParameters) DeepCopyInto 

func (in *ScaleOutPolicyInitParameters) DeepCopyInto(out *ScaleOutPolicyInitParameters)

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 

func (in *ScaleOutPolicyObservation) DeepCopy() *ScaleOutPolicyObservation

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

func (*ScaleOutPolicyObservation) DeepCopyInto 

func (in *ScaleOutPolicyObservation) DeepCopyInto(out *ScaleOutPolicyObservation)

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 

func (in *ScaleOutPolicyParameters) DeepCopy() *ScaleOutPolicyParameters

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 

func (in *WorkerConfigurationInitParameters) DeepCopy() *WorkerConfigurationInitParameters

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

func (*WorkerConfigurationInitParameters) DeepCopyInto 

func (in *WorkerConfigurationInitParameters) DeepCopyInto(out *WorkerConfigurationInitParameters)

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"`
}

func (*WorkerConfigurationInitParameters_2) DeepCopy 

func (in *WorkerConfigurationInitParameters_2) DeepCopy() *WorkerConfigurationInitParameters_2

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

func (*WorkerConfigurationInitParameters_2) DeepCopyInto 

func (in *WorkerConfigurationInitParameters_2) DeepCopyInto(out *WorkerConfigurationInitParameters_2)

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 

func (in *WorkerConfigurationList) DeepCopy() *WorkerConfigurationList

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 

func (in *WorkerConfigurationObservation) DeepCopy() *WorkerConfigurationObservation

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

func (*WorkerConfigurationObservation) DeepCopyInto 

func (in *WorkerConfigurationObservation) DeepCopyInto(out *WorkerConfigurationObservation)

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"`
}

func (*WorkerConfigurationObservation_2) DeepCopy 

func (in *WorkerConfigurationObservation_2) DeepCopy() *WorkerConfigurationObservation_2

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

func (*WorkerConfigurationObservation_2) DeepCopyInto 

func (in *WorkerConfigurationObservation_2) DeepCopyInto(out *WorkerConfigurationObservation_2)

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 

func (in *WorkerConfigurationParameters) DeepCopy() *WorkerConfigurationParameters

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

func (*WorkerConfigurationParameters) DeepCopyInto 

func (in *WorkerConfigurationParameters) DeepCopyInto(out *WorkerConfigurationParameters)

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:"-"`
}

func (*WorkerConfigurationParameters_2) DeepCopy 

func (in *WorkerConfigurationParameters_2) DeepCopy() *WorkerConfigurationParameters_2

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

func (*WorkerConfigurationParameters_2) DeepCopyInto 

func (in *WorkerConfigurationParameters_2) DeepCopyInto(out *WorkerConfigurationParameters_2)

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 

func (in *WorkerConfigurationSpec) DeepCopy() *WorkerConfigurationSpec

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 

func (in *WorkerConfigurationStatus) DeepCopy() *WorkerConfigurationStatus

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

func (*WorkerConfigurationStatus) DeepCopyInto 

func (in *WorkerConfigurationStatus) DeepCopyInto(out *WorkerConfigurationStatus)

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 

func (in *WorkerLogDeliveryInitParameters) DeepCopy() *WorkerLogDeliveryInitParameters

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

func (*WorkerLogDeliveryInitParameters) DeepCopyInto 

func (in *WorkerLogDeliveryInitParameters) DeepCopyInto(out *WorkerLogDeliveryInitParameters)

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 

func (in *WorkerLogDeliveryObservation) DeepCopy() *WorkerLogDeliveryObservation

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

func (*WorkerLogDeliveryObservation) DeepCopyInto 

func (in *WorkerLogDeliveryObservation) DeepCopyInto(out *WorkerLogDeliveryObservation)

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 

func (in *WorkerLogDeliveryParameters) DeepCopy() *WorkerLogDeliveryParameters

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

func (*WorkerLogDeliveryParameters) DeepCopyInto 

func (in *WorkerLogDeliveryParameters) DeepCopyInto(out *WorkerLogDeliveryParameters)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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