awskinesisfirehose

package
v1.124.0-devpreview Latest Latest
Warning

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

 Go to latest Published: Sep 21, 2021 License: Apache-2.0 Imports: 12 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CfnDeliveryStream_CFN_RESOURCE_TYPE_NAME 

func CfnDeliveryStream_CFN_RESOURCE_TYPE_NAME() *string

func CfnDeliveryStream_IsCfnElement 

func CfnDeliveryStream_IsCfnElement(x interface{}) *bool

Returns `true` if a construct is a stack element (i.e. part of the synthesized cloudformation template).

Uses duck-typing instead of `instanceof` to allow stack elements from different versions of this library to be included in the same stack.

Returns: The construct as a stack element or undefined if it is not a stack element. Experimental.

func CfnDeliveryStream_IsCfnResource 

func CfnDeliveryStream_IsCfnResource(construct constructs.IConstruct) *bool

Check whether the given construct is a CfnResource. Experimental.

func CfnDeliveryStream_IsConstruct 

func CfnDeliveryStream_IsConstruct(x interface{}) *bool

Return whether the given object is a Construct. Experimental.

func DeliveryStream_IsConstruct 

func DeliveryStream_IsConstruct(x interface{}) *bool

Return whether the given object is a Construct. Experimental.

func DeliveryStream_IsResource 

func DeliveryStream_IsResource(construct awscdk.IConstruct) *bool

Check whether the given construct is a Resource. Experimental.

func NewCfnDeliveryStream_Override 

func NewCfnDeliveryStream_Override(c CfnDeliveryStream, scope awscdk.Construct, id *string, props *CfnDeliveryStreamProps)

Create a new `AWS::KinesisFirehose::DeliveryStream`.

func NewDeliveryStream_Override 

func NewDeliveryStream_Override(d DeliveryStream, scope constructs.Construct, id *string, props *DeliveryStreamProps)

Experimental.

func NewLambdaFunctionProcessor_Override 

func NewLambdaFunctionProcessor_Override(l LambdaFunctionProcessor, lambdaFunction awslambda.IFunction, props *DataProcessorProps)

Experimental.

Types

type CfnDeliveryStream 

type CfnDeliveryStream interface {
	awscdk.CfnResource
	awscdk.IInspectable
	AttrArn() *string
	CfnOptions() awscdk.ICfnResourceOptions
	CfnProperties() *map[string]interface{}
	CfnResourceType() *string
	CreationStack() *[]*string
	DeliveryStreamEncryptionConfigurationInput() interface{}
	SetDeliveryStreamEncryptionConfigurationInput(val interface{})
	DeliveryStreamName() *string
	SetDeliveryStreamName(val *string)
	DeliveryStreamType() *string
	SetDeliveryStreamType(val *string)
	ElasticsearchDestinationConfiguration() interface{}
	SetElasticsearchDestinationConfiguration(val interface{})
	ExtendedS3DestinationConfiguration() interface{}
	SetExtendedS3DestinationConfiguration(val interface{})
	HttpEndpointDestinationConfiguration() interface{}
	SetHttpEndpointDestinationConfiguration(val interface{})
	KinesisStreamSourceConfiguration() interface{}
	SetKinesisStreamSourceConfiguration(val interface{})
	LogicalId() *string
	Node() awscdk.ConstructNode
	RedshiftDestinationConfiguration() interface{}
	SetRedshiftDestinationConfiguration(val interface{})
	Ref() *string
	S3DestinationConfiguration() interface{}
	SetS3DestinationConfiguration(val interface{})
	SplunkDestinationConfiguration() interface{}
	SetSplunkDestinationConfiguration(val interface{})
	Stack() awscdk.Stack
	Tags() awscdk.TagManager
	UpdatedProperites() *map[string]interface{}
	AddDeletionOverride(path *string)
	AddDependsOn(target awscdk.CfnResource)
	AddMetadata(key *string, value interface{})
	AddOverride(path *string, value interface{})
	AddPropertyDeletionOverride(propertyPath *string)
	AddPropertyOverride(propertyPath *string, value interface{})
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy, options *awscdk.RemovalPolicyOptions)
	GetAtt(attributeName *string) awscdk.Reference
	GetMetadata(key *string) interface{}
	Inspect(inspector awscdk.TreeInspector)
	OnPrepare()
	OnSynthesize(session constructs.ISynthesisSession)
	OnValidate() *[]*string
	OverrideLogicalId(newLogicalId *string)
	Prepare()
	RenderProperties(props *map[string]interface{}) *map[string]interface{}
	ShouldSynthesize() *bool
	Synthesize(session awscdk.ISynthesisSession)
	ToString() *string
	Validate() *[]*string
	ValidateProperties(_properties interface{})
}

A CloudFormation `AWS::KinesisFirehose::DeliveryStream`.

func NewCfnDeliveryStream 

func NewCfnDeliveryStream(scope awscdk.Construct, id *string, props *CfnDeliveryStreamProps) CfnDeliveryStream

Create a new `AWS::KinesisFirehose::DeliveryStream`.

type CfnDeliveryStreamProps 

type CfnDeliveryStreamProps struct {
	// `AWS::KinesisFirehose::DeliveryStream.DeliveryStreamEncryptionConfigurationInput`.
	DeliveryStreamEncryptionConfigurationInput interface{} `json:"deliveryStreamEncryptionConfigurationInput"`
	// `AWS::KinesisFirehose::DeliveryStream.DeliveryStreamName`.
	DeliveryStreamName *string `json:"deliveryStreamName"`
	// `AWS::KinesisFirehose::DeliveryStream.DeliveryStreamType`.
	DeliveryStreamType *string `json:"deliveryStreamType"`
	// `AWS::KinesisFirehose::DeliveryStream.ElasticsearchDestinationConfiguration`.
	ElasticsearchDestinationConfiguration interface{} `json:"elasticsearchDestinationConfiguration"`
	// `AWS::KinesisFirehose::DeliveryStream.ExtendedS3DestinationConfiguration`.
	ExtendedS3DestinationConfiguration interface{} `json:"extendedS3DestinationConfiguration"`
	// `AWS::KinesisFirehose::DeliveryStream.HttpEndpointDestinationConfiguration`.
	HttpEndpointDestinationConfiguration interface{} `json:"httpEndpointDestinationConfiguration"`
	// `AWS::KinesisFirehose::DeliveryStream.KinesisStreamSourceConfiguration`.
	KinesisStreamSourceConfiguration interface{} `json:"kinesisStreamSourceConfiguration"`
	// `AWS::KinesisFirehose::DeliveryStream.RedshiftDestinationConfiguration`.
	RedshiftDestinationConfiguration interface{} `json:"redshiftDestinationConfiguration"`
	// `AWS::KinesisFirehose::DeliveryStream.S3DestinationConfiguration`.
	S3DestinationConfiguration interface{} `json:"s3DestinationConfiguration"`
	// `AWS::KinesisFirehose::DeliveryStream.SplunkDestinationConfiguration`.
	SplunkDestinationConfiguration interface{} `json:"splunkDestinationConfiguration"`
	// `AWS::KinesisFirehose::DeliveryStream.Tags`.
	Tags *[]*awscdk.CfnTag `json:"tags"`
}

Properties for defining a `AWS::KinesisFirehose::DeliveryStream`.

type CfnDeliveryStream_BufferingHintsProperty 

type CfnDeliveryStream_BufferingHintsProperty struct {
	// `CfnDeliveryStream.BufferingHintsProperty.IntervalInSeconds`.
	IntervalInSeconds *float64 `json:"intervalInSeconds"`
	// `CfnDeliveryStream.BufferingHintsProperty.SizeInMBs`.
	SizeInMBs *float64 `json:"sizeInMBs"`
}

type CfnDeliveryStream_CloudWatchLoggingOptionsProperty 

type CfnDeliveryStream_CloudWatchLoggingOptionsProperty struct {
	// `CfnDeliveryStream.CloudWatchLoggingOptionsProperty.Enabled`.
	Enabled interface{} `json:"enabled"`
	// `CfnDeliveryStream.CloudWatchLoggingOptionsProperty.LogGroupName`.
	LogGroupName *string `json:"logGroupName"`
	// `CfnDeliveryStream.CloudWatchLoggingOptionsProperty.LogStreamName`.
	LogStreamName *string `json:"logStreamName"`
}

type CfnDeliveryStream_CopyCommandProperty 

type CfnDeliveryStream_CopyCommandProperty struct {
	// `CfnDeliveryStream.CopyCommandProperty.DataTableName`.
	DataTableName *string `json:"dataTableName"`
	// `CfnDeliveryStream.CopyCommandProperty.CopyOptions`.
	CopyOptions *string `json:"copyOptions"`
	// `CfnDeliveryStream.CopyCommandProperty.DataTableColumns`.
	DataTableColumns *string `json:"dataTableColumns"`
}

type CfnDeliveryStream_DataFormatConversionConfigurationProperty 

type CfnDeliveryStream_DataFormatConversionConfigurationProperty struct {
	// `CfnDeliveryStream.DataFormatConversionConfigurationProperty.Enabled`.
	Enabled interface{} `json:"enabled"`
	// `CfnDeliveryStream.DataFormatConversionConfigurationProperty.InputFormatConfiguration`.
	InputFormatConfiguration interface{} `json:"inputFormatConfiguration"`
	// `CfnDeliveryStream.DataFormatConversionConfigurationProperty.OutputFormatConfiguration`.
	OutputFormatConfiguration interface{} `json:"outputFormatConfiguration"`
	// `CfnDeliveryStream.DataFormatConversionConfigurationProperty.SchemaConfiguration`.
	SchemaConfiguration interface{} `json:"schemaConfiguration"`
}

type CfnDeliveryStream_DeliveryStreamEncryptionConfigurationInputProperty 

type CfnDeliveryStream_DeliveryStreamEncryptionConfigurationInputProperty struct {
	// `CfnDeliveryStream.DeliveryStreamEncryptionConfigurationInputProperty.KeyType`.
	KeyType *string `json:"keyType"`
	// `CfnDeliveryStream.DeliveryStreamEncryptionConfigurationInputProperty.KeyARN`.
	KeyArn *string `json:"keyArn"`
}

type CfnDeliveryStream_DeserializerProperty 

type CfnDeliveryStream_DeserializerProperty struct {
	// `CfnDeliveryStream.DeserializerProperty.HiveJsonSerDe`.
	HiveJsonSerDe interface{} `json:"hiveJsonSerDe"`
	// `CfnDeliveryStream.DeserializerProperty.OpenXJsonSerDe`.
	OpenXJsonSerDe interface{} `json:"openXJsonSerDe"`
}

type CfnDeliveryStream_DynamicPartitioningConfigurationProperty 

type CfnDeliveryStream_DynamicPartitioningConfigurationProperty struct {
	// `CfnDeliveryStream.DynamicPartitioningConfigurationProperty.Enabled`.
	Enabled interface{} `json:"enabled"`
	// `CfnDeliveryStream.DynamicPartitioningConfigurationProperty.RetryOptions`.
	RetryOptions interface{} `json:"retryOptions"`
}

type CfnDeliveryStream_ElasticsearchBufferingHintsProperty 

type CfnDeliveryStream_ElasticsearchBufferingHintsProperty struct {
	// `CfnDeliveryStream.ElasticsearchBufferingHintsProperty.IntervalInSeconds`.
	IntervalInSeconds *float64 `json:"intervalInSeconds"`
	// `CfnDeliveryStream.ElasticsearchBufferingHintsProperty.SizeInMBs`.
	SizeInMBs *float64 `json:"sizeInMBs"`
}

type CfnDeliveryStream_ElasticsearchDestinationConfigurationProperty 

type CfnDeliveryStream_ElasticsearchDestinationConfigurationProperty struct {
	// `CfnDeliveryStream.ElasticsearchDestinationConfigurationProperty.IndexName`.
	IndexName *string `json:"indexName"`
	// `CfnDeliveryStream.ElasticsearchDestinationConfigurationProperty.RoleARN`.
	RoleArn *string `json:"roleArn"`
	// `CfnDeliveryStream.ElasticsearchDestinationConfigurationProperty.S3Configuration`.
	S3Configuration interface{} `json:"s3Configuration"`
	// `CfnDeliveryStream.ElasticsearchDestinationConfigurationProperty.BufferingHints`.
	BufferingHints interface{} `json:"bufferingHints"`
	// `CfnDeliveryStream.ElasticsearchDestinationConfigurationProperty.CloudWatchLoggingOptions`.
	CloudWatchLoggingOptions interface{} `json:"cloudWatchLoggingOptions"`
	// `CfnDeliveryStream.ElasticsearchDestinationConfigurationProperty.ClusterEndpoint`.
	ClusterEndpoint *string `json:"clusterEndpoint"`
	// `CfnDeliveryStream.ElasticsearchDestinationConfigurationProperty.DomainARN`.
	DomainArn *string `json:"domainArn"`
	// `CfnDeliveryStream.ElasticsearchDestinationConfigurationProperty.IndexRotationPeriod`.
	IndexRotationPeriod *string `json:"indexRotationPeriod"`
	// `CfnDeliveryStream.ElasticsearchDestinationConfigurationProperty.ProcessingConfiguration`.
	ProcessingConfiguration interface{} `json:"processingConfiguration"`
	// `CfnDeliveryStream.ElasticsearchDestinationConfigurationProperty.RetryOptions`.
	RetryOptions interface{} `json:"retryOptions"`
	// `CfnDeliveryStream.ElasticsearchDestinationConfigurationProperty.S3BackupMode`.
	S3BackupMode *string `json:"s3BackupMode"`
	// `CfnDeliveryStream.ElasticsearchDestinationConfigurationProperty.TypeName`.
	TypeName *string `json:"typeName"`
	// `CfnDeliveryStream.ElasticsearchDestinationConfigurationProperty.VpcConfiguration`.
	VpcConfiguration interface{} `json:"vpcConfiguration"`
}

type CfnDeliveryStream_ElasticsearchRetryOptionsProperty 

type CfnDeliveryStream_ElasticsearchRetryOptionsProperty struct {
	// `CfnDeliveryStream.ElasticsearchRetryOptionsProperty.DurationInSeconds`.
	DurationInSeconds *float64 `json:"durationInSeconds"`
}

type CfnDeliveryStream_EncryptionConfigurationProperty 

type CfnDeliveryStream_EncryptionConfigurationProperty struct {
	// `CfnDeliveryStream.EncryptionConfigurationProperty.KMSEncryptionConfig`.
	KmsEncryptionConfig interface{} `json:"kmsEncryptionConfig"`
	// `CfnDeliveryStream.EncryptionConfigurationProperty.NoEncryptionConfig`.
	NoEncryptionConfig *string `json:"noEncryptionConfig"`
}

type CfnDeliveryStream_ExtendedS3DestinationConfigurationProperty 

type CfnDeliveryStream_ExtendedS3DestinationConfigurationProperty struct {
	// `CfnDeliveryStream.ExtendedS3DestinationConfigurationProperty.BucketARN`.
	BucketArn *string `json:"bucketArn"`
	// `CfnDeliveryStream.ExtendedS3DestinationConfigurationProperty.RoleARN`.
	RoleArn *string `json:"roleArn"`
	// `CfnDeliveryStream.ExtendedS3DestinationConfigurationProperty.BufferingHints`.
	BufferingHints interface{} `json:"bufferingHints"`
	// `CfnDeliveryStream.ExtendedS3DestinationConfigurationProperty.CloudWatchLoggingOptions`.
	CloudWatchLoggingOptions interface{} `json:"cloudWatchLoggingOptions"`
	// `CfnDeliveryStream.ExtendedS3DestinationConfigurationProperty.CompressionFormat`.
	CompressionFormat *string `json:"compressionFormat"`
	// `CfnDeliveryStream.ExtendedS3DestinationConfigurationProperty.DataFormatConversionConfiguration`.
	DataFormatConversionConfiguration interface{} `json:"dataFormatConversionConfiguration"`
	// `CfnDeliveryStream.ExtendedS3DestinationConfigurationProperty.DynamicPartitioningConfiguration`.
	DynamicPartitioningConfiguration interface{} `json:"dynamicPartitioningConfiguration"`
	// `CfnDeliveryStream.ExtendedS3DestinationConfigurationProperty.EncryptionConfiguration`.
	EncryptionConfiguration interface{} `json:"encryptionConfiguration"`
	// `CfnDeliveryStream.ExtendedS3DestinationConfigurationProperty.ErrorOutputPrefix`.
	ErrorOutputPrefix *string `json:"errorOutputPrefix"`
	// `CfnDeliveryStream.ExtendedS3DestinationConfigurationProperty.Prefix`.
	Prefix *string `json:"prefix"`
	// `CfnDeliveryStream.ExtendedS3DestinationConfigurationProperty.ProcessingConfiguration`.
	ProcessingConfiguration interface{} `json:"processingConfiguration"`
	// `CfnDeliveryStream.ExtendedS3DestinationConfigurationProperty.S3BackupConfiguration`.
	S3BackupConfiguration interface{} `json:"s3BackupConfiguration"`
	// `CfnDeliveryStream.ExtendedS3DestinationConfigurationProperty.S3BackupMode`.
	S3BackupMode *string `json:"s3BackupMode"`
}

type CfnDeliveryStream_HiveJsonSerDeProperty 

type CfnDeliveryStream_HiveJsonSerDeProperty struct {
	// `CfnDeliveryStream.HiveJsonSerDeProperty.TimestampFormats`.
	TimestampFormats *[]*string `json:"timestampFormats"`
}

type CfnDeliveryStream_HttpEndpointCommonAttributeProperty 

type CfnDeliveryStream_HttpEndpointCommonAttributeProperty struct {
	// `CfnDeliveryStream.HttpEndpointCommonAttributeProperty.AttributeName`.
	AttributeName *string `json:"attributeName"`
	// `CfnDeliveryStream.HttpEndpointCommonAttributeProperty.AttributeValue`.
	AttributeValue *string `json:"attributeValue"`
}

type CfnDeliveryStream_HttpEndpointConfigurationProperty 

type CfnDeliveryStream_HttpEndpointConfigurationProperty struct {
	// `CfnDeliveryStream.HttpEndpointConfigurationProperty.Url`.
	Url *string `json:"url"`
	// `CfnDeliveryStream.HttpEndpointConfigurationProperty.AccessKey`.
	AccessKey *string `json:"accessKey"`
	// `CfnDeliveryStream.HttpEndpointConfigurationProperty.Name`.
	Name *string `json:"name"`
}

type CfnDeliveryStream_HttpEndpointDestinationConfigurationProperty 

type CfnDeliveryStream_HttpEndpointDestinationConfigurationProperty struct {
	// `CfnDeliveryStream.HttpEndpointDestinationConfigurationProperty.EndpointConfiguration`.
	EndpointConfiguration interface{} `json:"endpointConfiguration"`
	// `CfnDeliveryStream.HttpEndpointDestinationConfigurationProperty.S3Configuration`.
	S3Configuration interface{} `json:"s3Configuration"`
	// `CfnDeliveryStream.HttpEndpointDestinationConfigurationProperty.BufferingHints`.
	BufferingHints interface{} `json:"bufferingHints"`
	// `CfnDeliveryStream.HttpEndpointDestinationConfigurationProperty.CloudWatchLoggingOptions`.
	CloudWatchLoggingOptions interface{} `json:"cloudWatchLoggingOptions"`
	// `CfnDeliveryStream.HttpEndpointDestinationConfigurationProperty.ProcessingConfiguration`.
	ProcessingConfiguration interface{} `json:"processingConfiguration"`
	// `CfnDeliveryStream.HttpEndpointDestinationConfigurationProperty.RequestConfiguration`.
	RequestConfiguration interface{} `json:"requestConfiguration"`
	// `CfnDeliveryStream.HttpEndpointDestinationConfigurationProperty.RetryOptions`.
	RetryOptions interface{} `json:"retryOptions"`
	// `CfnDeliveryStream.HttpEndpointDestinationConfigurationProperty.RoleARN`.
	RoleArn *string `json:"roleArn"`
	// `CfnDeliveryStream.HttpEndpointDestinationConfigurationProperty.S3BackupMode`.
	S3BackupMode *string `json:"s3BackupMode"`
}

type CfnDeliveryStream_HttpEndpointRequestConfigurationProperty 

type CfnDeliveryStream_HttpEndpointRequestConfigurationProperty struct {
	// `CfnDeliveryStream.HttpEndpointRequestConfigurationProperty.CommonAttributes`.
	CommonAttributes interface{} `json:"commonAttributes"`
	// `CfnDeliveryStream.HttpEndpointRequestConfigurationProperty.ContentEncoding`.
	ContentEncoding *string `json:"contentEncoding"`
}

type CfnDeliveryStream_InputFormatConfigurationProperty 

type CfnDeliveryStream_InputFormatConfigurationProperty struct {
	// `CfnDeliveryStream.InputFormatConfigurationProperty.Deserializer`.
	Deserializer interface{} `json:"deserializer"`
}

type CfnDeliveryStream_KMSEncryptionConfigProperty 

type CfnDeliveryStream_KMSEncryptionConfigProperty struct {
	// `CfnDeliveryStream.KMSEncryptionConfigProperty.AWSKMSKeyARN`.
	AwskmsKeyArn *string `json:"awskmsKeyArn"`
}

type CfnDeliveryStream_KinesisStreamSourceConfigurationProperty 

type CfnDeliveryStream_KinesisStreamSourceConfigurationProperty struct {
	// `CfnDeliveryStream.KinesisStreamSourceConfigurationProperty.KinesisStreamARN`.
	KinesisStreamArn *string `json:"kinesisStreamArn"`
	// `CfnDeliveryStream.KinesisStreamSourceConfigurationProperty.RoleARN`.
	RoleArn *string `json:"roleArn"`
}

type CfnDeliveryStream_OpenXJsonSerDeProperty 

type CfnDeliveryStream_OpenXJsonSerDeProperty struct {
	// `CfnDeliveryStream.OpenXJsonSerDeProperty.CaseInsensitive`.
	CaseInsensitive interface{} `json:"caseInsensitive"`
	// `CfnDeliveryStream.OpenXJsonSerDeProperty.ColumnToJsonKeyMappings`.
	ColumnToJsonKeyMappings interface{} `json:"columnToJsonKeyMappings"`
	// `CfnDeliveryStream.OpenXJsonSerDeProperty.ConvertDotsInJsonKeysToUnderscores`.
	ConvertDotsInJsonKeysToUnderscores interface{} `json:"convertDotsInJsonKeysToUnderscores"`
}

type CfnDeliveryStream_OrcSerDeProperty 

type CfnDeliveryStream_OrcSerDeProperty struct {
	// `CfnDeliveryStream.OrcSerDeProperty.BlockSizeBytes`.
	BlockSizeBytes *float64 `json:"blockSizeBytes"`
	// `CfnDeliveryStream.OrcSerDeProperty.BloomFilterColumns`.
	BloomFilterColumns *[]*string `json:"bloomFilterColumns"`
	// `CfnDeliveryStream.OrcSerDeProperty.BloomFilterFalsePositiveProbability`.
	BloomFilterFalsePositiveProbability *float64 `json:"bloomFilterFalsePositiveProbability"`
	// `CfnDeliveryStream.OrcSerDeProperty.Compression`.
	Compression *string `json:"compression"`
	// `CfnDeliveryStream.OrcSerDeProperty.DictionaryKeyThreshold`.
	DictionaryKeyThreshold *float64 `json:"dictionaryKeyThreshold"`
	// `CfnDeliveryStream.OrcSerDeProperty.EnablePadding`.
	EnablePadding interface{} `json:"enablePadding"`
	// `CfnDeliveryStream.OrcSerDeProperty.FormatVersion`.
	FormatVersion *string `json:"formatVersion"`
	// `CfnDeliveryStream.OrcSerDeProperty.PaddingTolerance`.
	PaddingTolerance *float64 `json:"paddingTolerance"`
	// `CfnDeliveryStream.OrcSerDeProperty.RowIndexStride`.
	RowIndexStride *float64 `json:"rowIndexStride"`
	// `CfnDeliveryStream.OrcSerDeProperty.StripeSizeBytes`.
	StripeSizeBytes *float64 `json:"stripeSizeBytes"`
}

type CfnDeliveryStream_OutputFormatConfigurationProperty 

type CfnDeliveryStream_OutputFormatConfigurationProperty struct {
	// `CfnDeliveryStream.OutputFormatConfigurationProperty.Serializer`.
	Serializer interface{} `json:"serializer"`
}

type CfnDeliveryStream_ParquetSerDeProperty 

type CfnDeliveryStream_ParquetSerDeProperty struct {
	// `CfnDeliveryStream.ParquetSerDeProperty.BlockSizeBytes`.
	BlockSizeBytes *float64 `json:"blockSizeBytes"`
	// `CfnDeliveryStream.ParquetSerDeProperty.Compression`.
	Compression *string `json:"compression"`
	// `CfnDeliveryStream.ParquetSerDeProperty.EnableDictionaryCompression`.
	EnableDictionaryCompression interface{} `json:"enableDictionaryCompression"`
	// `CfnDeliveryStream.ParquetSerDeProperty.MaxPaddingBytes`.
	MaxPaddingBytes *float64 `json:"maxPaddingBytes"`
	// `CfnDeliveryStream.ParquetSerDeProperty.PageSizeBytes`.
	PageSizeBytes *float64 `json:"pageSizeBytes"`
	// `CfnDeliveryStream.ParquetSerDeProperty.WriterVersion`.
	WriterVersion *string `json:"writerVersion"`
}

type CfnDeliveryStream_ProcessingConfigurationProperty 

type CfnDeliveryStream_ProcessingConfigurationProperty struct {
	// `CfnDeliveryStream.ProcessingConfigurationProperty.Enabled`.
	Enabled interface{} `json:"enabled"`
	// `CfnDeliveryStream.ProcessingConfigurationProperty.Processors`.
	Processors interface{} `json:"processors"`
}

type CfnDeliveryStream_ProcessorParameterProperty 

type CfnDeliveryStream_ProcessorParameterProperty struct {
	// `CfnDeliveryStream.ProcessorParameterProperty.ParameterName`.
	ParameterName *string `json:"parameterName"`
	// `CfnDeliveryStream.ProcessorParameterProperty.ParameterValue`.
	ParameterValue *string `json:"parameterValue"`
}

type CfnDeliveryStream_ProcessorProperty 

type CfnDeliveryStream_ProcessorProperty struct {
	// `CfnDeliveryStream.ProcessorProperty.Type`.
	Type *string `json:"type"`
	// `CfnDeliveryStream.ProcessorProperty.Parameters`.
	Parameters interface{} `json:"parameters"`
}

type CfnDeliveryStream_RedshiftDestinationConfigurationProperty 

type CfnDeliveryStream_RedshiftDestinationConfigurationProperty struct {
	// `CfnDeliveryStream.RedshiftDestinationConfigurationProperty.ClusterJDBCURL`.
	ClusterJdbcurl *string `json:"clusterJdbcurl"`
	// `CfnDeliveryStream.RedshiftDestinationConfigurationProperty.CopyCommand`.
	CopyCommand interface{} `json:"copyCommand"`
	// `CfnDeliveryStream.RedshiftDestinationConfigurationProperty.Password`.
	Password *string `json:"password"`
	// `CfnDeliveryStream.RedshiftDestinationConfigurationProperty.RoleARN`.
	RoleArn *string `json:"roleArn"`
	// `CfnDeliveryStream.RedshiftDestinationConfigurationProperty.S3Configuration`.
	S3Configuration interface{} `json:"s3Configuration"`
	// `CfnDeliveryStream.RedshiftDestinationConfigurationProperty.Username`.
	Username *string `json:"username"`
	// `CfnDeliveryStream.RedshiftDestinationConfigurationProperty.CloudWatchLoggingOptions`.
	CloudWatchLoggingOptions interface{} `json:"cloudWatchLoggingOptions"`
	// `CfnDeliveryStream.RedshiftDestinationConfigurationProperty.ProcessingConfiguration`.
	ProcessingConfiguration interface{} `json:"processingConfiguration"`
	// `CfnDeliveryStream.RedshiftDestinationConfigurationProperty.RetryOptions`.
	RetryOptions interface{} `json:"retryOptions"`
	// `CfnDeliveryStream.RedshiftDestinationConfigurationProperty.S3BackupConfiguration`.
	S3BackupConfiguration interface{} `json:"s3BackupConfiguration"`
	// `CfnDeliveryStream.RedshiftDestinationConfigurationProperty.S3BackupMode`.
	S3BackupMode *string `json:"s3BackupMode"`
}

type CfnDeliveryStream_RedshiftRetryOptionsProperty 

type CfnDeliveryStream_RedshiftRetryOptionsProperty struct {
	// `CfnDeliveryStream.RedshiftRetryOptionsProperty.DurationInSeconds`.
	DurationInSeconds *float64 `json:"durationInSeconds"`
}

type CfnDeliveryStream_RetryOptionsProperty 

type CfnDeliveryStream_RetryOptionsProperty struct {
	// `CfnDeliveryStream.RetryOptionsProperty.DurationInSeconds`.
	DurationInSeconds *float64 `json:"durationInSeconds"`
}

type CfnDeliveryStream_S3DestinationConfigurationProperty 

type CfnDeliveryStream_S3DestinationConfigurationProperty struct {
	// `CfnDeliveryStream.S3DestinationConfigurationProperty.BucketARN`.
	BucketArn *string `json:"bucketArn"`
	// `CfnDeliveryStream.S3DestinationConfigurationProperty.RoleARN`.
	RoleArn *string `json:"roleArn"`
	// `CfnDeliveryStream.S3DestinationConfigurationProperty.BufferingHints`.
	BufferingHints interface{} `json:"bufferingHints"`
	// `CfnDeliveryStream.S3DestinationConfigurationProperty.CloudWatchLoggingOptions`.
	CloudWatchLoggingOptions interface{} `json:"cloudWatchLoggingOptions"`
	// `CfnDeliveryStream.S3DestinationConfigurationProperty.CompressionFormat`.
	CompressionFormat *string `json:"compressionFormat"`
	// `CfnDeliveryStream.S3DestinationConfigurationProperty.EncryptionConfiguration`.
	EncryptionConfiguration interface{} `json:"encryptionConfiguration"`
	// `CfnDeliveryStream.S3DestinationConfigurationProperty.ErrorOutputPrefix`.
	ErrorOutputPrefix *string `json:"errorOutputPrefix"`
	// `CfnDeliveryStream.S3DestinationConfigurationProperty.Prefix`.
	Prefix *string `json:"prefix"`
}

type CfnDeliveryStream_SchemaConfigurationProperty 

type CfnDeliveryStream_SchemaConfigurationProperty struct {
	// `CfnDeliveryStream.SchemaConfigurationProperty.CatalogId`.
	CatalogId *string `json:"catalogId"`
	// `CfnDeliveryStream.SchemaConfigurationProperty.DatabaseName`.
	DatabaseName *string `json:"databaseName"`
	// `CfnDeliveryStream.SchemaConfigurationProperty.Region`.
	Region *string `json:"region"`
	// `CfnDeliveryStream.SchemaConfigurationProperty.RoleARN`.
	RoleArn *string `json:"roleArn"`
	// `CfnDeliveryStream.SchemaConfigurationProperty.TableName`.
	TableName *string `json:"tableName"`
	// `CfnDeliveryStream.SchemaConfigurationProperty.VersionId`.
	VersionId *string `json:"versionId"`
}

type CfnDeliveryStream_SerializerProperty 

type CfnDeliveryStream_SerializerProperty struct {
	// `CfnDeliveryStream.SerializerProperty.OrcSerDe`.
	OrcSerDe interface{} `json:"orcSerDe"`
	// `CfnDeliveryStream.SerializerProperty.ParquetSerDe`.
	ParquetSerDe interface{} `json:"parquetSerDe"`
}

type CfnDeliveryStream_SplunkDestinationConfigurationProperty 

type CfnDeliveryStream_SplunkDestinationConfigurationProperty struct {
	// `CfnDeliveryStream.SplunkDestinationConfigurationProperty.HECEndpoint`.
	HecEndpoint *string `json:"hecEndpoint"`
	// `CfnDeliveryStream.SplunkDestinationConfigurationProperty.HECEndpointType`.
	HecEndpointType *string `json:"hecEndpointType"`
	// `CfnDeliveryStream.SplunkDestinationConfigurationProperty.HECToken`.
	HecToken *string `json:"hecToken"`
	// `CfnDeliveryStream.SplunkDestinationConfigurationProperty.S3Configuration`.
	S3Configuration interface{} `json:"s3Configuration"`
	// `CfnDeliveryStream.SplunkDestinationConfigurationProperty.CloudWatchLoggingOptions`.
	CloudWatchLoggingOptions interface{} `json:"cloudWatchLoggingOptions"`
	// `CfnDeliveryStream.SplunkDestinationConfigurationProperty.HECAcknowledgmentTimeoutInSeconds`.
	HecAcknowledgmentTimeoutInSeconds *float64 `json:"hecAcknowledgmentTimeoutInSeconds"`
	// `CfnDeliveryStream.SplunkDestinationConfigurationProperty.ProcessingConfiguration`.
	ProcessingConfiguration interface{} `json:"processingConfiguration"`
	// `CfnDeliveryStream.SplunkDestinationConfigurationProperty.RetryOptions`.
	RetryOptions interface{} `json:"retryOptions"`
	// `CfnDeliveryStream.SplunkDestinationConfigurationProperty.S3BackupMode`.
	S3BackupMode *string `json:"s3BackupMode"`
}

type CfnDeliveryStream_SplunkRetryOptionsProperty 

type CfnDeliveryStream_SplunkRetryOptionsProperty struct {
	// `CfnDeliveryStream.SplunkRetryOptionsProperty.DurationInSeconds`.
	DurationInSeconds *float64 `json:"durationInSeconds"`
}

type CfnDeliveryStream_VpcConfigurationProperty 

type CfnDeliveryStream_VpcConfigurationProperty struct {
	// `CfnDeliveryStream.VpcConfigurationProperty.RoleARN`.
	RoleArn *string `json:"roleArn"`
	// `CfnDeliveryStream.VpcConfigurationProperty.SecurityGroupIds`.
	SecurityGroupIds *[]*string `json:"securityGroupIds"`
	// `CfnDeliveryStream.VpcConfigurationProperty.SubnetIds`.
	SubnetIds *[]*string `json:"subnetIds"`
}

type DataProcessorBindOptions 

type DataProcessorBindOptions struct {
	// The IAM role assumed by Kinesis Data Firehose to write to the destination that this DataProcessor will bind to.
	// Experimental.
	Role awsiam.IRole `json:"role"`
}

Options when binding a DataProcessor to a delivery stream destination. Experimental.

type DataProcessorConfig 

type DataProcessorConfig struct {
	// The key-value pair that identifies the underlying processor resource.
	// Experimental.
	ProcessorIdentifier *DataProcessorIdentifier `json:"processorIdentifier"`
	// The type of the underlying processor resource.
	//
	// Must be an accepted value in `CfnDeliveryStream.ProcessorProperty.Type`.
	//
	// TODO: EXAMPLE
	//
	// See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisfirehose-deliverystream-processor.html#cfn-kinesisfirehose-deliverystream-processor-type
	//
	// Experimental.
	ProcessorType *string `json:"processorType"`
}

The full configuration of a data processor. Experimental.

type DataProcessorIdentifier 

type DataProcessorIdentifier struct {
	// The parameter name that corresponds to the processor resource's identifier.
	//
	// Must be an accepted value in `CfnDeliveryStream.ProcessoryParameterProperty.ParameterName`.
	// Experimental.
	ParameterName *string `json:"parameterName"`
	// The identifier of the underlying processor resource.
	// Experimental.
	ParameterValue *string `json:"parameterValue"`
}

The key-value pair that identifies the underlying processor resource. See: http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-kinesisfirehose-deliverystream-processorparameter.html

Experimental.

type DataProcessorProps 

type DataProcessorProps struct {
	// The length of time Kinesis Data Firehose will buffer incoming data before calling the processor.
	//
	// s
	// Experimental.
	BufferInterval awscdk.Duration `json:"bufferInterval"`
	// The amount of incoming data Kinesis Data Firehose will buffer before calling the processor.
	// Experimental.
	BufferSize awscdk.Size `json:"bufferSize"`
	// The number of times Kinesis Data Firehose will retry the processor invocation after a failure due to network timeout or invocation limits.
	// Experimental.
	Retries *float64 `json:"retries"`
}

Configure the data processor. Experimental.

type DeliveryStream 

type DeliveryStream interface {
	awscdk.Resource
	IDeliveryStream
	Connections() awsec2.Connections
	DeliveryStreamArn() *string
	DeliveryStreamName() *string
	Env() *awscdk.ResourceEnvironment
	GrantPrincipal() awsiam.IPrincipal
	Node() awscdk.ConstructNode
	PhysicalName() *string
	Stack() awscdk.Stack
	ApplyRemovalPolicy(policy awscdk.RemovalPolicy)
	GeneratePhysicalName() *string
	GetResourceArnAttribute(arnAttr *string, arnComponents *awscdk.ArnComponents) *string
	GetResourceNameAttribute(nameAttr *string) *string
	Grant(grantee awsiam.IGrantable, actions ...*string) awsiam.Grant
	GrantPutRecords(grantee awsiam.IGrantable) awsiam.Grant
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricBackupToS3Bytes(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricBackupToS3DataFreshness(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricBackupToS3Records(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricIncomingBytes(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	MetricIncomingRecords(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	OnPrepare()
	OnSynthesize(session constructs.ISynthesisSession)
	OnValidate() *[]*string
	Prepare()
	Synthesize(session awscdk.ISynthesisSession)
	ToString() *string
	Validate() *[]*string
}

Create a Kinesis Data Firehose delivery stream. Experimental.

func NewDeliveryStream 

func NewDeliveryStream(scope constructs.Construct, id *string, props *DeliveryStreamProps) DeliveryStream

Experimental.

type DeliveryStreamAttributes 

type DeliveryStreamAttributes struct {
	// The ARN of the delivery stream.
	//
	// At least one of deliveryStreamArn and deliveryStreamName must be provided.
	// Experimental.
	DeliveryStreamArn *string `json:"deliveryStreamArn"`
	// The name of the delivery stream.
	//
	// At least one of deliveryStreamName and deliveryStreamArn  must be provided.
	// Experimental.
	DeliveryStreamName *string `json:"deliveryStreamName"`
	// The IAM role associated with this delivery stream.
	//
	// Assumed by Kinesis Data Firehose to read from sources and encrypt data server-side.
	// Experimental.
	Role awsiam.IRole `json:"role"`
}

A full specification of a delivery stream that can be used to import it fluently into the CDK application. Experimental.

type DeliveryStreamProps 

type DeliveryStreamProps struct {
	// The destinations that this delivery stream will deliver data to.
	//
	// Only a singleton array is supported at this time.
	// Experimental.
	Destinations *[]IDestination `json:"destinations"`
	// A name for the delivery stream.
	// Experimental.
	DeliveryStreamName *string `json:"deliveryStreamName"`
	// Indicates the type of customer master key (CMK) to use for server-side encryption, if any.
	// Experimental.
	Encryption StreamEncryption `json:"encryption"`
	// Customer managed key to server-side encrypt data in the stream.
	// Experimental.
	EncryptionKey awskms.IKey `json:"encryptionKey"`
	// The IAM role associated with this delivery stream.
	//
	// Assumed by Kinesis Data Firehose to read from sources and encrypt data server-side.
	// Experimental.
	Role awsiam.IRole `json:"role"`
	// The Kinesis data stream to use as a source for this delivery stream.
	// Experimental.
	SourceStream awskinesis.IStream `json:"sourceStream"`
}

Properties for a new delivery stream. Experimental.

type DestinationBindOptions 

type DestinationBindOptions struct {
}

Options when binding a destination to a delivery stream. Experimental.

type DestinationConfig 

type DestinationConfig struct {
	// Any resources that were created by the destination when binding it to the stack that must be deployed before the delivery stream is deployed.
	// Experimental.
	Dependables *[]awscdk.IDependable `json:"dependables"`
	// S3 destination configuration properties.
	// Experimental.
	ExtendedS3DestinationConfiguration *CfnDeliveryStream_ExtendedS3DestinationConfigurationProperty `json:"extendedS3DestinationConfiguration"`
}

A Kinesis Data Firehose delivery stream destination configuration. Experimental.

type IDataProcessor 

type IDataProcessor interface {
	// Binds this processor to a destination of a delivery stream.
	//
	// Implementers should use this method to grant processor invocation permissions to the provided stream and return the
	// necessary configuration to register as a processor.
	// Experimental.
	Bind(scope constructs.Construct, options *DataProcessorBindOptions) *DataProcessorConfig
	// The constructor props of the DataProcessor.
	// Experimental.
	Props() *DataProcessorProps
}

A data processor that Kinesis Data Firehose will call to transform records before delivering data. Experimental.

type IDeliveryStream 

type IDeliveryStream interface {
	awsec2.IConnectable
	awsiam.IGrantable
	awscdk.IResource
	// Grant the `grantee` identity permissions to perform `actions`.
	// Experimental.
	Grant(grantee awsiam.IGrantable, actions ...*string) awsiam.Grant
	// Grant the `grantee` identity permissions to perform `firehose:PutRecord` and `firehose:PutRecordBatch` actions on this delivery stream.
	// Experimental.
	GrantPutRecords(grantee awsiam.IGrantable) awsiam.Grant
	// Return the given named metric for this delivery stream.
	// Experimental.
	Metric(metricName *string, props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	// Metric for the number of bytes delivered to Amazon S3 for backup over the specified time period.
	//
	// By default, this metric will be calculated as an average over a period of 5 minutes.
	// Experimental.
	MetricBackupToS3Bytes(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	// Metric for the age (from getting into Kinesis Data Firehose to now) of the oldest record in Kinesis Data Firehose.
	//
	// Any record older than this age has been delivered to the Amazon S3 bucket for backup.
	//
	// By default, this metric will be calculated as an average over a period of 5 minutes.
	// Experimental.
	MetricBackupToS3DataFreshness(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	// Metric for the number of records delivered to Amazon S3 for backup over the specified time period.
	//
	// By default, this metric will be calculated as an average over a period of 5 minutes.
	// Experimental.
	MetricBackupToS3Records(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	// Metric for the number of bytes ingested successfully into the delivery stream over the specified time period after throttling.
	//
	// By default, this metric will be calculated as an average over a period of 5 minutes.
	// Experimental.
	MetricIncomingBytes(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	// Metric for the number of records ingested successfully into the delivery stream over the specified time period after throttling.
	//
	// By default, this metric will be calculated as an average over a period of 5 minutes.
	// Experimental.
	MetricIncomingRecords(props *awscloudwatch.MetricOptions) awscloudwatch.Metric
	// The ARN of the delivery stream.
	// Experimental.
	DeliveryStreamArn() *string
	// The name of the delivery stream.
	// Experimental.
	DeliveryStreamName() *string
}

Represents a Kinesis Data Firehose delivery stream. Experimental.

func DeliveryStream_FromDeliveryStreamArn 

func DeliveryStream_FromDeliveryStreamArn(scope constructs.Construct, id *string, deliveryStreamArn *string) IDeliveryStream

Import an existing delivery stream from its ARN. Experimental.

func DeliveryStream_FromDeliveryStreamAttributes 

func DeliveryStream_FromDeliveryStreamAttributes(scope constructs.Construct, id *string, attrs *DeliveryStreamAttributes) IDeliveryStream

Import an existing delivery stream from its attributes. Experimental.

func DeliveryStream_FromDeliveryStreamName 

func DeliveryStream_FromDeliveryStreamName(scope constructs.Construct, id *string, deliveryStreamName *string) IDeliveryStream

Import an existing delivery stream from its name. Experimental.

type IDestination 

type IDestination interface {
	// Binds this destination to the Kinesis Data Firehose delivery stream.
	//
	// Implementers should use this method to bind resources to the stack and initialize values using the provided stream.
	// Experimental.
	Bind(scope constructs.Construct, options *DestinationBindOptions) *DestinationConfig
}

A Kinesis Data Firehose delivery stream destination. Experimental.

type LambdaFunctionProcessor 

type LambdaFunctionProcessor interface {
	IDataProcessor
	Props() *DataProcessorProps
	Bind(_scope constructs.Construct, options *DataProcessorBindOptions) *DataProcessorConfig
}

Use an AWS Lambda function to transform records. Experimental.

func NewLambdaFunctionProcessor 

func NewLambdaFunctionProcessor(lambdaFunction awslambda.IFunction, props *DataProcessorProps) LambdaFunctionProcessor

Experimental.

type StreamEncryption 

type StreamEncryption string

Options for server-side encryption of a delivery stream. Experimental. 

const (
	StreamEncryption_UNENCRYPTED      StreamEncryption = "UNENCRYPTED"
	StreamEncryption_CUSTOMER_MANAGED StreamEncryption = "CUSTOMER_MANAGED"
	StreamEncryption_AWS_OWNED        StreamEncryption = "AWS_OWNED"
)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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