Module: FiberAudit::Runtime::Boot

Defined in:

lib/fiber_audit/runtime/boot.rb

Class Method Summary

• .activate_from_environment!(environment: ENV, clock: Clock.new, session_id_source: SecureRandom.method(:uuid), pid_source: Process.method(:pid), writer_factory: JSONL::Writer.method(:open), random: Sampler::RANDOM_SOURCE) ⇒ Object
• .activated? ⇒ Boolean
• .current ⇒ Object
• .shutdown(exception: nil) ⇒ Object

Class Method Details

.activate_from_environment!(environment: ENV, clock: Clock.new, session_id_source: SecureRandom.method(:uuid), pid_source: Process.method(:pid), writer_factory: JSONL::Writer.method(:open), random: Sampler::RANDOM_SOURCE) ⇒ Object

# File 'lib/fiber_audit/runtime/boot.rb', line 11

def activate_from_environment!(
  environment: ENV,
  clock: Clock.new,
  session_id_source: SecureRandom.method(:uuid),
  pid_source: Process.method(:pid),
  writer_factory: JSONL::Writer.method(:open),
  random: Sampler::RANDOM_SOURCE
)
  return current if activated_for_current_process?

  mode = Environment.failure_mode(environment)
  return unless Environment.activated?(environment)

  settings = Environment.load(environment)
  watchdog_policy = if environment.key?(Environment::WATCHDOG_SETTINGS_KEY)
                      Environment.load_watchdog_policy(environment)
                    end
  operation_liveness_policy = if environment.key?(Environment::OPERATION_LIVENESS_SETTINGS_KEY)
                                Environment.load_operation_liveness_policy(environment)
                              end
  @lifecycle = Lifecycle.start(
    settings: settings,
    watchdog_policy: watchdog_policy,
    operation_liveness_policy: operation_liveness_policy,
    probes_enabled: Environment.probes_enabled?(environment),
    clock: clock,
    session_id_source: session_id_source,
    pid_source: pid_source,
    writer_factory: writer_factory,
    random: random
  )
  @pid_source = pid_source
  @activation_pid = pid_source.call
  install_shutdown_hook!
  @lifecycle
rescue StandardError
  raise if defined?(mode) && mode == :closed

  nil
end

.activated? ⇒ Boolean

Returns:

• (Boolean)

# File 'lib/fiber_audit/runtime/boot.rb', line 60

def activated?
  !current.nil?
end

.current ⇒ Object

# File 'lib/fiber_audit/runtime/boot.rb', line 52

def current
  return unless @lifecycle

  @lifecycle.ensure_current_process!
  @activation_pid = @pid_source.call
  @lifecycle
end

.shutdown(exception: nil) ⇒ Object

# File 'lib/fiber_audit/runtime/boot.rb', line 64

def shutdown(exception: nil)
  current&.shutdown(exception: exception)
end