Snakepit.CrashBarrier (Snakepit v0.13.0)

Copy Markdown View Source

Crash barrier policy for worker failures.

Classifies worker crashes, taints unstable workers, and determines retry eligibility.

Summary

Functions

config(pool_config \\ %{})
crash_info(arg1, config)
enabled?(config)
idempotent?(args)
maybe_emit_restart(pool_name, worker_id)
normalize_crash_error(result, info)
retry_allowed?(config, idempotent, attempt)
retry_backoff(config, attempt)
taint_worker(pool_name, worker_id, info, config)
worker_tainted?(worker_id)

Functions

config(pool_config \\ %{})

crash_info(arg1, config)

enabled?(config)

@spec enabled?(map()) :: boolean()

idempotent?(args)

maybe_emit_restart(pool_name, worker_id)

normalize_crash_error(result, info)

retry_allowed?(config, idempotent, attempt)

@spec retry_allowed?(map(), boolean(), non_neg_integer()) :: boolean()

retry_backoff(config, attempt)

taint_worker(pool_name, worker_id, info, config)

worker_tainted?(worker_id)

@spec worker_tainted?(String.t()) :: boolean()