Method: OpenC3::ReducerModel.rm_file

Defined in:
lib/openc3/models/reducer_model.rb

.rm_file(bucket_key) ⇒ Object 



52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/openc3/models/reducer_model.rb', line 52

def self.rm_file(bucket_key)
  _, _, scope, target, _ = bucket_key.split('__')
  case bucket_key
  when /__decom\.bin.gz$/
    Store.srem("#{scope}__#{target}__reducer__decom", bucket_key)
  when /__reduced_minute\.bin.gz$/
    Store.srem("#{scope}__#{target}__reducer__minute", bucket_key)
  when /__reduced_hour\.bin.gz$/
    Store.srem("#{scope}__#{target}__reducer__hour", bucket_key)
  else
    # We should only remove files that were previously in the set
    # Thus if we don't match the bucket_key it is an error
    raise "Unknown file #{bucket_key}"
  end
end