class RedisHA::Router::Upstream
Attributes
debug[RW]
name[RW]
plexer[RW]
Public Class Methods
new(debug_on=false)
click to toggle source
# File lib/redis_ha/router/upstream.rb, line 8 def initialize debug_on=false @debug = debug_on @connected = EM::DefaultDeferrable.new end
Public Instance Methods
connection_completed()
click to toggle source
# File lib/redis_ha/router/upstream.rb, line 13 def connection_completed logger.debug [@name, :conn_complete] @plexer.connected(@name) @connected.succeed end
receive_data(data)
click to toggle source
# File lib/redis_ha/router/upstream.rb, line 19 def receive_data data logger.debug [@name, data] @plexer.relay_from_upstream(@name, data) end
send(data)
click to toggle source
# File lib/redis_ha/router/upstream.rb, line 24 def send data @connected.callback { send_data data } end
ubind()
click to toggle source
# File lib/redis_ha/router/upstream.rb, line 28 def ubind logger.debug [@name, :unbind] @plexer.unbind_backend(@name) end