Sha256: 048e80bbb95abb695eee5804b9c6fed000c13837d5cb3f873e84ae0ddb43f3e9
Contents?: true
Size: 754 Bytes
Versions: 9
Compression:
Stored size: 754 Bytes
Contents
require "cgi"
require "logstash/event"
require "logstash/logging"
require "logstash/namespace"
require "uri"
class LogStash::Outputs::Base
attr_accessor :logger
public
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
public
def register
raise "#{self.class}#register must be overidden"
end # def register
public
def receive(event)
raise "#{self.class}#receive must be overidden"
end # def receive
end # class LogStash::Outputs::Base
Version data entries
9 entries across 9 versions & 1 rubygems