| # from http://pushandpop.blogspot.com.au/2011/05/handling-gzip-responses-in-ruby-nethttp.html | |
| # i wanted syntax highlighting | |
| require 'net/http' | |
| debug = Proc.new{|msg| STDERR.puts "[#{Time.now.strftime('%Y-%m-%d %H:%M:%S')}] #{msg}" } | |
| page = nil | |
| http = Net::HTTP.new( "www.google.com", 80 ) | |
| req = Net::HTTP::Get.new( "/search?num=20&hl=en&noj=1&q=test&btnG=Search", { "Accept-Encoding" => "gzip", "User-Agent" => "gzip" } ) |
| # Rake task to launch multiple Resque workers in development/production with simple management included | |
| require 'resque/tasks' # Require Resque tasks | |
| namespace :workers do | |
| # = $ rake workers:start | |
| # | |
| # Launch multiple Resque workers with the Rails environment loaded, | |
| # so they have access to your models, etc. |
Since many deployments may start out with 3 nodes and so little is known about how to grow a cluster from 3 memebrs to 5 members without losing the existing Quorum, here is an example of how this might be achieved.
In this example, all 5 nodes will be running on the same Vagrant host for the purpose of illustration, running on distinct configurations (ports and data directories) without the actual load of clients.
YMMV. Caveat usufructuarius.
| # Signal catching | |
| def shut_down | |
| puts "\nShutting down gracefully..." | |
| sleep 1 | |
| end | |
| puts "I have PID #{Process.pid}" | |
| # Trap ^C | |
| Signal.trap("INT") { |
| #!/usr/bin/env jruby | |
| include Java | |
| options = { | |
| hdfs_uri: 'hdfs://0.0.0.0:8020/', | |
| hadoop_config_path: '/etc/hadoop/conf', | |
| hadoop_config_files: ['core-site.xml', 'hdfs-site.xml'], | |
| } | |
| hdfs_conf = org.apache.hadoop.conf.Configuration.new |
| #!/usr/bin/env jruby | |
| require 'snmp4jruby' | |
| class TrapListener | |
| def initialize() | |
| @transport = SNMP4JR::Transport::DefaultUdpTransportMapping.new | |
| @address = SNMP4JR::SMI::GenericAddress.parse("udp:127.0.0.1/1162") | |
| @snmp = SNMP4JR::Snmp.new(@transport) | |
| @callbacks = [] | |
| @snmp.addNotificationListener(@address, self) |
| # _ _ | |
| # __| |_ _ _(_)_ __ ___ | |
| # (_-< _| '_| | '_ \/ -_) | |
| # /__/\__|_| |_| .__/\___| | |
| # |_| | |
| # __ _ _ __| |_ ___ _ __ ___ _ _ | |
| # / _| || (_-< _/ _ \ ' \/ -_) '_| | |
| # \__|\_,_/__/\__\___/_|_|_\___|_| | |
| # | |
| # (c) 2013 stephan.com |
| Moved to a proprer repositoy, TSWS is a real boy now! | |
| https://github.com/dfletcher/tsws | |
| PRs welcomed. |
| *.tar.gz | |
| .sentinel.* |
