class Aerospike::IndexTask
Constants
- MATCHER
Public Class Methods
new(cluster, namespace, index_name, done=false)
click to toggle source
Calls superclass method
# File lib/aerospike/task/index_task.rb, line 30 def initialize(cluster, namespace, index_name, done=false) super(cluster, done) @namespace = namespace @index_name = index_name self end
Private Instance Methods
all_nodes_done?()
click to toggle source
# File lib/aerospike/task/index_task.rb, line 40 def all_nodes_done? command = "sindex/#{@namespace}/#{@index_name}" nodes = @cluster.nodes nodes.each do |node| conn = node.get_connection(1) response_map = Info.request(conn, command) _, response = response_map.first match = response.to_s.match(MATCHER) load = match.nil? ? nil : match[:load_pct] return false if load && (0...100).include?(load.to_f) end return true end