event_shipper / lib / event_shipper / event.rb

require 'addressable/uri'

module EventShipper
  class Event
    def initialize host, path, line
      @path = path
      @line = line
      @host = host
      @timestamp = Time.now.utc.iso8601(6)
      @source = Addressable::URI.new(
        :scheme => 'file', 
        :host => host, :path => path)
      @message = line.chomp.strip
      @fields = {}
      @tags = %w(shipped)
    def to_hash
        '@source' => @source.to_s,
        '@type' => @source.scheme,
        '@tags' => @tags,
        '@fields' => @fields,
        '@timestamp' => @timestamp,
        '@source_host' => @host,
        '@source_path' => @path,
        '@message' => @message
Tip: Filter by directory path e.g. /media app.js to search for public/media/app.js.
Tip: Use camelCasing e.g. ProjME to search for ProjectModifiedEvent.java.
Tip: Filter by extension type e.g. /repo .js to search for all .js files in the /repo directory.
Tip: Separate your search with spaces e.g. /ssh pom.xml to search for src/ssh/pom.xml.
Tip: Use ↑ and ↓ arrow keys to navigate and return to view the file.
Tip: You can also navigate files with Ctrl+j (next) and Ctrl+k (previous) and view the file with Ctrl+o.
Tip: You can also navigate files with Alt+j (next) and Alt+k (previous) and view the file with Alt+o.