v1beta1

Jul 29, 2024

Changes in this version

type ApplicationInitParameters

+ ApplicationMode *string

type ApplicationObservation

+ ApplicationMode *string

type ApplicationParameters

+ ApplicationMode *string

Jun 13, 2024

Changes in this version

type Application

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

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

Feb 16, 2024

Changes in this version

type Application

+ func (tr *Application) Hub()

type ApplicationSnapshot

+ func (tr *ApplicationSnapshot) Hub()

Dec 28, 2023

Changes in this version

type ApplicationInitParameters

+ ServiceExecutionRole *string

+ ServiceExecutionRoleRef *v1.Reference

+ ServiceExecutionRoleSelector *v1.Selector

type ApplicationSnapshotInitParameters

+ ApplicationName *string

+ ApplicationNameRef *v1.Reference

+ ApplicationNameSelector *v1.Selector

type CloudwatchLoggingOptionsInitParameters

+ LogStreamArn *string

+ LogStreamArnRef *v1.Reference

+ LogStreamArnSelector *v1.Selector

type KinesisFirehoseOutputInitParameters

+ ResourceArn *string

+ ResourceArnRef *v1.Reference

+ ResourceArnSelector *v1.Selector

type KinesisStreamsInputInitParameters

+ ResourceArn *string

+ ResourceArnRef *v1.Reference

+ ResourceArnSelector *v1.Selector

type LambdaOutputInitParameters

+ ResourceArn *string

+ ResourceArnRef *v1.Reference

+ ResourceArnSelector *v1.Selector

type S3ContentLocationInitParameters

+ BucketArn *string

+ BucketArnRef *v1.Reference

+ BucketArnSelector *v1.Selector

+ FileKey *string

+ FileKeyRef *v1.Reference

+ FileKeySelector *v1.Selector

type S3ReferenceDataSourceInitParameters

+ BucketArn *string

+ BucketArnRef *v1.Reference

+ BucketArnSelector *v1.Selector

Nov 16, 2023

Changes in this version

type Application

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

type ApplicationSnapshot

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

Aug 1, 2023

Changes in this version

type Application

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

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

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

+ type ApplicationCodeConfigurationInitParameters struct

+ CodeContent []CodeContentInitParameters

+ CodeContentType *string

+ func (in *ApplicationCodeConfigurationInitParameters) DeepCopy() *ApplicationCodeConfigurationInitParameters

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

+ type ApplicationConfigurationInitParameters struct

+ ApplicationCodeConfiguration []ApplicationCodeConfigurationInitParameters

+ ApplicationSnapshotConfiguration []ApplicationSnapshotConfigurationInitParameters

+ EnvironmentProperties []EnvironmentPropertiesInitParameters

+ FlinkApplicationConfiguration []FlinkApplicationConfigurationInitParameters

+ RunConfiguration []RunConfigurationInitParameters

+ SQLApplicationConfiguration []SQLApplicationConfigurationInitParameters

+ VPCConfiguration []VPCConfigurationInitParameters

+ func (in *ApplicationConfigurationInitParameters) DeepCopy() *ApplicationConfigurationInitParameters

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

+ type ApplicationInitParameters struct

+ ApplicationConfiguration []ApplicationConfigurationInitParameters

+ CloudwatchLoggingOptions []CloudwatchLoggingOptionsInitParameters

+ Description *string

+ ForceStop *bool

+ RuntimeEnvironment *string

+ StartApplication *bool

+ Tags map[string]*string

+ func (in *ApplicationInitParameters) DeepCopy() *ApplicationInitParameters

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

+ type ApplicationRestoreConfigurationInitParameters struct

+ ApplicationRestoreType *string

+ SnapshotName *string

+ func (in *ApplicationRestoreConfigurationInitParameters) DeepCopy() *ApplicationRestoreConfigurationInitParameters

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

type ApplicationSnapshot

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

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

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

+ type ApplicationSnapshotConfigurationInitParameters struct

+ SnapshotsEnabled *bool

+ func (in *ApplicationSnapshotConfigurationInitParameters) DeepCopy() *ApplicationSnapshotConfigurationInitParameters

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

+ type ApplicationSnapshotInitParameters struct

+ func (in *ApplicationSnapshotInitParameters) DeepCopy() *ApplicationSnapshotInitParameters

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

type ApplicationSnapshotSpec

+ InitProvider ApplicationSnapshotInitParameters

type ApplicationSpec

+ InitProvider ApplicationInitParameters

+ type CheckpointConfigurationInitParameters struct

+ CheckpointInterval *float64

+ CheckpointingEnabled *bool

+ ConfigurationType *string

+ MinPauseBetweenCheckpoints *float64

+ func (in *CheckpointConfigurationInitParameters) DeepCopy() *CheckpointConfigurationInitParameters

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

+ type CloudwatchLoggingOptionsInitParameters struct

+ func (in *CloudwatchLoggingOptionsInitParameters) DeepCopy() *CloudwatchLoggingOptionsInitParameters

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

+ type CodeContentInitParameters struct

+ S3ContentLocation []S3ContentLocationInitParameters

+ TextContent *string

+ func (in *CodeContentInitParameters) DeepCopy() *CodeContentInitParameters

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

+ type CsvMappingParametersInitParameters struct

+ RecordColumnDelimiter *string

+ RecordRowDelimiter *string

+ func (in *CsvMappingParametersInitParameters) DeepCopy() *CsvMappingParametersInitParameters

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

+ type DestinationSchemaInitParameters struct

+ RecordFormatType *string

+ func (in *DestinationSchemaInitParameters) DeepCopy() *DestinationSchemaInitParameters

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

+ type EnvironmentPropertiesInitParameters struct

+ PropertyGroup []PropertyGroupInitParameters

+ func (in *EnvironmentPropertiesInitParameters) DeepCopy() *EnvironmentPropertiesInitParameters

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

+ type FlinkApplicationConfigurationInitParameters struct

+ CheckpointConfiguration []CheckpointConfigurationInitParameters

+ MonitoringConfiguration []MonitoringConfigurationInitParameters

+ ParallelismConfiguration []ParallelismConfigurationInitParameters

+ func (in *FlinkApplicationConfigurationInitParameters) DeepCopy() *FlinkApplicationConfigurationInitParameters

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

+ type FlinkRunConfigurationInitParameters struct

+ AllowNonRestoredState *bool

+ func (in *FlinkRunConfigurationInitParameters) DeepCopy() *FlinkRunConfigurationInitParameters

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

+ type InputInitParameters struct

+ InputParallelism []InputParallelismInitParameters

+ InputProcessingConfiguration []InputProcessingConfigurationInitParameters

+ InputSchema []InputSchemaInitParameters

+ InputStartingPositionConfiguration []InputStartingPositionConfigurationInitParameters

+ KinesisFirehoseInput []KinesisFirehoseInputInitParameters

+ KinesisStreamsInput []KinesisStreamsInputInitParameters

+ NamePrefix *string

+ func (in *InputInitParameters) DeepCopy() *InputInitParameters

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

+ type InputLambdaProcessorInitParameters struct

+ ResourceArn *string

+ func (in *InputLambdaProcessorInitParameters) DeepCopy() *InputLambdaProcessorInitParameters

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

+ type InputParallelismInitParameters struct

+ Count *float64

+ func (in *InputParallelismInitParameters) DeepCopy() *InputParallelismInitParameters

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

+ type InputProcessingConfigurationInitParameters struct

+ InputLambdaProcessor []InputLambdaProcessorInitParameters

+ func (in *InputProcessingConfigurationInitParameters) DeepCopy() *InputProcessingConfigurationInitParameters

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

+ type InputSchemaInitParameters struct

+ RecordColumn []RecordColumnInitParameters

+ RecordEncoding *string

+ RecordFormat []RecordFormatInitParameters

+ func (in *InputSchemaInitParameters) DeepCopy() *InputSchemaInitParameters

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

+ type InputStartingPositionConfigurationInitParameters struct

+ InputStartingPosition *string

+ func (in *InputStartingPositionConfigurationInitParameters) DeepCopy() *InputStartingPositionConfigurationInitParameters

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

+ type JSONMappingParametersInitParameters struct

+ RecordRowPath *string

+ func (in *JSONMappingParametersInitParameters) DeepCopy() *JSONMappingParametersInitParameters

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

+ type KinesisFirehoseInputInitParameters struct

+ ResourceArn *string

+ func (in *KinesisFirehoseInputInitParameters) DeepCopy() *KinesisFirehoseInputInitParameters

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

+ type KinesisFirehoseOutputInitParameters struct

+ func (in *KinesisFirehoseOutputInitParameters) DeepCopy() *KinesisFirehoseOutputInitParameters

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

+ type KinesisStreamsInputInitParameters struct

+ func (in *KinesisStreamsInputInitParameters) DeepCopy() *KinesisStreamsInputInitParameters

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

+ type KinesisStreamsOutputInitParameters struct

+ ResourceArn *string

+ func (in *KinesisStreamsOutputInitParameters) DeepCopy() *KinesisStreamsOutputInitParameters

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

+ type LambdaOutputInitParameters struct

+ func (in *LambdaOutputInitParameters) DeepCopy() *LambdaOutputInitParameters

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

+ type MappingParametersCsvMappingParametersInitParameters struct

+ RecordColumnDelimiter *string

+ RecordRowDelimiter *string

+ func (in *MappingParametersCsvMappingParametersInitParameters) DeepCopy() *MappingParametersCsvMappingParametersInitParameters

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

+ type MappingParametersInitParameters struct

+ CsvMappingParameters []CsvMappingParametersInitParameters

+ JSONMappingParameters []JSONMappingParametersInitParameters

+ func (in *MappingParametersInitParameters) DeepCopy() *MappingParametersInitParameters

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

+ type MappingParametersJSONMappingParametersInitParameters struct

+ RecordRowPath *string

+ func (in *MappingParametersJSONMappingParametersInitParameters) DeepCopy() *MappingParametersJSONMappingParametersInitParameters

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

+ type MonitoringConfigurationInitParameters struct

+ ConfigurationType *string

+ LogLevel *string

+ MetricsLevel *string

+ func (in *MonitoringConfigurationInitParameters) DeepCopy() *MonitoringConfigurationInitParameters

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

+ type OutputInitParameters struct

+ DestinationSchema []DestinationSchemaInitParameters

+ KinesisFirehoseOutput []KinesisFirehoseOutputInitParameters

+ KinesisStreamsOutput []KinesisStreamsOutputInitParameters

+ LambdaOutput []LambdaOutputInitParameters

+ Name *string

+ func (in *OutputInitParameters) DeepCopy() *OutputInitParameters

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

+ type ParallelismConfigurationInitParameters struct

+ AutoScalingEnabled *bool

+ ConfigurationType *string

+ Parallelism *float64

+ ParallelismPerKpu *float64

+ func (in *ParallelismConfigurationInitParameters) DeepCopy() *ParallelismConfigurationInitParameters

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

+ type PropertyGroupInitParameters struct

+ PropertyGroupID *string

+ PropertyMap map[string]*string

+ func (in *PropertyGroupInitParameters) DeepCopy() *PropertyGroupInitParameters

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

+ type RecordColumnInitParameters struct

+ Mapping *string

+ Name *string

+ SQLType *string

+ func (in *RecordColumnInitParameters) DeepCopy() *RecordColumnInitParameters

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

+ type RecordFormatInitParameters struct

+ MappingParameters []MappingParametersInitParameters

+ RecordFormatType *string

+ func (in *RecordFormatInitParameters) DeepCopy() *RecordFormatInitParameters

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

+ type RecordFormatMappingParametersInitParameters struct

+ CsvMappingParameters []MappingParametersCsvMappingParametersInitParameters

+ JSONMappingParameters []MappingParametersJSONMappingParametersInitParameters

+ func (in *RecordFormatMappingParametersInitParameters) DeepCopy() *RecordFormatMappingParametersInitParameters

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

+ type ReferenceDataSourceInitParameters struct

+ ReferenceSchema []ReferenceSchemaInitParameters

+ S3ReferenceDataSource []S3ReferenceDataSourceInitParameters

+ TableName *string

+ func (in *ReferenceDataSourceInitParameters) DeepCopy() *ReferenceDataSourceInitParameters

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

+ type ReferenceSchemaInitParameters struct

+ RecordColumn []ReferenceSchemaRecordColumnInitParameters

+ RecordEncoding *string

+ RecordFormat []ReferenceSchemaRecordFormatInitParameters

+ func (in *ReferenceSchemaInitParameters) DeepCopy() *ReferenceSchemaInitParameters

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

+ type ReferenceSchemaRecordColumnInitParameters struct

+ Mapping *string

+ Name *string

+ SQLType *string

+ func (in *ReferenceSchemaRecordColumnInitParameters) DeepCopy() *ReferenceSchemaRecordColumnInitParameters

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

+ type ReferenceSchemaRecordFormatInitParameters struct

+ MappingParameters []RecordFormatMappingParametersInitParameters

+ RecordFormatType *string

+ func (in *ReferenceSchemaRecordFormatInitParameters) DeepCopy() *ReferenceSchemaRecordFormatInitParameters

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

+ type RunConfigurationInitParameters struct

+ ApplicationRestoreConfiguration []ApplicationRestoreConfigurationInitParameters

+ FlinkRunConfiguration []FlinkRunConfigurationInitParameters

+ func (in *RunConfigurationInitParameters) DeepCopy() *RunConfigurationInitParameters

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

+ type S3ContentLocationInitParameters struct

+ ObjectVersion *string

+ func (in *S3ContentLocationInitParameters) DeepCopy() *S3ContentLocationInitParameters

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

+ type S3ReferenceDataSourceInitParameters struct

+ FileKey *string

+ func (in *S3ReferenceDataSourceInitParameters) DeepCopy() *S3ReferenceDataSourceInitParameters

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

+ type SQLApplicationConfigurationInitParameters struct

+ Input []InputInitParameters

+ Output []OutputInitParameters

+ ReferenceDataSource []ReferenceDataSourceInitParameters

+ func (in *SQLApplicationConfigurationInitParameters) DeepCopy() *SQLApplicationConfigurationInitParameters

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

+ type VPCConfigurationInitParameters struct

+ SecurityGroupIds []*string

+ SubnetIds []*string

+ func (in *VPCConfigurationInitParameters) DeepCopy() *VPCConfigurationInitParameters

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

Apr 26, 2023

Changes in this version

type Application

+ func (mg *Application) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *Application) SetManagementPolicy(r xpv1.ManagementPolicy)

type ApplicationCodeConfigurationObservation

+ CodeContent []CodeContentObservation

+ CodeContentType *string

type ApplicationConfigurationObservation

+ ApplicationCodeConfiguration []ApplicationCodeConfigurationObservation

+ ApplicationSnapshotConfiguration []ApplicationSnapshotConfigurationObservation

+ EnvironmentProperties []EnvironmentPropertiesObservation

+ FlinkApplicationConfiguration []FlinkApplicationConfigurationObservation

+ RunConfiguration []RunConfigurationObservation

type ApplicationObservation

+ Description *string

+ ForceStop *bool

+ RuntimeEnvironment *string

+ ServiceExecutionRole *string

+ StartApplication *bool

+ Tags map[string]*string

type ApplicationRestoreConfigurationObservation

+ ApplicationRestoreType *string

+ SnapshotName *string

type ApplicationSnapshot

+ func (mg *ApplicationSnapshot) GetManagementPolicy() xpv1.ManagementPolicy

+ func (mg *ApplicationSnapshot) SetManagementPolicy(r xpv1.ManagementPolicy)

type ApplicationSnapshotConfigurationObservation

+ SnapshotsEnabled *bool

type ApplicationSnapshotObservation

+ ApplicationName *string

type CheckpointConfigurationObservation

+ CheckpointInterval *float64

+ CheckpointingEnabled *bool

+ ConfigurationType *string

+ MinPauseBetweenCheckpoints *float64

type CloudwatchLoggingOptionsObservation

+ LogStreamArn *string

type CodeContentObservation

+ S3ContentLocation []S3ContentLocationObservation

+ TextContent *string

type CsvMappingParametersObservation

+ RecordColumnDelimiter *string

+ RecordRowDelimiter *string

type DestinationSchemaObservation

+ RecordFormatType *string

type EnvironmentPropertiesObservation

+ PropertyGroup []PropertyGroupObservation

type FlinkApplicationConfigurationObservation

+ CheckpointConfiguration []CheckpointConfigurationObservation

+ MonitoringConfiguration []MonitoringConfigurationObservation

+ ParallelismConfiguration []ParallelismConfigurationObservation

type FlinkRunConfigurationObservation

+ AllowNonRestoredState *bool

type InputLambdaProcessorObservation

+ ResourceArn *string

type InputObservation

+ InputParallelism []InputParallelismObservation

+ InputProcessingConfiguration []InputProcessingConfigurationObservation

+ InputSchema []InputSchemaObservation

+ InputStartingPositionConfiguration []InputStartingPositionConfigurationObservation

+ KinesisFirehoseInput []KinesisFirehoseInputObservation

+ KinesisStreamsInput []KinesisStreamsInputObservation

+ NamePrefix *string

type InputParallelismObservation

+ Count *float64

type InputProcessingConfigurationObservation

+ InputLambdaProcessor []InputLambdaProcessorObservation

type InputSchemaObservation

+ RecordColumn []RecordColumnObservation

+ RecordEncoding *string

+ RecordFormat []RecordFormatObservation

type InputStartingPositionConfigurationObservation

+ InputStartingPosition *string

type JSONMappingParametersObservation

+ RecordRowPath *string

type KinesisFirehoseInputObservation

+ ResourceArn *string

type KinesisFirehoseOutputObservation

+ ResourceArn *string

type KinesisStreamsInputObservation

+ ResourceArn *string

type KinesisStreamsOutputObservation

+ ResourceArn *string

type LambdaOutputObservation

+ ResourceArn *string

type MappingParametersCsvMappingParametersObservation

+ RecordColumnDelimiter *string

+ RecordRowDelimiter *string

type MappingParametersJSONMappingParametersObservation

+ RecordRowPath *string

type MappingParametersObservation

+ CsvMappingParameters []CsvMappingParametersObservation

+ JSONMappingParameters []JSONMappingParametersObservation

type MonitoringConfigurationObservation

+ ConfigurationType *string

+ LogLevel *string

+ MetricsLevel *string

type OutputObservation

+ DestinationSchema []DestinationSchemaObservation

+ KinesisFirehoseOutput []KinesisFirehoseOutputObservation

+ KinesisStreamsOutput []KinesisStreamsOutputObservation

+ LambdaOutput []LambdaOutputObservation

+ Name *string

type ParallelismConfigurationObservation

+ AutoScalingEnabled *bool

+ ConfigurationType *string

+ Parallelism *float64

+ ParallelismPerKpu *float64

type PropertyGroupObservation

+ PropertyGroupID *string

+ PropertyMap map[string]*string

type RecordColumnObservation

+ Mapping *string

+ Name *string

+ SQLType *string

type RecordFormatMappingParametersObservation

+ CsvMappingParameters []MappingParametersCsvMappingParametersObservation

+ JSONMappingParameters []MappingParametersJSONMappingParametersObservation

type RecordFormatObservation

+ MappingParameters []MappingParametersObservation

+ RecordFormatType *string

type ReferenceDataSourceObservation

+ ReferenceSchema []ReferenceSchemaObservation

+ S3ReferenceDataSource []S3ReferenceDataSourceObservation

+ TableName *string

type ReferenceSchemaObservation

+ RecordColumn []ReferenceSchemaRecordColumnObservation

+ RecordEncoding *string

+ RecordFormat []ReferenceSchemaRecordFormatObservation

type ReferenceSchemaRecordColumnObservation

+ Mapping *string

+ Name *string

+ SQLType *string

type ReferenceSchemaRecordFormatObservation

+ MappingParameters []RecordFormatMappingParametersObservation

+ RecordFormatType *string

type RunConfigurationObservation

+ ApplicationRestoreConfiguration []ApplicationRestoreConfigurationObservation

+ FlinkRunConfiguration []FlinkRunConfigurationObservation

type S3ContentLocationObservation

+ BucketArn *string

+ FileKey *string

+ ObjectVersion *string

type S3ReferenceDataSourceObservation

+ BucketArn *string

+ FileKey *string

type VPCConfigurationObservation

+ SecurityGroupIds []*string

+ SubnetIds []*string

Nov 14, 2022

Changes in this version

type CloudwatchLoggingOptionsParameters

+ LogStreamArnRef *v1.Reference

+ LogStreamArnSelector *v1.Selector

Oct 17, 2022

Changes in this version

+ const CRDGroup

+ const CRDVersion

+ var AddToScheme = SchemeBuilder.AddToScheme

+ var ApplicationSnapshot_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: ApplicationSnapshot_Kind}.String()

+ var ApplicationSnapshot_GroupVersionKind = CRDGroupVersion.WithKind(ApplicationSnapshot_Kind)

+ var ApplicationSnapshot_Kind = "ApplicationSnapshot"

+ var ApplicationSnapshot_KindAPIVersion = ApplicationSnapshot_Kind + "." + CRDGroupVersion.String()

+ var Application_GroupKind = schema.GroupKind{Group: CRDGroup, Kind: Application_Kind}.String()

+ var Application_GroupVersionKind = CRDGroupVersion.WithKind(Application_Kind)

+ var Application_Kind = "Application"

+ var Application_KindAPIVersion = Application_Kind + "." + CRDGroupVersion.String()

+ var CRDGroupVersion = schema.GroupVersion

+ var SchemeBuilder = &scheme.Builder

+ type Application struct

+ Spec ApplicationSpec

+ Status ApplicationStatus

+ 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 (mg *Application) GetDeletionPolicy() xpv1.DeletionPolicy

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

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

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

+ func (mg *Application) GetTerraformResourceType() string

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

+ 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 (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)

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

+ func (tr *Application) GetID() string

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

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

+ func (tr *Application) GetTerraformSchemaVersion() int

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

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

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

+ type ApplicationCodeConfigurationObservation struct

+ func (in *ApplicationCodeConfigurationObservation) DeepCopy() *ApplicationCodeConfigurationObservation

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

+ type ApplicationCodeConfigurationParameters struct

+ CodeContent []CodeContentParameters

+ CodeContentType *string

+ func (in *ApplicationCodeConfigurationParameters) DeepCopy() *ApplicationCodeConfigurationParameters

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

+ type ApplicationConfigurationObservation struct

+ SQLApplicationConfiguration []SQLApplicationConfigurationObservation

+ VPCConfiguration []VPCConfigurationObservation

+ func (in *ApplicationConfigurationObservation) DeepCopy() *ApplicationConfigurationObservation

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

+ type ApplicationConfigurationParameters struct

+ ApplicationCodeConfiguration []ApplicationCodeConfigurationParameters

+ ApplicationSnapshotConfiguration []ApplicationSnapshotConfigurationParameters

+ EnvironmentProperties []EnvironmentPropertiesParameters

+ FlinkApplicationConfiguration []FlinkApplicationConfigurationParameters

+ RunConfiguration []RunConfigurationParameters

+ SQLApplicationConfiguration []SQLApplicationConfigurationParameters

+ VPCConfiguration []VPCConfigurationParameters

+ func (in *ApplicationConfigurationParameters) DeepCopy() *ApplicationConfigurationParameters

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

+ type ApplicationList struct

+ Items []Application

+ func (in *ApplicationList) DeepCopy() *ApplicationList

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

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

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

+ type ApplicationObservation struct

+ ApplicationConfiguration []ApplicationConfigurationObservation

+ Arn *string

+ CloudwatchLoggingOptions []CloudwatchLoggingOptionsObservation

+ CreateTimestamp *string

+ ID *string

+ LastUpdateTimestamp *string

+ Status *string

+ TagsAll map[string]*string

+ VersionID *float64

+ func (in *ApplicationObservation) DeepCopy() *ApplicationObservation

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

+ type ApplicationParameters struct

+ ApplicationConfiguration []ApplicationConfigurationParameters

+ CloudwatchLoggingOptions []CloudwatchLoggingOptionsParameters

+ Description *string

+ ForceStop *bool

+ Region *string

+ RuntimeEnvironment *string

+ ServiceExecutionRole *string

+ ServiceExecutionRoleRef *v1.Reference

+ ServiceExecutionRoleSelector *v1.Selector

+ StartApplication *bool

+ Tags map[string]*string

+ func (in *ApplicationParameters) DeepCopy() *ApplicationParameters

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

+ type ApplicationRestoreConfigurationObservation struct

+ func (in *ApplicationRestoreConfigurationObservation) DeepCopy() *ApplicationRestoreConfigurationObservation

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

+ type ApplicationRestoreConfigurationParameters struct

+ ApplicationRestoreType *string

+ SnapshotName *string

+ func (in *ApplicationRestoreConfigurationParameters) DeepCopy() *ApplicationRestoreConfigurationParameters

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

+ type ApplicationSnapshot struct

+ Spec ApplicationSnapshotSpec

+ Status ApplicationSnapshotStatus

+ 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 (mg *ApplicationSnapshot) GetDeletionPolicy() xpv1.DeletionPolicy

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

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

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

+ func (mg *ApplicationSnapshot) GetTerraformResourceType() string

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

+ 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 (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)

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

+ func (tr *ApplicationSnapshot) GetID() string

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

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

+ func (tr *ApplicationSnapshot) GetTerraformSchemaVersion() int

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

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

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

+ type ApplicationSnapshotConfigurationObservation struct

+ func (in *ApplicationSnapshotConfigurationObservation) DeepCopy() *ApplicationSnapshotConfigurationObservation

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

+ type ApplicationSnapshotConfigurationParameters struct

+ SnapshotsEnabled *bool

+ func (in *ApplicationSnapshotConfigurationParameters) DeepCopy() *ApplicationSnapshotConfigurationParameters

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

+ type ApplicationSnapshotList struct

+ Items []ApplicationSnapshot

+ func (in *ApplicationSnapshotList) DeepCopy() *ApplicationSnapshotList

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

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

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

+ type ApplicationSnapshotObservation struct

+ ApplicationVersionID *float64

+ ID *string

+ SnapshotCreationTimestamp *string

+ func (in *ApplicationSnapshotObservation) DeepCopy() *ApplicationSnapshotObservation

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

+ type ApplicationSnapshotParameters struct

+ ApplicationName *string

+ ApplicationNameRef *v1.Reference

+ ApplicationNameSelector *v1.Selector

+ Region *string

+ func (in *ApplicationSnapshotParameters) DeepCopy() *ApplicationSnapshotParameters

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

+ type ApplicationSnapshotSpec struct

+ ForProvider ApplicationSnapshotParameters

+ func (in *ApplicationSnapshotSpec) DeepCopy() *ApplicationSnapshotSpec

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

+ type ApplicationSnapshotStatus struct

+ AtProvider ApplicationSnapshotObservation

+ func (in *ApplicationSnapshotStatus) DeepCopy() *ApplicationSnapshotStatus

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

+ type ApplicationSpec struct

+ ForProvider ApplicationParameters

+ func (in *ApplicationSpec) DeepCopy() *ApplicationSpec

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

+ type ApplicationStatus struct

+ AtProvider ApplicationObservation

+ func (in *ApplicationStatus) DeepCopy() *ApplicationStatus

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

+ type CheckpointConfigurationObservation struct

+ func (in *CheckpointConfigurationObservation) DeepCopy() *CheckpointConfigurationObservation

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

+ type CheckpointConfigurationParameters struct

+ CheckpointInterval *float64

+ CheckpointingEnabled *bool

+ ConfigurationType *string

+ MinPauseBetweenCheckpoints *float64

+ func (in *CheckpointConfigurationParameters) DeepCopy() *CheckpointConfigurationParameters

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

+ type CloudwatchLoggingOptionsObservation struct

+ CloudwatchLoggingOptionID *string

+ func (in *CloudwatchLoggingOptionsObservation) DeepCopy() *CloudwatchLoggingOptionsObservation

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

+ type CloudwatchLoggingOptionsParameters struct

+ LogStreamArn *string

+ func (in *CloudwatchLoggingOptionsParameters) DeepCopy() *CloudwatchLoggingOptionsParameters

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

+ type CodeContentObservation struct

+ func (in *CodeContentObservation) DeepCopy() *CodeContentObservation

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

+ type CodeContentParameters struct

+ S3ContentLocation []S3ContentLocationParameters

+ TextContent *string

+ func (in *CodeContentParameters) DeepCopy() *CodeContentParameters

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

+ type CsvMappingParametersObservation struct

+ func (in *CsvMappingParametersObservation) DeepCopy() *CsvMappingParametersObservation

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

+ type CsvMappingParametersParameters struct

+ RecordColumnDelimiter *string

+ RecordRowDelimiter *string

+ func (in *CsvMappingParametersParameters) DeepCopy() *CsvMappingParametersParameters

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

+ type DestinationSchemaObservation struct

+ func (in *DestinationSchemaObservation) DeepCopy() *DestinationSchemaObservation

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

+ type DestinationSchemaParameters struct

+ RecordFormatType *string

+ func (in *DestinationSchemaParameters) DeepCopy() *DestinationSchemaParameters

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

+ type EnvironmentPropertiesObservation struct

+ func (in *EnvironmentPropertiesObservation) DeepCopy() *EnvironmentPropertiesObservation

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

+ type EnvironmentPropertiesParameters struct

+ PropertyGroup []PropertyGroupParameters

+ func (in *EnvironmentPropertiesParameters) DeepCopy() *EnvironmentPropertiesParameters

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

+ type FlinkApplicationConfigurationObservation struct

+ func (in *FlinkApplicationConfigurationObservation) DeepCopy() *FlinkApplicationConfigurationObservation

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

+ type FlinkApplicationConfigurationParameters struct

+ CheckpointConfiguration []CheckpointConfigurationParameters

+ MonitoringConfiguration []MonitoringConfigurationParameters

+ ParallelismConfiguration []ParallelismConfigurationParameters

+ func (in *FlinkApplicationConfigurationParameters) DeepCopy() *FlinkApplicationConfigurationParameters

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

+ type FlinkRunConfigurationObservation struct

+ func (in *FlinkRunConfigurationObservation) DeepCopy() *FlinkRunConfigurationObservation

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

+ type FlinkRunConfigurationParameters struct

+ AllowNonRestoredState *bool

+ func (in *FlinkRunConfigurationParameters) DeepCopy() *FlinkRunConfigurationParameters

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

+ type InputLambdaProcessorObservation struct

+ func (in *InputLambdaProcessorObservation) DeepCopy() *InputLambdaProcessorObservation

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

+ type InputLambdaProcessorParameters struct

+ ResourceArn *string

+ func (in *InputLambdaProcessorParameters) DeepCopy() *InputLambdaProcessorParameters

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

+ type InputObservation struct

+ InAppStreamNames []*string

+ InputID *string

+ func (in *InputObservation) DeepCopy() *InputObservation

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

+ type InputParallelismObservation struct

+ func (in *InputParallelismObservation) DeepCopy() *InputParallelismObservation

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

+ type InputParallelismParameters struct

+ Count *float64

+ func (in *InputParallelismParameters) DeepCopy() *InputParallelismParameters

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

+ type InputParameters struct

+ InputParallelism []InputParallelismParameters

+ InputProcessingConfiguration []InputProcessingConfigurationParameters

+ InputSchema []InputSchemaParameters

+ InputStartingPositionConfiguration []InputStartingPositionConfigurationParameters

+ KinesisFirehoseInput []KinesisFirehoseInputParameters

+ KinesisStreamsInput []KinesisStreamsInputParameters

+ NamePrefix *string

+ func (in *InputParameters) DeepCopy() *InputParameters

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

+ type InputProcessingConfigurationObservation struct

+ func (in *InputProcessingConfigurationObservation) DeepCopy() *InputProcessingConfigurationObservation

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

+ type InputProcessingConfigurationParameters struct

+ InputLambdaProcessor []InputLambdaProcessorParameters

+ func (in *InputProcessingConfigurationParameters) DeepCopy() *InputProcessingConfigurationParameters

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

+ type InputSchemaObservation struct

+ func (in *InputSchemaObservation) DeepCopy() *InputSchemaObservation

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

+ type InputSchemaParameters struct

+ RecordColumn []RecordColumnParameters

+ RecordEncoding *string

+ RecordFormat []RecordFormatParameters

+ func (in *InputSchemaParameters) DeepCopy() *InputSchemaParameters

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

+ type InputStartingPositionConfigurationObservation struct

+ func (in *InputStartingPositionConfigurationObservation) DeepCopy() *InputStartingPositionConfigurationObservation

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

+ type InputStartingPositionConfigurationParameters struct

+ InputStartingPosition *string

+ func (in *InputStartingPositionConfigurationParameters) DeepCopy() *InputStartingPositionConfigurationParameters

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

+ type JSONMappingParametersObservation struct

+ func (in *JSONMappingParametersObservation) DeepCopy() *JSONMappingParametersObservation

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

+ type JSONMappingParametersParameters struct

+ RecordRowPath *string

+ func (in *JSONMappingParametersParameters) DeepCopy() *JSONMappingParametersParameters

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

+ type KinesisFirehoseInputObservation struct

+ func (in *KinesisFirehoseInputObservation) DeepCopy() *KinesisFirehoseInputObservation

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

+ type KinesisFirehoseInputParameters struct

+ ResourceArn *string

+ func (in *KinesisFirehoseInputParameters) DeepCopy() *KinesisFirehoseInputParameters

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

+ type KinesisFirehoseOutputObservation struct

+ func (in *KinesisFirehoseOutputObservation) DeepCopy() *KinesisFirehoseOutputObservation

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

+ type KinesisFirehoseOutputParameters struct

+ ResourceArn *string

+ ResourceArnRef *v1.Reference

+ ResourceArnSelector *v1.Selector

+ func (in *KinesisFirehoseOutputParameters) DeepCopy() *KinesisFirehoseOutputParameters

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

+ type KinesisStreamsInputObservation struct

+ func (in *KinesisStreamsInputObservation) DeepCopy() *KinesisStreamsInputObservation

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

+ type KinesisStreamsInputParameters struct

+ ResourceArn *string

+ ResourceArnRef *v1.Reference

+ ResourceArnSelector *v1.Selector

+ func (in *KinesisStreamsInputParameters) DeepCopy() *KinesisStreamsInputParameters

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

+ type KinesisStreamsOutputObservation struct

+ func (in *KinesisStreamsOutputObservation) DeepCopy() *KinesisStreamsOutputObservation

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

+ type KinesisStreamsOutputParameters struct

+ ResourceArn *string

+ func (in *KinesisStreamsOutputParameters) DeepCopy() *KinesisStreamsOutputParameters

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

+ type LambdaOutputObservation struct

+ func (in *LambdaOutputObservation) DeepCopy() *LambdaOutputObservation

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

+ type LambdaOutputParameters struct

+ ResourceArn *string

+ ResourceArnRef *v1.Reference

+ ResourceArnSelector *v1.Selector

+ func (in *LambdaOutputParameters) DeepCopy() *LambdaOutputParameters

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

+ type MappingParametersCsvMappingParametersObservation struct

+ func (in *MappingParametersCsvMappingParametersObservation) DeepCopy() *MappingParametersCsvMappingParametersObservation

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

+ type MappingParametersCsvMappingParametersParameters struct

+ RecordColumnDelimiter *string

+ RecordRowDelimiter *string

+ func (in *MappingParametersCsvMappingParametersParameters) DeepCopy() *MappingParametersCsvMappingParametersParameters

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

+ type MappingParametersJSONMappingParametersObservation struct

+ func (in *MappingParametersJSONMappingParametersObservation) DeepCopy() *MappingParametersJSONMappingParametersObservation

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

+ type MappingParametersJSONMappingParametersParameters struct

+ RecordRowPath *string

+ func (in *MappingParametersJSONMappingParametersParameters) DeepCopy() *MappingParametersJSONMappingParametersParameters

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

+ type MappingParametersObservation struct

+ func (in *MappingParametersObservation) DeepCopy() *MappingParametersObservation

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

+ type MappingParametersParameters struct

+ CsvMappingParameters []CsvMappingParametersParameters

+ JSONMappingParameters []JSONMappingParametersParameters

+ func (in *MappingParametersParameters) DeepCopy() *MappingParametersParameters

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

+ type MonitoringConfigurationObservation struct

+ func (in *MonitoringConfigurationObservation) DeepCopy() *MonitoringConfigurationObservation

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

+ type MonitoringConfigurationParameters struct

+ ConfigurationType *string

+ LogLevel *string

+ MetricsLevel *string

+ func (in *MonitoringConfigurationParameters) DeepCopy() *MonitoringConfigurationParameters

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

+ type OutputObservation struct

+ OutputID *string

+ func (in *OutputObservation) DeepCopy() *OutputObservation

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

+ type OutputParameters struct

+ DestinationSchema []DestinationSchemaParameters

+ KinesisFirehoseOutput []KinesisFirehoseOutputParameters

+ KinesisStreamsOutput []KinesisStreamsOutputParameters

+ LambdaOutput []LambdaOutputParameters

+ Name *string

+ func (in *OutputParameters) DeepCopy() *OutputParameters

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

+ type ParallelismConfigurationObservation struct

+ func (in *ParallelismConfigurationObservation) DeepCopy() *ParallelismConfigurationObservation

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

+ type ParallelismConfigurationParameters struct

+ AutoScalingEnabled *bool

+ ConfigurationType *string

+ Parallelism *float64

+ ParallelismPerKpu *float64

+ func (in *ParallelismConfigurationParameters) DeepCopy() *ParallelismConfigurationParameters

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

+ type PropertyGroupObservation struct

+ func (in *PropertyGroupObservation) DeepCopy() *PropertyGroupObservation

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

+ type PropertyGroupParameters struct

+ PropertyGroupID *string

+ PropertyMap map[string]*string

+ func (in *PropertyGroupParameters) DeepCopy() *PropertyGroupParameters

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

+ type RecordColumnObservation struct

+ func (in *RecordColumnObservation) DeepCopy() *RecordColumnObservation

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

+ type RecordColumnParameters struct

+ Mapping *string

+ Name *string

+ SQLType *string

+ func (in *RecordColumnParameters) DeepCopy() *RecordColumnParameters

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

+ type RecordFormatMappingParametersObservation struct

+ func (in *RecordFormatMappingParametersObservation) DeepCopy() *RecordFormatMappingParametersObservation

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

+ type RecordFormatMappingParametersParameters struct

+ CsvMappingParameters []MappingParametersCsvMappingParametersParameters

+ JSONMappingParameters []MappingParametersJSONMappingParametersParameters

+ func (in *RecordFormatMappingParametersParameters) DeepCopy() *RecordFormatMappingParametersParameters

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

+ type RecordFormatObservation struct

+ func (in *RecordFormatObservation) DeepCopy() *RecordFormatObservation

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

+ type RecordFormatParameters struct

+ MappingParameters []MappingParametersParameters

+ RecordFormatType *string

+ func (in *RecordFormatParameters) DeepCopy() *RecordFormatParameters

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

+ type ReferenceDataSourceObservation struct

+ ReferenceID *string

+ func (in *ReferenceDataSourceObservation) DeepCopy() *ReferenceDataSourceObservation

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

+ type ReferenceDataSourceParameters struct

+ ReferenceSchema []ReferenceSchemaParameters

+ S3ReferenceDataSource []S3ReferenceDataSourceParameters

+ TableName *string

+ func (in *ReferenceDataSourceParameters) DeepCopy() *ReferenceDataSourceParameters

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

+ type ReferenceSchemaObservation struct

+ func (in *ReferenceSchemaObservation) DeepCopy() *ReferenceSchemaObservation

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

+ type ReferenceSchemaParameters struct

+ RecordColumn []ReferenceSchemaRecordColumnParameters

+ RecordEncoding *string

+ RecordFormat []ReferenceSchemaRecordFormatParameters

+ func (in *ReferenceSchemaParameters) DeepCopy() *ReferenceSchemaParameters

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

+ type ReferenceSchemaRecordColumnObservation struct

+ func (in *ReferenceSchemaRecordColumnObservation) DeepCopy() *ReferenceSchemaRecordColumnObservation

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

+ type ReferenceSchemaRecordColumnParameters struct

+ Mapping *string

+ Name *string

+ SQLType *string

+ func (in *ReferenceSchemaRecordColumnParameters) DeepCopy() *ReferenceSchemaRecordColumnParameters

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

+ type ReferenceSchemaRecordFormatObservation struct

+ func (in *ReferenceSchemaRecordFormatObservation) DeepCopy() *ReferenceSchemaRecordFormatObservation

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

+ type ReferenceSchemaRecordFormatParameters struct

+ MappingParameters []RecordFormatMappingParametersParameters

+ RecordFormatType *string

+ func (in *ReferenceSchemaRecordFormatParameters) DeepCopy() *ReferenceSchemaRecordFormatParameters

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

+ type RunConfigurationObservation struct

+ func (in *RunConfigurationObservation) DeepCopy() *RunConfigurationObservation

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

+ type RunConfigurationParameters struct

+ ApplicationRestoreConfiguration []ApplicationRestoreConfigurationParameters

+ FlinkRunConfiguration []FlinkRunConfigurationParameters

+ func (in *RunConfigurationParameters) DeepCopy() *RunConfigurationParameters

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

+ type S3ContentLocationObservation struct

+ func (in *S3ContentLocationObservation) DeepCopy() *S3ContentLocationObservation

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

+ type S3ContentLocationParameters struct

+ BucketArn *string

+ BucketArnRef *v1.Reference

+ BucketArnSelector *v1.Selector

+ FileKey *string

+ FileKeyRef *v1.Reference

+ FileKeySelector *v1.Selector

+ ObjectVersion *string

+ func (in *S3ContentLocationParameters) DeepCopy() *S3ContentLocationParameters

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

+ type S3ReferenceDataSourceObservation struct

+ func (in *S3ReferenceDataSourceObservation) DeepCopy() *S3ReferenceDataSourceObservation

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

+ type S3ReferenceDataSourceParameters struct

+ BucketArn *string

+ BucketArnRef *v1.Reference

+ BucketArnSelector *v1.Selector

+ FileKey *string

+ func (in *S3ReferenceDataSourceParameters) DeepCopy() *S3ReferenceDataSourceParameters

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

+ type SQLApplicationConfigurationObservation struct

+ Input []InputObservation

+ Output []OutputObservation

+ ReferenceDataSource []ReferenceDataSourceObservation

+ func (in *SQLApplicationConfigurationObservation) DeepCopy() *SQLApplicationConfigurationObservation

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

+ type SQLApplicationConfigurationParameters struct

+ Input []InputParameters

+ Output []OutputParameters

+ ReferenceDataSource []ReferenceDataSourceParameters

+ func (in *SQLApplicationConfigurationParameters) DeepCopy() *SQLApplicationConfigurationParameters

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

+ type VPCConfigurationObservation struct

+ VPCConfigurationID *string

+ VPCID *string

+ func (in *VPCConfigurationObservation) DeepCopy() *VPCConfigurationObservation

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

+ type VPCConfigurationParameters struct

+ SecurityGroupIds []*string

+ SubnetIds []*string

+ func (in *VPCConfigurationParameters) DeepCopy() *VPCConfigurationParameters

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