Class: LogStash::Outputs::Aerospike

Inherits:
Base
  • Object
show all
Defined in:
lib/logstash/outputs/aerospike.rb

Overview

An aerospike output.

Instance Method Summary collapse

Instance Method Details

#receive(event) ⇒ Object 



47
48
49
 
# File 'lib/logstash/outputs/aerospike.rb', line 47

def receive(event)
	@plugin.pushIntoQueue @host.to_s,@port.to_s,@namespace.to_s,@set.to_s,@ttl.to_s,event.sprintf(@key),@binnames.to_s,@bintypes.to_s,event.sprintf(@binvalues)
end

#register ⇒ Object 



40
41
42
43
44
 
# File 'lib/logstash/outputs/aerospike.rb', line 40

def register
	@plugin = com.qihoo.unad.cminitializer.logstash.aero.plugin.LogstashAeroOutPlug.new
	@plugin.registerClient @host.to_s,@port.to_s,@namespace.to_s,@set.to_s,@ttl.to_s
	@plugin.startSender @host.to_s,@port.to_s,@namespace.to_s,@set.to_s,@ttl.to_s
end