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 |