class Aerospike::UdfRegisterTask

Public Class Methods

new(cluster, package_name) click to toggle source
Calls superclass method Aerospike::Task::new
# File lib/aerospike/task/udf_register_task.rb, line 28
def initialize(cluster, package_name)
  super(cluster, false)
  @package_name = package_name

  self
end

Private Instance Methods

all_nodes_done?() click to toggle source
# File lib/aerospike/task/udf_register_task.rb, line 37
def all_nodes_done?
  command = 'udf-list'
  nodes = @cluster.nodes

  nodes.each do |node|
    conn = node.get_connection(1)
    response_map = Info.request(conn, command)
    _, response = response_map.first
    index = response.to_s.index("filename=#{@package_name}")

    return false if index.nil?
  end

  return true
end