v1beta2

package
v1.13.0-rc.0 Latest Latest
Warning

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

 Go to latest Published: Aug 22, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Overview

+kubebuilder:object:generate=true +groupName=kinesisanalyticsv2.aws.upbound.io +versionName=v1beta2

Index

Constants

View Source 
const (
	CRDGroup   = "kinesisanalyticsv2.aws.upbound.io"
	CRDVersion = "v1beta2"
)

Package type metadata.

Variables

View Source 
var (
	Application_Kind             = "Application"
	Application_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Application_Kind}.String()
	Application_KindAPIVersion   = Application_Kind + "." + CRDGroupVersion.String()
	Application_GroupVersionKind = CRDGroupVersion.WithKind(Application_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
)

Functions

This section is empty.

Types

type Application 

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

Application is the Schema for the Applications API. Manages a Kinesis Analytics v2 Application. +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 (*Application) DeepCopy 

func (in *Application) DeepCopy() *Application

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

func (*Application) DeepCopyInto 

func (in *Application) DeepCopyInto(out *Application)

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

func (*Application) DeepCopyObject 

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

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

func (*Application) GetCondition 

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

GetCondition of this Application.

func (*Application) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this Application

func (*Application) GetDeletionPolicy 

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

GetDeletionPolicy of this Application.

func (*Application) GetID 

func (tr *Application) GetID() string

GetID returns ID of underlying Terraform resource of this Application

func (*Application) GetInitParameters 

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

GetInitParameters of this Application

func (*Application) GetManagementPolicies 

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

GetManagementPolicies of this Application.

func (*Application) GetMergedParameters 

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

GetInitParameters of this Application

func (*Application) GetObservation 

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

GetObservation of this Application

func (*Application) GetParameters 

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

GetParameters of this Application

func (*Application) GetProviderConfigReference 

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

GetProviderConfigReference of this Application.

func (*Application) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Application.

func (*Application) GetTerraformResourceType 

func (mg *Application) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Application

func (*Application) GetTerraformSchemaVersion 

func (tr *Application) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Application) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this Application.

func (*Application) Hub 

func (tr *Application) Hub()

Hub marks this type as a conversion hub.

func (*Application) LateInitialize 

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

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

func (*Application) ResolveReferences 

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

func (*Application) SetConditions 

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

SetConditions of this Application.

func (*Application) SetDeletionPolicy 

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

SetDeletionPolicy of this Application.

func (*Application) SetManagementPolicies 

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

SetManagementPolicies of this Application.

func (*Application) SetObservation 

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

SetObservation for this Application

func (*Application) SetParameters 

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

SetParameters for this Application

func (*Application) SetProviderConfigReference 

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

SetProviderConfigReference of this Application.

func (*Application) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this Application.

func (*Application) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this Application.

type ApplicationCodeConfigurationInitParameters 

type ApplicationCodeConfigurationInitParameters struct {

	// The location and type of the application code.
	CodeContent *CodeContentInitParameters `json:"codeContent,omitempty" tf:"code_content,omitempty"`

	// Specifies whether the code content is in text or zip format. Valid values: PLAINTEXT, ZIPFILE.
	CodeContentType *string `json:"codeContentType,omitempty" tf:"code_content_type,omitempty"`
}

func (*ApplicationCodeConfigurationInitParameters) DeepCopy 

func (in *ApplicationCodeConfigurationInitParameters) DeepCopy() *ApplicationCodeConfigurationInitParameters

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

func (*ApplicationCodeConfigurationInitParameters) DeepCopyInto 

func (in *ApplicationCodeConfigurationInitParameters) DeepCopyInto(out *ApplicationCodeConfigurationInitParameters)

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

type ApplicationCodeConfigurationObservation 

type ApplicationCodeConfigurationObservation struct {

	// The location and type of the application code.
	CodeContent *CodeContentObservation `json:"codeContent,omitempty" tf:"code_content,omitempty"`

	// Specifies whether the code content is in text or zip format. Valid values: PLAINTEXT, ZIPFILE.
	CodeContentType *string `json:"codeContentType,omitempty" tf:"code_content_type,omitempty"`
}

func (*ApplicationCodeConfigurationObservation) DeepCopy 

func (in *ApplicationCodeConfigurationObservation) DeepCopy() *ApplicationCodeConfigurationObservation

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

func (*ApplicationCodeConfigurationObservation) DeepCopyInto 

func (in *ApplicationCodeConfigurationObservation) DeepCopyInto(out *ApplicationCodeConfigurationObservation)

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

type ApplicationCodeConfigurationParameters 

type ApplicationCodeConfigurationParameters struct {

	// The location and type of the application code.
	// +kubebuilder:validation:Optional
	CodeContent *CodeContentParameters `json:"codeContent,omitempty" tf:"code_content,omitempty"`

	// Specifies whether the code content is in text or zip format. Valid values: PLAINTEXT, ZIPFILE.
	// +kubebuilder:validation:Optional
	CodeContentType *string `json:"codeContentType" tf:"code_content_type,omitempty"`
}

func (*ApplicationCodeConfigurationParameters) DeepCopy 

func (in *ApplicationCodeConfigurationParameters) DeepCopy() *ApplicationCodeConfigurationParameters

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

func (*ApplicationCodeConfigurationParameters) DeepCopyInto 

func (in *ApplicationCodeConfigurationParameters) DeepCopyInto(out *ApplicationCodeConfigurationParameters)

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

type ApplicationConfigurationInitParameters 

type ApplicationConfigurationInitParameters struct {

	// The code location and type parameters for the application.
	ApplicationCodeConfiguration *ApplicationCodeConfigurationInitParameters `json:"applicationCodeConfiguration,omitempty" tf:"application_code_configuration,omitempty"`

	// Describes whether snapshots are enabled for a Flink-based application.
	ApplicationSnapshotConfiguration *ApplicationSnapshotConfigurationInitParameters `json:"applicationSnapshotConfiguration,omitempty" tf:"application_snapshot_configuration,omitempty"`

	// Describes execution properties for a Flink-based application.
	EnvironmentProperties *EnvironmentPropertiesInitParameters `json:"environmentProperties,omitempty" tf:"environment_properties,omitempty"`

	// The configuration of a Flink-based application.
	FlinkApplicationConfiguration *FlinkApplicationConfigurationInitParameters `json:"flinkApplicationConfiguration,omitempty" tf:"flink_application_configuration,omitempty"`

	// Describes the starting properties for a Flink-based application.
	RunConfiguration *RunConfigurationInitParameters `json:"runConfiguration,omitempty" tf:"run_configuration,omitempty"`

	// The configuration of a SQL-based application.
	SQLApplicationConfiguration *SQLApplicationConfigurationInitParameters `json:"sqlApplicationConfiguration,omitempty" tf:"sql_application_configuration,omitempty"`

	// The VPC configuration of a Flink-based application.
	VPCConfiguration *VPCConfigurationInitParameters `json:"vpcConfiguration,omitempty" tf:"vpc_configuration,omitempty"`
}

func (*ApplicationConfigurationInitParameters) DeepCopy 

func (in *ApplicationConfigurationInitParameters) DeepCopy() *ApplicationConfigurationInitParameters

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

func (*ApplicationConfigurationInitParameters) DeepCopyInto 

func (in *ApplicationConfigurationInitParameters) DeepCopyInto(out *ApplicationConfigurationInitParameters)

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

type ApplicationConfigurationObservation 

type ApplicationConfigurationObservation struct {

	// The code location and type parameters for the application.
	ApplicationCodeConfiguration *ApplicationCodeConfigurationObservation `json:"applicationCodeConfiguration,omitempty" tf:"application_code_configuration,omitempty"`

	// Describes whether snapshots are enabled for a Flink-based application.
	ApplicationSnapshotConfiguration *ApplicationSnapshotConfigurationObservation `json:"applicationSnapshotConfiguration,omitempty" tf:"application_snapshot_configuration,omitempty"`

	// Describes execution properties for a Flink-based application.
	EnvironmentProperties *EnvironmentPropertiesObservation `json:"environmentProperties,omitempty" tf:"environment_properties,omitempty"`

	// The configuration of a Flink-based application.
	FlinkApplicationConfiguration *FlinkApplicationConfigurationObservation `json:"flinkApplicationConfiguration,omitempty" tf:"flink_application_configuration,omitempty"`

	// Describes the starting properties for a Flink-based application.
	RunConfiguration *RunConfigurationObservation `json:"runConfiguration,omitempty" tf:"run_configuration,omitempty"`

	// The configuration of a SQL-based application.
	SQLApplicationConfiguration *SQLApplicationConfigurationObservation `json:"sqlApplicationConfiguration,omitempty" tf:"sql_application_configuration,omitempty"`

	// The VPC configuration of a Flink-based application.
	VPCConfiguration *VPCConfigurationObservation `json:"vpcConfiguration,omitempty" tf:"vpc_configuration,omitempty"`
}

func (*ApplicationConfigurationObservation) DeepCopy 

func (in *ApplicationConfigurationObservation) DeepCopy() *ApplicationConfigurationObservation

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

func (*ApplicationConfigurationObservation) DeepCopyInto 

func (in *ApplicationConfigurationObservation) DeepCopyInto(out *ApplicationConfigurationObservation)

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

type ApplicationConfigurationParameters 

type ApplicationConfigurationParameters struct {

	// The code location and type parameters for the application.
	// +kubebuilder:validation:Optional
	ApplicationCodeConfiguration *ApplicationCodeConfigurationParameters `json:"applicationCodeConfiguration" tf:"application_code_configuration,omitempty"`

	// Describes whether snapshots are enabled for a Flink-based application.
	// +kubebuilder:validation:Optional
	ApplicationSnapshotConfiguration *ApplicationSnapshotConfigurationParameters `json:"applicationSnapshotConfiguration,omitempty" tf:"application_snapshot_configuration,omitempty"`

	// Describes execution properties for a Flink-based application.
	// +kubebuilder:validation:Optional
	EnvironmentProperties *EnvironmentPropertiesParameters `json:"environmentProperties,omitempty" tf:"environment_properties,omitempty"`

	// The configuration of a Flink-based application.
	// +kubebuilder:validation:Optional
	FlinkApplicationConfiguration *FlinkApplicationConfigurationParameters `json:"flinkApplicationConfiguration,omitempty" tf:"flink_application_configuration,omitempty"`

	// Describes the starting properties for a Flink-based application.
	// +kubebuilder:validation:Optional
	RunConfiguration *RunConfigurationParameters `json:"runConfiguration,omitempty" tf:"run_configuration,omitempty"`

	// The configuration of a SQL-based application.
	// +kubebuilder:validation:Optional
	SQLApplicationConfiguration *SQLApplicationConfigurationParameters `json:"sqlApplicationConfiguration,omitempty" tf:"sql_application_configuration,omitempty"`

	// The VPC configuration of a Flink-based application.
	// +kubebuilder:validation:Optional
	VPCConfiguration *VPCConfigurationParameters `json:"vpcConfiguration,omitempty" tf:"vpc_configuration,omitempty"`
}

func (*ApplicationConfigurationParameters) DeepCopy 

func (in *ApplicationConfigurationParameters) DeepCopy() *ApplicationConfigurationParameters

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

func (*ApplicationConfigurationParameters) DeepCopyInto 

func (in *ApplicationConfigurationParameters) DeepCopyInto(out *ApplicationConfigurationParameters)

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

type ApplicationInitParameters 

type ApplicationInitParameters struct {

	// The application's configuration
	ApplicationConfiguration *ApplicationConfigurationInitParameters `json:"applicationConfiguration,omitempty" tf:"application_configuration,omitempty"`

	// The application's mode. Valid values are STREAMING, INTERACTIVE.
	ApplicationMode *string `json:"applicationMode,omitempty" tf:"application_mode,omitempty"`

	// A CloudWatch log stream to monitor application configuration errors.
	CloudwatchLoggingOptions *CloudwatchLoggingOptionsInitParameters `json:"cloudwatchLoggingOptions,omitempty" tf:"cloudwatch_logging_options,omitempty"`

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

	// Whether to force stop an unresponsive Flink-based application.
	ForceStop *bool `json:"forceStop,omitempty" tf:"force_stop,omitempty"`

	// The runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
	RuntimeEnvironment *string `json:"runtimeEnvironment,omitempty" tf:"runtime_environment,omitempty"`

	// The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
	// +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()
	ServiceExecutionRole *string `json:"serviceExecutionRole,omitempty" tf:"service_execution_role,omitempty"`

	// Reference to a Role in iam to populate serviceExecutionRole.
	// +kubebuilder:validation:Optional
	ServiceExecutionRoleRef *v1.Reference `json:"serviceExecutionRoleRef,omitempty" tf:"-"`

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

	// Whether to start or stop the application.
	StartApplication *bool `json:"startApplication,omitempty" tf:"start_application,omitempty"`

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

func (*ApplicationInitParameters) DeepCopy 

func (in *ApplicationInitParameters) DeepCopy() *ApplicationInitParameters

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

func (*ApplicationInitParameters) DeepCopyInto 

func (in *ApplicationInitParameters) DeepCopyInto(out *ApplicationInitParameters)

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

type ApplicationList 

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

ApplicationList contains a list of Applications

func (*ApplicationList) DeepCopy 

func (in *ApplicationList) DeepCopy() *ApplicationList

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

func (*ApplicationList) DeepCopyInto 

func (in *ApplicationList) DeepCopyInto(out *ApplicationList)

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

func (*ApplicationList) DeepCopyObject 

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

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

func (*ApplicationList) GetItems 

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

GetItems of this ApplicationList.

type ApplicationObservation 

type ApplicationObservation struct {

	// The application's configuration
	ApplicationConfiguration *ApplicationConfigurationObservation `json:"applicationConfiguration,omitempty" tf:"application_configuration,omitempty"`

	// The application's mode. Valid values are STREAMING, INTERACTIVE.
	ApplicationMode *string `json:"applicationMode,omitempty" tf:"application_mode,omitempty"`

	// The ARN of the application.
	Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`

	// A CloudWatch log stream to monitor application configuration errors.
	CloudwatchLoggingOptions *CloudwatchLoggingOptionsObservation `json:"cloudwatchLoggingOptions,omitempty" tf:"cloudwatch_logging_options,omitempty"`

	// The current timestamp when the application was created.
	CreateTimestamp *string `json:"createTimestamp,omitempty" tf:"create_timestamp,omitempty"`

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

	// Whether to force stop an unresponsive Flink-based application.
	ForceStop *bool `json:"forceStop,omitempty" tf:"force_stop,omitempty"`

	// The application identifier.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The current timestamp when the application was last updated.
	LastUpdateTimestamp *string `json:"lastUpdateTimestamp,omitempty" tf:"last_update_timestamp,omitempty"`

	// The runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
	RuntimeEnvironment *string `json:"runtimeEnvironment,omitempty" tf:"runtime_environment,omitempty"`

	// The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
	ServiceExecutionRole *string `json:"serviceExecutionRole,omitempty" tf:"service_execution_role,omitempty"`

	// Whether to start or stop the application.
	StartApplication *bool `json:"startApplication,omitempty" tf:"start_application,omitempty"`

	// The status of the application.
	Status *string `json:"status,omitempty" tf:"status,omitempty"`

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

	// A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.
	// +mapType=granular
	TagsAll map[string]*string `json:"tagsAll,omitempty" tf:"tags_all,omitempty"`

	// The current application version. Kinesis Data Analytics updates the version_id each time the application is updated.
	VersionID *float64 `json:"versionId,omitempty" tf:"version_id,omitempty"`
}

func (*ApplicationObservation) DeepCopy 

func (in *ApplicationObservation) DeepCopy() *ApplicationObservation

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

func (*ApplicationObservation) DeepCopyInto 

func (in *ApplicationObservation) DeepCopyInto(out *ApplicationObservation)

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

type ApplicationParameters 

type ApplicationParameters struct {

	// The application's configuration
	// +kubebuilder:validation:Optional
	ApplicationConfiguration *ApplicationConfigurationParameters `json:"applicationConfiguration,omitempty" tf:"application_configuration,omitempty"`

	// The application's mode. Valid values are STREAMING, INTERACTIVE.
	// +kubebuilder:validation:Optional
	ApplicationMode *string `json:"applicationMode,omitempty" tf:"application_mode,omitempty"`

	// A CloudWatch log stream to monitor application configuration errors.
	// +kubebuilder:validation:Optional
	CloudwatchLoggingOptions *CloudwatchLoggingOptionsParameters `json:"cloudwatchLoggingOptions,omitempty" tf:"cloudwatch_logging_options,omitempty"`

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

	// Whether to force stop an unresponsive Flink-based application.
	// +kubebuilder:validation:Optional
	ForceStop *bool `json:"forceStop,omitempty" tf:"force_stop,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 runtime environment for the application. Valid values: SQL-1_0, FLINK-1_6, FLINK-1_8, FLINK-1_11, FLINK-1_13, FLINK-1_15, FLINK-1_18.
	// +kubebuilder:validation:Optional
	RuntimeEnvironment *string `json:"runtimeEnvironment,omitempty" tf:"runtime_environment,omitempty"`

	// The ARN of the IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
	// +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
	ServiceExecutionRole *string `json:"serviceExecutionRole,omitempty" tf:"service_execution_role,omitempty"`

	// Reference to a Role in iam to populate serviceExecutionRole.
	// +kubebuilder:validation:Optional
	ServiceExecutionRoleRef *v1.Reference `json:"serviceExecutionRoleRef,omitempty" tf:"-"`

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

	// Whether to start or stop the application.
	// +kubebuilder:validation:Optional
	StartApplication *bool `json:"startApplication,omitempty" tf:"start_application,omitempty"`

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

func (*ApplicationParameters) DeepCopy 

func (in *ApplicationParameters) DeepCopy() *ApplicationParameters

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

func (*ApplicationParameters) DeepCopyInto 

func (in *ApplicationParameters) DeepCopyInto(out *ApplicationParameters)

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

type ApplicationRestoreConfigurationInitParameters 

type ApplicationRestoreConfigurationInitParameters struct {

	// Specifies how the application should be restored. Valid values: RESTORE_FROM_CUSTOM_SNAPSHOT, RESTORE_FROM_LATEST_SNAPSHOT, SKIP_RESTORE_FROM_SNAPSHOT.
	ApplicationRestoreType *string `json:"applicationRestoreType,omitempty" tf:"application_restore_type,omitempty"`

	// The identifier of an existing snapshot of application state to use to restart an application. The application uses this value if RESTORE_FROM_CUSTOM_SNAPSHOT is specified for application_restore_type.
	SnapshotName *string `json:"snapshotName,omitempty" tf:"snapshot_name,omitempty"`
}

func (*ApplicationRestoreConfigurationInitParameters) DeepCopy 

func (in *ApplicationRestoreConfigurationInitParameters) DeepCopy() *ApplicationRestoreConfigurationInitParameters

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

func (*ApplicationRestoreConfigurationInitParameters) DeepCopyInto 

func (in *ApplicationRestoreConfigurationInitParameters) DeepCopyInto(out *ApplicationRestoreConfigurationInitParameters)

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

type ApplicationRestoreConfigurationObservation 

type ApplicationRestoreConfigurationObservation struct {

	// Specifies how the application should be restored. Valid values: RESTORE_FROM_CUSTOM_SNAPSHOT, RESTORE_FROM_LATEST_SNAPSHOT, SKIP_RESTORE_FROM_SNAPSHOT.
	ApplicationRestoreType *string `json:"applicationRestoreType,omitempty" tf:"application_restore_type,omitempty"`

	// The identifier of an existing snapshot of application state to use to restart an application. The application uses this value if RESTORE_FROM_CUSTOM_SNAPSHOT is specified for application_restore_type.
	SnapshotName *string `json:"snapshotName,omitempty" tf:"snapshot_name,omitempty"`
}

func (*ApplicationRestoreConfigurationObservation) DeepCopy 

func (in *ApplicationRestoreConfigurationObservation) DeepCopy() *ApplicationRestoreConfigurationObservation

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

func (*ApplicationRestoreConfigurationObservation) DeepCopyInto 

func (in *ApplicationRestoreConfigurationObservation) DeepCopyInto(out *ApplicationRestoreConfigurationObservation)

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

type ApplicationRestoreConfigurationParameters 

type ApplicationRestoreConfigurationParameters struct {

	// Specifies how the application should be restored. Valid values: RESTORE_FROM_CUSTOM_SNAPSHOT, RESTORE_FROM_LATEST_SNAPSHOT, SKIP_RESTORE_FROM_SNAPSHOT.
	// +kubebuilder:validation:Optional
	ApplicationRestoreType *string `json:"applicationRestoreType,omitempty" tf:"application_restore_type,omitempty"`

	// The identifier of an existing snapshot of application state to use to restart an application. The application uses this value if RESTORE_FROM_CUSTOM_SNAPSHOT is specified for application_restore_type.
	// +kubebuilder:validation:Optional
	SnapshotName *string `json:"snapshotName,omitempty" tf:"snapshot_name,omitempty"`
}

func (*ApplicationRestoreConfigurationParameters) DeepCopy 

func (in *ApplicationRestoreConfigurationParameters) DeepCopy() *ApplicationRestoreConfigurationParameters

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

func (*ApplicationRestoreConfigurationParameters) DeepCopyInto 

func (in *ApplicationRestoreConfigurationParameters) DeepCopyInto(out *ApplicationRestoreConfigurationParameters)

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

type ApplicationSnapshotConfigurationInitParameters 

type ApplicationSnapshotConfigurationInitParameters struct {

	// Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
	SnapshotsEnabled *bool `json:"snapshotsEnabled,omitempty" tf:"snapshots_enabled,omitempty"`
}

func (*ApplicationSnapshotConfigurationInitParameters) DeepCopy 

func (in *ApplicationSnapshotConfigurationInitParameters) DeepCopy() *ApplicationSnapshotConfigurationInitParameters

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

func (*ApplicationSnapshotConfigurationInitParameters) DeepCopyInto 

func (in *ApplicationSnapshotConfigurationInitParameters) DeepCopyInto(out *ApplicationSnapshotConfigurationInitParameters)

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

type ApplicationSnapshotConfigurationObservation 

type ApplicationSnapshotConfigurationObservation struct {

	// Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
	SnapshotsEnabled *bool `json:"snapshotsEnabled,omitempty" tf:"snapshots_enabled,omitempty"`
}

func (*ApplicationSnapshotConfigurationObservation) DeepCopy 

func (in *ApplicationSnapshotConfigurationObservation) DeepCopy() *ApplicationSnapshotConfigurationObservation

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

func (*ApplicationSnapshotConfigurationObservation) DeepCopyInto 

func (in *ApplicationSnapshotConfigurationObservation) DeepCopyInto(out *ApplicationSnapshotConfigurationObservation)

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

type ApplicationSnapshotConfigurationParameters 

type ApplicationSnapshotConfigurationParameters struct {

	// Describes whether snapshots are enabled for a Flink-based Kinesis Data Analytics application.
	// +kubebuilder:validation:Optional
	SnapshotsEnabled *bool `json:"snapshotsEnabled" tf:"snapshots_enabled,omitempty"`
}

func (*ApplicationSnapshotConfigurationParameters) DeepCopy 

func (in *ApplicationSnapshotConfigurationParameters) DeepCopy() *ApplicationSnapshotConfigurationParameters

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

func (*ApplicationSnapshotConfigurationParameters) DeepCopyInto 

func (in *ApplicationSnapshotConfigurationParameters) DeepCopyInto(out *ApplicationSnapshotConfigurationParameters)

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

type ApplicationSpec 

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

ApplicationSpec defines the desired state of Application

func (*ApplicationSpec) DeepCopy 

func (in *ApplicationSpec) DeepCopy() *ApplicationSpec

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

func (*ApplicationSpec) DeepCopyInto 

func (in *ApplicationSpec) DeepCopyInto(out *ApplicationSpec)

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

type ApplicationStatus 

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

ApplicationStatus defines the observed state of Application.

func (*ApplicationStatus) DeepCopy 

func (in *ApplicationStatus) DeepCopy() *ApplicationStatus

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

func (*ApplicationStatus) DeepCopyInto 

func (in *ApplicationStatus) DeepCopyInto(out *ApplicationStatus)

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

type CheckpointConfigurationInitParameters 

type CheckpointConfigurationInitParameters struct {

	// Describes the interval in milliseconds between checkpoint operations.
	CheckpointInterval *float64 `json:"checkpointInterval,omitempty" tf:"checkpoint_interval,omitempty"`

	// Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.
	CheckpointingEnabled *bool `json:"checkpointingEnabled,omitempty" tf:"checkpointing_enabled,omitempty"`

	// Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:
	ConfigurationType *string `json:"configurationType,omitempty" tf:"configuration_type,omitempty"`

	// Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
	MinPauseBetweenCheckpoints *float64 `json:"minPauseBetweenCheckpoints,omitempty" tf:"min_pause_between_checkpoints,omitempty"`
}

func (*CheckpointConfigurationInitParameters) DeepCopy 

func (in *CheckpointConfigurationInitParameters) DeepCopy() *CheckpointConfigurationInitParameters

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

func (*CheckpointConfigurationInitParameters) DeepCopyInto 

func (in *CheckpointConfigurationInitParameters) DeepCopyInto(out *CheckpointConfigurationInitParameters)

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

type CheckpointConfigurationObservation 

type CheckpointConfigurationObservation struct {

	// Describes the interval in milliseconds between checkpoint operations.
	CheckpointInterval *float64 `json:"checkpointInterval,omitempty" tf:"checkpoint_interval,omitempty"`

	// Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.
	CheckpointingEnabled *bool `json:"checkpointingEnabled,omitempty" tf:"checkpointing_enabled,omitempty"`

	// Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:
	ConfigurationType *string `json:"configurationType,omitempty" tf:"configuration_type,omitempty"`

	// Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
	MinPauseBetweenCheckpoints *float64 `json:"minPauseBetweenCheckpoints,omitempty" tf:"min_pause_between_checkpoints,omitempty"`
}

func (*CheckpointConfigurationObservation) DeepCopy 

func (in *CheckpointConfigurationObservation) DeepCopy() *CheckpointConfigurationObservation

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

func (*CheckpointConfigurationObservation) DeepCopyInto 

func (in *CheckpointConfigurationObservation) DeepCopyInto(out *CheckpointConfigurationObservation)

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

type CheckpointConfigurationParameters 

type CheckpointConfigurationParameters struct {

	// Describes the interval in milliseconds between checkpoint operations.
	// +kubebuilder:validation:Optional
	CheckpointInterval *float64 `json:"checkpointInterval,omitempty" tf:"checkpoint_interval,omitempty"`

	// Describes whether checkpointing is enabled for a Flink-based Kinesis Data Analytics application.
	// +kubebuilder:validation:Optional
	CheckpointingEnabled *bool `json:"checkpointingEnabled,omitempty" tf:"checkpointing_enabled,omitempty"`

	// Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:
	// +kubebuilder:validation:Optional
	ConfigurationType *string `json:"configurationType" tf:"configuration_type,omitempty"`

	// Describes the minimum time in milliseconds after a checkpoint operation completes that a new checkpoint operation can start.
	// +kubebuilder:validation:Optional
	MinPauseBetweenCheckpoints *float64 `json:"minPauseBetweenCheckpoints,omitempty" tf:"min_pause_between_checkpoints,omitempty"`
}

func (*CheckpointConfigurationParameters) DeepCopy 

func (in *CheckpointConfigurationParameters) DeepCopy() *CheckpointConfigurationParameters

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

func (*CheckpointConfigurationParameters) DeepCopyInto 

func (in *CheckpointConfigurationParameters) DeepCopyInto(out *CheckpointConfigurationParameters)

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

type CloudwatchLoggingOptionsInitParameters 

type CloudwatchLoggingOptionsInitParameters struct {

	// The ARN of the CloudWatch log stream to receive application messages.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/cloudwatchlogs/v1beta1.Stream
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("arn",true)
	LogStreamArn *string `json:"logStreamArn,omitempty" tf:"log_stream_arn,omitempty"`

	// Reference to a Stream in cloudwatchlogs to populate logStreamArn.
	// +kubebuilder:validation:Optional
	LogStreamArnRef *v1.Reference `json:"logStreamArnRef,omitempty" tf:"-"`

	// Selector for a Stream in cloudwatchlogs to populate logStreamArn.
	// +kubebuilder:validation:Optional
	LogStreamArnSelector *v1.Selector `json:"logStreamArnSelector,omitempty" tf:"-"`
}

func (*CloudwatchLoggingOptionsInitParameters) DeepCopy 

func (in *CloudwatchLoggingOptionsInitParameters) DeepCopy() *CloudwatchLoggingOptionsInitParameters

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

func (*CloudwatchLoggingOptionsInitParameters) DeepCopyInto 

func (in *CloudwatchLoggingOptionsInitParameters) DeepCopyInto(out *CloudwatchLoggingOptionsInitParameters)

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

type CloudwatchLoggingOptionsObservation 

type CloudwatchLoggingOptionsObservation struct {

	// The application identifier.
	CloudwatchLoggingOptionID *string `json:"cloudwatchLoggingOptionId,omitempty" tf:"cloudwatch_logging_option_id,omitempty"`

	// The ARN of the CloudWatch log stream to receive application messages.
	LogStreamArn *string `json:"logStreamArn,omitempty" tf:"log_stream_arn,omitempty"`
}

func (*CloudwatchLoggingOptionsObservation) DeepCopy 

func (in *CloudwatchLoggingOptionsObservation) DeepCopy() *CloudwatchLoggingOptionsObservation

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

func (*CloudwatchLoggingOptionsObservation) DeepCopyInto 

func (in *CloudwatchLoggingOptionsObservation) DeepCopyInto(out *CloudwatchLoggingOptionsObservation)

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

type CloudwatchLoggingOptionsParameters 

type CloudwatchLoggingOptionsParameters struct {

	// The ARN of the CloudWatch log stream to receive application messages.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/cloudwatchlogs/v1beta1.Stream
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("arn",true)
	// +kubebuilder:validation:Optional
	LogStreamArn *string `json:"logStreamArn,omitempty" tf:"log_stream_arn,omitempty"`

	// Reference to a Stream in cloudwatchlogs to populate logStreamArn.
	// +kubebuilder:validation:Optional
	LogStreamArnRef *v1.Reference `json:"logStreamArnRef,omitempty" tf:"-"`

	// Selector for a Stream in cloudwatchlogs to populate logStreamArn.
	// +kubebuilder:validation:Optional
	LogStreamArnSelector *v1.Selector `json:"logStreamArnSelector,omitempty" tf:"-"`
}

func (*CloudwatchLoggingOptionsParameters) DeepCopy 

func (in *CloudwatchLoggingOptionsParameters) DeepCopy() *CloudwatchLoggingOptionsParameters

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

func (*CloudwatchLoggingOptionsParameters) DeepCopyInto 

func (in *CloudwatchLoggingOptionsParameters) DeepCopyInto(out *CloudwatchLoggingOptionsParameters)

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

type CodeContentInitParameters 

type CodeContentInitParameters struct {

	// Information about the Amazon S3 bucket containing the application code.
	S3ContentLocation *S3ContentLocationInitParameters `json:"s3ContentLocation,omitempty" tf:"s3_content_location,omitempty"`

	// The text-format code for the application.
	TextContent *string `json:"textContent,omitempty" tf:"text_content,omitempty"`
}

func (*CodeContentInitParameters) DeepCopy 

func (in *CodeContentInitParameters) DeepCopy() *CodeContentInitParameters

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

func (*CodeContentInitParameters) DeepCopyInto 

func (in *CodeContentInitParameters) DeepCopyInto(out *CodeContentInitParameters)

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

type CodeContentObservation 

type CodeContentObservation struct {

	// Information about the Amazon S3 bucket containing the application code.
	S3ContentLocation *S3ContentLocationObservation `json:"s3ContentLocation,omitempty" tf:"s3_content_location,omitempty"`

	// The text-format code for the application.
	TextContent *string `json:"textContent,omitempty" tf:"text_content,omitempty"`
}

func (*CodeContentObservation) DeepCopy 

func (in *CodeContentObservation) DeepCopy() *CodeContentObservation

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

func (*CodeContentObservation) DeepCopyInto 

func (in *CodeContentObservation) DeepCopyInto(out *CodeContentObservation)

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

type CodeContentParameters 

type CodeContentParameters struct {

	// Information about the Amazon S3 bucket containing the application code.
	// +kubebuilder:validation:Optional
	S3ContentLocation *S3ContentLocationParameters `json:"s3ContentLocation,omitempty" tf:"s3_content_location,omitempty"`

	// The text-format code for the application.
	// +kubebuilder:validation:Optional
	TextContent *string `json:"textContent,omitempty" tf:"text_content,omitempty"`
}

func (*CodeContentParameters) DeepCopy 

func (in *CodeContentParameters) DeepCopy() *CodeContentParameters

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

func (*CodeContentParameters) DeepCopyInto 

func (in *CodeContentParameters) DeepCopyInto(out *CodeContentParameters)

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

type CsvMappingParametersInitParameters 

type CsvMappingParametersInitParameters struct {

	// The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
	RecordColumnDelimiter *string `json:"recordColumnDelimiter,omitempty" tf:"record_column_delimiter,omitempty"`

	// The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
	RecordRowDelimiter *string `json:"recordRowDelimiter,omitempty" tf:"record_row_delimiter,omitempty"`
}

func (*CsvMappingParametersInitParameters) DeepCopy 

func (in *CsvMappingParametersInitParameters) DeepCopy() *CsvMappingParametersInitParameters

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

func (*CsvMappingParametersInitParameters) DeepCopyInto 

func (in *CsvMappingParametersInitParameters) DeepCopyInto(out *CsvMappingParametersInitParameters)

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

type CsvMappingParametersObservation 

type CsvMappingParametersObservation struct {

	// The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
	RecordColumnDelimiter *string `json:"recordColumnDelimiter,omitempty" tf:"record_column_delimiter,omitempty"`

	// The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
	RecordRowDelimiter *string `json:"recordRowDelimiter,omitempty" tf:"record_row_delimiter,omitempty"`
}

func (*CsvMappingParametersObservation) DeepCopy 

func (in *CsvMappingParametersObservation) DeepCopy() *CsvMappingParametersObservation

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

func (*CsvMappingParametersObservation) DeepCopyInto 

func (in *CsvMappingParametersObservation) DeepCopyInto(out *CsvMappingParametersObservation)

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

type CsvMappingParametersParameters 

type CsvMappingParametersParameters struct {

	// The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
	// +kubebuilder:validation:Optional
	RecordColumnDelimiter *string `json:"recordColumnDelimiter" tf:"record_column_delimiter,omitempty"`

	// The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
	// +kubebuilder:validation:Optional
	RecordRowDelimiter *string `json:"recordRowDelimiter" tf:"record_row_delimiter,omitempty"`
}

func (*CsvMappingParametersParameters) DeepCopy 

func (in *CsvMappingParametersParameters) DeepCopy() *CsvMappingParametersParameters

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

func (*CsvMappingParametersParameters) DeepCopyInto 

func (in *CsvMappingParametersParameters) DeepCopyInto(out *CsvMappingParametersParameters)

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

type DestinationSchemaInitParameters 

type DestinationSchemaInitParameters struct {

	// The type of record format. Valid values: CSV, JSON.
	RecordFormatType *string `json:"recordFormatType,omitempty" tf:"record_format_type,omitempty"`
}

func (*DestinationSchemaInitParameters) DeepCopy 

func (in *DestinationSchemaInitParameters) DeepCopy() *DestinationSchemaInitParameters

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

func (*DestinationSchemaInitParameters) DeepCopyInto 

func (in *DestinationSchemaInitParameters) DeepCopyInto(out *DestinationSchemaInitParameters)

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

type DestinationSchemaObservation 

type DestinationSchemaObservation struct {

	// The type of record format. Valid values: CSV, JSON.
	RecordFormatType *string `json:"recordFormatType,omitempty" tf:"record_format_type,omitempty"`
}

func (*DestinationSchemaObservation) DeepCopy 

func (in *DestinationSchemaObservation) DeepCopy() *DestinationSchemaObservation

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

func (*DestinationSchemaObservation) DeepCopyInto 

func (in *DestinationSchemaObservation) DeepCopyInto(out *DestinationSchemaObservation)

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

type DestinationSchemaParameters 

type DestinationSchemaParameters struct {

	// The type of record format. Valid values: CSV, JSON.
	// +kubebuilder:validation:Optional
	RecordFormatType *string `json:"recordFormatType" tf:"record_format_type,omitempty"`
}

func (*DestinationSchemaParameters) DeepCopy 

func (in *DestinationSchemaParameters) DeepCopy() *DestinationSchemaParameters

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

func (*DestinationSchemaParameters) DeepCopyInto 

func (in *DestinationSchemaParameters) DeepCopyInto(out *DestinationSchemaParameters)

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

type EnvironmentPropertiesInitParameters 

type EnvironmentPropertiesInitParameters struct {

	// Describes the execution property groups.
	PropertyGroup []PropertyGroupInitParameters `json:"propertyGroup,omitempty" tf:"property_group,omitempty"`
}

func (*EnvironmentPropertiesInitParameters) DeepCopy 

func (in *EnvironmentPropertiesInitParameters) DeepCopy() *EnvironmentPropertiesInitParameters

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

func (*EnvironmentPropertiesInitParameters) DeepCopyInto 

func (in *EnvironmentPropertiesInitParameters) DeepCopyInto(out *EnvironmentPropertiesInitParameters)

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

type EnvironmentPropertiesObservation 

type EnvironmentPropertiesObservation struct {

	// Describes the execution property groups.
	PropertyGroup []PropertyGroupObservation `json:"propertyGroup,omitempty" tf:"property_group,omitempty"`
}

func (*EnvironmentPropertiesObservation) DeepCopy 

func (in *EnvironmentPropertiesObservation) DeepCopy() *EnvironmentPropertiesObservation

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

func (*EnvironmentPropertiesObservation) DeepCopyInto 

func (in *EnvironmentPropertiesObservation) DeepCopyInto(out *EnvironmentPropertiesObservation)

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

type EnvironmentPropertiesParameters 

type EnvironmentPropertiesParameters struct {

	// Describes the execution property groups.
	// +kubebuilder:validation:Optional
	PropertyGroup []PropertyGroupParameters `json:"propertyGroup" tf:"property_group,omitempty"`
}

func (*EnvironmentPropertiesParameters) DeepCopy 

func (in *EnvironmentPropertiesParameters) DeepCopy() *EnvironmentPropertiesParameters

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

func (*EnvironmentPropertiesParameters) DeepCopyInto 

func (in *EnvironmentPropertiesParameters) DeepCopyInto(out *EnvironmentPropertiesParameters)

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

type FlinkApplicationConfigurationInitParameters 

type FlinkApplicationConfigurationInitParameters struct {

	// Describes an application's checkpointing configuration.
	CheckpointConfiguration *CheckpointConfigurationInitParameters `json:"checkpointConfiguration,omitempty" tf:"checkpoint_configuration,omitempty"`

	// Describes configuration parameters for CloudWatch logging for an application.
	MonitoringConfiguration *MonitoringConfigurationInitParameters `json:"monitoringConfiguration,omitempty" tf:"monitoring_configuration,omitempty"`

	// Describes parameters for how an application executes multiple tasks simultaneously.
	ParallelismConfiguration *ParallelismConfigurationInitParameters `json:"parallelismConfiguration,omitempty" tf:"parallelism_configuration,omitempty"`
}

func (*FlinkApplicationConfigurationInitParameters) DeepCopy 

func (in *FlinkApplicationConfigurationInitParameters) DeepCopy() *FlinkApplicationConfigurationInitParameters

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

func (*FlinkApplicationConfigurationInitParameters) DeepCopyInto 

func (in *FlinkApplicationConfigurationInitParameters) DeepCopyInto(out *FlinkApplicationConfigurationInitParameters)

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

type FlinkApplicationConfigurationObservation 

type FlinkApplicationConfigurationObservation struct {

	// Describes an application's checkpointing configuration.
	CheckpointConfiguration *CheckpointConfigurationObservation `json:"checkpointConfiguration,omitempty" tf:"checkpoint_configuration,omitempty"`

	// Describes configuration parameters for CloudWatch logging for an application.
	MonitoringConfiguration *MonitoringConfigurationObservation `json:"monitoringConfiguration,omitempty" tf:"monitoring_configuration,omitempty"`

	// Describes parameters for how an application executes multiple tasks simultaneously.
	ParallelismConfiguration *ParallelismConfigurationObservation `json:"parallelismConfiguration,omitempty" tf:"parallelism_configuration,omitempty"`
}

func (*FlinkApplicationConfigurationObservation) DeepCopy 

func (in *FlinkApplicationConfigurationObservation) DeepCopy() *FlinkApplicationConfigurationObservation

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

func (*FlinkApplicationConfigurationObservation) DeepCopyInto 

func (in *FlinkApplicationConfigurationObservation) DeepCopyInto(out *FlinkApplicationConfigurationObservation)

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

type FlinkApplicationConfigurationParameters 

type FlinkApplicationConfigurationParameters struct {

	// Describes an application's checkpointing configuration.
	// +kubebuilder:validation:Optional
	CheckpointConfiguration *CheckpointConfigurationParameters `json:"checkpointConfiguration,omitempty" tf:"checkpoint_configuration,omitempty"`

	// Describes configuration parameters for CloudWatch logging for an application.
	// +kubebuilder:validation:Optional
	MonitoringConfiguration *MonitoringConfigurationParameters `json:"monitoringConfiguration,omitempty" tf:"monitoring_configuration,omitempty"`

	// Describes parameters for how an application executes multiple tasks simultaneously.
	// +kubebuilder:validation:Optional
	ParallelismConfiguration *ParallelismConfigurationParameters `json:"parallelismConfiguration,omitempty" tf:"parallelism_configuration,omitempty"`
}

func (*FlinkApplicationConfigurationParameters) DeepCopy 

func (in *FlinkApplicationConfigurationParameters) DeepCopy() *FlinkApplicationConfigurationParameters

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

func (*FlinkApplicationConfigurationParameters) DeepCopyInto 

func (in *FlinkApplicationConfigurationParameters) DeepCopyInto(out *FlinkApplicationConfigurationParameters)

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

type FlinkRunConfigurationInitParameters 

type FlinkRunConfigurationInitParameters struct {

	// When restoring from a snapshot, specifies whether the runtime is allowed to skip a state that cannot be mapped to the new program. Default is false.
	AllowNonRestoredState *bool `json:"allowNonRestoredState,omitempty" tf:"allow_non_restored_state,omitempty"`
}

func (*FlinkRunConfigurationInitParameters) DeepCopy 

func (in *FlinkRunConfigurationInitParameters) DeepCopy() *FlinkRunConfigurationInitParameters

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

func (*FlinkRunConfigurationInitParameters) DeepCopyInto 

func (in *FlinkRunConfigurationInitParameters) DeepCopyInto(out *FlinkRunConfigurationInitParameters)

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

type FlinkRunConfigurationObservation 

type FlinkRunConfigurationObservation struct {

	// When restoring from a snapshot, specifies whether the runtime is allowed to skip a state that cannot be mapped to the new program. Default is false.
	AllowNonRestoredState *bool `json:"allowNonRestoredState,omitempty" tf:"allow_non_restored_state,omitempty"`
}

func (*FlinkRunConfigurationObservation) DeepCopy 

func (in *FlinkRunConfigurationObservation) DeepCopy() *FlinkRunConfigurationObservation

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

func (*FlinkRunConfigurationObservation) DeepCopyInto 

func (in *FlinkRunConfigurationObservation) DeepCopyInto(out *FlinkRunConfigurationObservation)

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

type FlinkRunConfigurationParameters 

type FlinkRunConfigurationParameters struct {

	// When restoring from a snapshot, specifies whether the runtime is allowed to skip a state that cannot be mapped to the new program. Default is false.
	// +kubebuilder:validation:Optional
	AllowNonRestoredState *bool `json:"allowNonRestoredState,omitempty" tf:"allow_non_restored_state,omitempty"`
}

func (*FlinkRunConfigurationParameters) DeepCopy 

func (in *FlinkRunConfigurationParameters) DeepCopy() *FlinkRunConfigurationParameters

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

func (*FlinkRunConfigurationParameters) DeepCopyInto 

func (in *FlinkRunConfigurationParameters) DeepCopyInto(out *FlinkRunConfigurationParameters)

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

type InputInitParameters 

type InputInitParameters struct {

	// Describes the number of in-application streams to create.
	InputParallelism *InputParallelismInitParameters `json:"inputParallelism,omitempty" tf:"input_parallelism,omitempty"`

	// The input processing configuration for the input.
	// An input processor transforms records as they are received from the stream, before the application's SQL code executes.
	InputProcessingConfiguration *InputProcessingConfigurationInitParameters `json:"inputProcessingConfiguration,omitempty" tf:"input_processing_configuration,omitempty"`

	// Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
	InputSchema *InputSchemaInitParameters `json:"inputSchema,omitempty" tf:"input_schema,omitempty"`

	// The point at which the application starts processing records from the streaming source.
	InputStartingPositionConfiguration []InputStartingPositionConfigurationInitParameters `json:"inputStartingPositionConfiguration,omitempty" tf:"input_starting_position_configuration,omitempty"`

	// If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
	KinesisFirehoseInput *KinesisFirehoseInputInitParameters `json:"kinesisFirehoseInput,omitempty" tf:"kinesis_firehose_input,omitempty"`

	// If the streaming source is a Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
	KinesisStreamsInput *KinesisStreamsInputInitParameters `json:"kinesisStreamsInput,omitempty" tf:"kinesis_streams_input,omitempty"`

	// The name prefix to use when creating an in-application stream.
	NamePrefix *string `json:"namePrefix,omitempty" tf:"name_prefix,omitempty"`
}

func (*InputInitParameters) DeepCopy 

func (in *InputInitParameters) DeepCopy() *InputInitParameters

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

func (*InputInitParameters) DeepCopyInto 

func (in *InputInitParameters) DeepCopyInto(out *InputInitParameters)

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

type InputLambdaProcessorInitParameters 

type InputLambdaProcessorInitParameters struct {

	// The ARN of the Lambda function that operates on records in the stream.
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`
}

func (*InputLambdaProcessorInitParameters) DeepCopy 

func (in *InputLambdaProcessorInitParameters) DeepCopy() *InputLambdaProcessorInitParameters

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

func (*InputLambdaProcessorInitParameters) DeepCopyInto 

func (in *InputLambdaProcessorInitParameters) DeepCopyInto(out *InputLambdaProcessorInitParameters)

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

type InputLambdaProcessorObservation 

type InputLambdaProcessorObservation struct {

	// The ARN of the Lambda function that operates on records in the stream.
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`
}

func (*InputLambdaProcessorObservation) DeepCopy 

func (in *InputLambdaProcessorObservation) DeepCopy() *InputLambdaProcessorObservation

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

func (*InputLambdaProcessorObservation) DeepCopyInto 

func (in *InputLambdaProcessorObservation) DeepCopyInto(out *InputLambdaProcessorObservation)

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

type InputLambdaProcessorParameters 

type InputLambdaProcessorParameters struct {

	// The ARN of the Lambda function that operates on records in the stream.
	// +kubebuilder:validation:Optional
	ResourceArn *string `json:"resourceArn" tf:"resource_arn,omitempty"`
}

func (*InputLambdaProcessorParameters) DeepCopy 

func (in *InputLambdaProcessorParameters) DeepCopy() *InputLambdaProcessorParameters

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

func (*InputLambdaProcessorParameters) DeepCopyInto 

func (in *InputLambdaProcessorParameters) DeepCopyInto(out *InputLambdaProcessorParameters)

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

type InputObservation 

type InputObservation struct {
	InAppStreamNames []*string `json:"inAppStreamNames,omitempty" tf:"in_app_stream_names,omitempty"`

	// The application identifier.
	InputID *string `json:"inputId,omitempty" tf:"input_id,omitempty"`

	// Describes the number of in-application streams to create.
	InputParallelism *InputParallelismObservation `json:"inputParallelism,omitempty" tf:"input_parallelism,omitempty"`

	// The input processing configuration for the input.
	// An input processor transforms records as they are received from the stream, before the application's SQL code executes.
	InputProcessingConfiguration *InputProcessingConfigurationObservation `json:"inputProcessingConfiguration,omitempty" tf:"input_processing_configuration,omitempty"`

	// Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
	InputSchema *InputSchemaObservation `json:"inputSchema,omitempty" tf:"input_schema,omitempty"`

	// The point at which the application starts processing records from the streaming source.
	InputStartingPositionConfiguration []InputStartingPositionConfigurationObservation `json:"inputStartingPositionConfiguration,omitempty" tf:"input_starting_position_configuration,omitempty"`

	// If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
	KinesisFirehoseInput *KinesisFirehoseInputObservation `json:"kinesisFirehoseInput,omitempty" tf:"kinesis_firehose_input,omitempty"`

	// If the streaming source is a Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
	KinesisStreamsInput *KinesisStreamsInputObservation `json:"kinesisStreamsInput,omitempty" tf:"kinesis_streams_input,omitempty"`

	// The name prefix to use when creating an in-application stream.
	NamePrefix *string `json:"namePrefix,omitempty" tf:"name_prefix,omitempty"`
}

func (*InputObservation) DeepCopy 

func (in *InputObservation) DeepCopy() *InputObservation

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

func (*InputObservation) DeepCopyInto 

func (in *InputObservation) DeepCopyInto(out *InputObservation)

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

type InputParallelismInitParameters 

type InputParallelismInitParameters struct {

	// The number of in-application streams to create.
	Count *float64 `json:"count,omitempty" tf:"count,omitempty"`
}

func (*InputParallelismInitParameters) DeepCopy 

func (in *InputParallelismInitParameters) DeepCopy() *InputParallelismInitParameters

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

func (*InputParallelismInitParameters) DeepCopyInto 

func (in *InputParallelismInitParameters) DeepCopyInto(out *InputParallelismInitParameters)

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

type InputParallelismObservation 

type InputParallelismObservation struct {

	// The number of in-application streams to create.
	Count *float64 `json:"count,omitempty" tf:"count,omitempty"`
}

func (*InputParallelismObservation) DeepCopy 

func (in *InputParallelismObservation) DeepCopy() *InputParallelismObservation

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

func (*InputParallelismObservation) DeepCopyInto 

func (in *InputParallelismObservation) DeepCopyInto(out *InputParallelismObservation)

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

type InputParallelismParameters 

type InputParallelismParameters struct {

	// The number of in-application streams to create.
	// +kubebuilder:validation:Optional
	Count *float64 `json:"count,omitempty" tf:"count,omitempty"`
}

func (*InputParallelismParameters) DeepCopy 

func (in *InputParallelismParameters) DeepCopy() *InputParallelismParameters

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

func (*InputParallelismParameters) DeepCopyInto 

func (in *InputParallelismParameters) DeepCopyInto(out *InputParallelismParameters)

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

type InputParameters 

type InputParameters struct {

	// Describes the number of in-application streams to create.
	// +kubebuilder:validation:Optional
	InputParallelism *InputParallelismParameters `json:"inputParallelism,omitempty" tf:"input_parallelism,omitempty"`

	// The input processing configuration for the input.
	// An input processor transforms records as they are received from the stream, before the application's SQL code executes.
	// +kubebuilder:validation:Optional
	InputProcessingConfiguration *InputProcessingConfigurationParameters `json:"inputProcessingConfiguration,omitempty" tf:"input_processing_configuration,omitempty"`

	// Describes the format of the data in the streaming source, and how each data element maps to corresponding columns in the in-application stream that is being created.
	// +kubebuilder:validation:Optional
	InputSchema *InputSchemaParameters `json:"inputSchema" tf:"input_schema,omitempty"`

	// The point at which the application starts processing records from the streaming source.
	// +kubebuilder:validation:Optional
	InputStartingPositionConfiguration []InputStartingPositionConfigurationParameters `json:"inputStartingPositionConfiguration,omitempty" tf:"input_starting_position_configuration,omitempty"`

	// If the streaming source is a Kinesis Data Firehose delivery stream, identifies the delivery stream's ARN.
	// +kubebuilder:validation:Optional
	KinesisFirehoseInput *KinesisFirehoseInputParameters `json:"kinesisFirehoseInput,omitempty" tf:"kinesis_firehose_input,omitempty"`

	// If the streaming source is a Kinesis data stream, identifies the stream's Amazon Resource Name (ARN).
	// +kubebuilder:validation:Optional
	KinesisStreamsInput *KinesisStreamsInputParameters `json:"kinesisStreamsInput,omitempty" tf:"kinesis_streams_input,omitempty"`

	// The name prefix to use when creating an in-application stream.
	// +kubebuilder:validation:Optional
	NamePrefix *string `json:"namePrefix" tf:"name_prefix,omitempty"`
}

func (*InputParameters) DeepCopy 

func (in *InputParameters) DeepCopy() *InputParameters

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

func (*InputParameters) DeepCopyInto 

func (in *InputParameters) DeepCopyInto(out *InputParameters)

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

type InputProcessingConfigurationInitParameters 

type InputProcessingConfigurationInitParameters struct {

	// Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.
	InputLambdaProcessor *InputLambdaProcessorInitParameters `json:"inputLambdaProcessor,omitempty" tf:"input_lambda_processor,omitempty"`
}

func (*InputProcessingConfigurationInitParameters) DeepCopy 

func (in *InputProcessingConfigurationInitParameters) DeepCopy() *InputProcessingConfigurationInitParameters

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

func (*InputProcessingConfigurationInitParameters) DeepCopyInto 

func (in *InputProcessingConfigurationInitParameters) DeepCopyInto(out *InputProcessingConfigurationInitParameters)

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

type InputProcessingConfigurationObservation 

type InputProcessingConfigurationObservation struct {

	// Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.
	InputLambdaProcessor *InputLambdaProcessorObservation `json:"inputLambdaProcessor,omitempty" tf:"input_lambda_processor,omitempty"`
}

func (*InputProcessingConfigurationObservation) DeepCopy 

func (in *InputProcessingConfigurationObservation) DeepCopy() *InputProcessingConfigurationObservation

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

func (*InputProcessingConfigurationObservation) DeepCopyInto 

func (in *InputProcessingConfigurationObservation) DeepCopyInto(out *InputProcessingConfigurationObservation)

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

type InputProcessingConfigurationParameters 

type InputProcessingConfigurationParameters struct {

	// Describes the Lambda function that is used to preprocess the records in the stream before being processed by your application code.
	// +kubebuilder:validation:Optional
	InputLambdaProcessor *InputLambdaProcessorParameters `json:"inputLambdaProcessor" tf:"input_lambda_processor,omitempty"`
}

func (*InputProcessingConfigurationParameters) DeepCopy 

func (in *InputProcessingConfigurationParameters) DeepCopy() *InputProcessingConfigurationParameters

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

func (*InputProcessingConfigurationParameters) DeepCopyInto 

func (in *InputProcessingConfigurationParameters) DeepCopyInto(out *InputProcessingConfigurationParameters)

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

type InputSchemaInitParameters 

type InputSchemaInitParameters struct {

	// Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
	RecordColumn []RecordColumnInitParameters `json:"recordColumn,omitempty" tf:"record_column,omitempty"`

	// Specifies the encoding of the records in the streaming source. For example, UTF-8.
	RecordEncoding *string `json:"recordEncoding,omitempty" tf:"record_encoding,omitempty"`

	// Specifies the format of the records on the streaming source.
	RecordFormat *RecordFormatInitParameters `json:"recordFormat,omitempty" tf:"record_format,omitempty"`
}

func (*InputSchemaInitParameters) DeepCopy 

func (in *InputSchemaInitParameters) DeepCopy() *InputSchemaInitParameters

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

func (*InputSchemaInitParameters) DeepCopyInto 

func (in *InputSchemaInitParameters) DeepCopyInto(out *InputSchemaInitParameters)

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

type InputSchemaObservation 

type InputSchemaObservation struct {

	// Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
	RecordColumn []RecordColumnObservation `json:"recordColumn,omitempty" tf:"record_column,omitempty"`

	// Specifies the encoding of the records in the streaming source. For example, UTF-8.
	RecordEncoding *string `json:"recordEncoding,omitempty" tf:"record_encoding,omitempty"`

	// Specifies the format of the records on the streaming source.
	RecordFormat *RecordFormatObservation `json:"recordFormat,omitempty" tf:"record_format,omitempty"`
}

func (*InputSchemaObservation) DeepCopy 

func (in *InputSchemaObservation) DeepCopy() *InputSchemaObservation

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

func (*InputSchemaObservation) DeepCopyInto 

func (in *InputSchemaObservation) DeepCopyInto(out *InputSchemaObservation)

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

type InputSchemaParameters 

type InputSchemaParameters struct {

	// Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
	// +kubebuilder:validation:Optional
	RecordColumn []RecordColumnParameters `json:"recordColumn" tf:"record_column,omitempty"`

	// Specifies the encoding of the records in the streaming source. For example, UTF-8.
	// +kubebuilder:validation:Optional
	RecordEncoding *string `json:"recordEncoding,omitempty" tf:"record_encoding,omitempty"`

	// Specifies the format of the records on the streaming source.
	// +kubebuilder:validation:Optional
	RecordFormat *RecordFormatParameters `json:"recordFormat" tf:"record_format,omitempty"`
}

func (*InputSchemaParameters) DeepCopy 

func (in *InputSchemaParameters) DeepCopy() *InputSchemaParameters

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

func (*InputSchemaParameters) DeepCopyInto 

func (in *InputSchemaParameters) DeepCopyInto(out *InputSchemaParameters)

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

type InputStartingPositionConfigurationInitParameters 

type InputStartingPositionConfigurationInitParameters struct {

	// The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.
	InputStartingPosition *string `json:"inputStartingPosition,omitempty" tf:"input_starting_position,omitempty"`
}

func (*InputStartingPositionConfigurationInitParameters) DeepCopy 

func (in *InputStartingPositionConfigurationInitParameters) DeepCopy() *InputStartingPositionConfigurationInitParameters

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

func (*InputStartingPositionConfigurationInitParameters) DeepCopyInto 

func (in *InputStartingPositionConfigurationInitParameters) DeepCopyInto(out *InputStartingPositionConfigurationInitParameters)

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

type InputStartingPositionConfigurationObservation 

type InputStartingPositionConfigurationObservation struct {

	// The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.
	InputStartingPosition *string `json:"inputStartingPosition,omitempty" tf:"input_starting_position,omitempty"`
}

func (*InputStartingPositionConfigurationObservation) DeepCopy 

func (in *InputStartingPositionConfigurationObservation) DeepCopy() *InputStartingPositionConfigurationObservation

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

func (*InputStartingPositionConfigurationObservation) DeepCopyInto 

func (in *InputStartingPositionConfigurationObservation) DeepCopyInto(out *InputStartingPositionConfigurationObservation)

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

type InputStartingPositionConfigurationParameters 

type InputStartingPositionConfigurationParameters struct {

	// The starting position on the stream. Valid values: LAST_STOPPED_POINT, NOW, TRIM_HORIZON.
	// +kubebuilder:validation:Optional
	InputStartingPosition *string `json:"inputStartingPosition,omitempty" tf:"input_starting_position,omitempty"`
}

func (*InputStartingPositionConfigurationParameters) DeepCopy 

func (in *InputStartingPositionConfigurationParameters) DeepCopy() *InputStartingPositionConfigurationParameters

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

func (*InputStartingPositionConfigurationParameters) DeepCopyInto 

func (in *InputStartingPositionConfigurationParameters) DeepCopyInto(out *InputStartingPositionConfigurationParameters)

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

type JSONMappingParametersInitParameters 

type JSONMappingParametersInitParameters struct {

	// The path to the top-level parent that contains the records.
	RecordRowPath *string `json:"recordRowPath,omitempty" tf:"record_row_path,omitempty"`
}

func (*JSONMappingParametersInitParameters) DeepCopy 

func (in *JSONMappingParametersInitParameters) DeepCopy() *JSONMappingParametersInitParameters

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

func (*JSONMappingParametersInitParameters) DeepCopyInto 

func (in *JSONMappingParametersInitParameters) DeepCopyInto(out *JSONMappingParametersInitParameters)

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

type JSONMappingParametersObservation 

type JSONMappingParametersObservation struct {

	// The path to the top-level parent that contains the records.
	RecordRowPath *string `json:"recordRowPath,omitempty" tf:"record_row_path,omitempty"`
}

func (*JSONMappingParametersObservation) DeepCopy 

func (in *JSONMappingParametersObservation) DeepCopy() *JSONMappingParametersObservation

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

func (*JSONMappingParametersObservation) DeepCopyInto 

func (in *JSONMappingParametersObservation) DeepCopyInto(out *JSONMappingParametersObservation)

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

type JSONMappingParametersParameters 

type JSONMappingParametersParameters struct {

	// The path to the top-level parent that contains the records.
	// +kubebuilder:validation:Optional
	RecordRowPath *string `json:"recordRowPath" tf:"record_row_path,omitempty"`
}

func (*JSONMappingParametersParameters) DeepCopy 

func (in *JSONMappingParametersParameters) DeepCopy() *JSONMappingParametersParameters

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

func (*JSONMappingParametersParameters) DeepCopyInto 

func (in *JSONMappingParametersParameters) DeepCopyInto(out *JSONMappingParametersParameters)

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

type KinesisFirehoseInputInitParameters 

type KinesisFirehoseInputInitParameters struct {

	// The ARN of the Lambda function that operates on records in the stream.
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`
}

func (*KinesisFirehoseInputInitParameters) DeepCopy 

func (in *KinesisFirehoseInputInitParameters) DeepCopy() *KinesisFirehoseInputInitParameters

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

func (*KinesisFirehoseInputInitParameters) DeepCopyInto 

func (in *KinesisFirehoseInputInitParameters) DeepCopyInto(out *KinesisFirehoseInputInitParameters)

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

type KinesisFirehoseInputObservation 

type KinesisFirehoseInputObservation struct {

	// The ARN of the Lambda function that operates on records in the stream.
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`
}

func (*KinesisFirehoseInputObservation) DeepCopy 

func (in *KinesisFirehoseInputObservation) DeepCopy() *KinesisFirehoseInputObservation

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

func (*KinesisFirehoseInputObservation) DeepCopyInto 

func (in *KinesisFirehoseInputObservation) DeepCopyInto(out *KinesisFirehoseInputObservation)

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

type KinesisFirehoseInputParameters 

type KinesisFirehoseInputParameters struct {

	// The ARN of the Lambda function that operates on records in the stream.
	// +kubebuilder:validation:Optional
	ResourceArn *string `json:"resourceArn" tf:"resource_arn,omitempty"`
}

func (*KinesisFirehoseInputParameters) DeepCopy 

func (in *KinesisFirehoseInputParameters) DeepCopy() *KinesisFirehoseInputParameters

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

func (*KinesisFirehoseInputParameters) DeepCopyInto 

func (in *KinesisFirehoseInputParameters) DeepCopyInto(out *KinesisFirehoseInputParameters)

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

type KinesisFirehoseOutputInitParameters 

type KinesisFirehoseOutputInitParameters struct {

	// The ARN of the Lambda function that operates on records in the stream.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/firehose/v1beta2.DeliveryStream
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("arn",false)
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`

	// Reference to a DeliveryStream in firehose to populate resourceArn.
	// +kubebuilder:validation:Optional
	ResourceArnRef *v1.Reference `json:"resourceArnRef,omitempty" tf:"-"`

	// Selector for a DeliveryStream in firehose to populate resourceArn.
	// +kubebuilder:validation:Optional
	ResourceArnSelector *v1.Selector `json:"resourceArnSelector,omitempty" tf:"-"`
}

func (*KinesisFirehoseOutputInitParameters) DeepCopy 

func (in *KinesisFirehoseOutputInitParameters) DeepCopy() *KinesisFirehoseOutputInitParameters

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

func (*KinesisFirehoseOutputInitParameters) DeepCopyInto 

func (in *KinesisFirehoseOutputInitParameters) DeepCopyInto(out *KinesisFirehoseOutputInitParameters)

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

type KinesisFirehoseOutputObservation 

type KinesisFirehoseOutputObservation struct {

	// The ARN of the Lambda function that operates on records in the stream.
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`
}

func (*KinesisFirehoseOutputObservation) DeepCopy 

func (in *KinesisFirehoseOutputObservation) DeepCopy() *KinesisFirehoseOutputObservation

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

func (*KinesisFirehoseOutputObservation) DeepCopyInto 

func (in *KinesisFirehoseOutputObservation) DeepCopyInto(out *KinesisFirehoseOutputObservation)

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

type KinesisFirehoseOutputParameters 

type KinesisFirehoseOutputParameters struct {

	// The ARN of the Lambda function that operates on records in the stream.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/firehose/v1beta2.DeliveryStream
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("arn",false)
	// +kubebuilder:validation:Optional
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`

	// Reference to a DeliveryStream in firehose to populate resourceArn.
	// +kubebuilder:validation:Optional
	ResourceArnRef *v1.Reference `json:"resourceArnRef,omitempty" tf:"-"`

	// Selector for a DeliveryStream in firehose to populate resourceArn.
	// +kubebuilder:validation:Optional
	ResourceArnSelector *v1.Selector `json:"resourceArnSelector,omitempty" tf:"-"`
}

func (*KinesisFirehoseOutputParameters) DeepCopy 

func (in *KinesisFirehoseOutputParameters) DeepCopy() *KinesisFirehoseOutputParameters

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

func (*KinesisFirehoseOutputParameters) DeepCopyInto 

func (in *KinesisFirehoseOutputParameters) DeepCopyInto(out *KinesisFirehoseOutputParameters)

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

type KinesisStreamsInputInitParameters 

type KinesisStreamsInputInitParameters struct {

	// The ARN of the Lambda function that operates on records in the stream.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kinesis/v1beta2.Stream
	// +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.TerraformID()
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`

	// Reference to a Stream in kinesis to populate resourceArn.
	// +kubebuilder:validation:Optional
	ResourceArnRef *v1.Reference `json:"resourceArnRef,omitempty" tf:"-"`

	// Selector for a Stream in kinesis to populate resourceArn.
	// +kubebuilder:validation:Optional
	ResourceArnSelector *v1.Selector `json:"resourceArnSelector,omitempty" tf:"-"`
}

func (*KinesisStreamsInputInitParameters) DeepCopy 

func (in *KinesisStreamsInputInitParameters) DeepCopy() *KinesisStreamsInputInitParameters

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

func (*KinesisStreamsInputInitParameters) DeepCopyInto 

func (in *KinesisStreamsInputInitParameters) DeepCopyInto(out *KinesisStreamsInputInitParameters)

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

type KinesisStreamsInputObservation 

type KinesisStreamsInputObservation struct {

	// The ARN of the Lambda function that operates on records in the stream.
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`
}

func (*KinesisStreamsInputObservation) DeepCopy 

func (in *KinesisStreamsInputObservation) DeepCopy() *KinesisStreamsInputObservation

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

func (*KinesisStreamsInputObservation) DeepCopyInto 

func (in *KinesisStreamsInputObservation) DeepCopyInto(out *KinesisStreamsInputObservation)

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

type KinesisStreamsInputParameters 

type KinesisStreamsInputParameters struct {

	// The ARN of the Lambda function that operates on records in the stream.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kinesis/v1beta2.Stream
	// +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.TerraformID()
	// +kubebuilder:validation:Optional
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`

	// Reference to a Stream in kinesis to populate resourceArn.
	// +kubebuilder:validation:Optional
	ResourceArnRef *v1.Reference `json:"resourceArnRef,omitempty" tf:"-"`

	// Selector for a Stream in kinesis to populate resourceArn.
	// +kubebuilder:validation:Optional
	ResourceArnSelector *v1.Selector `json:"resourceArnSelector,omitempty" tf:"-"`
}

func (*KinesisStreamsInputParameters) DeepCopy 

func (in *KinesisStreamsInputParameters) DeepCopy() *KinesisStreamsInputParameters

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

func (*KinesisStreamsInputParameters) DeepCopyInto 

func (in *KinesisStreamsInputParameters) DeepCopyInto(out *KinesisStreamsInputParameters)

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

type KinesisStreamsOutputInitParameters 

type KinesisStreamsOutputInitParameters struct {

	// The ARN of the Lambda function that operates on records in the stream.
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`
}

func (*KinesisStreamsOutputInitParameters) DeepCopy 

func (in *KinesisStreamsOutputInitParameters) DeepCopy() *KinesisStreamsOutputInitParameters

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

func (*KinesisStreamsOutputInitParameters) DeepCopyInto 

func (in *KinesisStreamsOutputInitParameters) DeepCopyInto(out *KinesisStreamsOutputInitParameters)

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

type KinesisStreamsOutputObservation 

type KinesisStreamsOutputObservation struct {

	// The ARN of the Lambda function that operates on records in the stream.
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`
}

func (*KinesisStreamsOutputObservation) DeepCopy 

func (in *KinesisStreamsOutputObservation) DeepCopy() *KinesisStreamsOutputObservation

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

func (*KinesisStreamsOutputObservation) DeepCopyInto 

func (in *KinesisStreamsOutputObservation) DeepCopyInto(out *KinesisStreamsOutputObservation)

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

type KinesisStreamsOutputParameters 

type KinesisStreamsOutputParameters struct {

	// The ARN of the Lambda function that operates on records in the stream.
	// +kubebuilder:validation:Optional
	ResourceArn *string `json:"resourceArn" tf:"resource_arn,omitempty"`
}

func (*KinesisStreamsOutputParameters) DeepCopy 

func (in *KinesisStreamsOutputParameters) DeepCopy() *KinesisStreamsOutputParameters

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

func (*KinesisStreamsOutputParameters) DeepCopyInto 

func (in *KinesisStreamsOutputParameters) DeepCopyInto(out *KinesisStreamsOutputParameters)

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

type LambdaOutputInitParameters 

type LambdaOutputInitParameters struct {

	// The ARN of the Lambda function that operates on records in the stream.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/lambda/v1beta2.Function
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("arn",true)
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`

	// Reference to a Function in lambda to populate resourceArn.
	// +kubebuilder:validation:Optional
	ResourceArnRef *v1.Reference `json:"resourceArnRef,omitempty" tf:"-"`

	// Selector for a Function in lambda to populate resourceArn.
	// +kubebuilder:validation:Optional
	ResourceArnSelector *v1.Selector `json:"resourceArnSelector,omitempty" tf:"-"`
}

func (*LambdaOutputInitParameters) DeepCopy 

func (in *LambdaOutputInitParameters) DeepCopy() *LambdaOutputInitParameters

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

func (*LambdaOutputInitParameters) DeepCopyInto 

func (in *LambdaOutputInitParameters) DeepCopyInto(out *LambdaOutputInitParameters)

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

type LambdaOutputObservation 

type LambdaOutputObservation struct {

	// The ARN of the Lambda function that operates on records in the stream.
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`
}

func (*LambdaOutputObservation) DeepCopy 

func (in *LambdaOutputObservation) DeepCopy() *LambdaOutputObservation

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

func (*LambdaOutputObservation) DeepCopyInto 

func (in *LambdaOutputObservation) DeepCopyInto(out *LambdaOutputObservation)

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

type LambdaOutputParameters 

type LambdaOutputParameters struct {

	// The ARN of the Lambda function that operates on records in the stream.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/lambda/v1beta2.Function
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("arn",true)
	// +kubebuilder:validation:Optional
	ResourceArn *string `json:"resourceArn,omitempty" tf:"resource_arn,omitempty"`

	// Reference to a Function in lambda to populate resourceArn.
	// +kubebuilder:validation:Optional
	ResourceArnRef *v1.Reference `json:"resourceArnRef,omitempty" tf:"-"`

	// Selector for a Function in lambda to populate resourceArn.
	// +kubebuilder:validation:Optional
	ResourceArnSelector *v1.Selector `json:"resourceArnSelector,omitempty" tf:"-"`
}

func (*LambdaOutputParameters) DeepCopy 

func (in *LambdaOutputParameters) DeepCopy() *LambdaOutputParameters

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

func (*LambdaOutputParameters) DeepCopyInto 

func (in *LambdaOutputParameters) DeepCopyInto(out *LambdaOutputParameters)

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

type MappingParametersCsvMappingParametersInitParameters 

type MappingParametersCsvMappingParametersInitParameters struct {

	// The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
	RecordColumnDelimiter *string `json:"recordColumnDelimiter,omitempty" tf:"record_column_delimiter,omitempty"`

	// The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
	RecordRowDelimiter *string `json:"recordRowDelimiter,omitempty" tf:"record_row_delimiter,omitempty"`
}

func (*MappingParametersCsvMappingParametersInitParameters) DeepCopy 

func (in *MappingParametersCsvMappingParametersInitParameters) DeepCopy() *MappingParametersCsvMappingParametersInitParameters

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

func (*MappingParametersCsvMappingParametersInitParameters) DeepCopyInto 

func (in *MappingParametersCsvMappingParametersInitParameters) DeepCopyInto(out *MappingParametersCsvMappingParametersInitParameters)

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

type MappingParametersCsvMappingParametersObservation 

type MappingParametersCsvMappingParametersObservation struct {

	// The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
	RecordColumnDelimiter *string `json:"recordColumnDelimiter,omitempty" tf:"record_column_delimiter,omitempty"`

	// The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
	RecordRowDelimiter *string `json:"recordRowDelimiter,omitempty" tf:"record_row_delimiter,omitempty"`
}

func (*MappingParametersCsvMappingParametersObservation) DeepCopy 

func (in *MappingParametersCsvMappingParametersObservation) DeepCopy() *MappingParametersCsvMappingParametersObservation

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

func (*MappingParametersCsvMappingParametersObservation) DeepCopyInto 

func (in *MappingParametersCsvMappingParametersObservation) DeepCopyInto(out *MappingParametersCsvMappingParametersObservation)

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

type MappingParametersCsvMappingParametersParameters 

type MappingParametersCsvMappingParametersParameters struct {

	// The column delimiter. For example, in a CSV format, a comma (,) is the typical column delimiter.
	// +kubebuilder:validation:Optional
	RecordColumnDelimiter *string `json:"recordColumnDelimiter" tf:"record_column_delimiter,omitempty"`

	// The row delimiter. For example, in a CSV format, \n is the typical row delimiter.
	// +kubebuilder:validation:Optional
	RecordRowDelimiter *string `json:"recordRowDelimiter" tf:"record_row_delimiter,omitempty"`
}

func (*MappingParametersCsvMappingParametersParameters) DeepCopy 

func (in *MappingParametersCsvMappingParametersParameters) DeepCopy() *MappingParametersCsvMappingParametersParameters

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

func (*MappingParametersCsvMappingParametersParameters) DeepCopyInto 

func (in *MappingParametersCsvMappingParametersParameters) DeepCopyInto(out *MappingParametersCsvMappingParametersParameters)

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

type MappingParametersInitParameters 

type MappingParametersInitParameters struct {

	// Provides additional mapping information when the record format uses delimiters (for example, CSV).
	CsvMappingParameters *CsvMappingParametersInitParameters `json:"csvMappingParameters,omitempty" tf:"csv_mapping_parameters,omitempty"`

	// Provides additional mapping information when JSON is the record format on the streaming source.
	JSONMappingParameters *JSONMappingParametersInitParameters `json:"jsonMappingParameters,omitempty" tf:"json_mapping_parameters,omitempty"`
}

func (*MappingParametersInitParameters) DeepCopy 

func (in *MappingParametersInitParameters) DeepCopy() *MappingParametersInitParameters

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

func (*MappingParametersInitParameters) DeepCopyInto 

func (in *MappingParametersInitParameters) DeepCopyInto(out *MappingParametersInitParameters)

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

type MappingParametersJSONMappingParametersInitParameters 

type MappingParametersJSONMappingParametersInitParameters struct {

	// The path to the top-level parent that contains the records.
	RecordRowPath *string `json:"recordRowPath,omitempty" tf:"record_row_path,omitempty"`
}

func (*MappingParametersJSONMappingParametersInitParameters) DeepCopy 

func (in *MappingParametersJSONMappingParametersInitParameters) DeepCopy() *MappingParametersJSONMappingParametersInitParameters

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

func (*MappingParametersJSONMappingParametersInitParameters) DeepCopyInto 

func (in *MappingParametersJSONMappingParametersInitParameters) DeepCopyInto(out *MappingParametersJSONMappingParametersInitParameters)

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

type MappingParametersJSONMappingParametersObservation 

type MappingParametersJSONMappingParametersObservation struct {

	// The path to the top-level parent that contains the records.
	RecordRowPath *string `json:"recordRowPath,omitempty" tf:"record_row_path,omitempty"`
}

func (*MappingParametersJSONMappingParametersObservation) DeepCopy 

func (in *MappingParametersJSONMappingParametersObservation) DeepCopy() *MappingParametersJSONMappingParametersObservation

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

func (*MappingParametersJSONMappingParametersObservation) DeepCopyInto 

func (in *MappingParametersJSONMappingParametersObservation) DeepCopyInto(out *MappingParametersJSONMappingParametersObservation)

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

type MappingParametersJSONMappingParametersParameters 

type MappingParametersJSONMappingParametersParameters struct {

	// The path to the top-level parent that contains the records.
	// +kubebuilder:validation:Optional
	RecordRowPath *string `json:"recordRowPath" tf:"record_row_path,omitempty"`
}

func (*MappingParametersJSONMappingParametersParameters) DeepCopy 

func (in *MappingParametersJSONMappingParametersParameters) DeepCopy() *MappingParametersJSONMappingParametersParameters

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

func (*MappingParametersJSONMappingParametersParameters) DeepCopyInto 

func (in *MappingParametersJSONMappingParametersParameters) DeepCopyInto(out *MappingParametersJSONMappingParametersParameters)

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

type MappingParametersObservation 

type MappingParametersObservation struct {

	// Provides additional mapping information when the record format uses delimiters (for example, CSV).
	CsvMappingParameters *CsvMappingParametersObservation `json:"csvMappingParameters,omitempty" tf:"csv_mapping_parameters,omitempty"`

	// Provides additional mapping information when JSON is the record format on the streaming source.
	JSONMappingParameters *JSONMappingParametersObservation `json:"jsonMappingParameters,omitempty" tf:"json_mapping_parameters,omitempty"`
}

func (*MappingParametersObservation) DeepCopy 

func (in *MappingParametersObservation) DeepCopy() *MappingParametersObservation

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

func (*MappingParametersObservation) DeepCopyInto 

func (in *MappingParametersObservation) DeepCopyInto(out *MappingParametersObservation)

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

type MappingParametersParameters 

type MappingParametersParameters struct {

	// Provides additional mapping information when the record format uses delimiters (for example, CSV).
	// +kubebuilder:validation:Optional
	CsvMappingParameters *CsvMappingParametersParameters `json:"csvMappingParameters,omitempty" tf:"csv_mapping_parameters,omitempty"`

	// Provides additional mapping information when JSON is the record format on the streaming source.
	// +kubebuilder:validation:Optional
	JSONMappingParameters *JSONMappingParametersParameters `json:"jsonMappingParameters,omitempty" tf:"json_mapping_parameters,omitempty"`
}

func (*MappingParametersParameters) DeepCopy 

func (in *MappingParametersParameters) DeepCopy() *MappingParametersParameters

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

func (*MappingParametersParameters) DeepCopyInto 

func (in *MappingParametersParameters) DeepCopyInto(out *MappingParametersParameters)

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

type MonitoringConfigurationInitParameters 

type MonitoringConfigurationInitParameters struct {

	// Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:
	ConfigurationType *string `json:"configurationType,omitempty" tf:"configuration_type,omitempty"`

	// Describes the verbosity of the CloudWatch Logs for an application. Valid values: DEBUG, ERROR, INFO, WARN.
	LogLevel *string `json:"logLevel,omitempty" tf:"log_level,omitempty"`

	// Describes the granularity of the CloudWatch Logs for an application. Valid values: APPLICATION, OPERATOR, PARALLELISM, TASK.
	MetricsLevel *string `json:"metricsLevel,omitempty" tf:"metrics_level,omitempty"`
}

func (*MonitoringConfigurationInitParameters) DeepCopy 

func (in *MonitoringConfigurationInitParameters) DeepCopy() *MonitoringConfigurationInitParameters

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

func (*MonitoringConfigurationInitParameters) DeepCopyInto 

func (in *MonitoringConfigurationInitParameters) DeepCopyInto(out *MonitoringConfigurationInitParameters)

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

type MonitoringConfigurationObservation 

type MonitoringConfigurationObservation struct {

	// Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:
	ConfigurationType *string `json:"configurationType,omitempty" tf:"configuration_type,omitempty"`

	// Describes the verbosity of the CloudWatch Logs for an application. Valid values: DEBUG, ERROR, INFO, WARN.
	LogLevel *string `json:"logLevel,omitempty" tf:"log_level,omitempty"`

	// Describes the granularity of the CloudWatch Logs for an application. Valid values: APPLICATION, OPERATOR, PARALLELISM, TASK.
	MetricsLevel *string `json:"metricsLevel,omitempty" tf:"metrics_level,omitempty"`
}

func (*MonitoringConfigurationObservation) DeepCopy 

func (in *MonitoringConfigurationObservation) DeepCopy() *MonitoringConfigurationObservation

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

func (*MonitoringConfigurationObservation) DeepCopyInto 

func (in *MonitoringConfigurationObservation) DeepCopyInto(out *MonitoringConfigurationObservation)

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

type MonitoringConfigurationParameters 

type MonitoringConfigurationParameters struct {

	// Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:
	// +kubebuilder:validation:Optional
	ConfigurationType *string `json:"configurationType" tf:"configuration_type,omitempty"`

	// Describes the verbosity of the CloudWatch Logs for an application. Valid values: DEBUG, ERROR, INFO, WARN.
	// +kubebuilder:validation:Optional
	LogLevel *string `json:"logLevel,omitempty" tf:"log_level,omitempty"`

	// Describes the granularity of the CloudWatch Logs for an application. Valid values: APPLICATION, OPERATOR, PARALLELISM, TASK.
	// +kubebuilder:validation:Optional
	MetricsLevel *string `json:"metricsLevel,omitempty" tf:"metrics_level,omitempty"`
}

func (*MonitoringConfigurationParameters) DeepCopy 

func (in *MonitoringConfigurationParameters) DeepCopy() *MonitoringConfigurationParameters

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

func (*MonitoringConfigurationParameters) DeepCopyInto 

func (in *MonitoringConfigurationParameters) DeepCopyInto(out *MonitoringConfigurationParameters)

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

type OutputInitParameters 

type OutputInitParameters struct {

	// Describes the data format when records are written to the destination.
	DestinationSchema *DestinationSchemaInitParameters `json:"destinationSchema,omitempty" tf:"destination_schema,omitempty"`

	// Identifies a Kinesis Data Firehose delivery stream as the destination.
	KinesisFirehoseOutput *KinesisFirehoseOutputInitParameters `json:"kinesisFirehoseOutput,omitempty" tf:"kinesis_firehose_output,omitempty"`

	// Identifies a Kinesis data stream as the destination.
	KinesisStreamsOutput *KinesisStreamsOutputInitParameters `json:"kinesisStreamsOutput,omitempty" tf:"kinesis_streams_output,omitempty"`

	// Identifies a Lambda function as the destination.
	LambdaOutput *LambdaOutputInitParameters `json:"lambdaOutput,omitempty" tf:"lambda_output,omitempty"`

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

func (*OutputInitParameters) DeepCopy 

func (in *OutputInitParameters) DeepCopy() *OutputInitParameters

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

func (*OutputInitParameters) DeepCopyInto 

func (in *OutputInitParameters) DeepCopyInto(out *OutputInitParameters)

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

type OutputObservation 

type OutputObservation struct {

	// Describes the data format when records are written to the destination.
	DestinationSchema *DestinationSchemaObservation `json:"destinationSchema,omitempty" tf:"destination_schema,omitempty"`

	// Identifies a Kinesis Data Firehose delivery stream as the destination.
	KinesisFirehoseOutput *KinesisFirehoseOutputObservation `json:"kinesisFirehoseOutput,omitempty" tf:"kinesis_firehose_output,omitempty"`

	// Identifies a Kinesis data stream as the destination.
	KinesisStreamsOutput *KinesisStreamsOutputObservation `json:"kinesisStreamsOutput,omitempty" tf:"kinesis_streams_output,omitempty"`

	// Identifies a Lambda function as the destination.
	LambdaOutput *LambdaOutputObservation `json:"lambdaOutput,omitempty" tf:"lambda_output,omitempty"`

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

	// The application identifier.
	OutputID *string `json:"outputId,omitempty" tf:"output_id,omitempty"`
}

func (*OutputObservation) DeepCopy 

func (in *OutputObservation) DeepCopy() *OutputObservation

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

func (*OutputObservation) DeepCopyInto 

func (in *OutputObservation) DeepCopyInto(out *OutputObservation)

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

type OutputParameters 

type OutputParameters struct {

	// Describes the data format when records are written to the destination.
	// +kubebuilder:validation:Optional
	DestinationSchema *DestinationSchemaParameters `json:"destinationSchema" tf:"destination_schema,omitempty"`

	// Identifies a Kinesis Data Firehose delivery stream as the destination.
	// +kubebuilder:validation:Optional
	KinesisFirehoseOutput *KinesisFirehoseOutputParameters `json:"kinesisFirehoseOutput,omitempty" tf:"kinesis_firehose_output,omitempty"`

	// Identifies a Kinesis data stream as the destination.
	// +kubebuilder:validation:Optional
	KinesisStreamsOutput *KinesisStreamsOutputParameters `json:"kinesisStreamsOutput,omitempty" tf:"kinesis_streams_output,omitempty"`

	// Identifies a Lambda function as the destination.
	// +kubebuilder:validation:Optional
	LambdaOutput *LambdaOutputParameters `json:"lambdaOutput,omitempty" tf:"lambda_output,omitempty"`

	// The name of the application.
	// +kubebuilder:validation:Optional
	Name *string `json:"name" tf:"name,omitempty"`
}

func (*OutputParameters) DeepCopy 

func (in *OutputParameters) DeepCopy() *OutputParameters

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

func (*OutputParameters) DeepCopyInto 

func (in *OutputParameters) DeepCopyInto(out *OutputParameters)

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

type ParallelismConfigurationInitParameters 

type ParallelismConfigurationInitParameters struct {

	// Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
	AutoScalingEnabled *bool `json:"autoScalingEnabled,omitempty" tf:"auto_scaling_enabled,omitempty"`

	// Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:
	ConfigurationType *string `json:"configurationType,omitempty" tf:"configuration_type,omitempty"`

	// Describes the initial number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform.
	Parallelism *float64 `json:"parallelism,omitempty" tf:"parallelism,omitempty"`

	// Describes the number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform per Kinesis Processing Unit (KPU) used by the application.
	ParallelismPerKpu *float64 `json:"parallelismPerKpu,omitempty" tf:"parallelism_per_kpu,omitempty"`
}

func (*ParallelismConfigurationInitParameters) DeepCopy 

func (in *ParallelismConfigurationInitParameters) DeepCopy() *ParallelismConfigurationInitParameters

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

func (*ParallelismConfigurationInitParameters) DeepCopyInto 

func (in *ParallelismConfigurationInitParameters) DeepCopyInto(out *ParallelismConfigurationInitParameters)

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

type ParallelismConfigurationObservation 

type ParallelismConfigurationObservation struct {

	// Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
	AutoScalingEnabled *bool `json:"autoScalingEnabled,omitempty" tf:"auto_scaling_enabled,omitempty"`

	// Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:
	ConfigurationType *string `json:"configurationType,omitempty" tf:"configuration_type,omitempty"`

	// Describes the initial number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform.
	Parallelism *float64 `json:"parallelism,omitempty" tf:"parallelism,omitempty"`

	// Describes the number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform per Kinesis Processing Unit (KPU) used by the application.
	ParallelismPerKpu *float64 `json:"parallelismPerKpu,omitempty" tf:"parallelism_per_kpu,omitempty"`
}

func (*ParallelismConfigurationObservation) DeepCopy 

func (in *ParallelismConfigurationObservation) DeepCopy() *ParallelismConfigurationObservation

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

func (*ParallelismConfigurationObservation) DeepCopyInto 

func (in *ParallelismConfigurationObservation) DeepCopyInto(out *ParallelismConfigurationObservation)

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

type ParallelismConfigurationParameters 

type ParallelismConfigurationParameters struct {

	// Describes whether the Kinesis Data Analytics service can increase the parallelism of the application in response to increased throughput.
	// +kubebuilder:validation:Optional
	AutoScalingEnabled *bool `json:"autoScalingEnabled,omitempty" tf:"auto_scaling_enabled,omitempty"`

	// Describes whether the application uses Kinesis Data Analytics' default checkpointing behavior. Valid values: CUSTOM, DEFAULT. Set this attribute to CUSTOM in order for any specified checkpointing_enabled, checkpoint_interval, or min_pause_between_checkpoints attribute values to be effective. If this attribute is set to DEFAULT, the application will always use the following values:
	// +kubebuilder:validation:Optional
	ConfigurationType *string `json:"configurationType" tf:"configuration_type,omitempty"`

	// Describes the initial number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform.
	// +kubebuilder:validation:Optional
	Parallelism *float64 `json:"parallelism,omitempty" tf:"parallelism,omitempty"`

	// Describes the number of parallel tasks that a Flink-based Kinesis Data Analytics application can perform per Kinesis Processing Unit (KPU) used by the application.
	// +kubebuilder:validation:Optional
	ParallelismPerKpu *float64 `json:"parallelismPerKpu,omitempty" tf:"parallelism_per_kpu,omitempty"`
}

func (*ParallelismConfigurationParameters) DeepCopy 

func (in *ParallelismConfigurationParameters) DeepCopy() *ParallelismConfigurationParameters

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

func (*ParallelismConfigurationParameters) DeepCopyInto 

func (in *ParallelismConfigurationParameters) DeepCopyInto(out *ParallelismConfigurationParameters)

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

type PropertyGroupInitParameters 

type PropertyGroupInitParameters struct {

	// The key of the application execution property key-value map.
	PropertyGroupID *string `json:"propertyGroupId,omitempty" tf:"property_group_id,omitempty"`

	// Application execution property key-value map.
	// +mapType=granular
	PropertyMap map[string]*string `json:"propertyMap,omitempty" tf:"property_map,omitempty"`
}

func (*PropertyGroupInitParameters) DeepCopy 

func (in *PropertyGroupInitParameters) DeepCopy() *PropertyGroupInitParameters

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

func (*PropertyGroupInitParameters) DeepCopyInto 

func (in *PropertyGroupInitParameters) DeepCopyInto(out *PropertyGroupInitParameters)

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

type PropertyGroupObservation 

type PropertyGroupObservation struct {

	// The key of the application execution property key-value map.
	PropertyGroupID *string `json:"propertyGroupId,omitempty" tf:"property_group_id,omitempty"`

	// Application execution property key-value map.
	// +mapType=granular
	PropertyMap map[string]*string `json:"propertyMap,omitempty" tf:"property_map,omitempty"`
}

func (*PropertyGroupObservation) DeepCopy 

func (in *PropertyGroupObservation) DeepCopy() *PropertyGroupObservation

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

func (*PropertyGroupObservation) DeepCopyInto 

func (in *PropertyGroupObservation) DeepCopyInto(out *PropertyGroupObservation)

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

type PropertyGroupParameters 

type PropertyGroupParameters struct {

	// The key of the application execution property key-value map.
	// +kubebuilder:validation:Optional
	PropertyGroupID *string `json:"propertyGroupId" tf:"property_group_id,omitempty"`

	// Application execution property key-value map.
	// +kubebuilder:validation:Optional
	// +mapType=granular
	PropertyMap map[string]*string `json:"propertyMap" tf:"property_map,omitempty"`
}

func (*PropertyGroupParameters) DeepCopy 

func (in *PropertyGroupParameters) DeepCopy() *PropertyGroupParameters

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

func (*PropertyGroupParameters) DeepCopyInto 

func (in *PropertyGroupParameters) DeepCopyInto(out *PropertyGroupParameters)

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

type RecordColumnInitParameters 

type RecordColumnInitParameters struct {

	// A reference to the data element in the streaming input or the reference data source.
	Mapping *string `json:"mapping,omitempty" tf:"mapping,omitempty"`

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

	// The type of column created in the in-application input stream or reference table.
	SQLType *string `json:"sqlType,omitempty" tf:"sql_type,omitempty"`
}

func (*RecordColumnInitParameters) DeepCopy 

func (in *RecordColumnInitParameters) DeepCopy() *RecordColumnInitParameters

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

func (*RecordColumnInitParameters) DeepCopyInto 

func (in *RecordColumnInitParameters) DeepCopyInto(out *RecordColumnInitParameters)

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

type RecordColumnObservation 

type RecordColumnObservation struct {

	// A reference to the data element in the streaming input or the reference data source.
	Mapping *string `json:"mapping,omitempty" tf:"mapping,omitempty"`

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

	// The type of column created in the in-application input stream or reference table.
	SQLType *string `json:"sqlType,omitempty" tf:"sql_type,omitempty"`
}

func (*RecordColumnObservation) DeepCopy 

func (in *RecordColumnObservation) DeepCopy() *RecordColumnObservation

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

func (*RecordColumnObservation) DeepCopyInto 

func (in *RecordColumnObservation) DeepCopyInto(out *RecordColumnObservation)

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

type RecordColumnParameters 

type RecordColumnParameters struct {

	// A reference to the data element in the streaming input or the reference data source.
	// +kubebuilder:validation:Optional
	Mapping *string `json:"mapping,omitempty" tf:"mapping,omitempty"`

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

	// The type of column created in the in-application input stream or reference table.
	// +kubebuilder:validation:Optional
	SQLType *string `json:"sqlType" tf:"sql_type,omitempty"`
}

func (*RecordColumnParameters) DeepCopy 

func (in *RecordColumnParameters) DeepCopy() *RecordColumnParameters

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

func (*RecordColumnParameters) DeepCopyInto 

func (in *RecordColumnParameters) DeepCopyInto(out *RecordColumnParameters)

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

type RecordFormatInitParameters 

type RecordFormatInitParameters struct {

	// Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
	MappingParameters *MappingParametersInitParameters `json:"mappingParameters,omitempty" tf:"mapping_parameters,omitempty"`

	// The type of record format. Valid values: CSV, JSON.
	RecordFormatType *string `json:"recordFormatType,omitempty" tf:"record_format_type,omitempty"`
}

func (*RecordFormatInitParameters) DeepCopy 

func (in *RecordFormatInitParameters) DeepCopy() *RecordFormatInitParameters

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

func (*RecordFormatInitParameters) DeepCopyInto 

func (in *RecordFormatInitParameters) DeepCopyInto(out *RecordFormatInitParameters)

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

type RecordFormatMappingParametersInitParameters 

type RecordFormatMappingParametersInitParameters struct {

	// Provides additional mapping information when the record format uses delimiters (for example, CSV).
	CsvMappingParameters *MappingParametersCsvMappingParametersInitParameters `json:"csvMappingParameters,omitempty" tf:"csv_mapping_parameters,omitempty"`

	// Provides additional mapping information when JSON is the record format on the streaming source.
	JSONMappingParameters *MappingParametersJSONMappingParametersInitParameters `json:"jsonMappingParameters,omitempty" tf:"json_mapping_parameters,omitempty"`
}

func (*RecordFormatMappingParametersInitParameters) DeepCopy 

func (in *RecordFormatMappingParametersInitParameters) DeepCopy() *RecordFormatMappingParametersInitParameters

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

func (*RecordFormatMappingParametersInitParameters) DeepCopyInto 

func (in *RecordFormatMappingParametersInitParameters) DeepCopyInto(out *RecordFormatMappingParametersInitParameters)

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

type RecordFormatMappingParametersObservation 

type RecordFormatMappingParametersObservation struct {

	// Provides additional mapping information when the record format uses delimiters (for example, CSV).
	CsvMappingParameters *MappingParametersCsvMappingParametersObservation `json:"csvMappingParameters,omitempty" tf:"csv_mapping_parameters,omitempty"`

	// Provides additional mapping information when JSON is the record format on the streaming source.
	JSONMappingParameters *MappingParametersJSONMappingParametersObservation `json:"jsonMappingParameters,omitempty" tf:"json_mapping_parameters,omitempty"`
}

func (*RecordFormatMappingParametersObservation) DeepCopy 

func (in *RecordFormatMappingParametersObservation) DeepCopy() *RecordFormatMappingParametersObservation

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

func (*RecordFormatMappingParametersObservation) DeepCopyInto 

func (in *RecordFormatMappingParametersObservation) DeepCopyInto(out *RecordFormatMappingParametersObservation)

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

type RecordFormatMappingParametersParameters 

type RecordFormatMappingParametersParameters struct {

	// Provides additional mapping information when the record format uses delimiters (for example, CSV).
	// +kubebuilder:validation:Optional
	CsvMappingParameters *MappingParametersCsvMappingParametersParameters `json:"csvMappingParameters,omitempty" tf:"csv_mapping_parameters,omitempty"`

	// Provides additional mapping information when JSON is the record format on the streaming source.
	// +kubebuilder:validation:Optional
	JSONMappingParameters *MappingParametersJSONMappingParametersParameters `json:"jsonMappingParameters,omitempty" tf:"json_mapping_parameters,omitempty"`
}

func (*RecordFormatMappingParametersParameters) DeepCopy 

func (in *RecordFormatMappingParametersParameters) DeepCopy() *RecordFormatMappingParametersParameters

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

func (*RecordFormatMappingParametersParameters) DeepCopyInto 

func (in *RecordFormatMappingParametersParameters) DeepCopyInto(out *RecordFormatMappingParametersParameters)

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

type RecordFormatObservation 

type RecordFormatObservation struct {

	// Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
	MappingParameters *MappingParametersObservation `json:"mappingParameters,omitempty" tf:"mapping_parameters,omitempty"`

	// The type of record format. Valid values: CSV, JSON.
	RecordFormatType *string `json:"recordFormatType,omitempty" tf:"record_format_type,omitempty"`
}

func (*RecordFormatObservation) DeepCopy 

func (in *RecordFormatObservation) DeepCopy() *RecordFormatObservation

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

func (*RecordFormatObservation) DeepCopyInto 

func (in *RecordFormatObservation) DeepCopyInto(out *RecordFormatObservation)

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

type RecordFormatParameters 

type RecordFormatParameters struct {

	// Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
	// +kubebuilder:validation:Optional
	MappingParameters *MappingParametersParameters `json:"mappingParameters" tf:"mapping_parameters,omitempty"`

	// The type of record format. Valid values: CSV, JSON.
	// +kubebuilder:validation:Optional
	RecordFormatType *string `json:"recordFormatType" tf:"record_format_type,omitempty"`
}

func (*RecordFormatParameters) DeepCopy 

func (in *RecordFormatParameters) DeepCopy() *RecordFormatParameters

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

func (*RecordFormatParameters) DeepCopyInto 

func (in *RecordFormatParameters) DeepCopyInto(out *RecordFormatParameters)

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

type ReferenceDataSourceInitParameters 

type ReferenceDataSourceInitParameters struct {

	// Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
	ReferenceSchema *ReferenceSchemaInitParameters `json:"referenceSchema,omitempty" tf:"reference_schema,omitempty"`

	// Identifies the S3 bucket and object that contains the reference data.
	S3ReferenceDataSource *S3ReferenceDataSourceInitParameters `json:"s3ReferenceDataSource,omitempty" tf:"s3_reference_data_source,omitempty"`

	// The name of the in-application table to create.
	TableName *string `json:"tableName,omitempty" tf:"table_name,omitempty"`
}

func (*ReferenceDataSourceInitParameters) DeepCopy 

func (in *ReferenceDataSourceInitParameters) DeepCopy() *ReferenceDataSourceInitParameters

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

func (*ReferenceDataSourceInitParameters) DeepCopyInto 

func (in *ReferenceDataSourceInitParameters) DeepCopyInto(out *ReferenceDataSourceInitParameters)

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

type ReferenceDataSourceObservation 

type ReferenceDataSourceObservation struct {

	// The application identifier.
	ReferenceID *string `json:"referenceId,omitempty" tf:"reference_id,omitempty"`

	// Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
	ReferenceSchema *ReferenceSchemaObservation `json:"referenceSchema,omitempty" tf:"reference_schema,omitempty"`

	// Identifies the S3 bucket and object that contains the reference data.
	S3ReferenceDataSource *S3ReferenceDataSourceObservation `json:"s3ReferenceDataSource,omitempty" tf:"s3_reference_data_source,omitempty"`

	// The name of the in-application table to create.
	TableName *string `json:"tableName,omitempty" tf:"table_name,omitempty"`
}

func (*ReferenceDataSourceObservation) DeepCopy 

func (in *ReferenceDataSourceObservation) DeepCopy() *ReferenceDataSourceObservation

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

func (*ReferenceDataSourceObservation) DeepCopyInto 

func (in *ReferenceDataSourceObservation) DeepCopyInto(out *ReferenceDataSourceObservation)

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

type ReferenceDataSourceParameters 

type ReferenceDataSourceParameters struct {

	// Describes the format of the data in the streaming source, and how each data element maps to corresponding columns created in the in-application stream.
	// +kubebuilder:validation:Optional
	ReferenceSchema *ReferenceSchemaParameters `json:"referenceSchema" tf:"reference_schema,omitempty"`

	// Identifies the S3 bucket and object that contains the reference data.
	// +kubebuilder:validation:Optional
	S3ReferenceDataSource *S3ReferenceDataSourceParameters `json:"s3ReferenceDataSource" tf:"s3_reference_data_source,omitempty"`

	// The name of the in-application table to create.
	// +kubebuilder:validation:Optional
	TableName *string `json:"tableName" tf:"table_name,omitempty"`
}

func (*ReferenceDataSourceParameters) DeepCopy 

func (in *ReferenceDataSourceParameters) DeepCopy() *ReferenceDataSourceParameters

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

func (*ReferenceDataSourceParameters) DeepCopyInto 

func (in *ReferenceDataSourceParameters) DeepCopyInto(out *ReferenceDataSourceParameters)

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

type ReferenceSchemaInitParameters 

type ReferenceSchemaInitParameters struct {

	// Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
	RecordColumn []ReferenceSchemaRecordColumnInitParameters `json:"recordColumn,omitempty" tf:"record_column,omitempty"`

	// Specifies the encoding of the records in the streaming source. For example, UTF-8.
	RecordEncoding *string `json:"recordEncoding,omitempty" tf:"record_encoding,omitempty"`

	// Specifies the format of the records on the streaming source.
	RecordFormat *ReferenceSchemaRecordFormatInitParameters `json:"recordFormat,omitempty" tf:"record_format,omitempty"`
}

func (*ReferenceSchemaInitParameters) DeepCopy 

func (in *ReferenceSchemaInitParameters) DeepCopy() *ReferenceSchemaInitParameters

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

func (*ReferenceSchemaInitParameters) DeepCopyInto 

func (in *ReferenceSchemaInitParameters) DeepCopyInto(out *ReferenceSchemaInitParameters)

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

type ReferenceSchemaObservation 

type ReferenceSchemaObservation struct {

	// Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
	RecordColumn []ReferenceSchemaRecordColumnObservation `json:"recordColumn,omitempty" tf:"record_column,omitempty"`

	// Specifies the encoding of the records in the streaming source. For example, UTF-8.
	RecordEncoding *string `json:"recordEncoding,omitempty" tf:"record_encoding,omitempty"`

	// Specifies the format of the records on the streaming source.
	RecordFormat *ReferenceSchemaRecordFormatObservation `json:"recordFormat,omitempty" tf:"record_format,omitempty"`
}

func (*ReferenceSchemaObservation) DeepCopy 

func (in *ReferenceSchemaObservation) DeepCopy() *ReferenceSchemaObservation

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

func (*ReferenceSchemaObservation) DeepCopyInto 

func (in *ReferenceSchemaObservation) DeepCopyInto(out *ReferenceSchemaObservation)

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

type ReferenceSchemaParameters 

type ReferenceSchemaParameters struct {

	// Describes the mapping of each data element in the streaming source to the corresponding column in the in-application stream.
	// +kubebuilder:validation:Optional
	RecordColumn []ReferenceSchemaRecordColumnParameters `json:"recordColumn" tf:"record_column,omitempty"`

	// Specifies the encoding of the records in the streaming source. For example, UTF-8.
	// +kubebuilder:validation:Optional
	RecordEncoding *string `json:"recordEncoding,omitempty" tf:"record_encoding,omitempty"`

	// Specifies the format of the records on the streaming source.
	// +kubebuilder:validation:Optional
	RecordFormat *ReferenceSchemaRecordFormatParameters `json:"recordFormat" tf:"record_format,omitempty"`
}

func (*ReferenceSchemaParameters) DeepCopy 

func (in *ReferenceSchemaParameters) DeepCopy() *ReferenceSchemaParameters

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

func (*ReferenceSchemaParameters) DeepCopyInto 

func (in *ReferenceSchemaParameters) DeepCopyInto(out *ReferenceSchemaParameters)

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

type ReferenceSchemaRecordColumnInitParameters 

type ReferenceSchemaRecordColumnInitParameters struct {

	// A reference to the data element in the streaming input or the reference data source.
	Mapping *string `json:"mapping,omitempty" tf:"mapping,omitempty"`

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

	// The type of column created in the in-application input stream or reference table.
	SQLType *string `json:"sqlType,omitempty" tf:"sql_type,omitempty"`
}

func (*ReferenceSchemaRecordColumnInitParameters) DeepCopy 

func (in *ReferenceSchemaRecordColumnInitParameters) DeepCopy() *ReferenceSchemaRecordColumnInitParameters

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

func (*ReferenceSchemaRecordColumnInitParameters) DeepCopyInto 

func (in *ReferenceSchemaRecordColumnInitParameters) DeepCopyInto(out *ReferenceSchemaRecordColumnInitParameters)

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

type ReferenceSchemaRecordColumnObservation 

type ReferenceSchemaRecordColumnObservation struct {

	// A reference to the data element in the streaming input or the reference data source.
	Mapping *string `json:"mapping,omitempty" tf:"mapping,omitempty"`

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

	// The type of column created in the in-application input stream or reference table.
	SQLType *string `json:"sqlType,omitempty" tf:"sql_type,omitempty"`
}

func (*ReferenceSchemaRecordColumnObservation) DeepCopy 

func (in *ReferenceSchemaRecordColumnObservation) DeepCopy() *ReferenceSchemaRecordColumnObservation

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

func (*ReferenceSchemaRecordColumnObservation) DeepCopyInto 

func (in *ReferenceSchemaRecordColumnObservation) DeepCopyInto(out *ReferenceSchemaRecordColumnObservation)

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

type ReferenceSchemaRecordColumnParameters 

type ReferenceSchemaRecordColumnParameters struct {

	// A reference to the data element in the streaming input or the reference data source.
	// +kubebuilder:validation:Optional
	Mapping *string `json:"mapping,omitempty" tf:"mapping,omitempty"`

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

	// The type of column created in the in-application input stream or reference table.
	// +kubebuilder:validation:Optional
	SQLType *string `json:"sqlType" tf:"sql_type,omitempty"`
}

func (*ReferenceSchemaRecordColumnParameters) DeepCopy 

func (in *ReferenceSchemaRecordColumnParameters) DeepCopy() *ReferenceSchemaRecordColumnParameters

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

func (*ReferenceSchemaRecordColumnParameters) DeepCopyInto 

func (in *ReferenceSchemaRecordColumnParameters) DeepCopyInto(out *ReferenceSchemaRecordColumnParameters)

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

type ReferenceSchemaRecordFormatInitParameters 

type ReferenceSchemaRecordFormatInitParameters struct {

	// Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
	MappingParameters *RecordFormatMappingParametersInitParameters `json:"mappingParameters,omitempty" tf:"mapping_parameters,omitempty"`

	// The type of record format. Valid values: CSV, JSON.
	RecordFormatType *string `json:"recordFormatType,omitempty" tf:"record_format_type,omitempty"`
}

func (*ReferenceSchemaRecordFormatInitParameters) DeepCopy 

func (in *ReferenceSchemaRecordFormatInitParameters) DeepCopy() *ReferenceSchemaRecordFormatInitParameters

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

func (*ReferenceSchemaRecordFormatInitParameters) DeepCopyInto 

func (in *ReferenceSchemaRecordFormatInitParameters) DeepCopyInto(out *ReferenceSchemaRecordFormatInitParameters)

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

type ReferenceSchemaRecordFormatObservation 

type ReferenceSchemaRecordFormatObservation struct {

	// Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
	MappingParameters *RecordFormatMappingParametersObservation `json:"mappingParameters,omitempty" tf:"mapping_parameters,omitempty"`

	// The type of record format. Valid values: CSV, JSON.
	RecordFormatType *string `json:"recordFormatType,omitempty" tf:"record_format_type,omitempty"`
}

func (*ReferenceSchemaRecordFormatObservation) DeepCopy 

func (in *ReferenceSchemaRecordFormatObservation) DeepCopy() *ReferenceSchemaRecordFormatObservation

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

func (*ReferenceSchemaRecordFormatObservation) DeepCopyInto 

func (in *ReferenceSchemaRecordFormatObservation) DeepCopyInto(out *ReferenceSchemaRecordFormatObservation)

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

type ReferenceSchemaRecordFormatParameters 

type ReferenceSchemaRecordFormatParameters struct {

	// Provides additional mapping information specific to the record format (such as JSON, CSV, or record fields delimited by some delimiter) on the streaming source.
	// +kubebuilder:validation:Optional
	MappingParameters *RecordFormatMappingParametersParameters `json:"mappingParameters" tf:"mapping_parameters,omitempty"`

	// The type of record format. Valid values: CSV, JSON.
	// +kubebuilder:validation:Optional
	RecordFormatType *string `json:"recordFormatType" tf:"record_format_type,omitempty"`
}

func (*ReferenceSchemaRecordFormatParameters) DeepCopy 

func (in *ReferenceSchemaRecordFormatParameters) DeepCopy() *ReferenceSchemaRecordFormatParameters

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

func (*ReferenceSchemaRecordFormatParameters) DeepCopyInto 

func (in *ReferenceSchemaRecordFormatParameters) DeepCopyInto(out *ReferenceSchemaRecordFormatParameters)

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

type RunConfigurationInitParameters 

type RunConfigurationInitParameters struct {

	// The restore behavior of a restarting application.
	ApplicationRestoreConfiguration *ApplicationRestoreConfigurationInitParameters `json:"applicationRestoreConfiguration,omitempty" tf:"application_restore_configuration,omitempty"`

	// The starting parameters for a Flink-based Kinesis Data Analytics application.
	FlinkRunConfiguration *FlinkRunConfigurationInitParameters `json:"flinkRunConfiguration,omitempty" tf:"flink_run_configuration,omitempty"`
}

func (*RunConfigurationInitParameters) DeepCopy 

func (in *RunConfigurationInitParameters) DeepCopy() *RunConfigurationInitParameters

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

func (*RunConfigurationInitParameters) DeepCopyInto 

func (in *RunConfigurationInitParameters) DeepCopyInto(out *RunConfigurationInitParameters)

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

type RunConfigurationObservation 

type RunConfigurationObservation struct {

	// The restore behavior of a restarting application.
	ApplicationRestoreConfiguration *ApplicationRestoreConfigurationObservation `json:"applicationRestoreConfiguration,omitempty" tf:"application_restore_configuration,omitempty"`

	// The starting parameters for a Flink-based Kinesis Data Analytics application.
	FlinkRunConfiguration *FlinkRunConfigurationObservation `json:"flinkRunConfiguration,omitempty" tf:"flink_run_configuration,omitempty"`
}

func (*RunConfigurationObservation) DeepCopy 

func (in *RunConfigurationObservation) DeepCopy() *RunConfigurationObservation

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

func (*RunConfigurationObservation) DeepCopyInto 

func (in *RunConfigurationObservation) DeepCopyInto(out *RunConfigurationObservation)

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

type RunConfigurationParameters 

type RunConfigurationParameters struct {

	// The restore behavior of a restarting application.
	// +kubebuilder:validation:Optional
	ApplicationRestoreConfiguration *ApplicationRestoreConfigurationParameters `json:"applicationRestoreConfiguration,omitempty" tf:"application_restore_configuration,omitempty"`

	// The starting parameters for a Flink-based Kinesis Data Analytics application.
	// +kubebuilder:validation:Optional
	FlinkRunConfiguration *FlinkRunConfigurationParameters `json:"flinkRunConfiguration,omitempty" tf:"flink_run_configuration,omitempty"`
}

func (*RunConfigurationParameters) DeepCopy 

func (in *RunConfigurationParameters) DeepCopy() *RunConfigurationParameters

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

func (*RunConfigurationParameters) DeepCopyInto 

func (in *RunConfigurationParameters) DeepCopyInto(out *RunConfigurationParameters)

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

type S3ContentLocationInitParameters 

type S3ContentLocationInitParameters struct {

	// The ARN for the S3 bucket containing the application code.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta2.Bucket
	// +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor()
	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 the object containing the application code.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta2.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 the object containing the application code.
	ObjectVersion *string `json:"objectVersion,omitempty" tf:"object_version,omitempty"`
}

func (*S3ContentLocationInitParameters) DeepCopy 

func (in *S3ContentLocationInitParameters) DeepCopy() *S3ContentLocationInitParameters

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

func (*S3ContentLocationInitParameters) DeepCopyInto 

func (in *S3ContentLocationInitParameters) DeepCopyInto(out *S3ContentLocationInitParameters)

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

type S3ContentLocationObservation 

type S3ContentLocationObservation struct {

	// The ARN for the S3 bucket containing the application code.
	BucketArn *string `json:"bucketArn,omitempty" tf:"bucket_arn,omitempty"`

	// The file key for the object containing the application code.
	FileKey *string `json:"fileKey,omitempty" tf:"file_key,omitempty"`

	// The version of the object containing the application code.
	ObjectVersion *string `json:"objectVersion,omitempty" tf:"object_version,omitempty"`
}

func (*S3ContentLocationObservation) DeepCopy 

func (in *S3ContentLocationObservation) DeepCopy() *S3ContentLocationObservation

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

func (*S3ContentLocationObservation) DeepCopyInto 

func (in *S3ContentLocationObservation) DeepCopyInto(out *S3ContentLocationObservation)

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

type S3ContentLocationParameters 

type S3ContentLocationParameters struct {

	// The ARN for the S3 bucket containing the application code.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta2.Bucket
	// +crossplane:generate:reference:extractor=github.com/upbound/provider-aws/config/common.ARNExtractor()
	// +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 the object containing the application code.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta2.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 the object containing the application code.
	// +kubebuilder:validation:Optional
	ObjectVersion *string `json:"objectVersion,omitempty" tf:"object_version,omitempty"`
}

func (*S3ContentLocationParameters) DeepCopy 

func (in *S3ContentLocationParameters) DeepCopy() *S3ContentLocationParameters

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

func (*S3ContentLocationParameters) DeepCopyInto 

func (in *S3ContentLocationParameters) DeepCopyInto(out *S3ContentLocationParameters)

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

type S3ReferenceDataSourceInitParameters 

type S3ReferenceDataSourceInitParameters struct {

	// The ARN for the S3 bucket containing the application code.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta2.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 the object containing the application code.
	FileKey *string `json:"fileKey,omitempty" tf:"file_key,omitempty"`
}

func (*S3ReferenceDataSourceInitParameters) DeepCopy 

func (in *S3ReferenceDataSourceInitParameters) DeepCopy() *S3ReferenceDataSourceInitParameters

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

func (*S3ReferenceDataSourceInitParameters) DeepCopyInto 

func (in *S3ReferenceDataSourceInitParameters) DeepCopyInto(out *S3ReferenceDataSourceInitParameters)

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

type S3ReferenceDataSourceObservation 

type S3ReferenceDataSourceObservation struct {

	// The ARN for the S3 bucket containing the application code.
	BucketArn *string `json:"bucketArn,omitempty" tf:"bucket_arn,omitempty"`

	// The file key for the object containing the application code.
	FileKey *string `json:"fileKey,omitempty" tf:"file_key,omitempty"`
}

func (*S3ReferenceDataSourceObservation) DeepCopy 

func (in *S3ReferenceDataSourceObservation) DeepCopy() *S3ReferenceDataSourceObservation

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

func (*S3ReferenceDataSourceObservation) DeepCopyInto 

func (in *S3ReferenceDataSourceObservation) DeepCopyInto(out *S3ReferenceDataSourceObservation)

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

type S3ReferenceDataSourceParameters 

type S3ReferenceDataSourceParameters struct {

	// The ARN for the S3 bucket containing the application code.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta2.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 the object containing the application code.
	// +kubebuilder:validation:Optional
	FileKey *string `json:"fileKey" tf:"file_key,omitempty"`
}

func (*S3ReferenceDataSourceParameters) DeepCopy 

func (in *S3ReferenceDataSourceParameters) DeepCopy() *S3ReferenceDataSourceParameters

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

func (*S3ReferenceDataSourceParameters) DeepCopyInto 

func (in *S3ReferenceDataSourceParameters) DeepCopyInto(out *S3ReferenceDataSourceParameters)

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

type SQLApplicationConfigurationInitParameters 

type SQLApplicationConfigurationInitParameters struct {

	// The input stream used by the application.
	Input *InputInitParameters `json:"input,omitempty" tf:"input,omitempty"`

	// The destination streams used by the application.
	Output []OutputInitParameters `json:"output,omitempty" tf:"output,omitempty"`

	// The reference data source used by the application.
	ReferenceDataSource *ReferenceDataSourceInitParameters `json:"referenceDataSource,omitempty" tf:"reference_data_source,omitempty"`
}

func (*SQLApplicationConfigurationInitParameters) DeepCopy 

func (in *SQLApplicationConfigurationInitParameters) DeepCopy() *SQLApplicationConfigurationInitParameters

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

func (*SQLApplicationConfigurationInitParameters) DeepCopyInto 

func (in *SQLApplicationConfigurationInitParameters) DeepCopyInto(out *SQLApplicationConfigurationInitParameters)

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

type SQLApplicationConfigurationObservation 

type SQLApplicationConfigurationObservation struct {

	// The input stream used by the application.
	Input *InputObservation `json:"input,omitempty" tf:"input,omitempty"`

	// The destination streams used by the application.
	Output []OutputObservation `json:"output,omitempty" tf:"output,omitempty"`

	// The reference data source used by the application.
	ReferenceDataSource *ReferenceDataSourceObservation `json:"referenceDataSource,omitempty" tf:"reference_data_source,omitempty"`
}

func (*SQLApplicationConfigurationObservation) DeepCopy 

func (in *SQLApplicationConfigurationObservation) DeepCopy() *SQLApplicationConfigurationObservation

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

func (*SQLApplicationConfigurationObservation) DeepCopyInto 

func (in *SQLApplicationConfigurationObservation) DeepCopyInto(out *SQLApplicationConfigurationObservation)

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

type SQLApplicationConfigurationParameters 

type SQLApplicationConfigurationParameters struct {

	// The input stream used by the application.
	// +kubebuilder:validation:Optional
	Input *InputParameters `json:"input,omitempty" tf:"input,omitempty"`

	// The destination streams used by the application.
	// +kubebuilder:validation:Optional
	Output []OutputParameters `json:"output,omitempty" tf:"output,omitempty"`

	// The reference data source used by the application.
	// +kubebuilder:validation:Optional
	ReferenceDataSource *ReferenceDataSourceParameters `json:"referenceDataSource,omitempty" tf:"reference_data_source,omitempty"`
}

func (*SQLApplicationConfigurationParameters) DeepCopy 

func (in *SQLApplicationConfigurationParameters) DeepCopy() *SQLApplicationConfigurationParameters

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

func (*SQLApplicationConfigurationParameters) DeepCopyInto 

func (in *SQLApplicationConfigurationParameters) DeepCopyInto(out *SQLApplicationConfigurationParameters)

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

type VPCConfigurationInitParameters 

type VPCConfigurationInitParameters struct {

	// The Security Group IDs used by the VPC configuration.
	// +listType=set
	SecurityGroupIds []*string `json:"securityGroupIds,omitempty" tf:"security_group_ids,omitempty"`

	// The Subnet IDs used by the VPC configuration.
	// +listType=set
	SubnetIds []*string `json:"subnetIds,omitempty" tf:"subnet_ids,omitempty"`
}

func (*VPCConfigurationInitParameters) DeepCopy 

func (in *VPCConfigurationInitParameters) DeepCopy() *VPCConfigurationInitParameters

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

func (*VPCConfigurationInitParameters) DeepCopyInto 

func (in *VPCConfigurationInitParameters) DeepCopyInto(out *VPCConfigurationInitParameters)

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

type VPCConfigurationObservation 

type VPCConfigurationObservation struct {

	// The Security Group IDs used by the VPC configuration.
	// +listType=set
	SecurityGroupIds []*string `json:"securityGroupIds,omitempty" tf:"security_group_ids,omitempty"`

	// The Subnet IDs used by the VPC configuration.
	// +listType=set
	SubnetIds []*string `json:"subnetIds,omitempty" tf:"subnet_ids,omitempty"`

	// The application identifier.
	VPCConfigurationID *string `json:"vpcConfigurationId,omitempty" tf:"vpc_configuration_id,omitempty"`

	// The application identifier.
	VPCID *string `json:"vpcId,omitempty" tf:"vpc_id,omitempty"`
}

func (*VPCConfigurationObservation) DeepCopy 

func (in *VPCConfigurationObservation) DeepCopy() *VPCConfigurationObservation

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

func (*VPCConfigurationObservation) DeepCopyInto 

func (in *VPCConfigurationObservation) DeepCopyInto(out *VPCConfigurationObservation)

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

type VPCConfigurationParameters 

type VPCConfigurationParameters struct {

	// The Security Group IDs used by the VPC configuration.
	// +kubebuilder:validation:Optional
	// +listType=set
	SecurityGroupIds []*string `json:"securityGroupIds" tf:"security_group_ids,omitempty"`

	// The Subnet IDs used by the VPC configuration.
	// +kubebuilder:validation:Optional
	// +listType=set
	SubnetIds []*string `json:"subnetIds" tf:"subnet_ids,omitempty"`
}

func (*VPCConfigurationParameters) DeepCopy 

func (in *VPCConfigurationParameters) DeepCopy() *VPCConfigurationParameters

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

func (*VPCConfigurationParameters) DeepCopyInto 

func (in *VPCConfigurationParameters) DeepCopyInto(out *VPCConfigurationParameters)

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.