Documentation
¶
Index ¶
- Constants
- Variables
- type AmazonOpenSearchServerlessBufferingHints
- type AmazonOpenSearchServerlessDestinationConfiguration
- type AmazonOpenSearchServerlessDestinationDescription
- type AmazonOpenSearchServerlessDestinationUpdate
- type AmazonOpenSearchServerlessRetryOptions
- type AmazonOpenSearchServerlessS3BackupMode
- type AmazonopensearchserviceBufferingHints
- type AmazonopensearchserviceDestinationConfiguration
- type AmazonopensearchserviceDestinationDescription
- type AmazonopensearchserviceDestinationUpdate
- type AmazonopensearchserviceIndexRotationPeriod
- type AmazonopensearchserviceRetryOptions
- type AmazonopensearchserviceS3BackupMode
- type AuthenticationConfiguration
- type BufferingHints
- type CloudWatchLoggingOptions
- type CompressionFormat
- type Connectivity
- type ContentEncoding
- type CopyCommand
- type CustomDeliveryStreamParameters
- type DataFormatConversionConfiguration
- type DefaultDocumentIDFormat
- type DeliveryStream
- func (in *DeliveryStream) DeepCopy() *DeliveryStream
- func (in *DeliveryStream) DeepCopyInto(out *DeliveryStream)
- func (in *DeliveryStream) DeepCopyObject() runtime.Object
- func (mg *DeliveryStream) GetCondition(ct xpv1.ConditionType) xpv1.Condition
- func (mg *DeliveryStream) GetDeletionPolicy() xpv1.DeletionPolicy
- func (mg *DeliveryStream) GetManagementPolicies() xpv1.ManagementPolicies
- func (mg *DeliveryStream) GetProviderConfigReference() *xpv1.Reference
- func (mg *DeliveryStream) GetPublishConnectionDetailsTo() *xpv1.PublishConnectionDetailsTo
- func (mg *DeliveryStream) GetWriteConnectionSecretToReference() *xpv1.SecretReference
- func (mg *DeliveryStream) ResolveReferences(ctx context.Context, c client.Reader) error
- func (mg *DeliveryStream) SetConditions(c ...xpv1.Condition)
- func (mg *DeliveryStream) SetDeletionPolicy(r xpv1.DeletionPolicy)
- func (mg *DeliveryStream) SetManagementPolicies(r xpv1.ManagementPolicies)
- func (mg *DeliveryStream) SetProviderConfigReference(r *xpv1.Reference)
- func (mg *DeliveryStream) SetPublishConnectionDetailsTo(r *xpv1.PublishConnectionDetailsTo)
- func (mg *DeliveryStream) SetWriteConnectionSecretToReference(r *xpv1.SecretReference)
- type DeliveryStreamDescription
- type DeliveryStreamEncryptionConfiguration
- type DeliveryStreamEncryptionConfigurationInput
- type DeliveryStreamEncryptionStatus
- type DeliveryStreamFailureType
- type DeliveryStreamList
- type DeliveryStreamObservation
- type DeliveryStreamParameters
- type DeliveryStreamSpec
- type DeliveryStreamStatus
- type DeliveryStreamStatus_SDK
- type DeliveryStreamType
- type Deserializer
- type DestinationDescription
- type DocumentIDOptions
- type DynamicPartitioningConfiguration
- type ElasticsearchBufferingHints
- type ElasticsearchDestinationConfiguration
- type ElasticsearchDestinationDescription
- type ElasticsearchDestinationUpdate
- type ElasticsearchIndexRotationPeriod
- type ElasticsearchRetryOptions
- type ElasticsearchS3BackupMode
- type EncryptionConfiguration
- type ExtendedS3DestinationConfiguration
- type ExtendedS3DestinationDescription
- type ExtendedS3DestinationUpdate
- type FailureDescription
- type HECEndpointType
- type HTTPEndpointBufferingHints
- type HTTPEndpointCommonAttribute
- type HTTPEndpointConfiguration
- type HTTPEndpointDescription
- type HTTPEndpointDestinationConfiguration
- type HTTPEndpointDestinationDescription
- type HTTPEndpointDestinationUpdate
- type HTTPEndpointRequestConfiguration
- type HTTPEndpointRetryOptions
- type HTTPEndpointS3BackupMode
- type HiveJSONSerDe
- type InputFormatConfiguration
- type KMSEncryptionConfig
- type KeyType
- type KinesisStreamSourceConfiguration
- type KinesisStreamSourceDescription
- type MSKSourceConfiguration
- type MSKSourceDescription
- type NoEncryptionConfig
- type OpenXJSONSerDe
- type OrcCompression
- type OrcFormatVersion
- type OrcSerDe
- type OutputFormatConfiguration
- type ParquetCompression
- type ParquetSerDe
- type ParquetWriterVersion
- type ProcessingConfiguration
- type Processor
- type ProcessorParameter
- type ProcessorParameterName
- type ProcessorType
- type RedshiftDestinationConfiguration
- type RedshiftDestinationDescription
- type RedshiftDestinationUpdate
- type RedshiftRetryOptions
- type RedshiftS3BackupMode
- type RetryOptions
- type S3BackupMode
- type S3DestinationConfiguration
- type S3DestinationDescription
- type S3DestinationUpdate
- type SchemaConfiguration
- type Serializer
- type SourceDescription
- type SplunkDestinationConfiguration
- type SplunkDestinationDescription
- type SplunkDestinationUpdate
- type SplunkRetryOptions
- type SplunkS3BackupMode
- type Tag
- type VPCConfiguration
- type VPCConfigurationDescription
Constants ¶
const ( CRDGroup = "firehose.aws.crossplane.io" CRDVersion = "v1alpha1" )
Package type metadata.
Variables ¶
var ( DeliveryStreamKind = "DeliveryStream" DeliveryStreamGroupKind = schema.GroupKind{Group: CRDGroup, Kind: DeliveryStreamKind}.String() DeliveryStreamKindAPIVersion = DeliveryStreamKind + "." + GroupVersion.String() DeliveryStreamGroupVersionKind = GroupVersion.WithKind(DeliveryStreamKind) )
Repository type metadata.
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 OpenSearch or Amazon OpenSearch Serverless
// 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"`
// Indicates the method for setting up document ID. The supported methods are
// Kinesis Data Firehose generated document ID and OpenSearch Service generated
// document ID.
DocumentIDOptions *DocumentIDOptions `json:"documentIDOptions,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 OpenSearch or Amazon OpenSearch Serverless
// 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"`
// Indicates the method for setting up document ID. The supported methods are
// Kinesis Data Firehose generated document ID and OpenSearch Service generated
// document ID.
DocumentIDOptions *DocumentIDOptions `json:"documentIDOptions,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"`
// Indicates the method for setting up document ID. The supported methods are
// Kinesis Data Firehose generated document ID and OpenSearch Service generated
// document ID.
DocumentIDOptions *DocumentIDOptions `json:"documentIDOptions,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 AuthenticationConfiguration ¶ added in v0.51.0
type AuthenticationConfiguration struct {
Connectivity *string `json:"connectivity,omitempty"`
RoleARN *string `json:"roleARN,omitempty"`
}
+kubebuilder:skipversion
func (*AuthenticationConfiguration) DeepCopy ¶ added in v0.51.0
func (in *AuthenticationConfiguration) DeepCopy() *AuthenticationConfiguration
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new AuthenticationConfiguration.
func (*AuthenticationConfiguration) DeepCopyInto ¶ added in v0.51.0
func (in *AuthenticationConfiguration) DeepCopyInto(out *AuthenticationConfiguration)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
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 Connectivity ¶ added in v0.51.0
type Connectivity string
const ( Connectivity_PUBLIC Connectivity = "PUBLIC" Connectivity_PRIVATE Connectivity = "PRIVATE" )
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 DefaultDocumentIDFormat ¶ added in v0.51.0
type DefaultDocumentIDFormat string
const ( DefaultDocumentIDFormat_FIREHOSE_DEFAULT DefaultDocumentIDFormat = "FIREHOSE_DEFAULT" DefaultDocumentIDFormat_NO_DOCUMENT_ID DefaultDocumentIDFormat = "NO_DOCUMENT_ID" )
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 ¶
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"`
MSKSourceConfiguration *MSKSourceConfiguration `json:"mSKSourceConfiguration,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" DeliveryStreamType_MSKAsSource DeliveryStreamType = "MSKAsSource" )
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 DocumentIDOptions ¶ added in v0.51.0
type DocumentIDOptions struct {
DefaultDocumentIDFormat *string `json:"defaultDocumentIDFormat,omitempty"`
}
+kubebuilder:skipversion
func (*DocumentIDOptions) DeepCopy ¶ added in v0.51.0
func (in *DocumentIDOptions) DeepCopy() *DocumentIDOptions
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new DocumentIDOptions.
func (*DocumentIDOptions) DeepCopyInto ¶ added in v0.51.0
func (in *DocumentIDOptions) DeepCopyInto(out *DocumentIDOptions)
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"`
// Indicates the method for setting up document ID. The supported methods are
// Kinesis Data Firehose generated document ID and OpenSearch Service generated
// document ID.
DocumentIDOptions *DocumentIDOptions `json:"documentIDOptions,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 OpenSearch or Amazon OpenSearch Serverless
// 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"`
// Indicates the method for setting up document ID. The supported methods are
// Kinesis Data Firehose generated document ID and OpenSearch Service generated
// document ID.
DocumentIDOptions *DocumentIDOptions `json:"documentIDOptions,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"`
// Indicates the method for setting up document ID. The supported methods are
// Kinesis Data Firehose generated document ID and OpenSearch Service generated
// document ID.
DocumentIDOptions *DocumentIDOptions `json:"documentIDOptions,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 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 MSKSourceConfiguration ¶ added in v0.51.0
type MSKSourceConfiguration struct {
// The authentication configuration of the Amazon MSK cluster.
AuthenticationConfiguration *AuthenticationConfiguration `json:"authenticationConfiguration,omitempty"`
MSKClusterARN *string `json:"mSKClusterARN,omitempty"`
TopicName *string `json:"topicName,omitempty"`
}
+kubebuilder:skipversion
func (*MSKSourceConfiguration) DeepCopy ¶ added in v0.51.0
func (in *MSKSourceConfiguration) DeepCopy() *MSKSourceConfiguration
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MSKSourceConfiguration.
func (*MSKSourceConfiguration) DeepCopyInto ¶ added in v0.51.0
func (in *MSKSourceConfiguration) DeepCopyInto(out *MSKSourceConfiguration)
DeepCopyInto is an autogenerated deepcopy function, copying the receiver, writing into out. in must be non-nil.
type MSKSourceDescription ¶ added in v0.51.0
type MSKSourceDescription struct {
// The authentication configuration of the Amazon MSK cluster.
AuthenticationConfiguration *AuthenticationConfiguration `json:"authenticationConfiguration,omitempty"`
DeliveryStartTimestamp *metav1.Time `json:"deliveryStartTimestamp,omitempty"`
MSKClusterARN *string `json:"mSKClusterARN,omitempty"`
TopicName *string `json:"topicName,omitempty"`
}
+kubebuilder:skipversion
func (*MSKSourceDescription) DeepCopy ¶ added in v0.51.0
func (in *MSKSourceDescription) DeepCopy() *MSKSourceDescription
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new MSKSourceDescription.
func (*MSKSourceDescription) DeepCopyInto ¶ added in v0.51.0
func (in *MSKSourceDescription) DeepCopyInto(out *MSKSourceDescription)
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new OrcSerDe.
func (*OrcSerDe) DeepCopyInto ¶
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 ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Processor.
func (*Processor) DeepCopyInto ¶
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" ProcessorParameterName_CompressionFormat ProcessorParameterName = "CompressionFormat" )
type ProcessorType ¶
type ProcessorType string
const ( ProcessorType_RecordDeAggregation ProcessorType = "RecordDeAggregation" ProcessorType_Decompression ProcessorType = "Decompression" 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"`
// Details about the Amazon MSK cluster used as the source for a Kinesis Data
// Firehose delivery stream.
MSKSourceDescription *MSKSourceDescription `json:"mSKSourceDescription,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 ¶
+kubebuilder:skipversion
func (*Tag) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Tag.
func (*Tag) DeepCopyInto ¶
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.