Class: Kettle::Ndjson::EventRecorder

Inherits:
Object
  • Object
show all
Defined in:
lib/kettle/ndjson.rb,
sig/kettle/ndjson.rbs

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(stream = nil, phase_timings = []) ⇒ EventRecorder

Returns a new instance of EventRecorder.

Parameters:

  • stream (Object) (defaults to: nil)
  • phase_timings (Array[Hash[Symbol, untyped]]) (defaults to: []) 


147
148
149
150
 
# File 'lib/kettle/ndjson.rb', line 147

def initialize(stream = nil, phase_timings = [])
  @stream = stream
  @phase_timings = phase_timings
end

Instance Attribute Details

#phase_timings ⇒ Array[Hash[Symbol, untyped]] (readonly)

Returns the value of attribute phase_timings.

Returns:

  • (Array[Hash[Symbol, untyped]]) 


152
153
154
 
# File 'lib/kettle/ndjson.rb', line 152

def phase_timings
  @phase_timings
end

Instance Method Details

#emit(payload) ⇒ void

This method returns an undefined value.

Parameters:

  • payload (Hash[Symbol, untyped]) 


154
155
156
 
# File 'lib/kettle/ndjson.rb', line 154

def emit(payload)
  @stream&.emit(payload)
end

#record_phase_timing(payload) ⇒ void

This method returns an undefined value.

Parameters:

  • payload (Hash[Symbol, untyped]) 


158
159
160
 
# File 'lib/kettle/ndjson.rb', line 158

def record_phase_timing(payload)
  @phase_timings << Kettle::Ndjson.compact_payload(payload)
end