Class: CloudwatchQuery::Parsers::Sidekiq::DoneSubParser

Inherits:
Object
  • Object
show all
Includes:
SubParser
Defined in:
lib/cloudwatch_query/parsers/sidekiq/sub_parsers.rb

Overview

Parses job done with elapsed: "elapsed=0.152 INFO: done"

Constant Summary collapse

ELAPSED_REGEX = 
/elapsed=(?<elapsed>[\d.]+)\s+INFO:\s+done$/

Class Method Summary collapse

Methods included from SubParser

included

Class Method Details

.matches?(message) ⇒ Boolean

Returns:

  • (Boolean) 


45
46
47
 
# File 'lib/cloudwatch_query/parsers/sidekiq/sub_parsers.rb', line 45

def self.matches?(message)
  message.include?("INFO: done")
end

.parse(message, _base_data) ⇒ Object 



49
50
51
52
53
54
55
56
57
58
 
# File 'lib/cloudwatch_query/parsers/sidekiq/sub_parsers.rb', line 49

def self.parse(message, _base_data)
  match = message.match(ELAPSED_REGEX)
  elapsed = match ? match[:elapsed].to_f : nil

  {
    line_type: :done,
    status: "done",
    elapsed: elapsed
  }
end