292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
|
# File 'lib/cluster/infrastructures/amazon.rb', line 292
def save_monitor(io, key)
if bucket.put key, io
old = sdb.select "select * from #{domain} where entry = 'monitor'"
monitor = unless old[:items].empty?
self.class.from_sdb_results(old).first
else
{ 'aws_id' => UUIDTools::UUID.timestamp_create.to_s,
'entry' => 'monitor' }
end
monitor.merge! 'updated_at' => Time.now.xmlschema(3),
'key' => key,
'bucket' => @cluster_bucket
sdb.put_attributes domain, monitor['aws_id'], self.class.to_sdb_attributes(monitor), :replace
monitor
end
end
|