Class: Logical::Naf::LogReader
- Inherits:
-
Object
- Object
- Logical::Naf::LogReader
- Defined in:
- app/models/logical/naf/log_reader.rb
Constant Summary collapse
- DATE_REGEX =
/((\d){4}-(\d){2}-(\d){2} (\d){2}:(\d){2}:(\d){2} UTC)/
Instance Method Summary collapse
- #log_files ⇒ Object
- #retrieve_file(file) ⇒ Object
- #retrieve_job_files(job_id) ⇒ Object
- #runner_log_files ⇒ Object
Instance Method Details
#log_files ⇒ Object
9 10 11 12 13 14 15 16 17 18 19 20 21 |
# File 'app/models/logical/naf/log_reader.rb', line 9 def log_files tree = bucket.objects.with_prefix(prefix).as_tree directories = tree.children.select(&:branch?).collect(&:prefix).uniq files = [] directories.each do |directory| tree = bucket.objects.with_prefix(directory).as_tree tree.children.select(&:leaf?).collect(&:key).each do |file| files << file end end return sort_files(files) end |
#retrieve_file(file) ⇒ Object
38 39 40 |
# File 'app/models/logical/naf/log_reader.rb', line 38 def retrieve_file(file) bucket.objects[file].read end |
#retrieve_job_files(job_id) ⇒ Object
42 43 44 45 |
# File 'app/models/logical/naf/log_reader.rb', line 42 def retrieve_job_files(job_id) tree = bucket.objects.with_prefix(prefix + "#{job_id}").as_tree sort_files(tree.children.select(&:leaf?).collect(&:key)) end |
#runner_log_files ⇒ Object
23 24 25 26 27 28 29 30 31 32 33 34 35 |
# File 'app/models/logical/naf/log_reader.rb', line 23 def runner_log_files tree = bucket.objects.with_prefix(prefix(true)).as_tree directories = tree.children.select(&:branch?).collect(&:prefix).uniq files = [] directories.each do |directory| tree = bucket.objects.with_prefix(directory).as_tree tree.children.select(&:leaf?).collect(&:key).each do |file| files << file end end return sort_files(files) end |