Sha256: c6eee68b967144f70a0ae69561e2ec0d4ffac5e4f8691c768efc18bf01c88f5f

Contents?: true

Size: 560 Bytes

Versions: 2

Compression:

Stored size: 560 Bytes

Contents

require 'cellect'

module Cellect
  module Client
    require 'cellect/client/node_set'
    require 'cellect/client/connection'
    
    class << self
      attr_accessor :connection, :_node_set
    end
    
    def self.node_set
      self._node_set ||= NodeSet.supervise
      _node_set.actors.first
    end
    
    def self.ready?
      node_set.ready?
    end
    
    def self.choose_host
      node_set.nodes.values.sample
    end
    
    Client.node_set
    Client.connection = Connection.pool size: ENV.fetch('CELLECT_POOL_SIZE', 100).to_i
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
cellect-client-0.0.2 lib/cellect/client.rb
cellect-client-0.0.1 lib/cellect/client.rb