Class: LogStash::Outputs::Zookeeper

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

Overview

An output plugin that send data to zookeeper.

Instance Method Summary collapse

Instance Method Details

#receive(event) ⇒ Object 



26
27
28
 
# File 'lib/logstash/outputs/zookeeper.rb', line 26

def receive(event)
	@zk.set(@path, @data)
end

#register ⇒ Object 



17
18
19
20
21
22
23
 
# File 'lib/logstash/outputs/zookeeper.rb', line 17

def register
	@zk = ZK.new(@ip_list)

	if @zk.exists?(@path) == false
@zk.create(@path, '')
	end
end