Module: Octopus::Model::InstanceMethods

Includes:
SharedMethods
Defined in:
lib/octopus/model.rb

Instance Method Summary collapse

Methods included from SharedMethods

#clean_table_name, #hijack_connection, #hijack_initializer, #set_current_shard, #using

Instance Method Details

#reload_connection ⇒ Object 



79
80
81
 
# File 'lib/octopus/model.rb', line 79

def reload_connection()
  set_connection() if should_set_current_shard?
end

#set_connection(*args) ⇒ Object 



66
67
68
69
70
71
72
73
 
# File 'lib/octopus/model.rb', line 66

def set_connection(*args)
  if(args.size == 1)
    arg = args.first
    arg.current_shard = self.current_shard if arg.respond_to?(:current_shard) && should_set_current_shard?
  end

  self.connection.current_shard = self.current_shard if should_set_current_shard?
end

#should_set_current_shard? ⇒ Boolean

Returns:

  • (Boolean) 


75
76
77
 
# File 'lib/octopus/model.rb', line 75

def should_set_current_shard?
  self.respond_to?(:current_shard) && self.current_shard != nil
end