module Awspec::Helper::Finder::CloudwatchLogs

Public Instance Methods

find_cloudwatch_logs_group(id) click to toggle source
# File lib/awspec/helper/finder/cloudwatch_logs.rb, line 4
def find_cloudwatch_logs_group(id)
  cloudwatch_logs_client.describe_log_groups({
                                               log_group_name_prefix: id
                                             }).log_groups.find do |log_group|
    log_group.log_group_name == id
  end
end
find_cloudwatch_logs_metric_fileter_by_log_group_name(id, filter_name) click to toggle source
# File lib/awspec/helper/finder/cloudwatch_logs.rb, line 16
def find_cloudwatch_logs_metric_fileter_by_log_group_name(id, filter_name)
  cloudwatch_logs_client.describe_metric_filters({
                                                   log_group_name: id,
                                                   filter_name_prefix: filter_name
                                                 }).metric_filters.find do |filter|
    filter.filter_name == filter_name
  end
end
find_cloudwatch_logs_stream_by_log_group_name(id) click to toggle source
# File lib/awspec/helper/finder/cloudwatch_logs.rb, line 12
def find_cloudwatch_logs_stream_by_log_group_name(id)
  cloudwatch_logs_client.describe_log_streams({ log_group_name: id }).log_streams.last
end
find_cloudwatch_logs_subscription_fileter_by_log_group_name(id, filter_name) click to toggle source
# File lib/awspec/helper/finder/cloudwatch_logs.rb, line 25
def find_cloudwatch_logs_subscription_fileter_by_log_group_name(id, filter_name)
  cloudwatch_logs_client.describe_subscription_filters({
                                                         log_group_name: id,
                                                         filter_name_prefix: filter_name
                                                       }).subscription_filters.find do |filter|
    filter.filter_name == filter_name
  end
end
select_all_cloudwatch_logs_log_groups() click to toggle source
# File lib/awspec/helper/finder/cloudwatch_logs.rb, line 34
def select_all_cloudwatch_logs_log_groups
  req = {}
  log_groups = []
  loop do
    res = cloudwatch_logs_client.describe_log_groups(req)
    log_groups.push(*res.log_groups)
    break if res.next_token.nil?
    req[:next_token] = res.next_token
  end
  log_groups
end