Class: WorkflowManager::Server::RedisDB

Inherits:
Object
  • Object
show all
Defined in:
lib/workflow_manager/server.rb

Instance Method Summary collapse

Constructor Details

#initialize(db_no = 0, redis_conf = nil) ⇒ RedisDB

Returns a new instance of RedisDB.



111
112
113
114
115
116
 
# File 'lib/workflow_manager/server.rb', line 111

def initialize(db_no=0, redis_conf=nil)
  if db_no==0
    run_redis_server(redis_conf)
  end
  @db = Redis.new(db: db_no)
end

Instance Method Details

#run_redis_server(redis_conf) ⇒ Object 



103
104
105
106
107
108
109
110
 
# File 'lib/workflow_manager/server.rb', line 103

def run_redis_server(redis_conf)
  @pid = fork do
    exec("redis-server #{redis_conf}")
  end
  @redis_thread = Thread.new do
    Process.waitpid @pid
  end
end

#transaction {|@db| ... } ⇒ Object

Yields:

  • (@db) 


117
118
119
120
121
 
# File 'lib/workflow_manager/server.rb', line 117

def transaction
  #@db.multi do
    yield(@db)
  #end
end