Method: Jets::Job::Dsl::KinesisEvent#default_kinesis_stream_policy

Defined in:
lib/jets/job/dsl/kinesis_event.rb

#default_kinesis_stream_policy(stream_name_arn = '*') ⇒ Object 



35
36
37
38
39
40
41
42
43
44
 
# File 'lib/jets/job/dsl/kinesis_event.rb', line 35

def default_kinesis_stream_policy(stream_name_arn='*')
  {
    Action: ["kinesis:GetRecords",
             "kinesis:GetShardIterator",
             "kinesis:DescribeStream",
             "kinesis:ListStreams"],
    Effect: "Allow",
    Resource: stream_name_arn,
  }
end