Documentation ¶
Overview ¶
+kubebuilder:object:generate=true +groupName=kinesisanalyticsv2.aws.upbound.io +versionName=v1beta1
Index ¶
- Constants
- Variables
- type Application
- func (in *Application) DeepCopy() *Application
- func (in *Application) DeepCopyInto(out *Application)
- func (in *Application) DeepCopyObject() runtime.Object
- func (mg *Application) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (tr *Application) GetConnectionDetailsMapping() map[string]string
- func (mg *Application) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *Application) GetID() string
- func (tr *Application) GetObservation() (map[string]any, error)
- func (tr *Application) GetParameters() (map[string]any, error)
- func (mg *Application) GetProviderConfigReference() *xpv1.Reference
- func (mg *Application) GetProviderReference() *xpv1.Reference
- func (mg *Application) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *Application) GetTerraformResourceType() string
- func (tr *Application) GetTerraformSchemaVersion() int
- func (mg *Application) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *Application) LateInitialize(attrs []byte) (bool, error)
- func (mg *Application) ResolveReferences(ctx context.Context, c client.Reader) error
- func (mg *Application) SetConditions(c ...xpv1.Condition)
- func (mg *Application) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (tr *Application) SetObservation(obs map[string]any) error
- func (tr *Application) SetParameters(params map[string]any) error
- func (mg *Application) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *Application) SetProviderReference(r *xpv1.Reference)
- func (mg *Application) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *Application) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type ApplicationCodeConfigurationObservation
- type ApplicationCodeConfigurationParameters
- type ApplicationConfigurationObservation
- type ApplicationConfigurationParameters
- type ApplicationList
- type ApplicationObservation
- type ApplicationParameters
- type ApplicationRestoreConfigurationObservation
- type ApplicationRestoreConfigurationParameters
- type ApplicationSnapshot
- func (in *ApplicationSnapshot) DeepCopy() *ApplicationSnapshot
- func (in *ApplicationSnapshot) DeepCopyInto(out *ApplicationSnapshot)
- func (in *ApplicationSnapshot) DeepCopyObject() runtime.Object
- func (mg *ApplicationSnapshot) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (tr *ApplicationSnapshot) GetConnectionDetailsMapping() map[string]string
- func (mg *ApplicationSnapshot) GetDeletionPolicy() xpv1.DeletionPolicy
- func (tr *ApplicationSnapshot) GetID() string
- func (tr *ApplicationSnapshot) GetObservation() (map[string]any, error)
- func (tr *ApplicationSnapshot) GetParameters() (map[string]any, error)
- func (mg *ApplicationSnapshot) GetProviderConfigReference() *xpv1.Reference
- func (mg *ApplicationSnapshot) GetProviderReference() *xpv1.Reference
- func (mg *ApplicationSnapshot) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *ApplicationSnapshot) GetTerraformResourceType() string
- func (tr *ApplicationSnapshot) GetTerraformSchemaVersion() int
- func (mg *ApplicationSnapshot) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (tr *ApplicationSnapshot) LateInitialize(attrs []byte) (bool, error)
- func (mg *ApplicationSnapshot) ResolveReferences(ctx context.Context, c client.Reader) error
- func (mg *ApplicationSnapshot) SetConditions(c ...xpv1.Condition)
- func (mg *ApplicationSnapshot) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (tr *ApplicationSnapshot) SetObservation(obs map[string]any) error
- func (tr *ApplicationSnapshot) SetParameters(params map[string]any) error
- func (mg *ApplicationSnapshot) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *ApplicationSnapshot) SetProviderReference(r *xpv1.Reference)
- func (mg *ApplicationSnapshot) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *ApplicationSnapshot) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type ApplicationSnapshotConfigurationObservation
- type ApplicationSnapshotConfigurationParameters
- type ApplicationSnapshotList
- type ApplicationSnapshotObservation
- type ApplicationSnapshotParameters
- type ApplicationSnapshotSpec
- type ApplicationSnapshotStatus
- type ApplicationSpec
- type ApplicationStatus
- type CheckpointConfigurationObservation
- type CheckpointConfigurationParameters
- type CloudwatchLoggingOptionsObservation
- type CloudwatchLoggingOptionsParameters
- type CodeContentObservation
- type CodeContentParameters
- type CsvMappingParametersObservation
- type CsvMappingParametersParameters
- type DestinationSchemaObservation
- type DestinationSchemaParameters
- type EnvironmentPropertiesObservation
- type EnvironmentPropertiesParameters
- type FlinkApplicationConfigurationObservation
- type FlinkApplicationConfigurationParameters
- type FlinkRunConfigurationObservation
- type FlinkRunConfigurationParameters
- type InputLambdaProcessorObservation
- type InputLambdaProcessorParameters
- type InputObservation
- type InputParallelismObservation
- type InputParallelismParameters
- type InputParameters
- type InputProcessingConfigurationObservation
- type InputProcessingConfigurationParameters
- type InputSchemaObservation
- type InputSchemaParameters
- type InputStartingPositionConfigurationObservation
- type InputStartingPositionConfigurationParameters
- type JSONMappingParametersObservation
- type JSONMappingParametersParameters
- type KinesisFirehoseInputObservation
- type KinesisFirehoseInputParameters
- type KinesisFirehoseOutputObservation
- type KinesisFirehoseOutputParameters
- type KinesisStreamsInputObservation
- type KinesisStreamsInputParameters
- type KinesisStreamsOutputObservation
- type KinesisStreamsOutputParameters
- type LambdaOutputObservation
- type LambdaOutputParameters
- type MappingParametersCsvMappingParametersObservation
- type MappingParametersCsvMappingParametersParameters
- type MappingParametersJSONMappingParametersObservation
- type MappingParametersJSONMappingParametersParameters
- type MappingParametersObservation
- type MappingParametersParameters
- type MonitoringConfigurationObservation
- type MonitoringConfigurationParameters
- type OutputObservation
- type OutputParameters
- type ParallelismConfigurationObservation
- type ParallelismConfigurationParameters
- type PropertyGroupObservation
- type PropertyGroupParameters
- type RecordColumnObservation
- type RecordColumnParameters
- type RecordFormatMappingParametersObservation
- type RecordFormatMappingParametersParameters
- type RecordFormatObservation
- type RecordFormatParameters
- type ReferenceDataSourceObservation
- type ReferenceDataSourceParameters
- type ReferenceSchemaObservation
- type ReferenceSchemaParameters
- type ReferenceSchemaRecordColumnObservation
- type ReferenceSchemaRecordColumnParameters
- type ReferenceSchemaRecordFormatObservation
- type ReferenceSchemaRecordFormatParameters
- type RunConfigurationObservation
- type RunConfigurationParameters
- type S3ContentLocationObservation
- type S3ContentLocationParameters
- type S3ReferenceDataSourceObservation
- type S3ReferenceDataSourceParameters
- type SQLApplicationConfigurationObservation
- type SQLApplicationConfigurationParameters
- type VPCConfigurationObservation
- type VPCConfigurationParameters
Constants ¶
const ( CRDGroup = "kinesisanalyticsv2.aws.upbound.io" CRDVersion = "v1beta1" )
Package type metadata.
Variables ¶
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.
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.
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 ¶
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 ¶
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:Required 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 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 ¶
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: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 ¶
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 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 ¶
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"` // 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 ¶
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 ApplicationRestoreConfigurationObservation ¶
type ApplicationRestoreConfigurationObservation struct { }
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="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 ¶
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 ¶
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:Required 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 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 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/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 ¶
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"` }
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"` }
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 ¶
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: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 ¶
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 CloudwatchLoggingOptionsObservation ¶
type CloudwatchLoggingOptionsObservation struct { // The application identifier. CloudwatchLoggingOptionID *string `json:"cloudwatchLoggingOptionId,omitempty" tf:"cloudwatch_logging_option_id,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/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 ¶
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 CodeContentObservation ¶
type CodeContentObservation struct { }
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 CsvMappingParametersObservation ¶
type CsvMappingParametersObservation struct { }
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: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 ¶
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 DestinationSchemaObservation ¶
type DestinationSchemaObservation struct { }
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:Required 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 EnvironmentPropertiesObservation ¶
type EnvironmentPropertiesObservation struct { }
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:Required 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 FlinkApplicationConfigurationObservation ¶
type FlinkApplicationConfigurationObservation struct { }
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 FlinkRunConfigurationObservation ¶
type FlinkRunConfigurationObservation struct { }
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 InputLambdaProcessorObservation ¶
type InputLambdaProcessorObservation struct { }
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:Required 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"` }
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 ¶
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: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 ¶
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:Required 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 InputSchemaObservation ¶
type InputSchemaObservation struct { }
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: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 ¶
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 InputStartingPositionConfigurationObservation ¶
type InputStartingPositionConfigurationObservation struct { }
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 JSONMappingParametersObservation ¶
type JSONMappingParametersObservation struct { }
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:Required 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 KinesisFirehoseInputObservation ¶
type KinesisFirehoseInputObservation struct { }
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:Required 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 KinesisFirehoseOutputObservation ¶
type KinesisFirehoseOutputObservation struct { }
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/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 ¶
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 KinesisStreamsInputObservation ¶
type KinesisStreamsInputObservation struct { }
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/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 ¶
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 KinesisStreamsOutputObservation ¶
type KinesisStreamsOutputObservation struct { }
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:Required 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 LambdaOutputObservation ¶
type LambdaOutputObservation struct { }
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. // +kubebuilder:validation:Required ResourceArn *string `json:"resourceArn" tf:"resource_arn,omitempty"` }
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 MappingParametersCsvMappingParametersObservation ¶
type MappingParametersCsvMappingParametersObservation struct { }
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: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 ¶
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 MappingParametersJSONMappingParametersObservation ¶
type MappingParametersJSONMappingParametersObservation struct { }
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:Required 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 { }
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 MonitoringConfigurationObservation ¶
type MonitoringConfigurationObservation struct { }
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: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 ¶
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 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 ¶
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: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 ¶
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 PropertyGroupObservation ¶
type PropertyGroupObservation struct { }
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: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 ¶
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 RecordColumnObservation ¶
type RecordColumnObservation struct { }
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: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 ¶
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 RecordFormatMappingParametersObservation ¶
type RecordFormatMappingParametersObservation struct { }
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 { }
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: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 ¶
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 ReferenceDataSourceObservation ¶
type ReferenceDataSourceObservation struct { // The application identifier. ReferenceID *string `json:"referenceId,omitempty" tf:"reference_id,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: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 ¶
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 ReferenceSchemaObservation ¶
type ReferenceSchemaObservation struct { }
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: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 ¶
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 ReferenceSchemaRecordColumnObservation ¶
type ReferenceSchemaRecordColumnObservation struct { }
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: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 ¶
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 ReferenceSchemaRecordFormatObservation ¶
type ReferenceSchemaRecordFormatObservation struct { }
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: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 ¶
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 RunConfigurationObservation ¶
type RunConfigurationObservation struct { }
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 S3ContentLocationObservation ¶
type S3ContentLocationObservation struct { }
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/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 ¶
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 S3ReferenceDataSourceObservation ¶
type S3ReferenceDataSourceObservation struct { }
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/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 ¶
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 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 ¶
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 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 ¶
func (in *VPCConfigurationObservation) DeepCopy() *VPCConfigurationObservation
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new VPCConfigurationObservation.
func (*VPCConfigurationObservation) DeepCopyInto ¶
func (in *VPCConfigurationObservation) DeepCopyInto(out *VPCConfigurationObservation)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type VPCConfigurationParameters ¶
type VPCConfigurationParameters struct { // The Security Group IDs used by the VPC configuration. // +kubebuilder:validation: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 ¶
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.