Method: Awspec::Helper::Finder::CloudwatchLogs#find_cloudwatch_logs_stream_by_log_group_name

Defined in:
lib/awspec/helper/finder/cloudwatch_logs.rb

#find_cloudwatch_logs_stream_by_log_group_name(id, stream_name) ⇒ Object



16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
# File 'lib/awspec/helper/finder/cloudwatch_logs.rb', line 16

def find_cloudwatch_logs_stream_by_log_group_name(id, stream_name)
  req = {
    log_group_name: id,
    log_stream_name_prefix: stream_name
  }
  ret = nil
  loop do
    res = cloudwatch_logs_client.describe_log_streams(req)
    res.log_streams.find do |log_stream|
      if log_stream[:log_stream_name] == stream_name
        ret = log_stream[:log_stream_name]
        break
      end
    end
    break if ret.present?
    break if res.next_token.nil?
    req[:next_token] = res.next_token
  end
  ret
end