v1alpha1

package
v0.47.2 Latest Latest
Warning

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

 Go to latest Published: Apr 15, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	CRDGroup   = "firehose.aws.crossplane.io"
	CRDVersion = "v1alpha1"
)

Package type metadata.

Variables

View Source 
var (
	DeliveryStreamKind             = "DeliveryStream"
	DeliveryStreamGroupKind        = schema.GroupKind{Group: CRDGroup, Kind: DeliveryStreamKind}.String()
	DeliveryStreamKindAPIVersion   = DeliveryStreamKind + "." + GroupVersion.String()
	DeliveryStreamGroupVersionKind = GroupVersion.WithKind(DeliveryStreamKind)
)

Repository type metadata.

View Source 
var (
	// GroupVersion is the API Group Version used to register the objects
	GroupVersion = schema.GroupVersion{Group: CRDGroup, Version: CRDVersion}

	// SchemeBuilder is used to add go types to the GroupVersionKind scheme
	SchemeBuilder = &scheme.Builder{GroupVersion: GroupVersion}

	// AddToScheme adds the types in this group-version to the given scheme.
	AddToScheme = SchemeBuilder.AddToScheme
)

Functions

This section is empty.

Types

type AmazonOpenSearchServerlessBufferingHints 

type AmazonOpenSearchServerlessBufferingHints struct {
	IntervalInSeconds *int64 `json:"intervalInSeconds,omitempty"`

	SizeInMBs *int64 `json:"sizeInMBs,omitempty"`
}

+kubebuilder:skipversion

func (*AmazonOpenSearchServerlessBufferingHints) DeepCopy 

func (in *AmazonOpenSearchServerlessBufferingHints) DeepCopy() *AmazonOpenSearchServerlessBufferingHints

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

func (*AmazonOpenSearchServerlessBufferingHints) DeepCopyInto 

func (in *AmazonOpenSearchServerlessBufferingHints) DeepCopyInto(out *AmazonOpenSearchServerlessBufferingHints)

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

type AmazonOpenSearchServerlessDestinationConfiguration 

type AmazonOpenSearchServerlessDestinationConfiguration struct {
	// Describes the buffering to perform before delivering data to the Serverless
	// offering for Amazon OpenSearch Service destination.
	BufferingHints *AmazonOpenSearchServerlessBufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	CollectionEndpoint *string `json:"collectionEndpoint,omitempty"`

	IndexName *string `json:"indexName,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to the Serverless offering for Amazon OpenSearch Service.
	RetryOptions *AmazonOpenSearchServerlessRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
	// Describes the configuration of a destination in Amazon S3.
	S3Configuration *S3DestinationConfiguration `json:"s3Configuration,omitempty"`
	// The details of the VPC of the Amazon ES destination.
	VPCConfiguration *VPCConfiguration `json:"vpcConfiguration,omitempty"`
}

+kubebuilder:skipversion

func (*AmazonOpenSearchServerlessDestinationConfiguration) DeepCopy 

func (in *AmazonOpenSearchServerlessDestinationConfiguration) DeepCopy() *AmazonOpenSearchServerlessDestinationConfiguration

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

func (*AmazonOpenSearchServerlessDestinationConfiguration) DeepCopyInto 

func (in *AmazonOpenSearchServerlessDestinationConfiguration) DeepCopyInto(out *AmazonOpenSearchServerlessDestinationConfiguration)

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

type AmazonOpenSearchServerlessDestinationDescription 

type AmazonOpenSearchServerlessDestinationDescription struct {
	// Describes the buffering to perform before delivering data to the Serverless
	// offering for Amazon OpenSearch Service destination.
	BufferingHints *AmazonOpenSearchServerlessBufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	CollectionEndpoint *string `json:"collectionEndpoint,omitempty"`

	IndexName *string `json:"indexName,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to the Serverless offering for Amazon OpenSearch Service.
	RetryOptions *AmazonOpenSearchServerlessRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
	// Describes a destination in Amazon S3.
	S3DestinationDescription *S3DestinationDescription `json:"s3DestinationDescription,omitempty"`
	// The details of the VPC of the Amazon ES destination.
	VPCConfigurationDescription *VPCConfigurationDescription `json:"vpcConfigurationDescription,omitempty"`
}

+kubebuilder:skipversion

func (*AmazonOpenSearchServerlessDestinationDescription) DeepCopy 

func (in *AmazonOpenSearchServerlessDestinationDescription) DeepCopy() *AmazonOpenSearchServerlessDestinationDescription

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

func (*AmazonOpenSearchServerlessDestinationDescription) DeepCopyInto 

func (in *AmazonOpenSearchServerlessDestinationDescription) DeepCopyInto(out *AmazonOpenSearchServerlessDestinationDescription)

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

type AmazonOpenSearchServerlessDestinationUpdate 

type AmazonOpenSearchServerlessDestinationUpdate struct {
	// Describes the buffering to perform before delivering data to the Serverless
	// offering for Amazon OpenSearch Service destination.
	BufferingHints *AmazonOpenSearchServerlessBufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	CollectionEndpoint *string `json:"collectionEndpoint,omitempty"`

	IndexName *string `json:"indexName,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to the Serverless offering for Amazon OpenSearch Service.
	RetryOptions *AmazonOpenSearchServerlessRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`
}

+kubebuilder:skipversion

func (*AmazonOpenSearchServerlessDestinationUpdate) DeepCopy 

func (in *AmazonOpenSearchServerlessDestinationUpdate) DeepCopy() *AmazonOpenSearchServerlessDestinationUpdate

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

func (*AmazonOpenSearchServerlessDestinationUpdate) DeepCopyInto 

func (in *AmazonOpenSearchServerlessDestinationUpdate) DeepCopyInto(out *AmazonOpenSearchServerlessDestinationUpdate)

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

type AmazonOpenSearchServerlessRetryOptions 

type AmazonOpenSearchServerlessRetryOptions struct {
	DurationInSeconds *int64 `json:"durationInSeconds,omitempty"`
}

+kubebuilder:skipversion

func (*AmazonOpenSearchServerlessRetryOptions) DeepCopy 

func (in *AmazonOpenSearchServerlessRetryOptions) DeepCopy() *AmazonOpenSearchServerlessRetryOptions

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

func (*AmazonOpenSearchServerlessRetryOptions) DeepCopyInto 

func (in *AmazonOpenSearchServerlessRetryOptions) DeepCopyInto(out *AmazonOpenSearchServerlessRetryOptions)

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

type AmazonOpenSearchServerlessS3BackupMode 

type AmazonOpenSearchServerlessS3BackupMode string
const (
	AmazonOpenSearchServerlessS3BackupMode_FailedDocumentsOnly AmazonOpenSearchServerlessS3BackupMode = "FailedDocumentsOnly"
	AmazonOpenSearchServerlessS3BackupMode_AllDocuments        AmazonOpenSearchServerlessS3BackupMode = "AllDocuments"
)

type AmazonopensearchserviceBufferingHints 

type AmazonopensearchserviceBufferingHints struct {
	IntervalInSeconds *int64 `json:"intervalInSeconds,omitempty"`

	SizeInMBs *int64 `json:"sizeInMBs,omitempty"`
}

+kubebuilder:skipversion

func (*AmazonopensearchserviceBufferingHints) DeepCopy 

func (in *AmazonopensearchserviceBufferingHints) DeepCopy() *AmazonopensearchserviceBufferingHints

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

func (*AmazonopensearchserviceBufferingHints) DeepCopyInto 

func (in *AmazonopensearchserviceBufferingHints) DeepCopyInto(out *AmazonopensearchserviceBufferingHints)

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

type AmazonopensearchserviceDestinationConfiguration 

type AmazonopensearchserviceDestinationConfiguration struct {
	// Describes the buffering to perform before delivering data to the Amazon OpenSearch
	// Service destination.
	BufferingHints *AmazonopensearchserviceBufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	ClusterEndpoint *string `json:"clusterEndpoint,omitempty"`

	DomainARN *string `json:"domainARN,omitempty"`

	IndexName *string `json:"indexName,omitempty"`

	IndexRotationPeriod *string `json:"indexRotationPeriod,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to Amazon OpenSearch Service.
	RetryOptions *AmazonopensearchserviceRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
	// Describes the configuration of a destination in Amazon S3.
	S3Configuration *S3DestinationConfiguration `json:"s3Configuration,omitempty"`

	TypeName *string `json:"typeName,omitempty"`
	// The details of the VPC of the Amazon ES destination.
	VPCConfiguration *VPCConfiguration `json:"vpcConfiguration,omitempty"`
}

+kubebuilder:skipversion

func (*AmazonopensearchserviceDestinationConfiguration) DeepCopy 

func (in *AmazonopensearchserviceDestinationConfiguration) DeepCopy() *AmazonopensearchserviceDestinationConfiguration

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

func (*AmazonopensearchserviceDestinationConfiguration) DeepCopyInto 

func (in *AmazonopensearchserviceDestinationConfiguration) DeepCopyInto(out *AmazonopensearchserviceDestinationConfiguration)

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

type AmazonopensearchserviceDestinationDescription 

type AmazonopensearchserviceDestinationDescription struct {
	// Describes the buffering to perform before delivering data to the Amazon OpenSearch
	// Service destination.
	BufferingHints *AmazonopensearchserviceBufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	ClusterEndpoint *string `json:"clusterEndpoint,omitempty"`

	DomainARN *string `json:"domainARN,omitempty"`

	IndexName *string `json:"indexName,omitempty"`

	IndexRotationPeriod *string `json:"indexRotationPeriod,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to Amazon OpenSearch Service.
	RetryOptions *AmazonopensearchserviceRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
	// Describes a destination in Amazon S3.
	S3DestinationDescription *S3DestinationDescription `json:"s3DestinationDescription,omitempty"`

	TypeName *string `json:"typeName,omitempty"`
	// The details of the VPC of the Amazon ES destination.
	VPCConfigurationDescription *VPCConfigurationDescription `json:"vpcConfigurationDescription,omitempty"`
}

+kubebuilder:skipversion

func (*AmazonopensearchserviceDestinationDescription) DeepCopy 

func (in *AmazonopensearchserviceDestinationDescription) DeepCopy() *AmazonopensearchserviceDestinationDescription

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

func (*AmazonopensearchserviceDestinationDescription) DeepCopyInto 

func (in *AmazonopensearchserviceDestinationDescription) DeepCopyInto(out *AmazonopensearchserviceDestinationDescription)

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

type AmazonopensearchserviceDestinationUpdate 

type AmazonopensearchserviceDestinationUpdate struct {
	// Describes the buffering to perform before delivering data to the Amazon OpenSearch
	// Service destination.
	BufferingHints *AmazonopensearchserviceBufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	ClusterEndpoint *string `json:"clusterEndpoint,omitempty"`

	DomainARN *string `json:"domainARN,omitempty"`

	IndexName *string `json:"indexName,omitempty"`

	IndexRotationPeriod *string `json:"indexRotationPeriod,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to Amazon OpenSearch Service.
	RetryOptions *AmazonopensearchserviceRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`

	TypeName *string `json:"typeName,omitempty"`
}

+kubebuilder:skipversion

func (*AmazonopensearchserviceDestinationUpdate) DeepCopy 

func (in *AmazonopensearchserviceDestinationUpdate) DeepCopy() *AmazonopensearchserviceDestinationUpdate

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

func (*AmazonopensearchserviceDestinationUpdate) DeepCopyInto 

func (in *AmazonopensearchserviceDestinationUpdate) DeepCopyInto(out *AmazonopensearchserviceDestinationUpdate)

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

type AmazonopensearchserviceIndexRotationPeriod 

type AmazonopensearchserviceIndexRotationPeriod string
const (
	AmazonopensearchserviceIndexRotationPeriod_NoRotation AmazonopensearchserviceIndexRotationPeriod = "NoRotation"
	AmazonopensearchserviceIndexRotationPeriod_OneHour    AmazonopensearchserviceIndexRotationPeriod = "OneHour"
	AmazonopensearchserviceIndexRotationPeriod_OneDay     AmazonopensearchserviceIndexRotationPeriod = "OneDay"
	AmazonopensearchserviceIndexRotationPeriod_OneWeek    AmazonopensearchserviceIndexRotationPeriod = "OneWeek"
	AmazonopensearchserviceIndexRotationPeriod_OneMonth   AmazonopensearchserviceIndexRotationPeriod = "OneMonth"
)

type AmazonopensearchserviceRetryOptions 

type AmazonopensearchserviceRetryOptions struct {
	DurationInSeconds *int64 `json:"durationInSeconds,omitempty"`
}

+kubebuilder:skipversion

func (*AmazonopensearchserviceRetryOptions) DeepCopy 

func (in *AmazonopensearchserviceRetryOptions) DeepCopy() *AmazonopensearchserviceRetryOptions

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

func (*AmazonopensearchserviceRetryOptions) DeepCopyInto 

func (in *AmazonopensearchserviceRetryOptions) DeepCopyInto(out *AmazonopensearchserviceRetryOptions)

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

type AmazonopensearchserviceS3BackupMode 

type AmazonopensearchserviceS3BackupMode string
const (
	AmazonopensearchserviceS3BackupMode_FailedDocumentsOnly AmazonopensearchserviceS3BackupMode = "FailedDocumentsOnly"
	AmazonopensearchserviceS3BackupMode_AllDocuments        AmazonopensearchserviceS3BackupMode = "AllDocuments"
)

type BufferingHints 

type BufferingHints struct {
	IntervalInSeconds *int64 `json:"intervalInSeconds,omitempty"`

	SizeInMBs *int64 `json:"sizeInMBs,omitempty"`
}

+kubebuilder:skipversion

func (*BufferingHints) DeepCopy 

func (in *BufferingHints) DeepCopy() *BufferingHints

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

func (*BufferingHints) DeepCopyInto 

func (in *BufferingHints) DeepCopyInto(out *BufferingHints)

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

type CloudWatchLoggingOptions 

type CloudWatchLoggingOptions struct {
	Enabled *bool `json:"enabled,omitempty"`

	LogGroupName *string `json:"logGroupName,omitempty"`

	LogStreamName *string `json:"logStreamName,omitempty"`
}

+kubebuilder:skipversion

func (*CloudWatchLoggingOptions) DeepCopy 

func (in *CloudWatchLoggingOptions) DeepCopy() *CloudWatchLoggingOptions

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

func (*CloudWatchLoggingOptions) DeepCopyInto 

func (in *CloudWatchLoggingOptions) DeepCopyInto(out *CloudWatchLoggingOptions)

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

type CompressionFormat 

type CompressionFormat string
const (
	CompressionFormat_UNCOMPRESSED  CompressionFormat = "UNCOMPRESSED"
	CompressionFormat_GZIP          CompressionFormat = "GZIP"
	CompressionFormat_ZIP           CompressionFormat = "ZIP"
	CompressionFormat_Snappy        CompressionFormat = "Snappy"
	CompressionFormat_HADOOP_SNAPPY CompressionFormat = "HADOOP_SNAPPY"
)

type ContentEncoding 

type ContentEncoding string
const (
	ContentEncoding_NONE ContentEncoding = "NONE"
	ContentEncoding_GZIP ContentEncoding = "GZIP"
)

type CopyCommand 

type CopyCommand struct {
	CopyOptions *string `json:"copyOptions,omitempty"`

	DataTableColumns *string `json:"dataTableColumns,omitempty"`

	DataTableName *string `json:"dataTableName,omitempty"`
}

+kubebuilder:skipversion

func (*CopyCommand) DeepCopy 

func (in *CopyCommand) DeepCopy() *CopyCommand

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

func (*CopyCommand) DeepCopyInto 

func (in *CopyCommand) DeepCopyInto(out *CopyCommand)

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

type CustomDeliveryStreamParameters 

type CustomDeliveryStreamParameters struct {
	// +optional
	// +crossplane:generate:reference:type=github.com/crossplane-contrib/provider-aws/apis/kms/v1alpha1.Key
	// +crossplane:generate:reference:extractor=github.com/crossplane-contrib/provider-aws/apis/kms/v1alpha1.KMSKeyARN()
	KMSKeyARN *string `json:"kmsKeyARN,omitempty"`

	KMSKeyARNRef *xpv1.Reference `json:"kmsKeyARNRef,omitempty"`

	KMSKeyARNSelector *xpv1.Selector `json:"kmsKeyARNSelector,omitempty"`
}

CustomDeliveryStreamParameters contains the additional fields for DeliveryStreamParameters.

func (*CustomDeliveryStreamParameters) DeepCopy 

func (in *CustomDeliveryStreamParameters) DeepCopy() *CustomDeliveryStreamParameters

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

func (*CustomDeliveryStreamParameters) DeepCopyInto 

func (in *CustomDeliveryStreamParameters) DeepCopyInto(out *CustomDeliveryStreamParameters)

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

type DataFormatConversionConfiguration 

type DataFormatConversionConfiguration struct {
	Enabled *bool `json:"enabled,omitempty"`
	// Specifies the deserializer you want to use to convert the format of the input
	// data. This parameter is required if Enabled is set to true.
	InputFormatConfiguration *InputFormatConfiguration `json:"inputFormatConfiguration,omitempty"`
	// Specifies the serializer that you want Kinesis Data Firehose to use to convert
	// the format of your data before it writes it to Amazon S3. This parameter
	// is required if Enabled is set to true.
	OutputFormatConfiguration *OutputFormatConfiguration `json:"outputFormatConfiguration,omitempty"`
	// Specifies the schema to which you want Kinesis Data Firehose to configure
	// your data before it writes it to Amazon S3. This parameter is required if
	// Enabled is set to true.
	SchemaConfiguration *SchemaConfiguration `json:"schemaConfiguration,omitempty"`
}

+kubebuilder:skipversion

func (*DataFormatConversionConfiguration) DeepCopy 

func (in *DataFormatConversionConfiguration) DeepCopy() *DataFormatConversionConfiguration

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

func (*DataFormatConversionConfiguration) DeepCopyInto 

func (in *DataFormatConversionConfiguration) DeepCopyInto(out *DataFormatConversionConfiguration)

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

type DeliveryStream 

type DeliveryStream struct {
	metav1.TypeMeta   `json:",inline"`
	metav1.ObjectMeta `json:"metadata,omitempty"`
	Spec              DeliveryStreamSpec   `json:"spec"`
	Status            DeliveryStreamStatus `json:"status,omitempty"`
}

DeliveryStream is the Schema for the DeliveryStreams API +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:storageversion +kubebuilder:resource:scope=Cluster,categories={crossplane,managed,aws}

func (*DeliveryStream) DeepCopy 

func (in *DeliveryStream) DeepCopy() *DeliveryStream

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

func (*DeliveryStream) DeepCopyInto 

func (in *DeliveryStream) DeepCopyInto(out *DeliveryStream)

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

func (*DeliveryStream) DeepCopyObject 

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

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

func (*DeliveryStream) GetCondition 

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

GetCondition of this DeliveryStream.

func (*DeliveryStream) GetDeletionPolicy 

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

GetDeletionPolicy of this DeliveryStream.

func (*DeliveryStream) GetManagementPolicies 

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

GetManagementPolicies of this DeliveryStream.

func (*DeliveryStream) GetProviderConfigReference 

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

GetProviderConfigReference of this DeliveryStream.

func (*DeliveryStream) GetPublishConnectionDetailsTo 

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

GetPublishConnectionDetailsTo of this DeliveryStream.

func (*DeliveryStream) GetWriteConnectionSecretToReference 

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

GetWriteConnectionSecretToReference of this DeliveryStream.

func (*DeliveryStream) ResolveReferences 

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

ResolveReferences of this DeliveryStream.

func (*DeliveryStream) SetConditions 

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

SetConditions of this DeliveryStream.

func (*DeliveryStream) SetDeletionPolicy 

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

SetDeletionPolicy of this DeliveryStream.

func (*DeliveryStream) SetManagementPolicies 

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

SetManagementPolicies of this DeliveryStream.

func (*DeliveryStream) SetProviderConfigReference 

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

SetProviderConfigReference of this DeliveryStream.

func (*DeliveryStream) SetPublishConnectionDetailsTo 

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

SetPublishConnectionDetailsTo of this DeliveryStream.

func (*DeliveryStream) SetWriteConnectionSecretToReference 

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

SetWriteConnectionSecretToReference of this DeliveryStream.

type DeliveryStreamDescription 

type DeliveryStreamDescription struct {
	CreateTimestamp *metav1.Time `json:"createTimestamp,omitempty"`

	DeliveryStreamARN *string `json:"deliveryStreamARN,omitempty"`
	// Contains information about the server-side encryption (SSE) status for the
	// delivery stream, the type customer master key (CMK) in use, if any, and the
	// ARN of the CMK. You can get DeliveryStreamEncryptionConfiguration by invoking
	// the DescribeDeliveryStream operation.
	DeliveryStreamEncryptionConfiguration *DeliveryStreamEncryptionConfiguration `json:"deliveryStreamEncryptionConfiguration,omitempty"`

	DeliveryStreamName *string `json:"deliveryStreamName,omitempty"`

	DeliveryStreamStatus *string `json:"deliveryStreamStatus,omitempty"`

	DeliveryStreamType *string `json:"deliveryStreamType,omitempty"`

	Destinations []*DestinationDescription `json:"destinations,omitempty"`
	// Provides details in case one of the following operations fails due to an
	// error related to KMS: CreateDeliveryStream, DeleteDeliveryStream, StartDeliveryStreamEncryption,
	// StopDeliveryStreamEncryption.
	FailureDescription *FailureDescription `json:"failureDescription,omitempty"`

	HasMoreDestinations *bool `json:"hasMoreDestinations,omitempty"`

	LastUpdateTimestamp *metav1.Time `json:"lastUpdateTimestamp,omitempty"`
	// Details about a Kinesis data stream used as the source for a Kinesis Data
	// Firehose delivery stream.
	Source *SourceDescription `json:"source,omitempty"`

	VersionID *string `json:"versionID,omitempty"`
}

+kubebuilder:skipversion

func (*DeliveryStreamDescription) DeepCopy 

func (in *DeliveryStreamDescription) DeepCopy() *DeliveryStreamDescription

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

func (*DeliveryStreamDescription) DeepCopyInto 

func (in *DeliveryStreamDescription) DeepCopyInto(out *DeliveryStreamDescription)

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

type DeliveryStreamEncryptionConfiguration 

type DeliveryStreamEncryptionConfiguration struct {
	// Provides details in case one of the following operations fails due to an
	// error related to KMS: CreateDeliveryStream, DeleteDeliveryStream, StartDeliveryStreamEncryption,
	// StopDeliveryStreamEncryption.
	FailureDescription *FailureDescription `json:"failureDescription,omitempty"`

	KeyARN *string `json:"keyARN,omitempty"`

	KeyType *string `json:"keyType,omitempty"`

	Status *string `json:"status,omitempty"`
}

+kubebuilder:skipversion

func (*DeliveryStreamEncryptionConfiguration) DeepCopy 

func (in *DeliveryStreamEncryptionConfiguration) DeepCopy() *DeliveryStreamEncryptionConfiguration

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

func (*DeliveryStreamEncryptionConfiguration) DeepCopyInto 

func (in *DeliveryStreamEncryptionConfiguration) DeepCopyInto(out *DeliveryStreamEncryptionConfiguration)

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

type DeliveryStreamEncryptionConfigurationInput 

type DeliveryStreamEncryptionConfigurationInput struct {
	KeyARN *string `json:"keyARN,omitempty"`

	KeyType *string `json:"keyType,omitempty"`
}

+kubebuilder:skipversion

func (*DeliveryStreamEncryptionConfigurationInput) DeepCopy 

func (in *DeliveryStreamEncryptionConfigurationInput) DeepCopy() *DeliveryStreamEncryptionConfigurationInput

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

func (*DeliveryStreamEncryptionConfigurationInput) DeepCopyInto 

func (in *DeliveryStreamEncryptionConfigurationInput) DeepCopyInto(out *DeliveryStreamEncryptionConfigurationInput)

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

type DeliveryStreamEncryptionStatus 

type DeliveryStreamEncryptionStatus string
const (
	DeliveryStreamEncryptionStatus_ENABLED          DeliveryStreamEncryptionStatus = "ENABLED"
	DeliveryStreamEncryptionStatus_ENABLING         DeliveryStreamEncryptionStatus = "ENABLING"
	DeliveryStreamEncryptionStatus_ENABLING_FAILED  DeliveryStreamEncryptionStatus = "ENABLING_FAILED"
	DeliveryStreamEncryptionStatus_DISABLED         DeliveryStreamEncryptionStatus = "DISABLED"
	DeliveryStreamEncryptionStatus_DISABLING        DeliveryStreamEncryptionStatus = "DISABLING"
	DeliveryStreamEncryptionStatus_DISABLING_FAILED DeliveryStreamEncryptionStatus = "DISABLING_FAILED"
)

type DeliveryStreamFailureType 

type DeliveryStreamFailureType string
const (
	DeliveryStreamFailureType_RETIRE_KMS_GRANT_FAILED      DeliveryStreamFailureType = "RETIRE_KMS_GRANT_FAILED"
	DeliveryStreamFailureType_CREATE_KMS_GRANT_FAILED      DeliveryStreamFailureType = "CREATE_KMS_GRANT_FAILED"
	DeliveryStreamFailureType_KMS_ACCESS_DENIED            DeliveryStreamFailureType = "KMS_ACCESS_DENIED"
	DeliveryStreamFailureType_DISABLED_KMS_KEY             DeliveryStreamFailureType = "DISABLED_KMS_KEY"
	DeliveryStreamFailureType_INVALID_KMS_KEY              DeliveryStreamFailureType = "INVALID_KMS_KEY"
	DeliveryStreamFailureType_KMS_KEY_NOT_FOUND            DeliveryStreamFailureType = "KMS_KEY_NOT_FOUND"
	DeliveryStreamFailureType_KMS_OPT_IN_REQUIRED          DeliveryStreamFailureType = "KMS_OPT_IN_REQUIRED"
	DeliveryStreamFailureType_CREATE_ENI_FAILED            DeliveryStreamFailureType = "CREATE_ENI_FAILED"
	DeliveryStreamFailureType_DELETE_ENI_FAILED            DeliveryStreamFailureType = "DELETE_ENI_FAILED"
	DeliveryStreamFailureType_SUBNET_NOT_FOUND             DeliveryStreamFailureType = "SUBNET_NOT_FOUND"
	DeliveryStreamFailureType_SECURITY_GROUP_NOT_FOUND     DeliveryStreamFailureType = "SECURITY_GROUP_NOT_FOUND"
	DeliveryStreamFailureType_ENI_ACCESS_DENIED            DeliveryStreamFailureType = "ENI_ACCESS_DENIED"
	DeliveryStreamFailureType_SUBNET_ACCESS_DENIED         DeliveryStreamFailureType = "SUBNET_ACCESS_DENIED"
	DeliveryStreamFailureType_SECURITY_GROUP_ACCESS_DENIED DeliveryStreamFailureType = "SECURITY_GROUP_ACCESS_DENIED"
	DeliveryStreamFailureType_UNKNOWN_ERROR                DeliveryStreamFailureType = "UNKNOWN_ERROR"
)

type DeliveryStreamList 

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

DeliveryStreamList contains a list of DeliveryStreams

func (*DeliveryStreamList) DeepCopy 

func (in *DeliveryStreamList) DeepCopy() *DeliveryStreamList

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

func (*DeliveryStreamList) DeepCopyInto 

func (in *DeliveryStreamList) DeepCopyInto(out *DeliveryStreamList)

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

func (*DeliveryStreamList) DeepCopyObject 

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

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

func (*DeliveryStreamList) GetItems 

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

GetItems of this DeliveryStreamList.

type DeliveryStreamObservation 

type DeliveryStreamObservation struct {
	// The Amazon Resource Name (ARN) of the delivery stream. For more information,
	// see Amazon Resource Names (ARNs) and Amazon Web Services Service Namespaces
	// (https://docs.aws.amazon.com/general/latest/gr/aws-arns-and-namespaces.html).
	DeliveryStreamARN *string `json:"deliveryStreamARN,omitempty"`
	// The status of the delivery stream. If the status of a delivery stream is
	// CREATING_FAILED, this status doesn't change, and you can't invoke CreateDeliveryStream
	// again on it. However, you can invoke the DeleteDeliveryStream operation to
	// delete it.
	DeliveryStreamStatus *string `json:"deliveryStreamStatus,omitempty"`
}

DeliveryStreamObservation defines the observed state of DeliveryStream

func (*DeliveryStreamObservation) DeepCopy 

func (in *DeliveryStreamObservation) DeepCopy() *DeliveryStreamObservation

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

func (*DeliveryStreamObservation) DeepCopyInto 

func (in *DeliveryStreamObservation) DeepCopyInto(out *DeliveryStreamObservation)

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

type DeliveryStreamParameters 

type DeliveryStreamParameters struct {
	// Region is which region the DeliveryStream will be created.
	// +kubebuilder:validation:Required
	Region string `json:"region"`
	// The destination in the Serverless offering for Amazon OpenSearch Service.
	// You can specify only one destination.
	AmazonOpenSearchServerlessDestinationConfiguration *AmazonOpenSearchServerlessDestinationConfiguration `json:"amazonOpenSearchServerlessDestinationConfiguration,omitempty"`
	// The destination in Amazon OpenSearch Service. You can specify only one destination.
	AmazonopensearchserviceDestinationConfiguration *AmazonopensearchserviceDestinationConfiguration `json:"amazonopensearchserviceDestinationConfiguration,omitempty"`
	// Used to specify the type and Amazon Resource Name (ARN) of the KMS key needed
	// for Server-Side Encryption (SSE).
	DeliveryStreamEncryptionConfigurationInput *DeliveryStreamEncryptionConfigurationInput `json:"deliveryStreamEncryptionConfigurationInput,omitempty"`
	// The name of the delivery stream. This name must be unique per Amazon Web
	// Services account in the same Amazon Web Services Region. If the delivery
	// streams are in different accounts or different Regions, you can have multiple
	// delivery streams with the same name.
	// +kubebuilder:validation:Required
	DeliveryStreamName *string `json:"deliveryStreamName"`
	// The delivery stream type. This parameter can be one of the following values:
	//
	//    * DirectPut: Provider applications access the delivery stream directly.
	//
	//    * KinesisStreamAsSource: The delivery stream uses a Kinesis data stream
	//    as a source.
	DeliveryStreamType *string `json:"deliveryStreamType,omitempty"`
	// The destination in Amazon ES. You can specify only one destination.
	ElasticsearchDestinationConfiguration *ElasticsearchDestinationConfiguration `json:"elasticsearchDestinationConfiguration,omitempty"`
	// The destination in Amazon S3. You can specify only one destination.
	ExtendedS3DestinationConfiguration *ExtendedS3DestinationConfiguration `json:"extendedS3DestinationConfiguration,omitempty"`
	// Enables configuring Kinesis Firehose to deliver data to any HTTP endpoint
	// destination. You can specify only one destination.
	HTTPEndpointDestinationConfiguration *HTTPEndpointDestinationConfiguration `json:"httpEndpointDestinationConfiguration,omitempty"`
	// When a Kinesis data stream is used as the source for the delivery stream,
	// a KinesisStreamSourceConfiguration containing the Kinesis data stream Amazon
	// Resource Name (ARN) and the role ARN for the source stream.
	KinesisStreamSourceConfiguration *KinesisStreamSourceConfiguration `json:"kinesisStreamSourceConfiguration,omitempty"`
	// The destination in Amazon Redshift. You can specify only one destination.
	RedshiftDestinationConfiguration *RedshiftDestinationConfiguration `json:"redshiftDestinationConfiguration,omitempty"`
	// [Deprecated] The destination in Amazon S3. You can specify only one destination.
	S3DestinationConfiguration *S3DestinationConfiguration `json:"s3DestinationConfiguration,omitempty"`
	// The destination in Splunk. You can specify only one destination.
	SplunkDestinationConfiguration *SplunkDestinationConfiguration `json:"splunkDestinationConfiguration,omitempty"`
	// A set of tags to assign to the delivery stream. A tag is a key-value pair
	// that you can define and assign to Amazon Web Services resources. Tags are
	// metadata. For example, you can add friendly names and descriptions or other
	// types of information that can help you distinguish the delivery stream. For
	// more information about tags, see Using Cost Allocation Tags (https://docs.aws.amazon.com/awsaccountbilling/latest/aboutv2/cost-alloc-tags.html)
	// in the Amazon Web Services Billing and Cost Management User Guide.
	//
	// You can specify up to 50 tags when creating a delivery stream.
	Tags                           []*Tag `json:"tags,omitempty"`
	CustomDeliveryStreamParameters `json:",inline"`
}

DeliveryStreamParameters defines the desired state of DeliveryStream

func (*DeliveryStreamParameters) DeepCopy 

func (in *DeliveryStreamParameters) DeepCopy() *DeliveryStreamParameters

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

func (*DeliveryStreamParameters) DeepCopyInto 

func (in *DeliveryStreamParameters) DeepCopyInto(out *DeliveryStreamParameters)

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

type DeliveryStreamSpec 

type DeliveryStreamSpec struct {
	xpv1.ResourceSpec `json:",inline"`
	ForProvider       DeliveryStreamParameters `json:"forProvider"`
}

DeliveryStreamSpec defines the desired state of DeliveryStream

func (*DeliveryStreamSpec) DeepCopy 

func (in *DeliveryStreamSpec) DeepCopy() *DeliveryStreamSpec

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

func (*DeliveryStreamSpec) DeepCopyInto 

func (in *DeliveryStreamSpec) DeepCopyInto(out *DeliveryStreamSpec)

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

type DeliveryStreamStatus 

type DeliveryStreamStatus struct {
	xpv1.ResourceStatus `json:",inline"`
	AtProvider          DeliveryStreamObservation `json:"atProvider,omitempty"`
}

DeliveryStreamStatus defines the observed state of DeliveryStream.

func (*DeliveryStreamStatus) DeepCopy 

func (in *DeliveryStreamStatus) DeepCopy() *DeliveryStreamStatus

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

func (*DeliveryStreamStatus) DeepCopyInto 

func (in *DeliveryStreamStatus) DeepCopyInto(out *DeliveryStreamStatus)

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

type DeliveryStreamStatus_SDK 

type DeliveryStreamStatus_SDK string
const (
	DeliveryStreamStatus_SDK_CREATING        DeliveryStreamStatus_SDK = "CREATING"
	DeliveryStreamStatus_SDK_CREATING_FAILED DeliveryStreamStatus_SDK = "CREATING_FAILED"
	DeliveryStreamStatus_SDK_DELETING        DeliveryStreamStatus_SDK = "DELETING"
	DeliveryStreamStatus_SDK_DELETING_FAILED DeliveryStreamStatus_SDK = "DELETING_FAILED"
	DeliveryStreamStatus_SDK_ACTIVE          DeliveryStreamStatus_SDK = "ACTIVE"
)

type DeliveryStreamType 

type DeliveryStreamType string
const (
	DeliveryStreamType_DirectPut             DeliveryStreamType = "DirectPut"
	DeliveryStreamType_KinesisStreamAsSource DeliveryStreamType = "KinesisStreamAsSource"
)

type Deserializer 

type Deserializer struct {
	// The native Hive / HCatalog JsonSerDe. Used by Kinesis Data Firehose for deserializing
	// data, which means converting it from the JSON format in preparation for serializing
	// it to the Parquet or ORC format. This is one of two deserializers you can
	// choose, depending on which one offers the functionality you need. The other
	// option is the OpenX SerDe.
	HiveJSONSerDe *HiveJSONSerDe `json:"hiveJSONSerDe,omitempty"`
	// The OpenX SerDe. Used by Kinesis Data Firehose for deserializing data, which
	// means converting it from the JSON format in preparation for serializing it
	// to the Parquet or ORC format. This is one of two deserializers you can choose,
	// depending on which one offers the functionality you need. The other option
	// is the native Hive / HCatalog JsonSerDe.
	OpenXJSONSerDe *OpenXJSONSerDe `json:"openXJSONSerDe,omitempty"`
}

+kubebuilder:skipversion

func (*Deserializer) DeepCopy 

func (in *Deserializer) DeepCopy() *Deserializer

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

func (*Deserializer) DeepCopyInto 

func (in *Deserializer) DeepCopyInto(out *Deserializer)

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

type DestinationDescription 

type DestinationDescription struct {
	// The destination description in the Serverless offering for Amazon OpenSearch
	// Service.
	AmazonOpenSearchServerlessDestinationDescription *AmazonOpenSearchServerlessDestinationDescription `json:"amazonOpenSearchServerlessDestinationDescription,omitempty"`
	// The destination description in Amazon OpenSearch Service.
	AmazonopensearchserviceDestinationDescription *AmazonopensearchserviceDestinationDescription `json:"amazonopensearchserviceDestinationDescription,omitempty"`

	DestinationID *string `json:"destinationID,omitempty"`
	// The destination description in Amazon ES.
	ElasticsearchDestinationDescription *ElasticsearchDestinationDescription `json:"elasticsearchDestinationDescription,omitempty"`
	// Describes a destination in Amazon S3.
	ExtendedS3DestinationDescription *ExtendedS3DestinationDescription `json:"extendedS3DestinationDescription,omitempty"`
	// Describes the HTTP endpoint destination.
	HTTPEndpointDestinationDescription *HTTPEndpointDestinationDescription `json:"httpEndpointDestinationDescription,omitempty"`
	// Describes a destination in Amazon Redshift.
	RedshiftDestinationDescription *RedshiftDestinationDescription `json:"redshiftDestinationDescription,omitempty"`
	// Describes a destination in Amazon S3.
	S3DestinationDescription *S3DestinationDescription `json:"s3DestinationDescription,omitempty"`
	// Describes a destination in Splunk.
	SplunkDestinationDescription *SplunkDestinationDescription `json:"splunkDestinationDescription,omitempty"`
}

+kubebuilder:skipversion

func (*DestinationDescription) DeepCopy 

func (in *DestinationDescription) DeepCopy() *DestinationDescription

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

func (*DestinationDescription) DeepCopyInto 

func (in *DestinationDescription) DeepCopyInto(out *DestinationDescription)

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

type DynamicPartitioningConfiguration 

type DynamicPartitioningConfiguration struct {
	Enabled *bool `json:"enabled,omitempty"`
	// The retry behavior in case Kinesis Data Firehose is unable to deliver data
	// to an Amazon S3 prefix.
	RetryOptions *RetryOptions `json:"retryOptions,omitempty"`
}

+kubebuilder:skipversion

func (*DynamicPartitioningConfiguration) DeepCopy 

func (in *DynamicPartitioningConfiguration) DeepCopy() *DynamicPartitioningConfiguration

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

func (*DynamicPartitioningConfiguration) DeepCopyInto 

func (in *DynamicPartitioningConfiguration) DeepCopyInto(out *DynamicPartitioningConfiguration)

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

type ElasticsearchBufferingHints 

type ElasticsearchBufferingHints struct {
	IntervalInSeconds *int64 `json:"intervalInSeconds,omitempty"`

	SizeInMBs *int64 `json:"sizeInMBs,omitempty"`
}

+kubebuilder:skipversion

func (*ElasticsearchBufferingHints) DeepCopy 

func (in *ElasticsearchBufferingHints) DeepCopy() *ElasticsearchBufferingHints

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

func (*ElasticsearchBufferingHints) DeepCopyInto 

func (in *ElasticsearchBufferingHints) DeepCopyInto(out *ElasticsearchBufferingHints)

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

type ElasticsearchDestinationConfiguration 

type ElasticsearchDestinationConfiguration struct {
	// Describes the buffering to perform before delivering data to the Amazon ES
	// destination.
	BufferingHints *ElasticsearchBufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	ClusterEndpoint *string `json:"clusterEndpoint,omitempty"`

	DomainARN *string `json:"domainARN,omitempty"`

	IndexName *string `json:"indexName,omitempty"`

	IndexRotationPeriod *string `json:"indexRotationPeriod,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to Amazon ES.
	RetryOptions *ElasticsearchRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
	// Describes the configuration of a destination in Amazon S3.
	S3Configuration *S3DestinationConfiguration `json:"s3Configuration,omitempty"`

	TypeName *string `json:"typeName,omitempty"`
	// The details of the VPC of the Amazon ES destination.
	VPCConfiguration *VPCConfiguration `json:"vpcConfiguration,omitempty"`
}

+kubebuilder:skipversion

func (*ElasticsearchDestinationConfiguration) DeepCopy 

func (in *ElasticsearchDestinationConfiguration) DeepCopy() *ElasticsearchDestinationConfiguration

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

func (*ElasticsearchDestinationConfiguration) DeepCopyInto 

func (in *ElasticsearchDestinationConfiguration) DeepCopyInto(out *ElasticsearchDestinationConfiguration)

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

type ElasticsearchDestinationDescription 

type ElasticsearchDestinationDescription struct {
	// Describes the buffering to perform before delivering data to the Amazon ES
	// destination.
	BufferingHints *ElasticsearchBufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	ClusterEndpoint *string `json:"clusterEndpoint,omitempty"`

	DomainARN *string `json:"domainARN,omitempty"`

	IndexName *string `json:"indexName,omitempty"`

	IndexRotationPeriod *string `json:"indexRotationPeriod,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to Amazon ES.
	RetryOptions *ElasticsearchRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
	// Describes a destination in Amazon S3.
	S3DestinationDescription *S3DestinationDescription `json:"s3DestinationDescription,omitempty"`

	TypeName *string `json:"typeName,omitempty"`
	// The details of the VPC of the Amazon ES destination.
	VPCConfigurationDescription *VPCConfigurationDescription `json:"vpcConfigurationDescription,omitempty"`
}

+kubebuilder:skipversion

func (*ElasticsearchDestinationDescription) DeepCopy 

func (in *ElasticsearchDestinationDescription) DeepCopy() *ElasticsearchDestinationDescription

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

func (*ElasticsearchDestinationDescription) DeepCopyInto 

func (in *ElasticsearchDestinationDescription) DeepCopyInto(out *ElasticsearchDestinationDescription)

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

type ElasticsearchDestinationUpdate 

type ElasticsearchDestinationUpdate struct {
	// Describes the buffering to perform before delivering data to the Amazon ES
	// destination.
	BufferingHints *ElasticsearchBufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	ClusterEndpoint *string `json:"clusterEndpoint,omitempty"`

	DomainARN *string `json:"domainARN,omitempty"`

	IndexName *string `json:"indexName,omitempty"`

	IndexRotationPeriod *string `json:"indexRotationPeriod,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to Amazon ES.
	RetryOptions *ElasticsearchRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`

	TypeName *string `json:"typeName,omitempty"`
}

+kubebuilder:skipversion

func (*ElasticsearchDestinationUpdate) DeepCopy 

func (in *ElasticsearchDestinationUpdate) DeepCopy() *ElasticsearchDestinationUpdate

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

func (*ElasticsearchDestinationUpdate) DeepCopyInto 

func (in *ElasticsearchDestinationUpdate) DeepCopyInto(out *ElasticsearchDestinationUpdate)

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

type ElasticsearchIndexRotationPeriod 

type ElasticsearchIndexRotationPeriod string
const (
	ElasticsearchIndexRotationPeriod_NoRotation ElasticsearchIndexRotationPeriod = "NoRotation"
	ElasticsearchIndexRotationPeriod_OneHour    ElasticsearchIndexRotationPeriod = "OneHour"
	ElasticsearchIndexRotationPeriod_OneDay     ElasticsearchIndexRotationPeriod = "OneDay"
	ElasticsearchIndexRotationPeriod_OneWeek    ElasticsearchIndexRotationPeriod = "OneWeek"
	ElasticsearchIndexRotationPeriod_OneMonth   ElasticsearchIndexRotationPeriod = "OneMonth"
)

type ElasticsearchRetryOptions 

type ElasticsearchRetryOptions struct {
	DurationInSeconds *int64 `json:"durationInSeconds,omitempty"`
}

+kubebuilder:skipversion

func (*ElasticsearchRetryOptions) DeepCopy 

func (in *ElasticsearchRetryOptions) DeepCopy() *ElasticsearchRetryOptions

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

func (*ElasticsearchRetryOptions) DeepCopyInto 

func (in *ElasticsearchRetryOptions) DeepCopyInto(out *ElasticsearchRetryOptions)

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

type ElasticsearchS3BackupMode 

type ElasticsearchS3BackupMode string
const (
	ElasticsearchS3BackupMode_FailedDocumentsOnly ElasticsearchS3BackupMode = "FailedDocumentsOnly"
	ElasticsearchS3BackupMode_AllDocuments        ElasticsearchS3BackupMode = "AllDocuments"
)

type EncryptionConfiguration 

type EncryptionConfiguration struct {
	// Describes an encryption key for a destination in Amazon S3.
	KMSEncryptionConfig *KMSEncryptionConfig `json:"kmsEncryptionConfig,omitempty"`

	NoEncryptionConfig *string `json:"noEncryptionConfig,omitempty"`
}

+kubebuilder:skipversion

func (*EncryptionConfiguration) DeepCopy 

func (in *EncryptionConfiguration) DeepCopy() *EncryptionConfiguration

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

func (*EncryptionConfiguration) DeepCopyInto 

func (in *EncryptionConfiguration) DeepCopyInto(out *EncryptionConfiguration)

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

type ExtendedS3DestinationConfiguration 

type ExtendedS3DestinationConfiguration struct {
	BucketARN *string `json:"bucketARN,omitempty"`
	// Describes hints for the buffering to perform before delivering data to the
	// destination. These options are treated as hints, and therefore Kinesis Data
	// Firehose might choose to use different values when it is optimal. The SizeInMBs
	// and IntervalInSeconds parameters are optional. However, if specify a value
	// for one of them, you must also provide a value for the other.
	BufferingHints *BufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	CompressionFormat *string `json:"compressionFormat,omitempty"`
	// Specifies that you want Kinesis Data Firehose to convert data from the JSON
	// format to the Parquet or ORC format before writing it to Amazon S3. Kinesis
	// Data Firehose uses the serializer and deserializer that you specify, in addition
	// to the column information from the Amazon Web Services Glue table, to deserialize
	// your input data from JSON and then serialize it to the Parquet or ORC format.
	// For more information, see Kinesis Data Firehose Record Format Conversion
	// (https://docs.aws.amazon.com/firehose/latest/dev/record-format-conversion.html).
	DataFormatConversionConfiguration *DataFormatConversionConfiguration `json:"dataFormatConversionConfiguration,omitempty"`
	// The configuration of the dynamic partitioning mechanism that creates smaller
	// data sets from the streaming data by partitioning it based on partition keys.
	// Currently, dynamic partitioning is only supported for Amazon S3 destinations.
	DynamicPartitioningConfiguration *DynamicPartitioningConfiguration `json:"dynamicPartitioningConfiguration,omitempty"`
	// Describes the encryption for a destination in Amazon S3.
	EncryptionConfiguration *EncryptionConfiguration `json:"encryptionConfiguration,omitempty"`

	ErrorOutputPrefix *string `json:"errorOutputPrefix,omitempty"`

	Prefix *string `json:"prefix,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`
	// Describes the configuration of a destination in Amazon S3.
	S3BackupConfiguration *S3DestinationConfiguration `json:"s3BackupConfiguration,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
}

+kubebuilder:skipversion

func (*ExtendedS3DestinationConfiguration) DeepCopy 

func (in *ExtendedS3DestinationConfiguration) DeepCopy() *ExtendedS3DestinationConfiguration

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

func (*ExtendedS3DestinationConfiguration) DeepCopyInto 

func (in *ExtendedS3DestinationConfiguration) DeepCopyInto(out *ExtendedS3DestinationConfiguration)

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

type ExtendedS3DestinationDescription 

type ExtendedS3DestinationDescription struct {
	BucketARN *string `json:"bucketARN,omitempty"`
	// Describes hints for the buffering to perform before delivering data to the
	// destination. These options are treated as hints, and therefore Kinesis Data
	// Firehose might choose to use different values when it is optimal. The SizeInMBs
	// and IntervalInSeconds parameters are optional. However, if specify a value
	// for one of them, you must also provide a value for the other.
	BufferingHints *BufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	CompressionFormat *string `json:"compressionFormat,omitempty"`
	// Specifies that you want Kinesis Data Firehose to convert data from the JSON
	// format to the Parquet or ORC format before writing it to Amazon S3. Kinesis
	// Data Firehose uses the serializer and deserializer that you specify, in addition
	// to the column information from the Amazon Web Services Glue table, to deserialize
	// your input data from JSON and then serialize it to the Parquet or ORC format.
	// For more information, see Kinesis Data Firehose Record Format Conversion
	// (https://docs.aws.amazon.com/firehose/latest/dev/record-format-conversion.html).
	DataFormatConversionConfiguration *DataFormatConversionConfiguration `json:"dataFormatConversionConfiguration,omitempty"`
	// The configuration of the dynamic partitioning mechanism that creates smaller
	// data sets from the streaming data by partitioning it based on partition keys.
	// Currently, dynamic partitioning is only supported for Amazon S3 destinations.
	DynamicPartitioningConfiguration *DynamicPartitioningConfiguration `json:"dynamicPartitioningConfiguration,omitempty"`
	// Describes the encryption for a destination in Amazon S3.
	EncryptionConfiguration *EncryptionConfiguration `json:"encryptionConfiguration,omitempty"`

	ErrorOutputPrefix *string `json:"errorOutputPrefix,omitempty"`

	Prefix *string `json:"prefix,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`
	// Describes a destination in Amazon S3.
	S3BackupDescription *S3DestinationDescription `json:"s3BackupDescription,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
}

+kubebuilder:skipversion

func (*ExtendedS3DestinationDescription) DeepCopy 

func (in *ExtendedS3DestinationDescription) DeepCopy() *ExtendedS3DestinationDescription

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

func (*ExtendedS3DestinationDescription) DeepCopyInto 

func (in *ExtendedS3DestinationDescription) DeepCopyInto(out *ExtendedS3DestinationDescription)

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

type ExtendedS3DestinationUpdate 

type ExtendedS3DestinationUpdate struct {
	BucketARN *string `json:"bucketARN,omitempty"`
	// Describes hints for the buffering to perform before delivering data to the
	// destination. These options are treated as hints, and therefore Kinesis Data
	// Firehose might choose to use different values when it is optimal. The SizeInMBs
	// and IntervalInSeconds parameters are optional. However, if specify a value
	// for one of them, you must also provide a value for the other.
	BufferingHints *BufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	CompressionFormat *string `json:"compressionFormat,omitempty"`
	// Specifies that you want Kinesis Data Firehose to convert data from the JSON
	// format to the Parquet or ORC format before writing it to Amazon S3. Kinesis
	// Data Firehose uses the serializer and deserializer that you specify, in addition
	// to the column information from the Amazon Web Services Glue table, to deserialize
	// your input data from JSON and then serialize it to the Parquet or ORC format.
	// For more information, see Kinesis Data Firehose Record Format Conversion
	// (https://docs.aws.amazon.com/firehose/latest/dev/record-format-conversion.html).
	DataFormatConversionConfiguration *DataFormatConversionConfiguration `json:"dataFormatConversionConfiguration,omitempty"`
	// The configuration of the dynamic partitioning mechanism that creates smaller
	// data sets from the streaming data by partitioning it based on partition keys.
	// Currently, dynamic partitioning is only supported for Amazon S3 destinations.
	DynamicPartitioningConfiguration *DynamicPartitioningConfiguration `json:"dynamicPartitioningConfiguration,omitempty"`
	// Describes the encryption for a destination in Amazon S3.
	EncryptionConfiguration *EncryptionConfiguration `json:"encryptionConfiguration,omitempty"`

	ErrorOutputPrefix *string `json:"errorOutputPrefix,omitempty"`

	Prefix *string `json:"prefix,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
}

+kubebuilder:skipversion

func (*ExtendedS3DestinationUpdate) DeepCopy 

func (in *ExtendedS3DestinationUpdate) DeepCopy() *ExtendedS3DestinationUpdate

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

func (*ExtendedS3DestinationUpdate) DeepCopyInto 

func (in *ExtendedS3DestinationUpdate) DeepCopyInto(out *ExtendedS3DestinationUpdate)

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

type FailureDescription 

type FailureDescription struct {
	Details *string `json:"details,omitempty"`

	Type *string `json:"type_,omitempty"`
}

+kubebuilder:skipversion

func (*FailureDescription) DeepCopy 

func (in *FailureDescription) DeepCopy() *FailureDescription

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

func (*FailureDescription) DeepCopyInto 

func (in *FailureDescription) DeepCopyInto(out *FailureDescription)

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

type HECEndpointType 

type HECEndpointType string
const (
	HECEndpointType_Raw   HECEndpointType = "Raw"
	HECEndpointType_Event HECEndpointType = "Event"
)

type HTTPEndpointBufferingHints 

type HTTPEndpointBufferingHints struct {
	IntervalInSeconds *int64 `json:"intervalInSeconds,omitempty"`

	SizeInMBs *int64 `json:"sizeInMBs,omitempty"`
}

+kubebuilder:skipversion

func (*HTTPEndpointBufferingHints) DeepCopy 

func (in *HTTPEndpointBufferingHints) DeepCopy() *HTTPEndpointBufferingHints

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

func (*HTTPEndpointBufferingHints) DeepCopyInto 

func (in *HTTPEndpointBufferingHints) DeepCopyInto(out *HTTPEndpointBufferingHints)

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

type HTTPEndpointCommonAttribute 

type HTTPEndpointCommonAttribute struct {
	AttributeName *string `json:"attributeName,omitempty"`

	AttributeValue *string `json:"attributeValue,omitempty"`
}

+kubebuilder:skipversion

func (*HTTPEndpointCommonAttribute) DeepCopy 

func (in *HTTPEndpointCommonAttribute) DeepCopy() *HTTPEndpointCommonAttribute

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

func (*HTTPEndpointCommonAttribute) DeepCopyInto 

func (in *HTTPEndpointCommonAttribute) DeepCopyInto(out *HTTPEndpointCommonAttribute)

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

type HTTPEndpointConfiguration 

type HTTPEndpointConfiguration struct {
	AccessKey *string `json:"accessKey,omitempty"`

	Name *string `json:"name,omitempty"`

	URL *string `json:"url,omitempty"`
}

+kubebuilder:skipversion

func (*HTTPEndpointConfiguration) DeepCopy 

func (in *HTTPEndpointConfiguration) DeepCopy() *HTTPEndpointConfiguration

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

func (*HTTPEndpointConfiguration) DeepCopyInto 

func (in *HTTPEndpointConfiguration) DeepCopyInto(out *HTTPEndpointConfiguration)

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

type HTTPEndpointDescription 

type HTTPEndpointDescription struct {
	Name *string `json:"name,omitempty"`

	URL *string `json:"url,omitempty"`
}

+kubebuilder:skipversion

func (*HTTPEndpointDescription) DeepCopy 

func (in *HTTPEndpointDescription) DeepCopy() *HTTPEndpointDescription

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

func (*HTTPEndpointDescription) DeepCopyInto 

func (in *HTTPEndpointDescription) DeepCopyInto(out *HTTPEndpointDescription)

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

type HTTPEndpointDestinationConfiguration 

type HTTPEndpointDestinationConfiguration struct {
	// Describes the buffering options that can be applied before data is delivered
	// to the HTTP endpoint destination. Kinesis Data Firehose treats these options
	// as hints, and it might choose to use more optimal values. The SizeInMBs and
	// IntervalInSeconds parameters are optional. However, if specify a value for
	// one of them, you must also provide a value for the other.
	BufferingHints *HTTPEndpointBufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`
	// Describes the configuration of the HTTP endpoint to which Kinesis Firehose
	// delivers data.
	EndpointConfiguration *HTTPEndpointConfiguration `json:"endpointConfiguration,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// The configuration of the HTTP endpoint request.
	RequestConfiguration *HTTPEndpointRequestConfiguration `json:"requestConfiguration,omitempty"`
	// Describes the retry behavior in case Kinesis Data Firehose is unable to deliver
	// data to the specified HTTP endpoint destination, or if it doesn't receive
	// a valid acknowledgment of receipt from the specified HTTP endpoint destination.
	RetryOptions *HTTPEndpointRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
	// Describes the configuration of a destination in Amazon S3.
	S3Configuration *S3DestinationConfiguration `json:"s3Configuration,omitempty"`
}

+kubebuilder:skipversion

func (*HTTPEndpointDestinationConfiguration) DeepCopy 

func (in *HTTPEndpointDestinationConfiguration) DeepCopy() *HTTPEndpointDestinationConfiguration

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

func (*HTTPEndpointDestinationConfiguration) DeepCopyInto 

func (in *HTTPEndpointDestinationConfiguration) DeepCopyInto(out *HTTPEndpointDestinationConfiguration)

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

type HTTPEndpointDestinationDescription 

type HTTPEndpointDestinationDescription struct {
	// Describes the buffering options that can be applied before data is delivered
	// to the HTTP endpoint destination. Kinesis Data Firehose treats these options
	// as hints, and it might choose to use more optimal values. The SizeInMBs and
	// IntervalInSeconds parameters are optional. However, if specify a value for
	// one of them, you must also provide a value for the other.
	BufferingHints *HTTPEndpointBufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`
	// Describes the HTTP endpoint selected as the destination.
	EndpointConfiguration *HTTPEndpointDescription `json:"endpointConfiguration,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// The configuration of the HTTP endpoint request.
	RequestConfiguration *HTTPEndpointRequestConfiguration `json:"requestConfiguration,omitempty"`
	// Describes the retry behavior in case Kinesis Data Firehose is unable to deliver
	// data to the specified HTTP endpoint destination, or if it doesn't receive
	// a valid acknowledgment of receipt from the specified HTTP endpoint destination.
	RetryOptions *HTTPEndpointRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
	// Describes a destination in Amazon S3.
	S3DestinationDescription *S3DestinationDescription `json:"s3DestinationDescription,omitempty"`
}

+kubebuilder:skipversion

func (*HTTPEndpointDestinationDescription) DeepCopy 

func (in *HTTPEndpointDestinationDescription) DeepCopy() *HTTPEndpointDestinationDescription

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

func (*HTTPEndpointDestinationDescription) DeepCopyInto 

func (in *HTTPEndpointDestinationDescription) DeepCopyInto(out *HTTPEndpointDestinationDescription)

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

type HTTPEndpointDestinationUpdate 

type HTTPEndpointDestinationUpdate struct {
	// Describes the buffering options that can be applied before data is delivered
	// to the HTTP endpoint destination. Kinesis Data Firehose treats these options
	// as hints, and it might choose to use more optimal values. The SizeInMBs and
	// IntervalInSeconds parameters are optional. However, if specify a value for
	// one of them, you must also provide a value for the other.
	BufferingHints *HTTPEndpointBufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`
	// Describes the configuration of the HTTP endpoint to which Kinesis Firehose
	// delivers data.
	EndpointConfiguration *HTTPEndpointConfiguration `json:"endpointConfiguration,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// The configuration of the HTTP endpoint request.
	RequestConfiguration *HTTPEndpointRequestConfiguration `json:"requestConfiguration,omitempty"`
	// Describes the retry behavior in case Kinesis Data Firehose is unable to deliver
	// data to the specified HTTP endpoint destination, or if it doesn't receive
	// a valid acknowledgment of receipt from the specified HTTP endpoint destination.
	RetryOptions *HTTPEndpointRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
}

+kubebuilder:skipversion

func (*HTTPEndpointDestinationUpdate) DeepCopy 

func (in *HTTPEndpointDestinationUpdate) DeepCopy() *HTTPEndpointDestinationUpdate

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

func (*HTTPEndpointDestinationUpdate) DeepCopyInto 

func (in *HTTPEndpointDestinationUpdate) DeepCopyInto(out *HTTPEndpointDestinationUpdate)

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

type HTTPEndpointRequestConfiguration 

type HTTPEndpointRequestConfiguration struct {
	CommonAttributes []*HTTPEndpointCommonAttribute `json:"commonAttributes,omitempty"`

	ContentEncoding *string `json:"contentEncoding,omitempty"`
}

+kubebuilder:skipversion

func (*HTTPEndpointRequestConfiguration) DeepCopy 

func (in *HTTPEndpointRequestConfiguration) DeepCopy() *HTTPEndpointRequestConfiguration

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

func (*HTTPEndpointRequestConfiguration) DeepCopyInto 

func (in *HTTPEndpointRequestConfiguration) DeepCopyInto(out *HTTPEndpointRequestConfiguration)

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

type HTTPEndpointRetryOptions 

type HTTPEndpointRetryOptions struct {
	DurationInSeconds *int64 `json:"durationInSeconds,omitempty"`
}

+kubebuilder:skipversion

func (*HTTPEndpointRetryOptions) DeepCopy 

func (in *HTTPEndpointRetryOptions) DeepCopy() *HTTPEndpointRetryOptions

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

func (*HTTPEndpointRetryOptions) DeepCopyInto 

func (in *HTTPEndpointRetryOptions) DeepCopyInto(out *HTTPEndpointRetryOptions)

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

type HTTPEndpointS3BackupMode 

type HTTPEndpointS3BackupMode string
const (
	HTTPEndpointS3BackupMode_FailedDataOnly HTTPEndpointS3BackupMode = "FailedDataOnly"
	HTTPEndpointS3BackupMode_AllData        HTTPEndpointS3BackupMode = "AllData"
)

type HiveJSONSerDe 

type HiveJSONSerDe struct {
	TimestampFormats []*string `json:"timestampFormats,omitempty"`
}

+kubebuilder:skipversion

func (*HiveJSONSerDe) DeepCopy 

func (in *HiveJSONSerDe) DeepCopy() *HiveJSONSerDe

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

func (*HiveJSONSerDe) DeepCopyInto 

func (in *HiveJSONSerDe) DeepCopyInto(out *HiveJSONSerDe)

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

type InputFormatConfiguration 

type InputFormatConfiguration struct {
	// The deserializer you want Kinesis Data Firehose to use for converting the
	// input data from JSON. Kinesis Data Firehose then serializes the data to its
	// final format using the Serializer. Kinesis Data Firehose supports two types
	// of deserializers: the Apache Hive JSON SerDe (https://cwiki.apache.org/confluence/display/Hive/LanguageManual+DDL#LanguageManualDDL-JSON)
	// and the OpenX JSON SerDe (https://github.com/rcongiu/Hive-JSON-Serde).
	Deserializer *Deserializer `json:"deserializer,omitempty"`
}

+kubebuilder:skipversion

func (*InputFormatConfiguration) DeepCopy 

func (in *InputFormatConfiguration) DeepCopy() *InputFormatConfiguration

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

func (*InputFormatConfiguration) DeepCopyInto 

func (in *InputFormatConfiguration) DeepCopyInto(out *InputFormatConfiguration)

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

type KMSEncryptionConfig 

type KMSEncryptionConfig struct {
	AWSKMSKeyARN *string `json:"awsKMSKeyARN,omitempty"`
}

+kubebuilder:skipversion

func (*KMSEncryptionConfig) DeepCopy 

func (in *KMSEncryptionConfig) DeepCopy() *KMSEncryptionConfig

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

func (*KMSEncryptionConfig) DeepCopyInto 

func (in *KMSEncryptionConfig) DeepCopyInto(out *KMSEncryptionConfig)

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

type KeyType 

type KeyType string
const (
	KeyType_AWS_OWNED_CMK        KeyType = "AWS_OWNED_CMK"
	KeyType_CUSTOMER_MANAGED_CMK KeyType = "CUSTOMER_MANAGED_CMK"
)

type KinesisStreamSourceConfiguration 

type KinesisStreamSourceConfiguration struct {
	KinesisStreamARN *string `json:"kinesisStreamARN,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`
}

+kubebuilder:skipversion

func (*KinesisStreamSourceConfiguration) DeepCopy 

func (in *KinesisStreamSourceConfiguration) DeepCopy() *KinesisStreamSourceConfiguration

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

func (*KinesisStreamSourceConfiguration) DeepCopyInto 

func (in *KinesisStreamSourceConfiguration) DeepCopyInto(out *KinesisStreamSourceConfiguration)

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

type KinesisStreamSourceDescription 

type KinesisStreamSourceDescription struct {
	DeliveryStartTimestamp *metav1.Time `json:"deliveryStartTimestamp,omitempty"`

	KinesisStreamARN *string `json:"kinesisStreamARN,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`
}

+kubebuilder:skipversion

func (*KinesisStreamSourceDescription) DeepCopy 

func (in *KinesisStreamSourceDescription) DeepCopy() *KinesisStreamSourceDescription

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

func (*KinesisStreamSourceDescription) DeepCopyInto 

func (in *KinesisStreamSourceDescription) DeepCopyInto(out *KinesisStreamSourceDescription)

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

type NoEncryptionConfig 

type NoEncryptionConfig string
const (
	NoEncryptionConfig_NoEncryption NoEncryptionConfig = "NoEncryption"
)

type OpenXJSONSerDe 

type OpenXJSONSerDe struct {
	CaseInsensitive *bool `json:"caseInsensitive,omitempty"`

	ColumnToJSONKeyMappings map[string]*string `json:"columnToJSONKeyMappings,omitempty"`

	ConvertDotsInJSONKeysToUnderscores *bool `json:"convertDotsInJSONKeysToUnderscores,omitempty"`
}

+kubebuilder:skipversion

func (*OpenXJSONSerDe) DeepCopy 

func (in *OpenXJSONSerDe) DeepCopy() *OpenXJSONSerDe

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

func (*OpenXJSONSerDe) DeepCopyInto 

func (in *OpenXJSONSerDe) DeepCopyInto(out *OpenXJSONSerDe)

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

type OrcCompression 

type OrcCompression string
const (
	OrcCompression_NONE   OrcCompression = "NONE"
	OrcCompression_ZLIB   OrcCompression = "ZLIB"
	OrcCompression_SNAPPY OrcCompression = "SNAPPY"
)

type OrcFormatVersion 

type OrcFormatVersion string
const (
	OrcFormatVersion_V0_11 OrcFormatVersion = "V0_11"
	OrcFormatVersion_V0_12 OrcFormatVersion = "V0_12"
)

type OrcSerDe 

type OrcSerDe struct {
	BlockSizeBytes *int64 `json:"blockSizeBytes,omitempty"`

	BloomFilterColumns []*string `json:"bloomFilterColumns,omitempty"`

	BloomFilterFalsePositiveProbability *float64 `json:"bloomFilterFalsePositiveProbability,omitempty"`

	Compression *string `json:"compression,omitempty"`

	DictionaryKeyThreshold *float64 `json:"dictionaryKeyThreshold,omitempty"`

	EnablePadding *bool `json:"enablePadding,omitempty"`

	FormatVersion *string `json:"formatVersion,omitempty"`

	PaddingTolerance *float64 `json:"paddingTolerance,omitempty"`

	RowIndexStride *int64 `json:"rowIndexStride,omitempty"`

	StripeSizeBytes *int64 `json:"stripeSizeBytes,omitempty"`
}

+kubebuilder:skipversion

func (*OrcSerDe) DeepCopy 

func (in *OrcSerDe) DeepCopy() *OrcSerDe

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

func (*OrcSerDe) DeepCopyInto 

func (in *OrcSerDe) DeepCopyInto(out *OrcSerDe)

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

type OutputFormatConfiguration 

type OutputFormatConfiguration struct {
	// The serializer that you want Kinesis Data Firehose to use to convert data
	// to the target format before writing it to Amazon S3. Kinesis Data Firehose
	// supports two types of serializers: the ORC SerDe (https://hive.apache.org/javadocs/r1.2.2/api/org/apache/hadoop/hive/ql/io/orc/OrcSerde.html)
	// and the Parquet SerDe (https://hive.apache.org/javadocs/r1.2.2/api/org/apache/hadoop/hive/ql/io/parquet/serde/ParquetHiveSerDe.html).
	Serializer *Serializer `json:"serializer,omitempty"`
}

+kubebuilder:skipversion

func (*OutputFormatConfiguration) DeepCopy 

func (in *OutputFormatConfiguration) DeepCopy() *OutputFormatConfiguration

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

func (*OutputFormatConfiguration) DeepCopyInto 

func (in *OutputFormatConfiguration) DeepCopyInto(out *OutputFormatConfiguration)

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

type ParquetCompression 

type ParquetCompression string
const (
	ParquetCompression_UNCOMPRESSED ParquetCompression = "UNCOMPRESSED"
	ParquetCompression_GZIP         ParquetCompression = "GZIP"
	ParquetCompression_SNAPPY       ParquetCompression = "SNAPPY"
)

type ParquetSerDe 

type ParquetSerDe struct {
	BlockSizeBytes *int64 `json:"blockSizeBytes,omitempty"`

	Compression *string `json:"compression,omitempty"`

	EnableDictionaryCompression *bool `json:"enableDictionaryCompression,omitempty"`

	MaxPaddingBytes *int64 `json:"maxPaddingBytes,omitempty"`

	PageSizeBytes *int64 `json:"pageSizeBytes,omitempty"`

	WriterVersion *string `json:"writerVersion,omitempty"`
}

+kubebuilder:skipversion

func (*ParquetSerDe) DeepCopy 

func (in *ParquetSerDe) DeepCopy() *ParquetSerDe

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

func (*ParquetSerDe) DeepCopyInto 

func (in *ParquetSerDe) DeepCopyInto(out *ParquetSerDe)

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

type ParquetWriterVersion 

type ParquetWriterVersion string
const (
	ParquetWriterVersion_V1 ParquetWriterVersion = "V1"
	ParquetWriterVersion_V2 ParquetWriterVersion = "V2"
)

type ProcessingConfiguration 

type ProcessingConfiguration struct {
	Enabled *bool `json:"enabled,omitempty"`

	Processors []*Processor `json:"processors,omitempty"`
}

+kubebuilder:skipversion

func (*ProcessingConfiguration) DeepCopy 

func (in *ProcessingConfiguration) DeepCopy() *ProcessingConfiguration

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

func (*ProcessingConfiguration) DeepCopyInto 

func (in *ProcessingConfiguration) DeepCopyInto(out *ProcessingConfiguration)

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

type Processor 

type Processor struct {
	Parameters []*ProcessorParameter `json:"parameters,omitempty"`

	Type *string `json:"type_,omitempty"`
}

+kubebuilder:skipversion

func (*Processor) DeepCopy 

func (in *Processor) DeepCopy() *Processor

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

func (*Processor) DeepCopyInto 

func (in *Processor) DeepCopyInto(out *Processor)

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

type ProcessorParameter 

type ProcessorParameter struct {
	ParameterName *string `json:"parameterName,omitempty"`

	ParameterValue *string `json:"parameterValue,omitempty"`
}

+kubebuilder:skipversion

func (*ProcessorParameter) DeepCopy 

func (in *ProcessorParameter) DeepCopy() *ProcessorParameter

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

func (*ProcessorParameter) DeepCopyInto 

func (in *ProcessorParameter) DeepCopyInto(out *ProcessorParameter)

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

type ProcessorParameterName 

type ProcessorParameterName string
const (
	ProcessorParameterName_LambdaArn               ProcessorParameterName = "LambdaArn"
	ProcessorParameterName_NumberOfRetries         ProcessorParameterName = "NumberOfRetries"
	ProcessorParameterName_MetadataExtractionQuery ProcessorParameterName = "MetadataExtractionQuery"
	ProcessorParameterName_JsonParsingEngine       ProcessorParameterName = "JsonParsingEngine"
	ProcessorParameterName_RoleArn                 ProcessorParameterName = "RoleArn"
	ProcessorParameterName_BufferSizeInMBs         ProcessorParameterName = "BufferSizeInMBs"
	ProcessorParameterName_BufferIntervalInSeconds ProcessorParameterName = "BufferIntervalInSeconds"
	ProcessorParameterName_SubRecordType           ProcessorParameterName = "SubRecordType"
	ProcessorParameterName_Delimiter               ProcessorParameterName = "Delimiter"
)

type ProcessorType 

type ProcessorType string
const (
	ProcessorType_RecordDeAggregation     ProcessorType = "RecordDeAggregation"
	ProcessorType_Lambda                  ProcessorType = "Lambda"
	ProcessorType_MetadataExtraction      ProcessorType = "MetadataExtraction"
	ProcessorType_AppendDelimiterToRecord ProcessorType = "AppendDelimiterToRecord"
)

type RedshiftDestinationConfiguration 

type RedshiftDestinationConfiguration struct {
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	ClusterJDBCURL *string `json:"clusterJDBCURL,omitempty"`
	// Describes a COPY command for Amazon Redshift.
	CopyCommand *CopyCommand `json:"copyCommand,omitempty"`

	Password *string `json:"password,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to Amazon Redshift.
	RetryOptions *RedshiftRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`
	// Describes the configuration of a destination in Amazon S3.
	S3BackupConfiguration *S3DestinationConfiguration `json:"s3BackupConfiguration,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
	// Describes the configuration of a destination in Amazon S3.
	S3Configuration *S3DestinationConfiguration `json:"s3Configuration,omitempty"`

	Username *string `json:"username,omitempty"`
}

+kubebuilder:skipversion

func (*RedshiftDestinationConfiguration) DeepCopy 

func (in *RedshiftDestinationConfiguration) DeepCopy() *RedshiftDestinationConfiguration

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

func (*RedshiftDestinationConfiguration) DeepCopyInto 

func (in *RedshiftDestinationConfiguration) DeepCopyInto(out *RedshiftDestinationConfiguration)

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

type RedshiftDestinationDescription 

type RedshiftDestinationDescription struct {
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	ClusterJDBCURL *string `json:"clusterJDBCURL,omitempty"`
	// Describes a COPY command for Amazon Redshift.
	CopyCommand *CopyCommand `json:"copyCommand,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to Amazon Redshift.
	RetryOptions *RedshiftRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`
	// Describes a destination in Amazon S3.
	S3BackupDescription *S3DestinationDescription `json:"s3BackupDescription,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
	// Describes a destination in Amazon S3.
	S3DestinationDescription *S3DestinationDescription `json:"s3DestinationDescription,omitempty"`

	Username *string `json:"username,omitempty"`
}

+kubebuilder:skipversion

func (*RedshiftDestinationDescription) DeepCopy 

func (in *RedshiftDestinationDescription) DeepCopy() *RedshiftDestinationDescription

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

func (*RedshiftDestinationDescription) DeepCopyInto 

func (in *RedshiftDestinationDescription) DeepCopyInto(out *RedshiftDestinationDescription)

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

type RedshiftDestinationUpdate 

type RedshiftDestinationUpdate struct {
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	ClusterJDBCURL *string `json:"clusterJDBCURL,omitempty"`
	// Describes a COPY command for Amazon Redshift.
	CopyCommand *CopyCommand `json:"copyCommand,omitempty"`

	Password *string `json:"password,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to Amazon Redshift.
	RetryOptions *RedshiftRetryOptions `json:"retryOptions,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`

	Username *string `json:"username,omitempty"`
}

+kubebuilder:skipversion

func (*RedshiftDestinationUpdate) DeepCopy 

func (in *RedshiftDestinationUpdate) DeepCopy() *RedshiftDestinationUpdate

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

func (*RedshiftDestinationUpdate) DeepCopyInto 

func (in *RedshiftDestinationUpdate) DeepCopyInto(out *RedshiftDestinationUpdate)

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

type RedshiftRetryOptions 

type RedshiftRetryOptions struct {
	DurationInSeconds *int64 `json:"durationInSeconds,omitempty"`
}

+kubebuilder:skipversion

func (*RedshiftRetryOptions) DeepCopy 

func (in *RedshiftRetryOptions) DeepCopy() *RedshiftRetryOptions

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

func (*RedshiftRetryOptions) DeepCopyInto 

func (in *RedshiftRetryOptions) DeepCopyInto(out *RedshiftRetryOptions)

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

type RedshiftS3BackupMode 

type RedshiftS3BackupMode string
const (
	RedshiftS3BackupMode_Disabled RedshiftS3BackupMode = "Disabled"
	RedshiftS3BackupMode_Enabled  RedshiftS3BackupMode = "Enabled"
)

type RetryOptions 

type RetryOptions struct {
	DurationInSeconds *int64 `json:"durationInSeconds,omitempty"`
}

+kubebuilder:skipversion

func (*RetryOptions) DeepCopy 

func (in *RetryOptions) DeepCopy() *RetryOptions

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

func (*RetryOptions) DeepCopyInto 

func (in *RetryOptions) DeepCopyInto(out *RetryOptions)

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

type S3BackupMode 

type S3BackupMode string
const (
	S3BackupMode_Disabled S3BackupMode = "Disabled"
	S3BackupMode_Enabled  S3BackupMode = "Enabled"
)

type S3DestinationConfiguration 

type S3DestinationConfiguration struct {
	BucketARN *string `json:"bucketARN,omitempty"`
	// Describes hints for the buffering to perform before delivering data to the
	// destination. These options are treated as hints, and therefore Kinesis Data
	// Firehose might choose to use different values when it is optimal. The SizeInMBs
	// and IntervalInSeconds parameters are optional. However, if specify a value
	// for one of them, you must also provide a value for the other.
	BufferingHints *BufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	CompressionFormat *string `json:"compressionFormat,omitempty"`
	// Describes the encryption for a destination in Amazon S3.
	EncryptionConfiguration *EncryptionConfiguration `json:"encryptionConfiguration,omitempty"`

	ErrorOutputPrefix *string `json:"errorOutputPrefix,omitempty"`

	Prefix *string `json:"prefix,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`
}

+kubebuilder:skipversion

func (*S3DestinationConfiguration) DeepCopy 

func (in *S3DestinationConfiguration) DeepCopy() *S3DestinationConfiguration

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

func (*S3DestinationConfiguration) DeepCopyInto 

func (in *S3DestinationConfiguration) DeepCopyInto(out *S3DestinationConfiguration)

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

type S3DestinationDescription 

type S3DestinationDescription struct {
	BucketARN *string `json:"bucketARN,omitempty"`
	// Describes hints for the buffering to perform before delivering data to the
	// destination. These options are treated as hints, and therefore Kinesis Data
	// Firehose might choose to use different values when it is optimal. The SizeInMBs
	// and IntervalInSeconds parameters are optional. However, if specify a value
	// for one of them, you must also provide a value for the other.
	BufferingHints *BufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	CompressionFormat *string `json:"compressionFormat,omitempty"`
	// Describes the encryption for a destination in Amazon S3.
	EncryptionConfiguration *EncryptionConfiguration `json:"encryptionConfiguration,omitempty"`

	ErrorOutputPrefix *string `json:"errorOutputPrefix,omitempty"`

	Prefix *string `json:"prefix,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`
}

+kubebuilder:skipversion

func (*S3DestinationDescription) DeepCopy 

func (in *S3DestinationDescription) DeepCopy() *S3DestinationDescription

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

func (*S3DestinationDescription) DeepCopyInto 

func (in *S3DestinationDescription) DeepCopyInto(out *S3DestinationDescription)

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

type S3DestinationUpdate 

type S3DestinationUpdate struct {
	BucketARN *string `json:"bucketARN,omitempty"`
	// Describes hints for the buffering to perform before delivering data to the
	// destination. These options are treated as hints, and therefore Kinesis Data
	// Firehose might choose to use different values when it is optimal. The SizeInMBs
	// and IntervalInSeconds parameters are optional. However, if specify a value
	// for one of them, you must also provide a value for the other.
	BufferingHints *BufferingHints `json:"bufferingHints,omitempty"`
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	CompressionFormat *string `json:"compressionFormat,omitempty"`
	// Describes the encryption for a destination in Amazon S3.
	EncryptionConfiguration *EncryptionConfiguration `json:"encryptionConfiguration,omitempty"`

	ErrorOutputPrefix *string `json:"errorOutputPrefix,omitempty"`

	Prefix *string `json:"prefix,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`
}

+kubebuilder:skipversion

func (*S3DestinationUpdate) DeepCopy 

func (in *S3DestinationUpdate) DeepCopy() *S3DestinationUpdate

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

func (*S3DestinationUpdate) DeepCopyInto 

func (in *S3DestinationUpdate) DeepCopyInto(out *S3DestinationUpdate)

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

type SchemaConfiguration 

type SchemaConfiguration struct {
	CatalogID *string `json:"catalogID,omitempty"`

	DatabaseName *string `json:"databaseName,omitempty"`

	Region *string `json:"region,omitempty"`

	RoleARN *string `json:"roleARN,omitempty"`

	TableName *string `json:"tableName,omitempty"`

	VersionID *string `json:"versionID,omitempty"`
}

+kubebuilder:skipversion

func (*SchemaConfiguration) DeepCopy 

func (in *SchemaConfiguration) DeepCopy() *SchemaConfiguration

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

func (*SchemaConfiguration) DeepCopyInto 

func (in *SchemaConfiguration) DeepCopyInto(out *SchemaConfiguration)

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

type Serializer 

type Serializer struct {
	// A serializer to use for converting data to the ORC format before storing
	// it in Amazon S3. For more information, see Apache ORC (https://orc.apache.org/docs/).
	OrcSerDe *OrcSerDe `json:"orcSerDe,omitempty"`
	// A serializer to use for converting data to the Parquet format before storing
	// it in Amazon S3. For more information, see Apache Parquet (https://parquet.apache.org/documentation/latest/).
	ParquetSerDe *ParquetSerDe `json:"parquetSerDe,omitempty"`
}

+kubebuilder:skipversion

func (*Serializer) DeepCopy 

func (in *Serializer) DeepCopy() *Serializer

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

func (*Serializer) DeepCopyInto 

func (in *Serializer) DeepCopyInto(out *Serializer)

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

type SourceDescription 

type SourceDescription struct {
	// Details about a Kinesis data stream used as the source for a Kinesis Data
	// Firehose delivery stream.
	KinesisStreamSourceDescription *KinesisStreamSourceDescription `json:"kinesisStreamSourceDescription,omitempty"`
}

+kubebuilder:skipversion

func (*SourceDescription) DeepCopy 

func (in *SourceDescription) DeepCopy() *SourceDescription

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

func (*SourceDescription) DeepCopyInto 

func (in *SourceDescription) DeepCopyInto(out *SourceDescription)

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

type SplunkDestinationConfiguration 

type SplunkDestinationConfiguration struct {
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	HECAcknowledgmentTimeoutInSeconds *int64 `json:"hECAcknowledgmentTimeoutInSeconds,omitempty"`

	HECEndpoint *string `json:"hECEndpoint,omitempty"`

	HECEndpointType *string `json:"hECEndpointType,omitempty"`

	HECToken *string `json:"hECToken,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to Splunk, or if it doesn't receive an acknowledgment from Splunk.
	RetryOptions *SplunkRetryOptions `json:"retryOptions,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
	// Describes the configuration of a destination in Amazon S3.
	S3Configuration *S3DestinationConfiguration `json:"s3Configuration,omitempty"`
}

+kubebuilder:skipversion

func (*SplunkDestinationConfiguration) DeepCopy 

func (in *SplunkDestinationConfiguration) DeepCopy() *SplunkDestinationConfiguration

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

func (*SplunkDestinationConfiguration) DeepCopyInto 

func (in *SplunkDestinationConfiguration) DeepCopyInto(out *SplunkDestinationConfiguration)

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

type SplunkDestinationDescription 

type SplunkDestinationDescription struct {
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	HECAcknowledgmentTimeoutInSeconds *int64 `json:"hECAcknowledgmentTimeoutInSeconds,omitempty"`

	HECEndpoint *string `json:"hECEndpoint,omitempty"`

	HECEndpointType *string `json:"hECEndpointType,omitempty"`

	HECToken *string `json:"hECToken,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to Splunk, or if it doesn't receive an acknowledgment from Splunk.
	RetryOptions *SplunkRetryOptions `json:"retryOptions,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
	// Describes a destination in Amazon S3.
	S3DestinationDescription *S3DestinationDescription `json:"s3DestinationDescription,omitempty"`
}

+kubebuilder:skipversion

func (*SplunkDestinationDescription) DeepCopy 

func (in *SplunkDestinationDescription) DeepCopy() *SplunkDestinationDescription

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

func (*SplunkDestinationDescription) DeepCopyInto 

func (in *SplunkDestinationDescription) DeepCopyInto(out *SplunkDestinationDescription)

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

type SplunkDestinationUpdate 

type SplunkDestinationUpdate struct {
	// Describes the Amazon CloudWatch logging options for your delivery stream.
	CloudWatchLoggingOptions *CloudWatchLoggingOptions `json:"cloudWatchLoggingOptions,omitempty"`

	HECAcknowledgmentTimeoutInSeconds *int64 `json:"hECAcknowledgmentTimeoutInSeconds,omitempty"`

	HECEndpoint *string `json:"hECEndpoint,omitempty"`

	HECEndpointType *string `json:"hECEndpointType,omitempty"`

	HECToken *string `json:"hECToken,omitempty"`
	// Describes a data processing configuration.
	ProcessingConfiguration *ProcessingConfiguration `json:"processingConfiguration,omitempty"`
	// Configures retry behavior in case Kinesis Data Firehose is unable to deliver
	// documents to Splunk, or if it doesn't receive an acknowledgment from Splunk.
	RetryOptions *SplunkRetryOptions `json:"retryOptions,omitempty"`

	S3BackupMode *string `json:"s3BackupMode,omitempty"`
}

+kubebuilder:skipversion

func (*SplunkDestinationUpdate) DeepCopy 

func (in *SplunkDestinationUpdate) DeepCopy() *SplunkDestinationUpdate

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

func (*SplunkDestinationUpdate) DeepCopyInto 

func (in *SplunkDestinationUpdate) DeepCopyInto(out *SplunkDestinationUpdate)

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

type SplunkRetryOptions 

type SplunkRetryOptions struct {
	DurationInSeconds *int64 `json:"durationInSeconds,omitempty"`
}

+kubebuilder:skipversion

func (*SplunkRetryOptions) DeepCopy 

func (in *SplunkRetryOptions) DeepCopy() *SplunkRetryOptions

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

func (*SplunkRetryOptions) DeepCopyInto 

func (in *SplunkRetryOptions) DeepCopyInto(out *SplunkRetryOptions)

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

type SplunkS3BackupMode 

type SplunkS3BackupMode string
const (
	SplunkS3BackupMode_FailedEventsOnly SplunkS3BackupMode = "FailedEventsOnly"
	SplunkS3BackupMode_AllEvents        SplunkS3BackupMode = "AllEvents"
)

type Tag 

type Tag struct {
	Key *string `json:"key,omitempty"`

	Value *string `json:"value,omitempty"`
}

+kubebuilder:skipversion

func (*Tag) DeepCopy 

func (in *Tag) DeepCopy() *Tag

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

func (*Tag) DeepCopyInto 

func (in *Tag) DeepCopyInto(out *Tag)

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

type VPCConfiguration 

type VPCConfiguration struct {
	RoleARN *string `json:"roleARN,omitempty"`

	SecurityGroupIDs []*string `json:"securityGroupIDs,omitempty"`

	SubnetIDs []*string `json:"subnetIDs,omitempty"`
}

+kubebuilder:skipversion

func (*VPCConfiguration) DeepCopy 

func (in *VPCConfiguration) DeepCopy() *VPCConfiguration

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

func (*VPCConfiguration) DeepCopyInto 

func (in *VPCConfiguration) DeepCopyInto(out *VPCConfiguration)

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

type VPCConfigurationDescription 

type VPCConfigurationDescription struct {
	RoleARN *string `json:"roleARN,omitempty"`

	SecurityGroupIDs []*string `json:"securityGroupIDs,omitempty"`

	SubnetIDs []*string `json:"subnetIDs,omitempty"`

	VPCID *string `json:"vpcID,omitempty"`
}

+kubebuilder:skipversion

func (*VPCConfigurationDescription) DeepCopy 

func (in *VPCConfigurationDescription) DeepCopy() *VPCConfigurationDescription

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

func (*VPCConfigurationDescription) DeepCopyInto 

func (in *VPCConfigurationDescription) DeepCopyInto(out *VPCConfigurationDescription)

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.