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