Contents

class Scribe
  # Created a new client instance. Accepts an optional host, port, and default 
  # category.
  def initialize(host = "127.0.0.1", port = 1463, category = "Ruby")
    @host = host
    @port = port
    @category = category

    transport = Thrift::FramedTransport.new(Thrift::Socket.new(@host, @port))
    transport.open
    
    @client = ScribeThrift::SafeClient.new(
      ScribeThrift::Client.new(Thrift::BinaryProtocol.new(transport, false)),
      transport)
  end

  # Log a message. Accepts a string and an optional category.
  def log(message, category = @category)
    raise ArgumentError, "Message must be a string" unless message.is_a?(String)
    raise ArgumentError, "Category must be a string" unless category.is_a?(String)
    
    entry = ScribeThrift::LogEntry.new(:message => message, :category => category)
    @batch ? @batch << entry : @client.Log(Array(entry))
  end
  
  # Batch several calls to Scribe#log together. Yields to a block.
  def batch
    @batch = []
    yield
    @client.Log(@batch)
  ensure
    @batch = nil
  end
  
  alias :debug :log
  alias :error :log
  alias :fatal :log
  alias :info :log
  alias :warn :log  
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
scribe-0.1.1	lib/scribe/scribe.rb