module FayeAudit
Constants
- VERSION
Public Class Methods
audit(bayeux)
click to toggle source
# File lib/faye_audit.rb, line 26 def audit(bayeux) @@bayeux = bayeux bayeux.on(:handshake) do |client_id| logger.info <<LOG faye: { client_count: #{client_count + 1}, channel_count: #{channel_count} } handshake: client_id: #{client_id} LOG end bayeux.on(:subscribe) do |client_id, channel| logger.info <<LOG faye: { client_count: #{client_count}, channel_count: #{channel_count} } subscribe: client_id: #{client_id} channel: #{channel} LOG end bayeux.on(:unsubscribe) do |client_id, channel| logger.info <<LOG faye: { client_count: #{client_count}, channel_count: #{channel_count} } unsubscribe: client_id: #{client_id} channel: #{channel} LOG end bayeux.on(:publish) do |client_id, channel, data| logger.info <<LOG faye: { client_count: #{client_count}, channel_count: #{channel_count} } publish: client_id: #{client_id} channel: #{channel} data: #{data} LOG end bayeux.on(:disconnect) do |client_id| logger.info <<LOG faye: { client_count: #{client_count}, channel_count: #{channel_count} } disconnect: client_id: #{client_id} LOG end end
channel_count()
click to toggle source
# File lib/faye_audit.rb, line 19 def channel_count @@bayeux.instance_variable_get(:@server) .instance_variable_get(:@engine) .instance_variable_get(:@engine) .instance_variable_get(:@channels).size end
client_count()
click to toggle source
# File lib/faye_audit.rb, line 12 def client_count @@bayeux.instance_variable_get(:@server) .instance_variable_get(:@engine) .instance_variable_get(:@engine) .instance_variable_get(:@clients).keys.size end
logger()
click to toggle source
# File lib/faye_audit.rb, line 4 def logger @@logger end
logger=(logger)
click to toggle source
# File lib/faye_audit.rb, line 8 def logger=(logger) @@logger = logger end
Private Instance Methods
audit(bayeux)
click to toggle source
# File lib/faye_audit.rb, line 26 def audit(bayeux) @@bayeux = bayeux bayeux.on(:handshake) do |client_id| logger.info <<LOG faye: { client_count: #{client_count + 1}, channel_count: #{channel_count} } handshake: client_id: #{client_id} LOG end bayeux.on(:subscribe) do |client_id, channel| logger.info <<LOG faye: { client_count: #{client_count}, channel_count: #{channel_count} } subscribe: client_id: #{client_id} channel: #{channel} LOG end bayeux.on(:unsubscribe) do |client_id, channel| logger.info <<LOG faye: { client_count: #{client_count}, channel_count: #{channel_count} } unsubscribe: client_id: #{client_id} channel: #{channel} LOG end bayeux.on(:publish) do |client_id, channel, data| logger.info <<LOG faye: { client_count: #{client_count}, channel_count: #{channel_count} } publish: client_id: #{client_id} channel: #{channel} data: #{data} LOG end bayeux.on(:disconnect) do |client_id| logger.info <<LOG faye: { client_count: #{client_count}, channel_count: #{channel_count} } disconnect: client_id: #{client_id} LOG end end
channel_count()
click to toggle source
# File lib/faye_audit.rb, line 19 def channel_count @@bayeux.instance_variable_get(:@server) .instance_variable_get(:@engine) .instance_variable_get(:@engine) .instance_variable_get(:@channels).size end
client_count()
click to toggle source
# File lib/faye_audit.rb, line 12 def client_count @@bayeux.instance_variable_get(:@server) .instance_variable_get(:@engine) .instance_variable_get(:@engine) .instance_variable_get(:@clients).keys.size end
logger()
click to toggle source
# File lib/faye_audit.rb, line 4 def logger @@logger end
logger=(logger)
click to toggle source
# File lib/faye_audit.rb, line 8 def logger=(logger) @@logger = logger end