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: []) 


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

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]]) 


160
161
162
 
# File 'lib/kettle/ndjson.rb', line 160

def phase_timings
  @phase_timings
end

Instance Method Details

#emit(payload) ⇒ void

This method returns an undefined value.

Parameters:

  • payload (Hash[Symbol, untyped]) 


162
163
164
 
# File 'lib/kettle/ndjson.rb', line 162

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

#record_phase_timing(payload) ⇒ void

This method returns an undefined value.

Parameters:

  • payload (Hash[Symbol, untyped]) 


166
167
168
 
# File 'lib/kettle/ndjson.rb', line 166

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