v1beta1

package
v0.31.16 Latest Latest
Warning

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

 Go to latest Published: Jun 12, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Overview

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

Index

Constants

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

Package type metadata.

Variables

View Source 
var (
	Application_Kind             = "Application"
	Application_GroupKind        = schema.GroupKind{Group: CRDGroup, Kind: Application_Kind}.String()
	Application_KindAPIVersion   = Application_Kind + "." + CRDGroupVersion.String()
	Application_GroupVersionKind = CRDGroupVersion.WithKind(Application_Kind)
)

Repository type metadata.

View Source 
var (
	// 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. Provides a AWS Kinesis Analytics Application +kubebuilder:printcolumn:name="READY",type="string",JSONPath=".status.conditions[?(@.type=='Ready')].status" +kubebuilder:printcolumn:name="SYNCED",type="string",JSONPath=".status.conditions[?(@.type=='Synced')].status" +kubebuilder:printcolumn:name="EXTERNAL-NAME",type="string",JSONPath=".metadata.annotations.crossplane\\.io/external-name" +kubebuilder:printcolumn:name="AGE",type="date",JSONPath=".metadata.creationTimestamp" +kubebuilder:subresource:status +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}

func (*Application) DeepCopy 

func (in *Application) DeepCopy() *Application

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

func (*Application) DeepCopyInto 

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

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

func (*Application) DeepCopyObject 

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

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

func (*Application) GetCondition 

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

GetCondition of this Application.

func (*Application) GetConnectionDetailsMapping 

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

GetConnectionDetailsMapping for this Application

func (*Application) GetDeletionPolicy 

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

GetDeletionPolicy of this Application.

func (*Application) GetID 

func (tr *Application) GetID() string

GetID returns ID of underlying Terraform resource of this Application

func (*Application) GetObservation 

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

GetObservation of this Application

func (*Application) GetParameters 

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

GetParameters of this Application

func (*Application) GetProviderConfigReference 

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

GetProviderConfigReference of this Application.

func (*Application) GetProviderReference 

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

GetProviderReference of this Application. Deprecated: Use GetProviderConfigReference.

func (*Application) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this Application.

func (*Application) GetTerraformResourceType 

func (mg *Application) GetTerraformResourceType() string

GetTerraformResourceType returns Terraform resource type for this Application

func (*Application) GetTerraformSchemaVersion 

func (tr *Application) GetTerraformSchemaVersion() int

GetTerraformSchemaVersion returns the associated Terraform schema version

func (*Application) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this Application.

func (*Application) LateInitialize 

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

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

func (*Application) ResolveReferences 

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

ResolveReferences of this Application.

func (*Application) SetConditions 

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

SetConditions of this Application.

func (*Application) SetDeletionPolicy 

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

SetDeletionPolicy of this Application.

func (*Application) SetObservation 

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

SetObservation for this Application

func (*Application) SetParameters 

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

SetParameters for this Application

func (*Application) SetProviderConfigReference 

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

SetProviderConfigReference of this Application.

func (*Application) SetProviderReference 

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

SetProviderReference of this Application. Deprecated: Use SetProviderConfigReference.

func (*Application) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this Application.

func (*Application) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this Application.

type 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 ARN of the Kinesis Analytics Appliation.
	Arn *string `json:"arn,omitempty" tf:"arn,omitempty"`

	// The CloudWatch log stream options to monitor application errors.
	// See CloudWatch Logging Options below for more details.
	// +kubebuilder:validation:Optional
	CloudwatchLoggingOptions []CloudwatchLoggingOptionsObservation `json:"cloudwatchLoggingOptions,omitempty" tf:"cloudwatch_logging_options,omitempty"`

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

	// The ARN of the Kinesis Analytics Application.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// Input configuration of the application. See Inputs below for more details.
	// +kubebuilder:validation:Optional
	Inputs []InputsObservation `json:"inputs,omitempty" tf:"inputs,omitempty"`

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

	// Output destination configuration of the application. See Outputs below for more details.
	// +kubebuilder:validation:Optional
	Outputs []OutputsObservation `json:"outputs,omitempty" tf:"outputs,omitempty"`

	// An S3 Reference Data Source for the application.
	// See Reference Data Sources below for more details.
	// +kubebuilder:validation:Optional
	ReferenceDataSources []ReferenceDataSourcesObservation `json:"referenceDataSources,omitempty" tf:"reference_data_sources,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 Version of the application.
	Version *float64 `json:"version,omitempty" tf:"version,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 CloudWatch log stream options to monitor application errors.
	// See CloudWatch Logging Options below for more details.
	// +kubebuilder:validation:Optional
	CloudwatchLoggingOptions []CloudwatchLoggingOptionsParameters `json:"cloudwatchLoggingOptions,omitempty" tf:"cloudwatch_logging_options,omitempty"`

	// SQL Code to transform input data, and generate output.
	// +kubebuilder:validation:Optional
	Code *string `json:"code,omitempty" tf:"code,omitempty"`

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

	// Input configuration of the application. See Inputs below for more details.
	// +kubebuilder:validation:Optional
	Inputs []InputsParameters `json:"inputs,omitempty" tf:"inputs,omitempty"`

	// Output destination configuration of the application. See Outputs below for more details.
	// +kubebuilder:validation:Optional
	Outputs []OutputsParameters `json:"outputs,omitempty" tf:"outputs,omitempty"`

	// An S3 Reference Data Source for the application.
	// See Reference Data Sources below for more details.
	// +kubebuilder:validation:Optional
	ReferenceDataSources []ReferenceDataSourcesParameters `json:"referenceDataSources,omitempty" tf:"reference_data_sources,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:"-"`

	// Whether to start or stop the Kinesis Analytics Application. To start an application, an input with a defined starting_position must be configured.
	// To modify an application's starting position, first stop the application by setting start_application = false, then update starting_position and set start_application = true.
	// +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 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 CloudwatchLoggingOptionsObservation 

type CloudwatchLoggingOptionsObservation struct {

	// The ARN of the Kinesis Analytics Application.
	ID *string `json:"id,omitempty" tf:"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.
	// +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:"-"`

	// The ARN of the IAM Role used to send application messages.
	// +crossplane:generate:reference:type=github.com/dkb-bank/official-provider-aws/apis/iam/v1beta1.Role
	// +crossplane:generate:reference:extractor=github.com/upbound/upjet/pkg/resource.ExtractParamPath("arn",true)
	// +kubebuilder:validation:Optional
	RoleArn *string `json:"roleArn,omitempty" tf:"role_arn,omitempty"`

	// Reference to a Role in iam to populate roleArn.
	// +kubebuilder:validation:Optional
	RoleArnRef *v1.Reference `json:"roleArnRef,omitempty" tf:"-"`

	// Selector for a Role in iam to populate roleArn.
	// +kubebuilder:validation:Optional
	RoleArnSelector *v1.Selector `json:"roleArnSelector,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 CsvObservation 

type CsvObservation struct {
}

func (*CsvObservation) DeepCopy 

func (in *CsvObservation) DeepCopy() *CsvObservation

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

func (*CsvObservation) DeepCopyInto 

func (in *CsvObservation) DeepCopyInto(out *CsvObservation)

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

type CsvParameters 

type CsvParameters struct {

	// The Column Delimiter.
	// +kubebuilder:validation:Required
	RecordColumnDelimiter *string `json:"recordColumnDelimiter" tf:"record_column_delimiter,omitempty"`

	// The Row Delimiter.
	// +kubebuilder:validation:Required
	RecordRowDelimiter *string `json:"recordRowDelimiter" tf:"record_row_delimiter,omitempty"`
}

func (*CsvParameters) DeepCopy 

func (in *CsvParameters) DeepCopy() *CsvParameters

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

func (*CsvParameters) DeepCopyInto 

func (in *CsvParameters) DeepCopyInto(out *CsvParameters)

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

type InputsObservation 

type InputsObservation struct {

	// The ARN of the Kinesis Analytics Application.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The Schema format of the data in the streaming source. See Source Schema below for more details.
	// +kubebuilder:validation:Required
	Schema []SchemaObservation `json:"schema,omitempty" tf:"schema,omitempty"`

	StreamNames []*string `json:"streamNames,omitempty" tf:"stream_names,omitempty"`
}

func (*InputsObservation) DeepCopy 

func (in *InputsObservation) DeepCopy() *InputsObservation

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

func (*InputsObservation) DeepCopyInto 

func (in *InputsObservation) DeepCopyInto(out *InputsObservation)

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

type InputsParameters 

type InputsParameters struct {

	// The Kinesis Firehose configuration for the streaming source. Conflicts with kinesis_stream.
	// See Kinesis Firehose below for more details.
	// +kubebuilder:validation:Optional
	KinesisFirehose []KinesisFirehoseParameters `json:"kinesisFirehose,omitempty" tf:"kinesis_firehose,omitempty"`

	// The Kinesis Stream configuration for the streaming source. Conflicts with kinesis_firehose.
	// See Kinesis Stream below for more details.
	// +kubebuilder:validation:Optional
	KinesisStream []KinesisStreamParameters `json:"kinesisStream,omitempty" tf:"kinesis_stream,omitempty"`

	// The Name Prefix to use when creating an in-application stream.
	// +kubebuilder:validation:Required
	NamePrefix *string `json:"namePrefix" tf:"name_prefix,omitempty"`

	// The number of Parallel in-application streams to create.
	// See Parallelism below for more details.
	// +kubebuilder:validation:Optional
	Parallelism []ParallelismParameters `json:"parallelism,omitempty" tf:"parallelism,omitempty"`

	// The Processing Configuration to transform records as they are received from the stream.
	// See Processing Configuration below for more details.
	// +kubebuilder:validation:Optional
	ProcessingConfiguration []ProcessingConfigurationParameters `json:"processingConfiguration,omitempty" tf:"processing_configuration,omitempty"`

	// The Schema format of the data in the streaming source. See Source Schema below for more details.
	// +kubebuilder:validation:Required
	Schema []SchemaParameters `json:"schema" tf:"schema,omitempty"`

	// The point at which the application starts processing records from the streaming source.
	// See Starting Position Configuration below for more details.
	// +kubebuilder:validation:Optional
	StartingPositionConfiguration []StartingPositionConfigurationParameters `json:"startingPositionConfiguration,omitempty" tf:"starting_position_configuration,omitempty"`
}

func (*InputsParameters) DeepCopy 

func (in *InputsParameters) DeepCopy() *InputsParameters

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

func (*InputsParameters) DeepCopyInto 

func (in *InputsParameters) DeepCopyInto(out *InputsParameters)

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

type JSONObservation 

type JSONObservation struct {
}

func (*JSONObservation) DeepCopy 

func (in *JSONObservation) DeepCopy() *JSONObservation

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

func (*JSONObservation) DeepCopyInto 

func (in *JSONObservation) DeepCopyInto(out *JSONObservation)

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

type JSONParameters 

type JSONParameters struct {

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

func (*JSONParameters) DeepCopy 

func (in *JSONParameters) DeepCopy() *JSONParameters

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

func (*JSONParameters) DeepCopyInto 

func (in *JSONParameters) DeepCopyInto(out *JSONParameters)

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

type KinesisFirehoseObservation 

type KinesisFirehoseObservation struct {
}

func (*KinesisFirehoseObservation) DeepCopy 

func (in *KinesisFirehoseObservation) DeepCopy() *KinesisFirehoseObservation

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

func (*KinesisFirehoseObservation) DeepCopyInto 

func (in *KinesisFirehoseObservation) DeepCopyInto(out *KinesisFirehoseObservation)

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

type KinesisFirehoseParameters 

type KinesisFirehoseParameters struct {

	// The ARN of the Lambda function.
	// +kubebuilder:validation:Required
	ResourceArn *string `json:"resourceArn" tf:"resource_arn,omitempty"`

	// The IAM Role ARN to read the data.
	// +kubebuilder:validation:Required
	RoleArn *string `json:"roleArn" tf:"role_arn,omitempty"`
}

func (*KinesisFirehoseParameters) DeepCopy 

func (in *KinesisFirehoseParameters) DeepCopy() *KinesisFirehoseParameters

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

func (*KinesisFirehoseParameters) DeepCopyInto 

func (in *KinesisFirehoseParameters) DeepCopyInto(out *KinesisFirehoseParameters)

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

type KinesisStreamObservation 

type KinesisStreamObservation struct {
}

func (*KinesisStreamObservation) DeepCopy 

func (in *KinesisStreamObservation) DeepCopy() *KinesisStreamObservation

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

func (*KinesisStreamObservation) DeepCopyInto 

func (in *KinesisStreamObservation) DeepCopyInto(out *KinesisStreamObservation)

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

type KinesisStreamParameters 

type KinesisStreamParameters struct {

	// The ARN of the Lambda function.
	// +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:"-"`

	// The IAM Role ARN to read the data.
	// +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
	RoleArn *string `json:"roleArn,omitempty" tf:"role_arn,omitempty"`

	// Reference to a Role in iam to populate roleArn.
	// +kubebuilder:validation:Optional
	RoleArnRef *v1.Reference `json:"roleArnRef,omitempty" tf:"-"`

	// Selector for a Role in iam to populate roleArn.
	// +kubebuilder:validation:Optional
	RoleArnSelector *v1.Selector `json:"roleArnSelector,omitempty" tf:"-"`
}

func (*KinesisStreamParameters) DeepCopy 

func (in *KinesisStreamParameters) DeepCopy() *KinesisStreamParameters

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

func (*KinesisStreamParameters) DeepCopyInto 

func (in *KinesisStreamParameters) DeepCopyInto(out *KinesisStreamParameters)

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

type LambdaObservation 

type LambdaObservation struct {
}

func (*LambdaObservation) DeepCopy 

func (in *LambdaObservation) DeepCopy() *LambdaObservation

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

func (*LambdaObservation) DeepCopyInto 

func (in *LambdaObservation) DeepCopyInto(out *LambdaObservation)

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

type LambdaParameters 

type LambdaParameters struct {

	// The ARN of the Lambda function.
	// +kubebuilder:validation:Required
	ResourceArn *string `json:"resourceArn" tf:"resource_arn,omitempty"`

	// The IAM Role ARN to read the data.
	// +kubebuilder:validation:Required
	RoleArn *string `json:"roleArn" tf:"role_arn,omitempty"`
}

func (*LambdaParameters) DeepCopy 

func (in *LambdaParameters) DeepCopy() *LambdaParameters

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

func (*LambdaParameters) DeepCopyInto 

func (in *LambdaParameters) DeepCopyInto(out *LambdaParameters)

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

type MappingParametersCsvObservation 

type MappingParametersCsvObservation struct {
}

func (*MappingParametersCsvObservation) DeepCopy 

func (in *MappingParametersCsvObservation) DeepCopy() *MappingParametersCsvObservation

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

func (*MappingParametersCsvObservation) DeepCopyInto 

func (in *MappingParametersCsvObservation) DeepCopyInto(out *MappingParametersCsvObservation)

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

type MappingParametersCsvParameters 

type MappingParametersCsvParameters struct {

	// The Column Delimiter.
	// +kubebuilder:validation:Required
	RecordColumnDelimiter *string `json:"recordColumnDelimiter" tf:"record_column_delimiter,omitempty"`

	// The Row Delimiter.
	// +kubebuilder:validation:Required
	RecordRowDelimiter *string `json:"recordRowDelimiter" tf:"record_row_delimiter,omitempty"`
}

func (*MappingParametersCsvParameters) DeepCopy 

func (in *MappingParametersCsvParameters) DeepCopy() *MappingParametersCsvParameters

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

func (*MappingParametersCsvParameters) DeepCopyInto 

func (in *MappingParametersCsvParameters) DeepCopyInto(out *MappingParametersCsvParameters)

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

type MappingParametersJSONObservation 

type MappingParametersJSONObservation struct {
}

func (*MappingParametersJSONObservation) DeepCopy 

func (in *MappingParametersJSONObservation) DeepCopy() *MappingParametersJSONObservation

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

func (*MappingParametersJSONObservation) DeepCopyInto 

func (in *MappingParametersJSONObservation) DeepCopyInto(out *MappingParametersJSONObservation)

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

type MappingParametersJSONParameters 

type MappingParametersJSONParameters struct {

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

func (*MappingParametersJSONParameters) DeepCopy 

func (in *MappingParametersJSONParameters) DeepCopy() *MappingParametersJSONParameters

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

func (*MappingParametersJSONParameters) DeepCopyInto 

func (in *MappingParametersJSONParameters) DeepCopyInto(out *MappingParametersJSONParameters)

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 {

	// Mapping information when the record format uses delimiters.
	// See CSV Mapping Parameters below for more details.
	// +kubebuilder:validation:Optional
	Csv []CsvParameters `json:"csv,omitempty" tf:"csv,omitempty"`

	// Mapping information when JSON is the record format on the streaming source.
	// See JSON Mapping Parameters below for more details.
	// +kubebuilder:validation:Optional
	JSON []JSONParameters `json:"json,omitempty" tf:"json,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 OutputsKinesisFirehoseObservation 

type OutputsKinesisFirehoseObservation struct {
}

func (*OutputsKinesisFirehoseObservation) DeepCopy 

func (in *OutputsKinesisFirehoseObservation) DeepCopy() *OutputsKinesisFirehoseObservation

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

func (*OutputsKinesisFirehoseObservation) DeepCopyInto 

func (in *OutputsKinesisFirehoseObservation) DeepCopyInto(out *OutputsKinesisFirehoseObservation)

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

type OutputsKinesisFirehoseParameters 

type OutputsKinesisFirehoseParameters struct {

	// The ARN of the Lambda function.
	// +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:"-"`

	// The IAM Role ARN to read the data.
	// +crossplane:generate:reference:type=github.com/dkb-bank/official-provider-aws/apis/iam/v1beta1.Role
	// +crossplane:generate:reference:extractor=github.com/upbound/upjet/pkg/resource.ExtractParamPath("arn",true)
	// +kubebuilder:validation:Optional
	RoleArn *string `json:"roleArn,omitempty" tf:"role_arn,omitempty"`

	// Reference to a Role in iam to populate roleArn.
	// +kubebuilder:validation:Optional
	RoleArnRef *v1.Reference `json:"roleArnRef,omitempty" tf:"-"`

	// Selector for a Role in iam to populate roleArn.
	// +kubebuilder:validation:Optional
	RoleArnSelector *v1.Selector `json:"roleArnSelector,omitempty" tf:"-"`
}

func (*OutputsKinesisFirehoseParameters) DeepCopy 

func (in *OutputsKinesisFirehoseParameters) DeepCopy() *OutputsKinesisFirehoseParameters

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

func (*OutputsKinesisFirehoseParameters) DeepCopyInto 

func (in *OutputsKinesisFirehoseParameters) DeepCopyInto(out *OutputsKinesisFirehoseParameters)

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

type OutputsKinesisStreamObservation 

type OutputsKinesisStreamObservation struct {
}

func (*OutputsKinesisStreamObservation) DeepCopy 

func (in *OutputsKinesisStreamObservation) DeepCopy() *OutputsKinesisStreamObservation

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

func (*OutputsKinesisStreamObservation) DeepCopyInto 

func (in *OutputsKinesisStreamObservation) DeepCopyInto(out *OutputsKinesisStreamObservation)

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

type OutputsKinesisStreamParameters 

type OutputsKinesisStreamParameters struct {

	// The ARN of the Lambda function.
	// +kubebuilder:validation:Required
	ResourceArn *string `json:"resourceArn" tf:"resource_arn,omitempty"`

	// The IAM Role ARN to read the data.
	// +kubebuilder:validation:Required
	RoleArn *string `json:"roleArn" tf:"role_arn,omitempty"`
}

func (*OutputsKinesisStreamParameters) DeepCopy 

func (in *OutputsKinesisStreamParameters) DeepCopy() *OutputsKinesisStreamParameters

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

func (*OutputsKinesisStreamParameters) DeepCopyInto 

func (in *OutputsKinesisStreamParameters) DeepCopyInto(out *OutputsKinesisStreamParameters)

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

type OutputsLambdaObservation 

type OutputsLambdaObservation struct {
}

func (*OutputsLambdaObservation) DeepCopy 

func (in *OutputsLambdaObservation) DeepCopy() *OutputsLambdaObservation

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

func (*OutputsLambdaObservation) DeepCopyInto 

func (in *OutputsLambdaObservation) DeepCopyInto(out *OutputsLambdaObservation)

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

type OutputsLambdaParameters 

type OutputsLambdaParameters struct {

	// The ARN of the Lambda function.
	// +kubebuilder:validation:Required
	ResourceArn *string `json:"resourceArn" tf:"resource_arn,omitempty"`

	// The IAM Role ARN to read the data.
	// +kubebuilder:validation:Required
	RoleArn *string `json:"roleArn" tf:"role_arn,omitempty"`
}

func (*OutputsLambdaParameters) DeepCopy 

func (in *OutputsLambdaParameters) DeepCopy() *OutputsLambdaParameters

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

func (*OutputsLambdaParameters) DeepCopyInto 

func (in *OutputsLambdaParameters) DeepCopyInto(out *OutputsLambdaParameters)

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

type OutputsObservation 

type OutputsObservation struct {

	// The ARN of the Kinesis Analytics Application.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`
}

func (*OutputsObservation) DeepCopy 

func (in *OutputsObservation) DeepCopy() *OutputsObservation

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

func (*OutputsObservation) DeepCopyInto 

func (in *OutputsObservation) DeepCopyInto(out *OutputsObservation)

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

type OutputsParameters 

type OutputsParameters struct {

	// The Kinesis Firehose configuration for the destination stream. Conflicts with kinesis_stream.
	// See Kinesis Firehose below for more details.
	// +kubebuilder:validation:Optional
	KinesisFirehose []OutputsKinesisFirehoseParameters `json:"kinesisFirehose,omitempty" tf:"kinesis_firehose,omitempty"`

	// The Kinesis Stream configuration for the destination stream. Conflicts with kinesis_firehose.
	// See Kinesis Stream below for more details.
	// +kubebuilder:validation:Optional
	KinesisStream []OutputsKinesisStreamParameters `json:"kinesisStream,omitempty" tf:"kinesis_stream,omitempty"`

	// The Lambda function destination. See Lambda below for more details.
	// +kubebuilder:validation:Optional
	Lambda []OutputsLambdaParameters `json:"lambda,omitempty" tf:"lambda,omitempty"`

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

	// The Schema format of the data written to the destination. See Destination Schema below for more details.
	// +kubebuilder:validation:Required
	Schema []OutputsSchemaParameters `json:"schema" tf:"schema,omitempty"`
}

func (*OutputsParameters) DeepCopy 

func (in *OutputsParameters) DeepCopy() *OutputsParameters

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

func (*OutputsParameters) DeepCopyInto 

func (in *OutputsParameters) DeepCopyInto(out *OutputsParameters)

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

type OutputsSchemaObservation 

type OutputsSchemaObservation struct {
}

func (*OutputsSchemaObservation) DeepCopy 

func (in *OutputsSchemaObservation) DeepCopy() *OutputsSchemaObservation

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

func (*OutputsSchemaObservation) DeepCopyInto 

func (in *OutputsSchemaObservation) DeepCopyInto(out *OutputsSchemaObservation)

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

type OutputsSchemaParameters 

type OutputsSchemaParameters struct {

	// The Format Type of the records on the output stream. Can be CSV or JSON.
	// +kubebuilder:validation:Required
	RecordFormatType *string `json:"recordFormatType" tf:"record_format_type,omitempty"`
}

func (*OutputsSchemaParameters) DeepCopy 

func (in *OutputsSchemaParameters) DeepCopy() *OutputsSchemaParameters

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

func (*OutputsSchemaParameters) DeepCopyInto 

func (in *OutputsSchemaParameters) DeepCopyInto(out *OutputsSchemaParameters)

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

type ParallelismObservation 

type ParallelismObservation struct {
}

func (*ParallelismObservation) DeepCopy 

func (in *ParallelismObservation) DeepCopy() *ParallelismObservation

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

func (*ParallelismObservation) DeepCopyInto 

func (in *ParallelismObservation) DeepCopyInto(out *ParallelismObservation)

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

type ParallelismParameters 

type ParallelismParameters struct {

	// The Count of streams.
	// +kubebuilder:validation:Optional
	Count *float64 `json:"count,omitempty" tf:"count,omitempty"`
}

func (*ParallelismParameters) DeepCopy 

func (in *ParallelismParameters) DeepCopy() *ParallelismParameters

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

func (*ParallelismParameters) DeepCopyInto 

func (in *ParallelismParameters) DeepCopyInto(out *ParallelismParameters)

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

type ProcessingConfigurationObservation 

type ProcessingConfigurationObservation struct {
}

func (*ProcessingConfigurationObservation) DeepCopy 

func (in *ProcessingConfigurationObservation) DeepCopy() *ProcessingConfigurationObservation

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

func (*ProcessingConfigurationObservation) DeepCopyInto 

func (in *ProcessingConfigurationObservation) DeepCopyInto(out *ProcessingConfigurationObservation)

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

type ProcessingConfigurationParameters 

type ProcessingConfigurationParameters struct {

	// The Lambda function configuration. See Lambda below for more details.
	// +kubebuilder:validation:Required
	Lambda []LambdaParameters `json:"lambda" tf:"lambda,omitempty"`
}

func (*ProcessingConfigurationParameters) DeepCopy 

func (in *ProcessingConfigurationParameters) DeepCopy() *ProcessingConfigurationParameters

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

func (*ProcessingConfigurationParameters) DeepCopyInto 

func (in *ProcessingConfigurationParameters) DeepCopyInto(out *ProcessingConfigurationParameters)

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

type RecordColumnsObservation 

type RecordColumnsObservation struct {
}

func (*RecordColumnsObservation) DeepCopy 

func (in *RecordColumnsObservation) DeepCopy() *RecordColumnsObservation

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

func (*RecordColumnsObservation) DeepCopyInto 

func (in *RecordColumnsObservation) DeepCopyInto(out *RecordColumnsObservation)

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

type RecordColumnsParameters 

type RecordColumnsParameters struct {

	// The Mapping reference to the data element.
	// +kubebuilder:validation:Optional
	Mapping *string `json:"mapping,omitempty" tf:"mapping,omitempty"`

	// Name of the column.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// The SQL Type of the column.
	// +kubebuilder:validation:Required
	SQLType *string `json:"sqlType" tf:"sql_type,omitempty"`
}

func (*RecordColumnsParameters) DeepCopy 

func (in *RecordColumnsParameters) DeepCopy() *RecordColumnsParameters

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

func (*RecordColumnsParameters) DeepCopyInto 

func (in *RecordColumnsParameters) DeepCopyInto(out *RecordColumnsParameters)

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 {

	// Mapping information when the record format uses delimiters.
	// See CSV Mapping Parameters below for more details.
	// +kubebuilder:validation:Optional
	Csv []MappingParametersCsvParameters `json:"csv,omitempty" tf:"csv,omitempty"`

	// Mapping information when JSON is the record format on the streaming source.
	// See JSON Mapping Parameters below for more details.
	// +kubebuilder:validation:Optional
	JSON []MappingParametersJSONParameters `json:"json,omitempty" tf:"json,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 {

	// The Format Type of the records on the output stream. Can be CSV or JSON.
	RecordFormatType *string `json:"recordFormatType,omitempty" tf:"record_format_type,omitempty"`
}

func (*RecordFormatObservation) DeepCopy 

func (in *RecordFormatObservation) DeepCopy() *RecordFormatObservation

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

func (*RecordFormatObservation) DeepCopyInto 

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

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

type RecordFormatParameters 

type RecordFormatParameters struct {

	// The Mapping Information for the record format.
	// See Mapping Parameters below for more details.
	// +kubebuilder:validation:Optional
	MappingParameters []MappingParametersParameters `json:"mappingParameters,omitempty" tf:"mapping_parameters,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 ReferenceDataSourcesObservation 

type ReferenceDataSourcesObservation struct {

	// The ARN of the Kinesis Analytics Application.
	ID *string `json:"id,omitempty" tf:"id,omitempty"`

	// The Schema format of the data in the streaming source. See Source Schema below for more details.
	// +kubebuilder:validation:Required
	Schema []ReferenceDataSourcesSchemaObservation `json:"schema,omitempty" tf:"schema,omitempty"`
}

func (*ReferenceDataSourcesObservation) DeepCopy 

func (in *ReferenceDataSourcesObservation) DeepCopy() *ReferenceDataSourcesObservation

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

func (*ReferenceDataSourcesObservation) DeepCopyInto 

func (in *ReferenceDataSourcesObservation) DeepCopyInto(out *ReferenceDataSourcesObservation)

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

type ReferenceDataSourcesParameters 

type ReferenceDataSourcesParameters struct {

	// The S3 configuration for the reference data source. See S3 Reference below for more details.
	// +kubebuilder:validation:Required
	S3 []S3Parameters `json:"s3" tf:"s3,omitempty"`

	// The Schema format of the data in the streaming source. See Source Schema below for more details.
	// +kubebuilder:validation:Required
	Schema []ReferenceDataSourcesSchemaParameters `json:"schema" tf:"schema,omitempty"`

	// The in-application Table Name.
	// +kubebuilder:validation:Required
	TableName *string `json:"tableName" tf:"table_name,omitempty"`
}

func (*ReferenceDataSourcesParameters) DeepCopy 

func (in *ReferenceDataSourcesParameters) DeepCopy() *ReferenceDataSourcesParameters

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

func (*ReferenceDataSourcesParameters) DeepCopyInto 

func (in *ReferenceDataSourcesParameters) DeepCopyInto(out *ReferenceDataSourcesParameters)

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

type ReferenceDataSourcesSchemaObservation 

type ReferenceDataSourcesSchemaObservation struct {

	// The Record Format and mapping information to schematize a record.
	// See Record Format below for more details.
	// +kubebuilder:validation:Required
	RecordFormat []SchemaRecordFormatObservation `json:"recordFormat,omitempty" tf:"record_format,omitempty"`
}

func (*ReferenceDataSourcesSchemaObservation) DeepCopy 

func (in *ReferenceDataSourcesSchemaObservation) DeepCopy() *ReferenceDataSourcesSchemaObservation

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

func (*ReferenceDataSourcesSchemaObservation) DeepCopyInto 

func (in *ReferenceDataSourcesSchemaObservation) DeepCopyInto(out *ReferenceDataSourcesSchemaObservation)

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

type ReferenceDataSourcesSchemaParameters 

type ReferenceDataSourcesSchemaParameters struct {

	// The Record Column mapping for the streaming source data element.
	// See Record Columns below for more details.
	// +kubebuilder:validation:Required
	RecordColumns []SchemaRecordColumnsParameters `json:"recordColumns" tf:"record_columns,omitempty"`

	// The Encoding of the record in the streaming source.
	// +kubebuilder:validation:Optional
	RecordEncoding *string `json:"recordEncoding,omitempty" tf:"record_encoding,omitempty"`

	// The Record Format and mapping information to schematize a record.
	// See Record Format below for more details.
	// +kubebuilder:validation:Required
	RecordFormat []SchemaRecordFormatParameters `json:"recordFormat" tf:"record_format,omitempty"`
}

func (*ReferenceDataSourcesSchemaParameters) DeepCopy 

func (in *ReferenceDataSourcesSchemaParameters) DeepCopy() *ReferenceDataSourcesSchemaParameters

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

func (*ReferenceDataSourcesSchemaParameters) DeepCopyInto 

func (in *ReferenceDataSourcesSchemaParameters) DeepCopyInto(out *ReferenceDataSourcesSchemaParameters)

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

type S3Observation 

type S3Observation struct {
}

func (*S3Observation) DeepCopy 

func (in *S3Observation) DeepCopy() *S3Observation

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

func (*S3Observation) DeepCopyInto 

func (in *S3Observation) DeepCopyInto(out *S3Observation)

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

type S3Parameters 

type S3Parameters struct {

	// The S3 Bucket ARN.
	// +kubebuilder:validation:Required
	BucketArn *string `json:"bucketArn" tf:"bucket_arn,omitempty"`

	// The File Key name containing reference data.
	// +kubebuilder:validation:Required
	FileKey *string `json:"fileKey" tf:"file_key,omitempty"`

	// The IAM Role ARN to read the data.
	// +kubebuilder:validation:Required
	RoleArn *string `json:"roleArn" tf:"role_arn,omitempty"`
}

func (*S3Parameters) DeepCopy 

func (in *S3Parameters) DeepCopy() *S3Parameters

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

func (*S3Parameters) DeepCopyInto 

func (in *S3Parameters) DeepCopyInto(out *S3Parameters)

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

type SchemaObservation 

type SchemaObservation struct {

	// The Record Format and mapping information to schematize a record.
	// See Record Format below for more details.
	// +kubebuilder:validation:Required
	RecordFormat []RecordFormatObservation `json:"recordFormat,omitempty" tf:"record_format,omitempty"`
}

func (*SchemaObservation) DeepCopy 

func (in *SchemaObservation) DeepCopy() *SchemaObservation

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

func (*SchemaObservation) DeepCopyInto 

func (in *SchemaObservation) DeepCopyInto(out *SchemaObservation)

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

type SchemaParameters 

type SchemaParameters struct {

	// The Record Column mapping for the streaming source data element.
	// See Record Columns below for more details.
	// +kubebuilder:validation:Required
	RecordColumns []RecordColumnsParameters `json:"recordColumns" tf:"record_columns,omitempty"`

	// The Encoding of the record in the streaming source.
	// +kubebuilder:validation:Optional
	RecordEncoding *string `json:"recordEncoding,omitempty" tf:"record_encoding,omitempty"`

	// The Record Format and mapping information to schematize a record.
	// See Record Format below for more details.
	// +kubebuilder:validation:Required
	RecordFormat []RecordFormatParameters `json:"recordFormat" tf:"record_format,omitempty"`
}

func (*SchemaParameters) DeepCopy 

func (in *SchemaParameters) DeepCopy() *SchemaParameters

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

func (*SchemaParameters) DeepCopyInto 

func (in *SchemaParameters) DeepCopyInto(out *SchemaParameters)

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

type SchemaRecordColumnsObservation 

type SchemaRecordColumnsObservation struct {
}

func (*SchemaRecordColumnsObservation) DeepCopy 

func (in *SchemaRecordColumnsObservation) DeepCopy() *SchemaRecordColumnsObservation

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

func (*SchemaRecordColumnsObservation) DeepCopyInto 

func (in *SchemaRecordColumnsObservation) DeepCopyInto(out *SchemaRecordColumnsObservation)

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

type SchemaRecordColumnsParameters 

type SchemaRecordColumnsParameters struct {

	// The Mapping reference to the data element.
	// +kubebuilder:validation:Optional
	Mapping *string `json:"mapping,omitempty" tf:"mapping,omitempty"`

	// Name of the column.
	// +kubebuilder:validation:Required
	Name *string `json:"name" tf:"name,omitempty"`

	// The SQL Type of the column.
	// +kubebuilder:validation:Required
	SQLType *string `json:"sqlType" tf:"sql_type,omitempty"`
}

func (*SchemaRecordColumnsParameters) DeepCopy 

func (in *SchemaRecordColumnsParameters) DeepCopy() *SchemaRecordColumnsParameters

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

func (*SchemaRecordColumnsParameters) DeepCopyInto 

func (in *SchemaRecordColumnsParameters) DeepCopyInto(out *SchemaRecordColumnsParameters)

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

type SchemaRecordFormatObservation 

type SchemaRecordFormatObservation struct {

	// The Format Type of the records on the output stream. Can be CSV or JSON.
	RecordFormatType *string `json:"recordFormatType,omitempty" tf:"record_format_type,omitempty"`
}

func (*SchemaRecordFormatObservation) DeepCopy 

func (in *SchemaRecordFormatObservation) DeepCopy() *SchemaRecordFormatObservation

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

func (*SchemaRecordFormatObservation) DeepCopyInto 

func (in *SchemaRecordFormatObservation) DeepCopyInto(out *SchemaRecordFormatObservation)

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

type SchemaRecordFormatParameters 

type SchemaRecordFormatParameters struct {

	// The Mapping Information for the record format.
	// See Mapping Parameters below for more details.
	// +kubebuilder:validation:Optional
	MappingParameters []RecordFormatMappingParametersParameters `json:"mappingParameters,omitempty" tf:"mapping_parameters,omitempty"`
}

func (*SchemaRecordFormatParameters) DeepCopy 

func (in *SchemaRecordFormatParameters) DeepCopy() *SchemaRecordFormatParameters

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

func (*SchemaRecordFormatParameters) DeepCopyInto 

func (in *SchemaRecordFormatParameters) DeepCopyInto(out *SchemaRecordFormatParameters)

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

type StartingPositionConfigurationObservation 

type StartingPositionConfigurationObservation struct {
}

func (*StartingPositionConfigurationObservation) DeepCopy 

func (in *StartingPositionConfigurationObservation) DeepCopy() *StartingPositionConfigurationObservation

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

func (*StartingPositionConfigurationObservation) DeepCopyInto 

func (in *StartingPositionConfigurationObservation) DeepCopyInto(out *StartingPositionConfigurationObservation)

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

type StartingPositionConfigurationParameters 

type StartingPositionConfigurationParameters struct {

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

func (*StartingPositionConfigurationParameters) DeepCopy 

func (in *StartingPositionConfigurationParameters) DeepCopy() *StartingPositionConfigurationParameters

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

func (*StartingPositionConfigurationParameters) DeepCopyInto 

func (in *StartingPositionConfigurationParameters) DeepCopyInto(out *StartingPositionConfigurationParameters)

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.