Class: Fluent::Plugin::JSONStreamInput
- Inherits:
-
Input
- Object
- Input
- Fluent::Plugin::JSONStreamInput
- Defined in:
- lib/fluent/plugin/in_jsonstream.rb
Instance Method Summary collapse
Instance Method Details
#configure(conf) ⇒ Object
23 24 25 |
# File 'lib/fluent/plugin/in_jsonstream.rb', line 23 def configure(conf) super end |
#multi_workers_ready? ⇒ Boolean
27 28 29 |
# File 'lib/fluent/plugin/in_jsonstream.rb', line 27 def multi_workers_ready? true end |
#start ⇒ Object
31 32 33 34 35 36 37 38 39 40 41 42 43 44 |
# File 'lib/fluent/plugin/in_jsonstream.rb', line 31 def start super server_create_connection(:in_jsonstream_server, @port, bind: @bind) do |conn| parser = newParser() conn.data do |data| begin parser << data rescue Yajl::ParseError parser = newParser() end end end end |