Method: Fluent::PgLogicalInput#start

Defined in:
lib/fluent/plugin/in_pg_logical.rb

#startObject



40
41
42
# File 'lib/fluent/plugin/in_pg_logical.rb', line 40

def start
  @thread = Thread.new(&method(:run))
end