Class: Wakame::ClusterManager::ServiceClusterPool

Inherits:

Sequel::Model

• Object
• Sequel::Model
• Wakame::ClusterManager::ServiceClusterPool

Defined in:

lib/wakame/master.rb

Class Method Summary

• .each_cluster(&blk) ⇒ Object
• .initialize_table ⇒ Object
• .register_cluster(name) ⇒ Object
• .unregister_cluster(name) ⇒ Object

Class Method Details

.each_cluster(&blk) ⇒ Object

# File 'lib/wakame/master.rb', line 339

def self.each_cluster(&blk)
  self.all.each { |m|
    cluster = Service::ServiceCluster.find(m.service_cluster_id)
    blk.call(cluster)
  }
end

.initialize_table ⇒ Object

# File 'lib/wakame/master.rb', line 319

def self.initialize_table
  set_schema do
    primary_key :id, :type => Integer
    varchar :service_cluster_id
  end
  create_table unless table_exists?
end

.register_cluster(name) ⇒ Object

# File 'lib/wakame/master.rb', line 328

def self.register_cluster(name)
  id = Service::ServiceCluster.id(name)
  
  self.find_or_create(:service_cluster_id=>id)
end

.unregister_cluster(name) ⇒ Object

# File 'lib/wakame/master.rb', line 334

def self.unregister_cluster(name)
  id = Service::ServiceCluster.id(name)
  self.delete(:service_cluster_id=>id)
end