v1beta1

package
v0.31.16 Latest Latest
Warning

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

Go to latest
Published: Jun 12, 2023 License: Apache-2.0 Imports: 18 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"`
	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="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}

func (*Application) DeepCopy

func (in *Application) DeepCopy() *Application

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

func (*Application) DeepCopyInto

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

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

func (*Application) DeepCopyObject

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

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

func (*Application) GetCondition

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

GetCondition of this Application.

func (*Application) GetConnectionDetailsMapping

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

GetConnectionDetailsMapping for this Application

func (*Application) GetDeletionPolicy

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

GetDeletionPolicy of this Application.

func (*Application) GetID

func (tr *Application) GetID() string

GetID returns ID of underlying Terraform resource of this Application

func (*Application) 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) GetProviderReference

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

GetProviderReference of this Application. Deprecated: Use GetProviderConfigReference.

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

ResolveReferences of this Application.

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

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

SetProviderReference of this Application. Deprecated: Use SetProviderConfigReference.

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 ApplicationCodeConfigurationObservation

type ApplicationCodeConfigurationObservation struct {
}

func (*ApplicationCodeConfigurationObservation) DeepCopy

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

func (*ApplicationCodeConfigurationObservation) DeepCopyInto

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:Required
	CodeContentType *string `json:"codeContentType" tf:"code_content_type,omitempty"`
}

func (*ApplicationCodeConfigurationParameters) DeepCopy

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

func (*ApplicationCodeConfigurationParameters) DeepCopyInto

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

type ApplicationConfigurationObservation

type ApplicationConfigurationObservation struct {

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

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

func (*ApplicationConfigurationObservation) DeepCopy

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

func (*ApplicationConfigurationObservation) DeepCopyInto

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:Required
	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

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

func (*ApplicationConfigurationParameters) DeepCopyInto

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
	// +kubebuilder:validation:Optional
	ApplicationConfiguration []ApplicationConfigurationObservation `json:"applicationConfiguration,omitempty" tf:"application_configuration,omitempty"`

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

	// A CloudWatch log stream to monitor application configuration errors.
	// +kubebuilder:validation:Optional
	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"`

	// 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 status of the application.
	Status *string `json:"status,omitempty" tf:"status,omitempty"`

	// A map of tags assigned to the resource, including those inherited from the provider default_tags configuration block.
	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

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

	// 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.
	// +kubebuilder:validation:Required
	RuntimeEnvironment *string `json:"runtimeEnvironment" 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/dkb-bank/official-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
	Tags map[string]*string `json:"tags,omitempty" tf:"tags,omitempty"`
}

func (*ApplicationParameters) DeepCopy

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 ApplicationRestoreConfigurationObservation

type ApplicationRestoreConfigurationObservation struct {
}

func (*ApplicationRestoreConfigurationObservation) DeepCopy

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

func (*ApplicationRestoreConfigurationObservation) DeepCopyInto

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

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

func (*ApplicationRestoreConfigurationParameters) DeepCopyInto

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="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +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) 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) GetProviderReference

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

GetProviderReference of this ApplicationSnapshot. Deprecated: Use GetProviderConfigReference.

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

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

SetProviderReference of this ApplicationSnapshot. Deprecated: Use SetProviderConfigReference.

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 ApplicationSnapshotConfigurationObservation

type ApplicationSnapshotConfigurationObservation struct {
}

func (*ApplicationSnapshotConfigurationObservation) DeepCopy

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

func (*ApplicationSnapshotConfigurationObservation) DeepCopyInto

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:Required
	SnapshotsEnabled *bool `json:"snapshotsEnabled" tf:"snapshots_enabled,omitempty"`
}

func (*ApplicationSnapshotConfigurationParameters) DeepCopy

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

func (*ApplicationSnapshotConfigurationParameters) DeepCopyInto

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

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

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

func (*ApplicationSnapshotObservation) DeepCopyInto

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/dkb-bank/official-provider-aws/apis/kinesisanalyticsv2/v1beta1.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

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

func (*ApplicationSnapshotParameters) DeepCopyInto

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

ApplicationSnapshotSpec defines the desired state of ApplicationSnapshot

func (*ApplicationSnapshotSpec) DeepCopy

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

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

func (*ApplicationSnapshotStatus) DeepCopyInto

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

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 CheckpointConfigurationObservation

type CheckpointConfigurationObservation struct {
}

func (*CheckpointConfigurationObservation) DeepCopy

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

func (*CheckpointConfigurationObservation) DeepCopyInto

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:Required
	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

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

func (*CheckpointConfigurationParameters) DeepCopyInto

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

func (*CloudwatchLoggingOptionsObservation) DeepCopy

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

func (*CloudwatchLoggingOptionsObservation) DeepCopyInto

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/dkb-bank/official-provider-aws/apis/cloudwatchlogs/v1beta1.Stream
	// +crossplane:generate:reference:extractor=github.com/upbound/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

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

func (*CloudwatchLoggingOptionsParameters) DeepCopyInto

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

type CodeContentObservation

type CodeContentObservation struct {
}

func (*CodeContentObservation) DeepCopy

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

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 CsvMappingParametersObservation

type CsvMappingParametersObservation struct {
}

func (*CsvMappingParametersObservation) DeepCopy

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

func (*CsvMappingParametersObservation) DeepCopyInto

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:Required
	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:Required
	RecordRowDelimiter *string `json:"recordRowDelimiter" tf:"record_row_delimiter,omitempty"`
}

func (*CsvMappingParametersParameters) DeepCopy

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

func (*CsvMappingParametersParameters) DeepCopyInto

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

type DestinationSchemaObservation

type DestinationSchemaObservation struct {
}

func (*DestinationSchemaObservation) DeepCopy

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

func (*DestinationSchemaObservation) DeepCopyInto

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:Required
	RecordFormatType *string `json:"recordFormatType" tf:"record_format_type,omitempty"`
}

func (*DestinationSchemaParameters) DeepCopy

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

func (*DestinationSchemaParameters) DeepCopyInto

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

type EnvironmentPropertiesObservation

type EnvironmentPropertiesObservation struct {
}

func (*EnvironmentPropertiesObservation) DeepCopy

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

func (*EnvironmentPropertiesObservation) DeepCopyInto

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:Required
	PropertyGroup []PropertyGroupParameters `json:"propertyGroup" tf:"property_group,omitempty"`
}

func (*EnvironmentPropertiesParameters) DeepCopy

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

func (*EnvironmentPropertiesParameters) DeepCopyInto

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

type FlinkApplicationConfigurationObservation

type FlinkApplicationConfigurationObservation struct {
}

func (*FlinkApplicationConfigurationObservation) DeepCopy

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

func (*FlinkApplicationConfigurationObservation) DeepCopyInto

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

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

func (*FlinkApplicationConfigurationParameters) DeepCopyInto

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

type FlinkRunConfigurationObservation

type FlinkRunConfigurationObservation struct {
}

func (*FlinkRunConfigurationObservation) DeepCopy

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

func (*FlinkRunConfigurationObservation) DeepCopyInto

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

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

func (*FlinkRunConfigurationParameters) DeepCopyInto

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

type InputLambdaProcessorObservation

type InputLambdaProcessorObservation struct {
}

func (*InputLambdaProcessorObservation) DeepCopy

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

func (*InputLambdaProcessorObservation) DeepCopyInto

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:Required
	ResourceArn *string `json:"resourceArn" tf:"resource_arn,omitempty"`
}

func (*InputLambdaProcessorParameters) DeepCopy

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

func (*InputLambdaProcessorParameters) DeepCopyInto

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

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 InputParallelismObservation

type InputParallelismObservation struct {
}

func (*InputParallelismObservation) DeepCopy

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

func (*InputParallelismObservation) DeepCopyInto

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

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

func (*InputParallelismParameters) DeepCopyInto

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:Required
	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:Required
	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 InputProcessingConfigurationObservation

type InputProcessingConfigurationObservation struct {
}

func (*InputProcessingConfigurationObservation) DeepCopy

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

func (*InputProcessingConfigurationObservation) DeepCopyInto

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:Required
	InputLambdaProcessor []InputLambdaProcessorParameters `json:"inputLambdaProcessor" tf:"input_lambda_processor,omitempty"`
}

func (*InputProcessingConfigurationParameters) DeepCopy

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

func (*InputProcessingConfigurationParameters) DeepCopyInto

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

type InputSchemaObservation

type InputSchemaObservation struct {
}

func (*InputSchemaObservation) DeepCopy

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:Required
	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:Required
	RecordFormat []RecordFormatParameters `json:"recordFormat" tf:"record_format,omitempty"`
}

func (*InputSchemaParameters) DeepCopy

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 InputStartingPositionConfigurationObservation

type InputStartingPositionConfigurationObservation struct {
}

func (*InputStartingPositionConfigurationObservation) DeepCopy

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

func (*InputStartingPositionConfigurationObservation) DeepCopyInto

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

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

func (*InputStartingPositionConfigurationParameters) DeepCopyInto

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

type JSONMappingParametersObservation

type JSONMappingParametersObservation struct {
}

func (*JSONMappingParametersObservation) DeepCopy

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

func (*JSONMappingParametersObservation) DeepCopyInto

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:Required
	RecordRowPath *string `json:"recordRowPath" tf:"record_row_path,omitempty"`
}

func (*JSONMappingParametersParameters) DeepCopy

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

func (*JSONMappingParametersParameters) DeepCopyInto

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

type KinesisFirehoseInputObservation

type KinesisFirehoseInputObservation struct {
}

func (*KinesisFirehoseInputObservation) DeepCopy

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

func (*KinesisFirehoseInputObservation) DeepCopyInto

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:Required
	ResourceArn *string `json:"resourceArn" tf:"resource_arn,omitempty"`
}

func (*KinesisFirehoseInputParameters) DeepCopy

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

func (*KinesisFirehoseInputParameters) DeepCopyInto

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

type KinesisFirehoseOutputObservation

type KinesisFirehoseOutputObservation struct {
}

func (*KinesisFirehoseOutputObservation) DeepCopy

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

func (*KinesisFirehoseOutputObservation) DeepCopyInto

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/dkb-bank/official-provider-aws/apis/firehose/v1beta1.DeliveryStream
	// +crossplane:generate:reference:extractor=github.com/upbound/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

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

func (*KinesisFirehoseOutputParameters) DeepCopyInto

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

type KinesisStreamsInputObservation

type KinesisStreamsInputObservation struct {
}

func (*KinesisStreamsInputObservation) DeepCopy

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

func (*KinesisStreamsInputObservation) DeepCopyInto

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/dkb-bank/official-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

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

func (*KinesisStreamsInputParameters) DeepCopyInto

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

type KinesisStreamsOutputObservation

type KinesisStreamsOutputObservation struct {
}

func (*KinesisStreamsOutputObservation) DeepCopy

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

func (*KinesisStreamsOutputObservation) DeepCopyInto

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:Required
	ResourceArn *string `json:"resourceArn" tf:"resource_arn,omitempty"`
}

func (*KinesisStreamsOutputParameters) DeepCopy

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

func (*KinesisStreamsOutputParameters) DeepCopyInto

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

type LambdaOutputObservation

type LambdaOutputObservation struct {
}

func (*LambdaOutputObservation) DeepCopy

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.
	// +kubebuilder:validation:Required
	ResourceArn *string `json:"resourceArn" tf:"resource_arn,omitempty"`
}

func (*LambdaOutputParameters) DeepCopy

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 MappingParametersCsvMappingParametersObservation

type MappingParametersCsvMappingParametersObservation struct {
}

func (*MappingParametersCsvMappingParametersObservation) DeepCopy

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

func (*MappingParametersCsvMappingParametersObservation) DeepCopyInto

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:Required
	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:Required
	RecordRowDelimiter *string `json:"recordRowDelimiter" tf:"record_row_delimiter,omitempty"`
}

func (*MappingParametersCsvMappingParametersParameters) DeepCopy

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

func (*MappingParametersCsvMappingParametersParameters) DeepCopyInto

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

type MappingParametersJSONMappingParametersObservation

type MappingParametersJSONMappingParametersObservation struct {
}

func (*MappingParametersJSONMappingParametersObservation) DeepCopy

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

func (*MappingParametersJSONMappingParametersObservation) DeepCopyInto

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:Required
	RecordRowPath *string `json:"recordRowPath" tf:"record_row_path,omitempty"`
}

func (*MappingParametersJSONMappingParametersParameters) DeepCopy

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

func (*MappingParametersJSONMappingParametersParameters) DeepCopyInto

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

type MappingParametersObservation

type MappingParametersObservation struct {
}

func (*MappingParametersObservation) DeepCopy

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

func (*MappingParametersObservation) DeepCopyInto

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

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

func (*MappingParametersParameters) DeepCopyInto

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

type MonitoringConfigurationObservation

type MonitoringConfigurationObservation struct {
}

func (*MonitoringConfigurationObservation) DeepCopy

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

func (*MonitoringConfigurationObservation) DeepCopyInto

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:Required
	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

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

func (*MonitoringConfigurationParameters) DeepCopyInto

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

type OutputObservation

type OutputObservation struct {

	// 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:Required
	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:Required
	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 ParallelismConfigurationObservation

type ParallelismConfigurationObservation struct {
}

func (*ParallelismConfigurationObservation) DeepCopy

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

func (*ParallelismConfigurationObservation) DeepCopyInto

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:Required
	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

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

func (*ParallelismConfigurationParameters) DeepCopyInto

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

type PropertyGroupObservation

type PropertyGroupObservation struct {
}

func (*PropertyGroupObservation) DeepCopy

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:Required
	PropertyGroupID *string `json:"propertyGroupId" tf:"property_group_id,omitempty"`

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

func (*PropertyGroupParameters) DeepCopy

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 RecordColumnObservation

type RecordColumnObservation struct {
}

func (*RecordColumnObservation) DeepCopy

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:Required
	Name *string `json:"name" tf:"name,omitempty"`

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

func (*RecordColumnParameters) DeepCopy

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 RecordFormatMappingParametersObservation

type RecordFormatMappingParametersObservation struct {
}

func (*RecordFormatMappingParametersObservation) DeepCopy

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

func (*RecordFormatMappingParametersObservation) DeepCopyInto

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

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

func (*RecordFormatMappingParametersParameters) DeepCopyInto

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

type RecordFormatObservation

type RecordFormatObservation struct {
}

func (*RecordFormatObservation) DeepCopy

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:Required
	MappingParameters []MappingParametersParameters `json:"mappingParameters" tf:"mapping_parameters,omitempty"`

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

func (*RecordFormatParameters) DeepCopy

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 ReferenceDataSourceObservation

type ReferenceDataSourceObservation struct {

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

func (*ReferenceDataSourceObservation) DeepCopy

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

func (*ReferenceDataSourceObservation) DeepCopyInto

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:Required
	ReferenceSchema []ReferenceSchemaParameters `json:"referenceSchema" tf:"reference_schema,omitempty"`

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

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

func (*ReferenceDataSourceParameters) DeepCopy

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

func (*ReferenceDataSourceParameters) DeepCopyInto

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

type ReferenceSchemaObservation

type ReferenceSchemaObservation struct {
}

func (*ReferenceSchemaObservation) DeepCopy

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

func (*ReferenceSchemaObservation) DeepCopyInto

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:Required
	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:Required
	RecordFormat []ReferenceSchemaRecordFormatParameters `json:"recordFormat" tf:"record_format,omitempty"`
}

func (*ReferenceSchemaParameters) DeepCopy

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

func (*ReferenceSchemaParameters) DeepCopyInto

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

type ReferenceSchemaRecordColumnObservation

type ReferenceSchemaRecordColumnObservation struct {
}

func (*ReferenceSchemaRecordColumnObservation) DeepCopy

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

func (*ReferenceSchemaRecordColumnObservation) DeepCopyInto

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:Required
	Name *string `json:"name" tf:"name,omitempty"`

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

func (*ReferenceSchemaRecordColumnParameters) DeepCopy

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

func (*ReferenceSchemaRecordColumnParameters) DeepCopyInto

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

type ReferenceSchemaRecordFormatObservation

type ReferenceSchemaRecordFormatObservation struct {
}

func (*ReferenceSchemaRecordFormatObservation) DeepCopy

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

func (*ReferenceSchemaRecordFormatObservation) DeepCopyInto

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:Required
	MappingParameters []RecordFormatMappingParametersParameters `json:"mappingParameters" tf:"mapping_parameters,omitempty"`

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

func (*ReferenceSchemaRecordFormatParameters) DeepCopy

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

func (*ReferenceSchemaRecordFormatParameters) DeepCopyInto

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

type RunConfigurationObservation

type RunConfigurationObservation struct {
}

func (*RunConfigurationObservation) DeepCopy

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

func (*RunConfigurationObservation) DeepCopyInto

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

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

func (*RunConfigurationParameters) DeepCopyInto

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

type S3ContentLocationObservation

type S3ContentLocationObservation struct {
}

func (*S3ContentLocationObservation) DeepCopy

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

func (*S3ContentLocationObservation) DeepCopyInto

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/dkb-bank/official-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/dkb-bank/official-provider-aws/apis/s3/v1beta1.Object
	// +crossplane:generate:reference:extractor=github.com/upbound/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

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

func (*S3ContentLocationParameters) DeepCopyInto

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

type S3ReferenceDataSourceObservation

type S3ReferenceDataSourceObservation struct {
}

func (*S3ReferenceDataSourceObservation) DeepCopy

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

func (*S3ReferenceDataSourceObservation) DeepCopyInto

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/dkb-bank/official-provider-aws/apis/s3/v1beta1.Bucket
	// +crossplane:generate:reference:extractor=github.com/upbound/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:Required
	FileKey *string `json:"fileKey" tf:"file_key,omitempty"`
}

func (*S3ReferenceDataSourceParameters) DeepCopy

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

func (*S3ReferenceDataSourceParameters) DeepCopyInto

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.
	// +kubebuilder:validation:Optional
	Input []InputObservation `json:"input,omitempty" tf:"input,omitempty"`

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

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

func (*SQLApplicationConfigurationObservation) DeepCopy

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

func (*SQLApplicationConfigurationObservation) DeepCopyInto

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

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

func (*SQLApplicationConfigurationParameters) DeepCopyInto

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

type VPCConfigurationObservation

type VPCConfigurationObservation struct {

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

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

func (*VPCConfigurationObservation) DeepCopyInto

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

type VPCConfigurationParameters

type VPCConfigurationParameters struct {

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

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

func (*VPCConfigurationParameters) DeepCopy

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

func (*VPCConfigurationParameters) DeepCopyInto

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

Jump to

Keyboard shortcuts

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