rashidkpc

#!/usr/bin/ruby
require 'rubygems'
require 'digest/md5'
require 'time'
require 'tire'

class IPGenerator
  public
  def initialize(session_count, session_length)
    @session_count = session_count

rashidkpc

require 'json'
require 'time'
require 'tire'

# File to read
file = 'test.txt'

# Field in which time value can be found
timefield = '@timestamp'

rashidkpc

require 'rubygems'
require 'digest/md5'
require 'time'
require 'tire'

class IPGenerator
  public
  def initialize(session_count, session_length)
    @session_count = session_count
    @session_length = session_length

rashidkpc

#!/usr/bin/ruby

require 'digest/md5'
require 'time'
#require 'tire'

class IPGenerator
  public
  def initialize(session_count, session_length)
    @session_count = session_count

rashidkpc

server {
  listen                *:80 ;
  
  server_name           my.host.org;
  location ~ ^/_aliases$ {
    proxy_pass http://127.0.0.1:9200;
    proxy_read_timeout 90;
  }
  location ~ ^/.*/_search$ {
    proxy_pass http://127.0.0.1:9200;

rashidkpc

require 'rubygems'
require 'tire'
require 'tweetstream'

# How many events to index at once
bulk_limit = 50

# Twitter will feed us ~50 events/sec, how many of those do we really want?
throttle = 10

rashidkpc

require 'rubygems'
require 'tire'
require 'tweetstream'

bulk_limit = 50
throttle = 10
total_limit = 4320000

TweetStream.configure do |config|
  config.consumer_key       = 'foo'

rashidkpc

#!/usr/bin/ruby
queue_list = `rabbitmqctl list_queues`.split("\n") 
queue_list.pop
queue_list.shift

queues = Hash.new
queue_list.each do |queue|
  queue = queue.strip.split(/\s+/).collect(&:strip)
  queue_stat = queue.pop
  queue_name = queue.pop

rashidkpc

LoadModule passenger_module /usr/lib/ruby/gems/1.8/gems/passenger-3.0.11/ext/apache2/mod_passenger.so
PassengerRoot /usr/lib/ruby/gems/1.8/gems/passenger-3.0.11
PassengerRuby /usr/bin/ruby


<VirtualHost *:80>
    ServerName logs.example.com 
    ServerAlias logs.example.com 
    DocumentRoot /home/httpd/Kibana/static

rashidkpc

filter {
  mutate {
    replace => [ "@tags", "" ]
    type => "syslog"
  }
}