mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 06:37:19 -04:00
Fake redis for now until I get some vagrant/puppet stuff going to build proper servicse
This commit is contained in:
parent
6e0fc203b3
commit
968ed8c72d
2 changed files with 50 additions and 1 deletions
|
@ -1,4 +1,28 @@
|
|||
require "test_utils"
|
||||
require "redis"
|
||||
|
||||
class Redis
|
||||
def initialize(*args)
|
||||
@@data ||= Hash.new { |h,k| h[k] = [] }
|
||||
end
|
||||
|
||||
def rpush(key, value)
|
||||
@@data[key] << value
|
||||
end
|
||||
|
||||
def llen(key)
|
||||
@@data[key].length
|
||||
end
|
||||
|
||||
def lpop(key)
|
||||
@@data[key].shift
|
||||
end
|
||||
|
||||
def blpop(key, timeout=0)
|
||||
sleep 0.1 while llen(key) == 0
|
||||
return "whatever", lpop(key)
|
||||
end
|
||||
end # class Redis
|
||||
|
||||
describe "inputs/redis" do
|
||||
extend LogStash::RSpec
|
||||
|
|
|
@ -1,6 +1,31 @@
|
|||
require "test_utils"
|
||||
require "logstash/outputs/redis"
|
||||
require "redis"
|
||||
|
||||
describe "outputs/redis" do
|
||||
class Redis
|
||||
def initialize(*args)
|
||||
@@data ||= Hash.new { |h,k| h[k] = [] }
|
||||
end
|
||||
|
||||
def rpush(key, value)
|
||||
@@data[key] << value
|
||||
end
|
||||
|
||||
def llen(key)
|
||||
@@data[key].length
|
||||
end
|
||||
|
||||
def lpop(key)
|
||||
@@data[key].shift
|
||||
end
|
||||
|
||||
def blpop(key, timeout=0)
|
||||
sleep 0.1 while llen(key) == 0
|
||||
return "whatever", lpop(key)
|
||||
end
|
||||
end # class Redis
|
||||
|
||||
describe LogStash::Outputs::Redis do
|
||||
extend LogStash::RSpec
|
||||
|
||||
describe "ship lots of events to a list" do
|
||||
|
|
Loading…
Add table
Add a link
Reference in a new issue