class LogStash::Filters::Jdbc::SingleLoadRunner
Attributes
loaders[R]
local[R]
preloaders[R]
Public Class Methods
new(local, loaders, preloaders)
click to toggle source
# File lib/logstash/filters/jdbc/single_load_runner.rb, line 9 def initialize(local, loaders, preloaders) @local = local @loaders = loaders @preloaders = [] @reload_counter = Concurrent::AtomicFixnum.new(0) preloaders.map do |pre| @preloaders << DbObject.new(pre) end @preloaders.sort! end
Public Instance Methods
call()
click to toggle source
# File lib/logstash/filters/jdbc/single_load_runner.rb, line 29 def call repeated_load end
initial_load()
click to toggle source
# File lib/logstash/filters/jdbc/single_load_runner.rb, line 20 def initial_load do_preload local.populate_all(loaders) @reload_counter.increment end
reload_count()
click to toggle source
# File lib/logstash/filters/jdbc/single_load_runner.rb, line 33 def reload_count @reload_counter.value end
repeated_load()
click to toggle source
# File lib/logstash/filters/jdbc/single_load_runner.rb, line 26 def repeated_load end
Private Instance Methods
do_preload()
click to toggle source
# File lib/logstash/filters/jdbc/single_load_runner.rb, line 39 def do_preload preloaders.each do |db_object| local.build_db_object(db_object) end end