Sha256: 88fa037c8e986c813183b13812d1be059851d455b0f0a789ad3e834db1e1652c
Contents?: true
Size: 1.06 KB
Versions: 2
Compression:
Stored size: 1.06 KB
Contents
require_relative('source_driver') module Wukong module Load # Runs the wu-source command. class SourceRunner < Wukong::Local::LocalRunner usage "PROCESSOR|DATAFLOW" description <<-EOF.gsub(/^ {8}/,'') wu-source is a tool for using Wukong processors as sources of data in streams. Run any Wukong processor as a source for data: $ wu-source fake_log_data 205.4.75.208 - 3918471017 [27/Nov/2012:05:06:57 -0600] "GET /products/eget HTTP/1.0" 200 25600 63.181.105.15 - 3650805763 [27/Nov/2012:05:06:57 -0600] "GET /products/lacinia-nulla-vitae HTTP/1.0" 200 3790 227.190.78.101 - 39543891 [27/Nov/2012:05:06:58 -0600] "GET /products/odio-nulla-nulla-ipsum HTTP/1.0" 200 31718 ... The fake_log_data processor will receive an event once every second. Each event will consist of a single string giving a consecutive integer starting with '1' as the first event. EOF include Logging def driver SourceDriver end end end end
Version data entries
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
wukong-load-0.1.1 | lib/wukong-load/source_runner.rb |
wukong-load-0.1.0 | lib/wukong-load/source_runner.rb |