Class: AWSCDK::KinesisFirehose::DataProcessorProps

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
kinesis_firehose/data_processor_props.rb

Overview

Configure the LambdaFunctionProcessor.

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(buffer_interval: nil, buffer_size: nil, retries: nil) ⇒ DataProcessorProps

Returns a new instance of DataProcessorProps.

Parameters:

  • buffer_interval (AWSCDK::Duration, nil) (defaults to: nil) —

    The length of time Amazon Data Firehose will buffer incoming data before calling the processor.

  • buffer_size (AWSCDK::Size, nil) (defaults to: nil) —

    The amount of incoming data Amazon Data Firehose will buffer before calling the processor.

  • retries (Numeric, nil) (defaults to: nil) —

    The number of times Amazon Data Firehose will retry the processor invocation after a failure due to network timeout or invocation limits.



10
11
12
13
14
15
16
17
 
# File 'kinesis_firehose/data_processor_props.rb', line 10

def initialize(buffer_interval: nil, buffer_size: nil, retries: nil)
  @buffer_interval = buffer_interval
  Jsii::Type.check_type(@buffer_interval, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5EdXJhdGlvbiJ9")), "bufferInterval") unless @buffer_interval.nil?
  @buffer_size = buffer_size
  Jsii::Type.check_type(@buffer_size, JSON.parse(Base64.strict_decode64("eyJmcW4iOiJhd3MtY2RrLWxpYi5TaXplIn0=")), "bufferSize") unless @buffer_size.nil?
  @retries = retries
  Jsii::Type.check_type(@retries, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "retries") unless @retries.nil?
end

Instance Attribute Details

#buffer_interval ⇒ AWSCDK::Duration? (readonly)

Note:

Default: Duration.minutes(1)

The length of time Amazon Data Firehose will buffer incoming data before calling the processor.

s

Returns:



25
26
27
 
# File 'kinesis_firehose/data_processor_props.rb', line 25

def buffer_interval
  @buffer_interval
end

#buffer_size ⇒ AWSCDK::Size? (readonly)

Note:

Default: Size.mebibytes(3)

The amount of incoming data Amazon Data Firehose will buffer before calling the processor.

Returns:



30
31
32
 
# File 'kinesis_firehose/data_processor_props.rb', line 30

def buffer_size
  @buffer_size
end

#retries ⇒ Numeric? (readonly)

Note:

Default: 3

The number of times Amazon Data Firehose will retry the processor invocation after a failure due to network timeout or invocation limits.

Returns:

  • (Numeric, nil) 


35
36
37
 
# File 'kinesis_firehose/data_processor_props.rb', line 35

def retries
  @retries
end

Class Method Details

.jsii_properties ⇒ Object 



37
38
39
40
41
42
43
 
# File 'kinesis_firehose/data_processor_props.rb', line 37

def self.jsii_properties
  {
    :buffer_interval => "bufferInterval",
    :buffer_size => "bufferSize",
    :retries => "retries",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



45
46
47
48
49
50
51
52
53
 
# File 'kinesis_firehose/data_processor_props.rb', line 45

def to_jsii
  result = {}
  result.merge!({
    "bufferInterval" => @buffer_interval,
    "bufferSize" => @buffer_size,
    "retries" => @retries,
  })
  result.compact
end