Module: Anycable

Defined in:
lib/anycable.rb,
lib/anycable/config.rb,
lib/anycable/pubsub.rb,
lib/anycable/server.rb,
lib/anycable/rpc/rpc.rb,
lib/anycable/version.rb,
lib/anycable/rpc_handler.rb,
lib/anycable/rpc/rpc_services.rb

Overview

rubocop:disable Metrics/ClassLength rubocop:disable Metrics/AbcSize rubocop:disable Metrics/MethodLength

Defined Under Namespace

Modules: RPC, Server Classes: Config, PubSub, RPCHandler

Constant Summary collapse

ConnectionRequest = 
Google::Protobuf::DescriptorPool.generated_pool.lookup("anycable.ConnectionRequest").msgclass
ConnectionResponse = 
Google::Protobuf::DescriptorPool.generated_pool.lookup("anycable.ConnectionResponse").msgclass
CommandMessage = 
Google::Protobuf::DescriptorPool.generated_pool.lookup("anycable.CommandMessage").msgclass
CommandResponse = 
Google::Protobuf::DescriptorPool.generated_pool.lookup("anycable.CommandResponse").msgclass
DisconnectRequest = 
Google::Protobuf::DescriptorPool.generated_pool.lookup("anycable.DisconnectRequest").msgclass
DisconnectResponse = 
Google::Protobuf::DescriptorPool.generated_pool.lookup("anycable.DisconnectResponse").msgclass
Status = 
Google::Protobuf::DescriptorPool.generated_pool.lookup("anycable.Status").enummodule
VERSION = 
"0.2.0"

Class Method Summary collapse

Class Method Details

.config ⇒ Object 



22
23
24
 
# File 'lib/anycable.rb', line 22

def self.config
  @config ||= Config.new
end

.configure {|config| ... } ⇒ Object

Yields:



26
27
28
 
# File 'lib/anycable.rb', line 26

def self.configure
  yield(config) if block_given?
end

.logger ⇒ Object 



18
19
20
 
# File 'lib/anycable.rb', line 18

def self.logger
  @logger ||= Anycable.config.debug ? Logger.new(STDOUT) : Logger.new('/dev/null')
end

.logger=(logger) ⇒ Object 



14
15
16
 
# File 'lib/anycable.rb', line 14

def self.logger=(logger)
  @logger = logger
end