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

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

Class Method Summary collapse

Class Method Details

.emit_error(error, error_backtrace_lines:) ⇒ Object 



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

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

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



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

def processor_error(processor_name:, error:, record_metadata:, error_backtrace_lines:)
  Core::Records::Draft.build(
    {
      severity: :error,
      kind: :point,
      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: {},
    scope: nil,
    error_backtrace_lines: error_backtrace_lines
  )
end