Method: Jets::Job::Dsl::KinesisEvent#full_kinesis_stream_arn

Defined in:

lib/jets/job/dsl/kinesis_event.rb

#full_kinesis_stream_arn(stream_name) ⇒ Object

Expands table name to the full stream arn. Example:

test-table

To:

arn:aws:kinesis:us-west-2:112233445566:table/test-table/stream/2019-02-15T21:41:15.217

Note, this does not check if the stream has been disabled.

# File 'lib/jets/job/dsl/kinesis_event.rb', line 29

def full_kinesis_stream_arn(stream_name)
  return stream_name if stream_name.include?("arn:aws:kinesis") # assume full stream arn

  "arn:aws:kinesis:#{Jets.aws.region}:#{Jets.aws.account}:stream/#{stream_name}"
end