class LogStash::Outputs::Base

Attributes

logger[RW]

Public Class Methods

new(url, config={}, &block) click to toggle source
# File lib/logstash/outputs/base.rb, line 11
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 Instance Methods

receive(event) click to toggle source
# File lib/logstash/outputs/base.rb, line 31
def receive(event)
  raise "#{self.class}#receive must be overidden"
end
register() click to toggle source
# File lib/logstash/outputs/base.rb, line 26
def register
  raise "#{self.class}#register must be overidden"
end