class DeliveryObserver
def self.delivered_email(message)
new(message).record
end
def initialize(message)
package com.example.observability;
public final class CorrelationIdConstants {
public static final String HEADER_NAME = "X-Correlation-Id";
public static final String MDC_KEY = "correlationId";
package main
import (
"log"
"net/http"
"time"
package com.example.tracing;
import jakarta.servlet.Filter;
import jakarta.servlet.FilterChain;
import jakarta.servlet.ServletException;
import jakarta.servlet.ServletRequest;
package observability
import (
"time"
"go.uber.org/zap"
module QueryBudget
class Counter
IGNORED = %w[SCHEMA CACHE TRANSACTION].freeze
attr_reader :count
class ApplicationError < StandardError
attr_reader :context
class << self
def context_keys(*keys)
@context_keys = keys unless keys.empty?
package health
import (
"context"
"sync"
"time"
package logctx
import (
"context"
"log/slog"
)