Class: AWSCDK::Pipes::CfnPipe::PipeSourceSQSQueueParametersProperty

Inherits:

Jsii::Struct

• Object
• Jsii::Struct
• AWSCDK::Pipes::CfnPipe::PipeSourceSQSQueueParametersProperty

Defined in:

pipes/cfn_pipe.rb

Overview

The parameters for using a Amazon SQS stream as a source.

See Also:

• http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcesqsqueueparameters.html

Instance Attribute Summary

• #batch_size ⇒ Numeric^? readonly

  The maximum number of records to include in each batch.

• #maximum_batching_window_in_seconds ⇒ Numeric^? readonly

  The maximum length of a time to wait for events.

Class Method Summary

• .jsii_properties ⇒ Object

Instance Method Summary

• #initialize(batch_size: nil, maximum_batching_window_in_seconds: nil) ⇒ PipeSourceSQSQueueParametersProperty constructor

  A new instance of PipeSourceSQSQueueParametersProperty.

• #to_jsii ⇒ Object

Constructor Details

#initialize(batch_size: nil, maximum_batching_window_in_seconds: nil) ⇒ PipeSourceSQSQueueParametersProperty

Returns a new instance of PipeSourceSQSQueueParametersProperty.

Parameters:

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

  The maximum number of records to include in each batch.

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

  The maximum length of a time to wait for events.

# File 'pipes/cfn_pipe.rb', line 2922

def initialize(batch_size: nil, maximum_batching_window_in_seconds: nil)
  @batch_size = batch_size
  Jsii::Type.check_type(@batch_size, JSON.parse(Base64.strict_decode64("eyJwcmltaXRpdmUiOiJudW1iZXIifQ==")), "batchSize") unless @batch_size.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?
end

Instance Attribute Details

#batch_size ⇒ Numeric^? (readonly)

The maximum number of records to include in each batch.

Returns:

• (Numeric, nil)

See Also:

• http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcesqsqueueparameters.html#cfn-pipes-pipe-pipesourcesqsqueueparameters-batchsize

# File 'pipes/cfn_pipe.rb', line 2933

def batch_size
  @batch_size
end

#maximum_batching_window_in_seconds ⇒ Numeric^? (readonly)

The maximum length of a time to wait for events.

Returns:

• (Numeric, nil)

See Also:

• http://docs.aws.amazon.com/AWSCloudFormation/latest/UserGuide/aws-properties-pipes-pipe-pipesourcesqsqueueparameters.html#cfn-pipes-pipe-pipesourcesqsqueueparameters-maximumbatchingwindowinseconds

# File 'pipes/cfn_pipe.rb', line 2938

def maximum_batching_window_in_seconds
  @maximum_batching_window_in_seconds
end

Class Method Details

.jsii_properties ⇒ Object

# File 'pipes/cfn_pipe.rb', line 2940

def self.jsii_properties
  {
    :batch_size => "batchSize",
    :maximum_batching_window_in_seconds => "maximumBatchingWindowInSeconds",
  }
end

Instance Method Details

#to_jsii ⇒ Object

# File 'pipes/cfn_pipe.rb', line 2947

def to_jsii
  result = {}
  result.merge!({
    "batchSize" => @batch_size,
    "maximumBatchingWindowInSeconds" => @maximum_batching_window_in_seconds,
  })
  result.compact
end