8
9
10
11
12
13
14
15
16
17
|
# File 'lib/textus/store/jobs/sweep.rb', line 8
def self.call(container:, call:, scope: {}, key: nil)
prefix = key || (scope.is_a?(Hash) ? scope["prefix"] : nil)
lane = scope.is_a?(Hash) ? scope["lane"] : nil
rows = Textus::Core::Retention::Sweep.new(
manifest: container.manifest,
file_stat: Textus::Port::Storage::FileStat.new,
clock: Textus::Port::Clock.new,
).call(prefix: prefix, lane: lane)
Textus::Store::Jobs::Retention.new(container: container, call: call).call(rows)
end
|