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