Class: LogStash::OutputDelegatorStrategies::Single

Inherits:
Object
  • Object
show all
Defined in:
lib/logstash/output_delegator_strategies/single.rb

Instance Method Summary collapse

Constructor Details

#initialize(logger, klass, metric, plugin_args) ⇒ Single

Returns a new instance of Single.



2
3
4
5
6
 
# File 'lib/logstash/output_delegator_strategies/single.rb', line 2

def initialize(logger, klass, metric, plugin_args)
  @output = klass.new(plugin_args)
  @output.metric = metric
  @mutex = Mutex.new
end

Instance Method Details

#do_close ⇒ Object 



18
19
20
21
 
# File 'lib/logstash/output_delegator_strategies/single.rb', line 18

def do_close
  # No mutex needed since this is only called when the pipeline is clear
  @output.do_close
end

#multi_receive(events) ⇒ Object 



12
13
14
15
16
 
# File 'lib/logstash/output_delegator_strategies/single.rb', line 12

def multi_receive(events)
  @mutex.synchronize do
    @output.multi_receive(events)
  end
end

#register ⇒ Object 



8
9
10
 
# File 'lib/logstash/output_delegator_strategies/single.rb', line 8

def register
  @output.register
end