Module: Julewire::Core::Diagnostics::InternalRecords

Defined in:
lib/julewire/core/diagnostics/internal_records.rb

Class Method Summary collapse

Class Method Details

.emit_error(error) ⇒ Object 



8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/julewire/core/diagnostics/internal_records.rb', line 8

def emit_error(error)
  Records::Draft.build(
    {
      severity: :error,
      event: "julewire.emit_error",
      source: "julewire",
      message: "Julewire emit failed",
      payload: {
        error: failure_details(error)
      }
    },
    context: nil,
    scope: nil
  )
end

.processor_error(processor_name:, error:, record_metadata:) ⇒ Object 



24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
 
# File 'lib/julewire/core/diagnostics/internal_records.rb', line 24

def processor_error(processor_name:, error:, record_metadata:)
  Records::Draft.build(
    {
      severity: :error,
      event: "julewire.processor_error",
      source: "julewire",
      message: "Julewire processor failed",
      labels: labels(record_metadata),
      payload: {
        processor: processor_name,
        error: failure_details(error),
        record: record_metadata
      }
    },
    context: nil,
    scope: nil
  )
end