Module: Cellect::Client

Defined in:
lib/cellect/client.rb,
lib/cellect/testing.rb,
lib/cellect/client/railtie.rb,
lib/cellect/client/node_set.rb,
lib/cellect/client/connection.rb

Defined Under Namespace

Classes: CellectRailtie, CellectServerError, ConfigurationError, Connection, NodeSet

Class Attribute Summary collapse

Class Method Summary collapse

Class Attribute Details

._node_set ⇒ Object

Returns the value of attribute _node_set.



9
10
11
 
# File 'lib/cellect/client.rb', line 9

def _node_set
  @_node_set
end

.connection ⇒ Object

Returns the value of attribute connection.



9
10
11
 
# File 'lib/cellect/client.rb', line 9

def connection
  @connection
end

Class Method Details

.choose_host ⇒ Object

Selects a server for a user



23
24
25
 
# File 'lib/cellect/client.rb', line 23

def self.choose_host
  node_set.nodes.values.sample
end

.host_exists?(ip) ⇒ Boolean

Ensure a previously selected server is still available

Returns:

  • (Boolean) 


28
29
30
 
# File 'lib/cellect/client.rb', line 28

def self.host_exists?(ip)
  node_set.nodes.values.include? ip
end

.mock_zookeeper? ⇒ Boolean

Returns:

  • (Boolean) 


3
4
5
 
# File 'lib/cellect/testing.rb', line 3

def self.mock_zookeeper?
  true
end

.node_set(zk_url = nil) ⇒ Object

Sets up the set of server nodes



13
14
15
16
 
# File 'lib/cellect/client.rb', line 13

def self.node_set(zk_url=nil)
  self._node_set ||= NodeSet.supervise(zk_url)
  _node_set.actors.first
end

.ready? ⇒ Boolean

Returns:

  • (Boolean) 


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

def self.ready?
  node_set.ready?
end