v1beta1

package
v1.19.0-rc.0 Latest Latest
Warning

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

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

Documentation

Overview

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

Index

Constants

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

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 (
	ApplicationSnapshot_Kind             = "ApplicationSnapshot"
	ApplicationSnapshot_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: ApplicationSnapshot_Kind}.String()
	ApplicationSnapshot_KindAPIVersion   = ApplicationSnapshot_Kind + "." + CRDGroupVersion.String()
	ApplicationSnapshot_GroupVersionKind = CRDGroupVersion.WithKind(ApplicationSnapshot_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) ConvertFrom added in v1.7.0 

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

ConvertFrom converts from the hub type to the Application type.

func (*Application) ConvertTo added in v1.7.0 

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

ConvertTo converts this Application to the hub type.

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 added in v0.38.0 

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

GetInitParameters of this Application

func (*Application) GetManagementPolicies added in v0.38.0 

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

GetManagementPolicies of this Application.

func (*Application) GetMergedParameters added in v0.44.0 

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) 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 added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *ApplicationCodeConfigurationInitParameters) DeepCopy() *ApplicationCodeConfigurationInitParameters

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

func (*ApplicationCodeConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *ApplicationConfigurationInitParameters) DeepCopy() *ApplicationConfigurationInitParameters

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

func (*ApplicationConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *ApplicationInitParameters) DeepCopy() *ApplicationInitParameters

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

func (*ApplicationInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *ApplicationRestoreConfigurationInitParameters) DeepCopy() *ApplicationRestoreConfigurationInitParameters

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

func (*ApplicationRestoreConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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 ApplicationSnapshot 

type ApplicationSnapshot struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              ApplicationSnapshotSpec   `json:"spec"`
	Status            ApplicationSnapshotStatus `json:"status,omitempty"`
}

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

func (in *ApplicationSnapshot) DeepCopy() *ApplicationSnapshot

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

func (*ApplicationSnapshot) DeepCopyInto 

func (in *ApplicationSnapshot) DeepCopyInto(out *ApplicationSnapshot)

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

func (*ApplicationSnapshot) DeepCopyObject 

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

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

func (*ApplicationSnapshot) GetCondition 

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

GetCondition of this ApplicationSnapshot.

func (*ApplicationSnapshot) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this ApplicationSnapshot

func (*ApplicationSnapshot) GetDeletionPolicy 

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

GetDeletionPolicy of this ApplicationSnapshot.

func (*ApplicationSnapshot) GetID 

func (tr *ApplicationSnapshot) GetID() string

GetID returns ID of underlying Terraform resource of this ApplicationSnapshot

func (*ApplicationSnapshot) GetInitParameters added in v0.38.0 

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

GetInitParameters of this ApplicationSnapshot

func (*ApplicationSnapshot) GetManagementPolicies added in v0.38.0 

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

GetManagementPolicies of this ApplicationSnapshot.

func (*ApplicationSnapshot) GetMergedParameters added in v0.44.0 

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

GetInitParameters of this ApplicationSnapshot

func (*ApplicationSnapshot) GetObservation 

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

GetObservation of this ApplicationSnapshot

func (*ApplicationSnapshot) GetParameters 

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

GetParameters of this ApplicationSnapshot

func (*ApplicationSnapshot) GetProviderConfigReference 

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

GetProviderConfigReference of this ApplicationSnapshot.

func (*ApplicationSnapshot) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this ApplicationSnapshot.

func (*ApplicationSnapshot) GetTerraformResourceType 

func (mg *ApplicationSnapshot) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this ApplicationSnapshot

func (*ApplicationSnapshot) GetTerraformSchemaVersion 

func (tr *ApplicationSnapshot) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*ApplicationSnapshot) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this ApplicationSnapshot.

func (*ApplicationSnapshot) Hub added in v0.47.2 

func (tr *ApplicationSnapshot) Hub()

Hub marks this type as a conversion hub.

func (*ApplicationSnapshot) LateInitialize 

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

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

func (*ApplicationSnapshot) ResolveReferences 

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

ResolveReferences of this ApplicationSnapshot.

func (*ApplicationSnapshot) SetConditions 

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

SetConditions of this ApplicationSnapshot.

func (*ApplicationSnapshot) SetDeletionPolicy 

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

SetDeletionPolicy of this ApplicationSnapshot.

func (*ApplicationSnapshot) SetManagementPolicies added in v0.38.0 

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

SetManagementPolicies of this ApplicationSnapshot.

func (*ApplicationSnapshot) SetObservation 

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

SetObservation for this ApplicationSnapshot

func (*ApplicationSnapshot) SetParameters 

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

SetParameters for this ApplicationSnapshot

func (*ApplicationSnapshot) SetProviderConfigReference 

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

SetProviderConfigReference of this ApplicationSnapshot.

func (*ApplicationSnapshot) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this ApplicationSnapshot.

func (*ApplicationSnapshot) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this ApplicationSnapshot.

type ApplicationSnapshotConfigurationInitParameters added in v0.38.0 

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 added in v0.38.0 

func (in *ApplicationSnapshotConfigurationInitParameters) DeepCopy() *ApplicationSnapshotConfigurationInitParameters

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

func (*ApplicationSnapshotConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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 ApplicationSnapshotInitParameters added in v0.38.0 

type ApplicationSnapshotInitParameters struct {

	// The name of an existing  Kinesis Analytics v2 Application. Note that the application must be running for a snapshot to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kinesisanalyticsv2/v1beta2.Application
	ApplicationName *string `json:"applicationName,omitempty" tf:"application_name,omitempty"`

	// Reference to a Application in kinesisanalyticsv2 to populate applicationName.
	// +kubebuilder:validation:Optional
	ApplicationNameRef *v1.Reference `json:"applicationNameRef,omitempty" tf:"-"`

	// Selector for a Application in kinesisanalyticsv2 to populate applicationName.
	// +kubebuilder:validation:Optional
	ApplicationNameSelector *v1.Selector `json:"applicationNameSelector,omitempty" tf:"-"`
}

func (*ApplicationSnapshotInitParameters) DeepCopy added in v0.38.0 

func (in *ApplicationSnapshotInitParameters) DeepCopy() *ApplicationSnapshotInitParameters

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

func (*ApplicationSnapshotInitParameters) DeepCopyInto added in v0.38.0 

func (in *ApplicationSnapshotInitParameters) DeepCopyInto(out *ApplicationSnapshotInitParameters)

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

type ApplicationSnapshotList 

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

ApplicationSnapshotList contains a list of ApplicationSnapshots

func (*ApplicationSnapshotList) DeepCopy 

func (in *ApplicationSnapshotList) DeepCopy() *ApplicationSnapshotList

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

func (*ApplicationSnapshotList) DeepCopyInto 

func (in *ApplicationSnapshotList) DeepCopyInto(out *ApplicationSnapshotList)

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

func (*ApplicationSnapshotList) DeepCopyObject 

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

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

func (*ApplicationSnapshotList) GetItems 

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

GetItems of this ApplicationSnapshotList.

type ApplicationSnapshotObservation 

type ApplicationSnapshotObservation struct {

	// The name of an existing  Kinesis Analytics v2 Application. Note that the application must be running for a snapshot to be created.
	ApplicationName *string `json:"applicationName,omitempty" tf:"application_name,omitempty"`

	// The current application version ID when the snapshot was created.
	ApplicationVersionID *float64 `json:"applicationVersionId,omitempty" tf:"application_version_id,omitempty"`

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

	// The timestamp of the application snapshot.
	SnapshotCreationTimestamp *string `json:"snapshotCreationTimestamp,omitempty" tf:"snapshot_creation_timestamp,omitempty"`
}

func (*ApplicationSnapshotObservation) DeepCopy 

func (in *ApplicationSnapshotObservation) DeepCopy() *ApplicationSnapshotObservation

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

func (*ApplicationSnapshotObservation) DeepCopyInto 

func (in *ApplicationSnapshotObservation) DeepCopyInto(out *ApplicationSnapshotObservation)

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

type ApplicationSnapshotParameters 

type ApplicationSnapshotParameters struct {

	// The name of an existing  Kinesis Analytics v2 Application. Note that the application must be running for a snapshot to be created.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/kinesisanalyticsv2/v1beta2.Application
	// +kubebuilder:validation:Optional
	ApplicationName *string `json:"applicationName,omitempty" tf:"application_name,omitempty"`

	// Reference to a Application in kinesisanalyticsv2 to populate applicationName.
	// +kubebuilder:validation:Optional
	ApplicationNameRef *v1.Reference `json:"applicationNameRef,omitempty" tf:"-"`

	// Selector for a Application in kinesisanalyticsv2 to populate applicationName.
	// +kubebuilder:validation:Optional
	ApplicationNameSelector *v1.Selector `json:"applicationNameSelector,omitempty" tf:"-"`

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

func (*ApplicationSnapshotParameters) DeepCopy 

func (in *ApplicationSnapshotParameters) DeepCopy() *ApplicationSnapshotParameters

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

func (*ApplicationSnapshotParameters) DeepCopyInto 

func (in *ApplicationSnapshotParameters) DeepCopyInto(out *ApplicationSnapshotParameters)

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

type ApplicationSnapshotSpec 

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

ApplicationSnapshotSpec defines the desired state of ApplicationSnapshot

func (*ApplicationSnapshotSpec) DeepCopy 

func (in *ApplicationSnapshotSpec) DeepCopy() *ApplicationSnapshotSpec

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

func (*ApplicationSnapshotSpec) DeepCopyInto 

func (in *ApplicationSnapshotSpec) DeepCopyInto(out *ApplicationSnapshotSpec)

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

type ApplicationSnapshotStatus 

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

ApplicationSnapshotStatus defines the observed state of ApplicationSnapshot.

func (*ApplicationSnapshotStatus) DeepCopy 

func (in *ApplicationSnapshotStatus) DeepCopy() *ApplicationSnapshotStatus

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

func (*ApplicationSnapshotStatus) DeepCopyInto 

func (in *ApplicationSnapshotStatus) DeepCopyInto(out *ApplicationSnapshotStatus)

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 added in v0.38.0 

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 added in v0.38.0 

func (in *CheckpointConfigurationInitParameters) DeepCopy() *CheckpointConfigurationInitParameters

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

func (*CheckpointConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *CloudwatchLoggingOptionsInitParameters) DeepCopy() *CloudwatchLoggingOptionsInitParameters

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

func (*CloudwatchLoggingOptionsInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *CodeContentInitParameters) DeepCopy() *CodeContentInitParameters

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

func (*CodeContentInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *CsvMappingParametersInitParameters) DeepCopy() *CsvMappingParametersInitParameters

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

func (*CsvMappingParametersInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *DestinationSchemaInitParameters) DeepCopy() *DestinationSchemaInitParameters

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

func (*DestinationSchemaInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

type EnvironmentPropertiesInitParameters struct {

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

func (*EnvironmentPropertiesInitParameters) DeepCopy added in v0.38.0 

func (in *EnvironmentPropertiesInitParameters) DeepCopy() *EnvironmentPropertiesInitParameters

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

func (*EnvironmentPropertiesInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *FlinkApplicationConfigurationInitParameters) DeepCopy() *FlinkApplicationConfigurationInitParameters

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

func (*FlinkApplicationConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *FlinkRunConfigurationInitParameters) DeepCopy() *FlinkRunConfigurationInitParameters

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

func (*FlinkRunConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *InputInitParameters) DeepCopy() *InputInitParameters

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

func (*InputInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *InputLambdaProcessorInitParameters) DeepCopy() *InputLambdaProcessorInitParameters

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

func (*InputLambdaProcessorInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

type InputParallelismInitParameters struct {

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

func (*InputParallelismInitParameters) DeepCopy added in v0.38.0 

func (in *InputParallelismInitParameters) DeepCopy() *InputParallelismInitParameters

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

func (*InputParallelismInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *InputProcessingConfigurationInitParameters) DeepCopy() *InputProcessingConfigurationInitParameters

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

func (*InputProcessingConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *InputSchemaInitParameters) DeepCopy() *InputSchemaInitParameters

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

func (*InputSchemaInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *InputStartingPositionConfigurationInitParameters) DeepCopy() *InputStartingPositionConfigurationInitParameters

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

func (*InputStartingPositionConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *JSONMappingParametersInitParameters) DeepCopy() *JSONMappingParametersInitParameters

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

func (*JSONMappingParametersInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *KinesisFirehoseInputInitParameters) DeepCopy() *KinesisFirehoseInputInitParameters

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

func (*KinesisFirehoseInputInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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/v1beta1.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 added in v0.38.0 

func (in *KinesisFirehoseOutputInitParameters) DeepCopy() *KinesisFirehoseOutputInitParameters

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

func (*KinesisFirehoseOutputInitParameters) DeepCopyInto added in v0.38.0 

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/v1beta1.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 added in v0.38.0 

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/v1beta1.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 added in v0.38.0 

func (in *KinesisStreamsInputInitParameters) DeepCopy() *KinesisStreamsInputInitParameters

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

func (*KinesisStreamsInputInitParameters) DeepCopyInto added in v0.38.0 

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/v1beta1.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 added in v0.38.0 

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 added in v0.38.0 

func (in *KinesisStreamsOutputInitParameters) DeepCopy() *KinesisStreamsOutputInitParameters

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

func (*KinesisStreamsOutputInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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/v1beta1.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 added in v0.38.0 

func (in *LambdaOutputInitParameters) DeepCopy() *LambdaOutputInitParameters

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

func (*LambdaOutputInitParameters) DeepCopyInto added in v0.38.0 

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/v1beta1.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 added in v0.38.0 

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 added in v0.38.0 

func (in *MappingParametersCsvMappingParametersInitParameters) DeepCopy() *MappingParametersCsvMappingParametersInitParameters

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

func (*MappingParametersCsvMappingParametersInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *MappingParametersInitParameters) DeepCopy() *MappingParametersInitParameters

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

func (*MappingParametersInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *MappingParametersJSONMappingParametersInitParameters) DeepCopy() *MappingParametersJSONMappingParametersInitParameters

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

func (*MappingParametersJSONMappingParametersInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *MonitoringConfigurationInitParameters) DeepCopy() *MonitoringConfigurationInitParameters

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

func (*MonitoringConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *OutputInitParameters) DeepCopy() *OutputInitParameters

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

func (*OutputInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *ParallelismConfigurationInitParameters) DeepCopy() *ParallelismConfigurationInitParameters

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

func (*ParallelismConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *PropertyGroupInitParameters) DeepCopy() *PropertyGroupInitParameters

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

func (*PropertyGroupInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *RecordColumnInitParameters) DeepCopy() *RecordColumnInitParameters

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

func (*RecordColumnInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *RecordFormatInitParameters) DeepCopy() *RecordFormatInitParameters

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

func (*RecordFormatInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *RecordFormatMappingParametersInitParameters) DeepCopy() *RecordFormatMappingParametersInitParameters

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

func (*RecordFormatMappingParametersInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *ReferenceDataSourceInitParameters) DeepCopy() *ReferenceDataSourceInitParameters

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

func (*ReferenceDataSourceInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *ReferenceSchemaInitParameters) DeepCopy() *ReferenceSchemaInitParameters

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

func (*ReferenceSchemaInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *ReferenceSchemaRecordColumnInitParameters) DeepCopy() *ReferenceSchemaRecordColumnInitParameters

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

func (*ReferenceSchemaRecordColumnInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *ReferenceSchemaRecordFormatInitParameters) DeepCopy() *ReferenceSchemaRecordFormatInitParameters

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

func (*ReferenceSchemaRecordFormatInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

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 added in v0.38.0 

func (in *RunConfigurationInitParameters) DeepCopy() *RunConfigurationInitParameters

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

func (*RunConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

type S3ContentLocationInitParameters struct {

	// The ARN for the S3 bucket containing the application code.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/s3/v1beta1.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/v1beta1.Object
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("key",false)
	FileKey *string `json:"fileKey,omitempty" tf:"file_key,omitempty"`

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

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

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

func (*S3ContentLocationInitParameters) DeepCopy added in v0.38.0 

func (in *S3ContentLocationInitParameters) DeepCopy() *S3ContentLocationInitParameters

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

func (*S3ContentLocationInitParameters) DeepCopyInto added in v0.38.0 

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/v1beta1.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/v1beta1.Object
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("key",false)
	// +kubebuilder:validation:Optional
	FileKey *string `json:"fileKey,omitempty" tf:"file_key,omitempty"`

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

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

	// The version of 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 added in v0.38.0 

type S3ReferenceDataSourceInitParameters struct {

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

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

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

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

func (*S3ReferenceDataSourceInitParameters) DeepCopy added in v0.38.0 

func (in *S3ReferenceDataSourceInitParameters) DeepCopy() *S3ReferenceDataSourceInitParameters

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

func (*S3ReferenceDataSourceInitParameters) DeepCopyInto added in v0.38.0 

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/v1beta1.Bucket
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractParamPath("arn",true)
	// +kubebuilder:validation:Optional
	BucketArn *string `json:"bucketArn,omitempty" tf:"bucket_arn,omitempty"`

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

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

	// The file key for 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 added in v0.38.0 

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 added in v0.38.0 

func (in *SQLApplicationConfigurationInitParameters) DeepCopy() *SQLApplicationConfigurationInitParameters

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

func (*SQLApplicationConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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 added in v0.38.0 

type VPCConfigurationInitParameters struct {

	// The Security Group IDs used by the VPC configuration.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.SecurityGroup
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractResourceID()
	// +listType=set
	SecurityGroupIds []*string `json:"securityGroupIds,omitempty" tf:"security_group_ids,omitempty"`

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

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

	// The Subnet IDs used by the VPC configuration.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.Subnet
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractResourceID()
	// +listType=set
	SubnetIds []*string `json:"subnetIds,omitempty" tf:"subnet_ids,omitempty"`

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

	// Selector for a list of Subnet in ec2 to populate subnetIds.
	// +kubebuilder:validation:Optional
	SubnetIdsSelector *v1.Selector `json:"subnetIdsSelector,omitempty" tf:"-"`
}

func (*VPCConfigurationInitParameters) DeepCopy added in v0.38.0 

func (in *VPCConfigurationInitParameters) DeepCopy() *VPCConfigurationInitParameters

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

func (*VPCConfigurationInitParameters) DeepCopyInto added in v0.38.0 

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.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.SecurityGroup
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractResourceID()
	// +kubebuilder:validation:Optional
	// +listType=set
	SecurityGroupIds []*string `json:"securityGroupIds,omitempty" tf:"security_group_ids,omitempty"`

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

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

	// The Subnet IDs used by the VPC configuration.
	// +crossplane:generate:reference:type=github.com/upbound/provider-aws/apis/ec2/v1beta1.Subnet
	// +crossplane:generate:reference:extractor=github.com/crossplane/upjet/pkg/resource.ExtractResourceID()
	// +kubebuilder:validation:Optional
	// +listType=set
	SubnetIds []*string `json:"subnetIds,omitempty" tf:"subnet_ids,omitempty"`

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

	// Selector for a list of Subnet in ec2 to populate subnetIds.
	// +kubebuilder:validation:Optional
	SubnetIdsSelector *v1.Selector `json:"subnetIdsSelector,omitempty" tf:"-"`
}

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.