Class: MigrateSsdb2pika::Migration

Inherits:
Object
  • Object
show all
Defined in:
lib/migrate_ssdb2pika/migration.rb

Constant Summary collapse

SCAN_LIMIT = 
100

Instance Method Summary collapse

Constructor Details

#initialize(options) ⇒ Migration

Returns a new instance of Migration.



9
10
11
 
# File 'lib/migrate_ssdb2pika/migration.rb', line 9

def initialize(options)
  @options = options
end

Instance Method Details

#start ⇒ Object 



13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
 
# File 'lib/migrate_ssdb2pika/migration.rb', line 13

def start
  setup_client
  log_message("start")
  case @options[:mode]
    when 'kv'
      scan_key_values
      log_message("scan_key_values done")
    when 'hash'
      scan_all_hashs
      log_message("scan_all_hashs done")
    when 'zset'
      scan_all_zsets
      log_message("scan_all_zsets done")
    when 'queue'
      scan_all_queues
      log_message("scan_all_queues done")
    else
      scan_key_values
      log_message("scan_key_values done")
      scan_all_hashs
      log_message("scan_all_hashs done")
      scan_all_zsets
      log_message("scan_all_zsets done")
      scan_all_queues
      log_message("scan_all_queues done")
  end
end