Class: AWSCDK::SAM::CfnFunction::DynamoDBEventProperty

Inherits:
Jsii::Struct
  • Object
show all
Defined in:
sam/cfn_function.rb

Overview

See Also:

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(starting_position:, stream:, batch_size: nil, bisect_batch_on_function_error: nil, destination_config: nil, enabled: nil, maximum_batching_window_in_seconds: nil, maximum_record_age_in_seconds: nil, maximum_retry_attempts: nil, parallelization_factor: nil) ⇒ DynamoDBEventProperty

Returns a new instance of DynamoDBEventProperty.

Parameters:

  • starting_position (String)
  • stream (String)
  • batch_size (Numeric, nil) (defaults to: nil)
  • bisect_batch_on_function_error (Boolean, AWSCDK::IResolvable, nil) (defaults to: nil)
  • destination_config (AWSCDK::IResolvable, AWSCDK::SAM::CfnFunction::DestinationConfigProperty, nil) (defaults to: nil)
  • enabled (Boolean, AWSCDK::IResolvable, nil) (defaults to: nil)
  • maximum_batching_window_in_seconds (Numeric, nil) (defaults to: nil)
  • maximum_record_age_in_seconds (Numeric, nil) (defaults to: nil)
  • maximum_retry_attempts (Numeric, nil) (defaults to: nil)
  • parallelization_factor (Numeric, nil) (defaults to: nil) 


1589
1590
1591
1592
1593
1594
1595
1596
1597
1598
1599
1600
1601
1602
1603
1604
1605
1606
1607
1608
1609
1610
 
# File 'sam/cfn_function.rb', line 1589

def initialize(starting_position:, stream:, batch_size: nil, bisect_batch_on_function_error: nil, destination_config: nil, enabled: nil, maximum_batching_window_in_seconds: nil, maximum_record_age_in_seconds: nil, maximum_retry_attempts: nil, parallelization_factor: nil)
  @starting_position = starting_position
  Jsii::Type.check_type(@starting_position, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "startingPosition")
  @stream = stream
  Jsii::Type.check_type(@stream, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJzdHJpbmcifQ==")), "stream")
  @batch_size = batch_size
  Jsii::Type.check_type(@batch_size, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "batchSize") unless @batch_size.nil?
  @bisect_batch_on_function_error = bisect_batch_on_function_error
  Jsii::Type.check_type(@bisect_batch_on_function_error, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3sicHJpbWl0aXZlIjoiYm9vbGVhbiJ9LHsiZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifV19fQ==")), "bisectBatchOnFunctionError") unless @bisect_batch_on_function_error.nil?
  @destination_config = destination_config.is_a?(Hash) ? ::AWSCDK::SAM::CfnFunction::DestinationConfigProperty.new(**destination_config.transform_keys(&:to_sym)) : destination_config
  Jsii::Type.check_type(@destination_config, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3siZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifSx7ImZxbiI6ImF3cy1jZGstbGliLmF3c19zYW0uQ2ZuRnVuY3Rpb24uRGVzdGluYXRpb25Db25maWdQcm9wZXJ0eSJ9XX19")), "destinationConfig") unless @destination_config.nil?
  @enabled = enabled
  Jsii::Type.check_type(@enabled, JSON.parse(Base64.strict_decode64("eyJ1bmlvbiI6eyJ0eXBlcyI6W3sicHJpbWl0aXZlIjoiYm9vbGVhbiJ9LHsiZnFuIjoiYXdzLWNkay1saWIuSVJlc29sdmFibGUifV19fQ==")), "enabled") unless @enabled.nil?
  @maximum_batching_window_in_seconds = maximum_batching_window_in_seconds
  Jsii::Type.check_type(@maximum_batching_window_in_seconds, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "maximumBatchingWindowInSeconds") unless @maximum_batching_window_in_seconds.nil?
  @maximum_record_age_in_seconds = maximum_record_age_in_seconds
  Jsii::Type.check_type(@maximum_record_age_in_seconds, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "maximumRecordAgeInSeconds") unless @maximum_record_age_in_seconds.nil?
  @maximum_retry_attempts = maximum_retry_attempts
  Jsii::Type.check_type(@maximum_retry_attempts, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "maximumRetryAttempts") unless @maximum_retry_attempts.nil?
  @parallelization_factor = parallelization_factor
  Jsii::Type.check_type(@parallelization_factor, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "parallelizationFactor") unless @parallelization_factor.nil?
end

Instance Attribute Details

#batch_size ⇒ Numeric? (readonly)

Returns:

  • (Numeric, nil)

See Also:



1620
1621
1622
 
# File 'sam/cfn_function.rb', line 1620

def batch_size
  @batch_size
end

#bisect_batch_on_function_error ⇒ Boolean, ... (readonly)

Returns:

See Also:



1623
1624
1625
 
# File 'sam/cfn_function.rb', line 1623

def bisect_batch_on_function_error
  @bisect_batch_on_function_error
end

#destination_config ⇒ AWSCDK::IResolvable, ... (readonly)

Returns:

See Also:



1626
1627
1628
 
# File 'sam/cfn_function.rb', line 1626

def destination_config
  @destination_config
end

#enabled ⇒ Boolean, ... (readonly)

Returns:

See Also:



1629
1630
1631
 
# File 'sam/cfn_function.rb', line 1629

def enabled
  @enabled
end

#maximum_batching_window_in_seconds ⇒ Numeric? (readonly)

Returns:

  • (Numeric, nil)

See Also:



1632
1633
1634
 
# File 'sam/cfn_function.rb', line 1632

def maximum_batching_window_in_seconds
  @maximum_batching_window_in_seconds
end

#maximum_record_age_in_seconds ⇒ Numeric? (readonly)

Returns:

  • (Numeric, nil)

See Also:



1635
1636
1637
 
# File 'sam/cfn_function.rb', line 1635

def maximum_record_age_in_seconds
  @maximum_record_age_in_seconds
end

#maximum_retry_attempts ⇒ Numeric? (readonly)

Returns:

  • (Numeric, nil)

See Also:



1638
1639
1640
 
# File 'sam/cfn_function.rb', line 1638

def maximum_retry_attempts
  @maximum_retry_attempts
end

#parallelization_factor ⇒ Numeric? (readonly)

Returns:

  • (Numeric, nil)

See Also:



1641
1642
1643
 
# File 'sam/cfn_function.rb', line 1641

def parallelization_factor
  @parallelization_factor
end

#starting_position ⇒ String (readonly)

Returns:

  • (String)

See Also:



1614
1615
1616
 
# File 'sam/cfn_function.rb', line 1614

def starting_position
  @starting_position
end

#stream ⇒ String (readonly)

Returns:

  • (String)

See Also:



1617
1618
1619
 
# File 'sam/cfn_function.rb', line 1617

def stream
  @stream
end

Class Method Details

.jsii_properties ⇒ Object 



1643
1644
1645
1646
1647
1648
1649
1650
1651
1652
1653
1654
1655
1656
 
# File 'sam/cfn_function.rb', line 1643

def self.jsii_properties
  {
    :starting_position => "startingPosition",
    :stream => "stream",
    :batch_size => "batchSize",
    :bisect_batch_on_function_error => "bisectBatchOnFunctionError",
    :destination_config => "destinationConfig",
    :enabled => "enabled",
    :maximum_batching_window_in_seconds => "maximumBatchingWindowInSeconds",
    :maximum_record_age_in_seconds => "maximumRecordAgeInSeconds",
    :maximum_retry_attempts => "maximumRetryAttempts",
    :parallelization_factor => "parallelizationFactor",
  }
end

Instance Method Details

#to_jsii ⇒ Object 



1658
1659
1660
1661
1662
1663
1664
1665
1666
1667
1668
1669
1670
1671
1672
1673
 
# File 'sam/cfn_function.rb', line 1658

def to_jsii
  result = {}
  result.merge!({
    "startingPosition" => @starting_position,
    "stream" => @stream,
    "batchSize" => @batch_size,
    "bisectBatchOnFunctionError" => @bisect_batch_on_function_error,
    "destinationConfig" => @destination_config,
    "enabled" => @enabled,
    "maximumBatchingWindowInSeconds" => @maximum_batching_window_in_seconds,
    "maximumRecordAgeInSeconds" => @maximum_record_age_in_seconds,
    "maximumRetryAttempts" => @maximum_retry_attempts,
    "parallelizationFactor" => @parallelization_factor,
  })
  result.compact
end