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