mirror of
https://github.com/elastic/logstash.git
synced 2025-04-24 06:37:19 -04:00
- add udp output
This commit is contained in:
parent
8b109303e5
commit
a71e17b34e
1 changed files with 34 additions and 0 deletions
34
lib/logstash/outputs/udp.rb
Normal file
34
lib/logstash/outputs/udp.rb
Normal file
|
@ -0,0 +1,34 @@
|
|||
require "logstash/outputs/base"
|
||||
require "logstash/namespace"
|
||||
require "socket"
|
||||
|
||||
class LogStash::Outputs::UDP < LogStash::Outputs::Base
|
||||
config_name "udp"
|
||||
milestone 1
|
||||
|
||||
default :codec, "json"
|
||||
|
||||
# The address to send messages to
|
||||
config :host, :validate => :string, :required => true
|
||||
|
||||
# The port to send messages on
|
||||
config :port, :validate => :number, :required => true
|
||||
|
||||
public
|
||||
def register
|
||||
@socket = UDPSocket.new
|
||||
@codec.on_event do |payload|
|
||||
@socket.send(payload, 0, @host, @port)
|
||||
end
|
||||
end
|
||||
|
||||
def receive(event)
|
||||
return unless output?(event)
|
||||
if event == LogStash::SHUTDOWN
|
||||
finished
|
||||
return
|
||||
end
|
||||
@codec.encode(event)
|
||||
end
|
||||
|
||||
end # class LogStash::Outputs::Stdout
|
Loading…
Add table
Add a link
Reference in a new issue