class Meteorlog::Wrapper::LogStreamCollection

Public Class Methods

new(cloud_watch_logs, log_streams, log_group, options = {}) click to toggle source
# File lib/meteorlog/wrapper/log_stream_collection.rb, line 7
def initialize(cloud_watch_logs, log_streams, log_group, options = {})
  @cloud_watch_logs = cloud_watch_logs
  @log_streams = log_streams
  @log_group = log_group
  @options = options
end

Public Instance Methods

create(name, opts = {}) click to toggle source
# File lib/meteorlog/wrapper/log_stream_collection.rb, line 21
def create(name, opts = {})
  log(:info, 'Create LogStream', :cyan, "#{self.log_group_name} > #{name}")

  unless @options[:dry_run]
    @cloud_watch_logs.create_log_stream(
      :log_group_name => self.log_group_name,
      :log_stream_name => name)
    @options[:modified] = true
  end

  log_stream = OpenStruct.new(:log_stream_name => name)

  Meteorlog::Wrapper::LogStream.new(
    @cloud_watch_logs, log_stream, @log_group, @options)
end
each() { |log_stream| ... } click to toggle source
# File lib/meteorlog/wrapper/log_stream_collection.rb, line 14
def each
  @log_streams.each do |log_stream|
    yield(Meteorlog::Wrapper::LogStream.new(
      @cloud_watch_logs, log_stream, @log_group, @options))
  end
end