github github
  • Home
  • Pricing and Signup
  • Training
  • Gist
  • Blog
  • Login

igrigorik / em-proxy

  • Admin
  • Watch Unwatch
  • Fork
  • Your Fork
  • Pull Request
  • Download Source
    • 223
    • 17
  • Source
  • Commits
  • Network (17)
  • Issues (0)
  • Downloads (0)
  • Graphs
  • Branch: master

click here to add a description

click here to add a homepage

  • Switch Branches (1)
    • master ✓
  • Switch Tags (0)
  • Branch List
Sending Request…

EventMachine Proxy DSL for writing high-performance transparent / intercepting proxies in Ruby — Read more

  Cancel

http://www.igvita.com/2009/04/20/ruby-proxies-for-scale-and-monitoring/

  Cancel
  • HTTP
  • Git Read-Only

This URL has Read+Write access

Version bump to 0.1.3 
igrigorik (author)
Sat May 29 07:47:29 -0700 2010
commit  8d7c5e74a102522033e9
tree    0d0babebc596a2e5d4d6
parent  ba6ab51987aa2da2de60
em-proxy /
name age
history
message
file README.rdoc Mon Mar 01 11:33:42 -0800 2010 update readme with schema-free mysql example [igrigorik]
file Rakefile Sun Dec 20 14:11:11 -0800 2009 add rakefile [igrigorik]
file VERSION Sat May 29 07:47:29 -0700 2010 Version bump to 0.1.3 [igrigorik]
directory examples/ Mon Mar 01 11:33:42 -0800 2010 update readme with schema-free mysql example [igrigorik]
directory lib/ Thu May 27 15:35:15 -0700 2010 As per the EM documentation get_peername can re... [Matthew Kent]
directory spec/ Mon Mar 29 21:13:32 -0700 2010 on_connect should fire after connection is esta... [igrigorik]
README.rdoc

EM-Proxy

EventMachine Proxy DSL for writing high-performance transparent / intercepting proxies in Ruby.

  • Slides from RailsConf 2009: bit.ly/D7oWB
  • GoGaRuCo notes & Slides: www.igvita.com/2009/04/20/ruby-proxies-for-scale-and-monitoring/

Getting started

  # install & configure gemcutter repos
  gem update --system
  gem install gemcutter
  gem tumble

  gem install em-proxy

  irb:0> require 'em-proxy'

Simple port forwarding proxy

    Proxy.start(:host => "0.0.0.0", :port => 80, :debug => true) do |conn|
      conn.server :srv, :host => "127.0.0.1", :port => 81

      # modify / process request stream
      conn.on_data do |data|
        p [:on_data, data]
        data
      end

      # modify / process response stream
      conn.on_response do |backend, resp|
        p [:on_response, backend, resp]
        resp
      end

      # termination logic
      conn.on_finish do |backend, name|
        p [:on_finish, name]

        # terminate connection (in duplex mode, you can terminate when prod is done)
        unbind if backend == :srv
      end
    end

For more examples see the /examples directory.

  • SMTP Spam Filtering
  • Duplicating traffic
  • Selective forwarding
  • Beanstalkd interceptor
  • etc.

A schema-free MySQL proof of concept, via an EM-Proxy server:

  • www.igvita.com/2010/03/01/schema-free-mysql-vs-nosql/
  • Code in examples/schemaless-mysql

License

(The MIT License)

Copyright © 2010 Ilya Grigorik

Permission is hereby granted, free of charge, to any person obtaining a copy of this software and associated documentation files (the ‘Software’), to deal in the Software without restriction, including without limitation the rights to use, copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the Software, and to permit persons to whom the Software is furnished to do so, subject to the following conditions:

The above copyright notice and this permission notice shall be included in all copies or substantial portions of the Software.

THE SOFTWARE IS PROVIDED ‘AS IS’, WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.

Dedicated Server Powered by the Dedicated Servers and
Cloud Computing of Rackspace Hosting®
  • Blog
  • Support
  • Training
  • Job Board
  • Shop
  • Contact
  • API
  • Status
  • © 2010 GitHub Inc. All rights reserved.
  • Terms of Service
  • Privacy
  • Security
  • English
  • Deutsch
  • Français
  • 日本語
  • Português (BR)
  • 中文
  • See all available languages

Your current locale selection: English. Choose another?

  • English
  • Afrikaans
  • Català
  • Čeština
  • Deutsch
  • Español
  • Français
  • Hrvatski
  • Indonesia
  • Italiano
  • 日本語
  • Nederlands
  • Norsk
  • Polski
  • Português (BR)
  • Српски
  • Svenska
  • 中文