Module: Jets::Stack::Main::Dsl::Kinesis

Defined in:
lib/jets/stack/main/dsl/kinesis.rb

Instance Method Summary collapse

Instance Method Details

#kinesis_stream(id, props = {}) ⇒ Object 



3
4
5
6
7
8
9
10
11
12
13
 
# File 'lib/jets/stack/main/dsl/kinesis.rb', line 3

def kinesis_stream(id, props={})
  defaults = {
    name: id,
    shard_count: 1
  }

  props = defaults.merge(props)

  resource(id, "AWS::Kinesis::Stream", props)
  output(id)
end