module Wukong::Load

Loads data from the command-line into data stores.

Constants

VERSION

Public Class Methods

boot(settings, dir) click to toggle source

Boot Wukong-Load from the resolved `settings` in the given `dir`.

@param [Configliere::Param] settings the resolved settings @param [String] dir the directory to boot in

# File lib/wukong-load.rb, line 30
def self.boot settings, dir
end
configure(settings, program) click to toggle source

Configure `settings` for Wukong-Load.

Will ensure that `wu-load` has the same settings as `wu-local`.

@param [Configliere::Param] settings the settings to configure @param [String] program the currently executing program name

# File lib/wukong-load.rb, line 14
def self.configure settings, program
  case program
  when 'wu-load'
    settings.define :tcp_port, description: "Consume TCP requests on the given port instead of lines over STDIN", type: Integer, flag: 't'
  when 'wu-source'
    settings.define :per_sec,    description: "Number of events produced per second", type: Float
    settings.define :period,     description: "Number of seconds between events (overrides --per_sec)", type: Float
    settings.define :batch_size, description: "Trigger a finalize across the dataflow each time this many records are processed", type: Integer
  end
end