Contents

# encoding: utf-8
require "logstash/devutils/rspec/spec_helper"
require "logstash/inputs/cloudwatch_logs"
require "logstash/errors"
require "aws-sdk-resources"
require_relative "./support/helpers"

describe LogStash::Inputs::CloudWatch_Logs do
  let(:sincedb_path) { Stud::Temporary.pathname }
  let(:day) { 3600 * 24 }
  let(:creds) { Aws::Credentials.new('1234', 'secret') }
  let(:config) {
    {
        "access_key_id" => "1234",
        "secret_access_key" => "secret",
        "log_group" => "logstash-test-group",
        "sincedb_path" => File.join(sincedb_path, ".sincedb")
    }
  }

  before do
    FileUtils.mkdir_p(sincedb_path)
    Aws.config[:stub_responses] = true
    Thread.abort_on_exception = true
  end

  context "when interrupting the plugin" do
    let(:config) { super.merge({ "interval" => 5 }) }

    before do
      # expect_any_instance_of(LogStash::Inputs::CloudWatch_Logs).to receive(:list_new_streams_for_log_group).and_return(TestInfinteCloudWatchObject.new)
    end

    it_behaves_like "an interruptible input plugin"
  end

end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
logstash-input-cloudwatch_logs-0.10.1	spec/inputs/cloudwatch_logs_spec.rb