class Fluentspec::Supervisor

Public Class Methods

new(conf = nil) click to toggle source
# File lib/fluentspec/supervisor.rb, line 33
def initialize(conf = nil)
  raise ArgumentError if conf.nil?
  @conf = conf
  opts = Fluent::Supervisor.default_options
  opts[:config_path] = @conf
  @sv = Fluent::Supervisor.new(opts)
  @sv.run_spec
end

Public Instance Methods

reset() click to toggle source

rubocop:disable Lint/HandleExceptions

# File lib/fluentspec/supervisor.rb, line 43
def reset
  opts = Fluent::Supervisor.default_options
  @sv = Fluent::Supervisor.new(opts)
  @sv.run_spec
rescue
end