We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 27eefc8 commit b251fb3Copy full SHA for b251fb3
spec/inputs/redis_spec.rb
@@ -72,6 +72,28 @@ def process(conf, event_count)
72
type => "blah"
73
key => "#{key}.*"
74
data_type => "pattern_list"
75
+ batch_count => 1
76
+ }
77
78
+ CONFIG
79
+ total_event_count = 0
80
+ (0..10).each do |idx|
81
+ event_count = 100 + rand(50)
82
+ total_event_count += event_count
83
+ populate("#{key_base}.#{idx}", event_count)
84
+ end
85
+ process(conf, total_event_count)
86
87
+
88
+ it "should read events from a list pattern using batch_count (default 125)" do
89
+ key_base = SecureRandom.hex
90
+ conf = <<-CONFIG
91
+ input {
92
+ redis {
93
+ type => "blah"
94
+ key => "#{key}.*"
95
+ data_type => "pattern_list"
96
+ batch_count => 125
97
}
98
99
CONFIG
0 commit comments