Sha256: 651a83194003e08b81d8ccd143439b52c6972d9caf3891474e38e98fd61182a0
Contents?: true
Size: 688 Bytes
Versions: 13
Compression:
Stored size: 688 Bytes
Contents
require "logstash/namespace"
require "logstash/event"
require "logstash/logging"
require "cgi"
require "uri"
class LogStash::Outputs::Base
def initialize(url, config={}, &block)
@url = url
@url = URI.parse(url) if url.is_a? String
@config = config
@logger = LogStash::Logger.new(STDOUT)
@urlopts = {}
if @url.query
@urlopts = CGI.parse(@url.query)
@urlopts.each do |k, v|
@urlopts[k] = v.last if v.is_a?(Array)
end
end
end
def register
raise "#{self.class}#register must be overidden"
end # def register
def receive(event)
raise "#{self.class}#receive must be overidden"
end
end # class LogStash::Outputs::Base
Version data entries
13 entries across 13 versions & 1 rubygems