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