Contents

require "logstash/devutils/rspec/spec_helper"
require "logstash/inputs/nakadi"

describe LogStash::Inputs::Nakadi do
  let(:config) { {
      'event_types' => ['personalized-content-decision'],
      'host' => 'nakadi-staging.aruha-test.zalan.do'
  } }

  it "should start and stop" do
    #nakadi = LogStash::Inputs::Nakadi.new(config)
    #expect { nakadi.register }.not_to raise_error
    #sleep 1
    #expect { nakadi.stop }.not_to raise_error
  end

  it "should start listening" do
    nakadi = LogStash::Inputs::Nakadi.new(config)
    expect { nakadi.register }.not_to raise_error
    nakadi.run([])
    sleep 2
    expect { nakadi.stop }.not_to raise_error
  end
end

Version data entries

4 entries across 4 versions & 2 rubygems

Version	Path
logstash-input-nakadi-elk24-0.3.0	spec/inputs/nakadi_spec.rb
logstash-input-nakadi-0.3.0	spec/inputs/nakadi_spec.rb
logstash-input-nakadi-0.2.1	spec/inputs/nakadi_spec.rb
logstash-input-nakadi-0.1.0	spec/inputs/nakadi_spec.rb