Class: Fragmenter::Redis

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/fragmenter/redis.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(fragmenter) ⇒ Redis

Returns a new instance of Redis.



13
14
15
 
# File 'lib/fragmenter/redis.rb', line 13

def initialize(fragmenter)
  @fragmenter = fragmenter
end

Instance Attribute Details

#fragmenter ⇒ Object (readonly)

Returns the value of attribute fragmenter.



11
12
13
 
# File 'lib/fragmenter/redis.rb', line 11

def fragmenter
  @fragmenter
end

Instance Method Details

#clean! ⇒ Object 



57
58
59
 
# File 'lib/fragmenter/redis.rb', line 57

def clean!
  redis.del store_key, meta_key
end

#complete? ⇒ Boolean

Returns:

  • (Boolean) 


43
44
45
 
# File 'lib/fragmenter/redis.rb', line 43

def complete?
  redis.hlen(store_key).to_s == redis.hget(meta_key, :total)
end

#fragments ⇒ Object 



39
40
41
 
# File 'lib/fragmenter/redis.rb', line 39

def fragments
  redis.hkeys(store_key).sort
end

#meta ⇒ Object 



35
36
37
 
# File 'lib/fragmenter/redis.rb', line 35

def meta
  redis.hgetall meta_key
end

#meta_key ⇒ Object 



21
22
23
 
# File 'lib/fragmenter/redis.rb', line 21

def meta_key
  [store_key, 'options'].join('-')
end

#rebuild ⇒ Object 



47
48
49
50
51
52
53
54
55
 
# File 'lib/fragmenter/redis.rb', line 47

def rebuild
  benchmark_rebuilding do
    redis.hmget(store_key, *fragments).join('')
  end
rescue ::Redis::CommandError
  log 'Failure rebuilding, most likely there are no fragments to rebuild'

  ''
end

#store(blob, options) ⇒ Object 



25
26
27
28
29
30
31
32
33
 
# File 'lib/fragmenter/redis.rb', line 25

def store(blob, options)
  fragment = Fragmenter::Fragment.new(blob, options)

  if fragment.valid?
    persist_fragment(fragment)
  else
    false
  end
end

#store_key ⇒ Object 



17
18
19
 
# File 'lib/fragmenter/redis.rb', line 17

def store_key
  fragmenter.key
end