Contents

#!/usr/bin/env ruby
# manually test erp5_data_streams ingestion via Ruby HTTP lib
# XXX draft/stub

require_relative 'wendelin_test'
require 'msgpack'
require 'time'

# t -> 2015-08-11 14:51:50+02:00
def tfmt(t)
    t.strftime('%Y-%m-%d %H:%M:%S%:z')
end

t = Time.now
s = ''
s += [1, {'date' => tfmt(t),    'hello' => 1,   'world' => 2}].to_msgpack
s += [2, {'date' => tfmt(t+1),  'pi' => 3.1415, 'e' => 2.71828}].to_msgpack

# puts s
ingest 'testds', s

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
fluent-plugin-wendelin-0.5	test/ingest.rb
fluent-plugin-wendelin-0.4	test/ingest.rb
fluent-plugin-wendelin-0.3	test/ingest.rb
fluent-plugin-wendelin-0.2	test/ingest.rb
fluent-plugin-wendelin-0.1	test/ingest.rb