pub suberror LockError {
  Invalid(line~ : Int, reason~ : String)
} derive(
@moonbitlang/core/debug.Debug
Debug)

pub(all) struct Bottleneck {
  holder_line : Int
  owner : Owner
  direct_waiters : Int
  total_waiters : Int
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) struct ByteRange {
  start : Int64
  end : Int64?
} derive(Eq, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) struct Entry {
  line : Int
  ordinal : Int64
  depth : Int
  kind : LockKind
  state : String
  mode : LockMode
  owner : Owner
  file : FileKey?
  range : ByteRange
  parent_line : Int?
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug)

pub struct FileCapture {
  // private fields
}

pub(all) struct FileFrameReport {
  elapsed_ms : Int64
  path_state : String
  waiting_records : Int
  entries : Array[Entry]
  issues : Array[String]
} derive(ToJson)

pub(all) struct FileKey {
  major : UInt
  minor : UInt
  inode : UInt64
} derive(Eq, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) struct FileReport {
  file : FileKey
  sample_count : Int
  observed_span_ms : Int64
  peak_waiting_records : Int
  max_consecutive_wait_samples : Int
  frames : Array[FileFrameReport]
} derive(ToJson)

pub(all) enum LockKind {
  Posix
  Flock
  Ofd
  Lease
  Other(String)
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) enum LockMode {
  Read
  Write
  Unlock
  Other(String)
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) enum Owner {
  Process(Int)
  OpenDescription
  NotVisible
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) struct ProcessInfo {
  pid : Int
  parent_pid : Int
  name : String
  state : String
  start_ticks : String
  wchan : String
  wchan_status : String
} derive(Eq, ToJson, 
@moonbitlang/core/debug.Debug
Debug)

pub struct Snapshot {
  // private fields
} derive(
@moonbitlang/core/debug.Debug
Debug)

pub struct TaskCapture {
  // private fields
}

pub(all) struct TaskChange {
  pid : Int
  start_ticks : String
  change : String
  before : String
  after : String
} derive(ToJson)

pub(all) struct TaskComparison {
  root_pid : Int
  root_start_ticks : String
  evidence_complete : Bool
  before_waiters : Int
  after_waiters : Int
  resolved_lock_waits : Int
  new_lock_waits : Int
  changes : Array[TaskChange]
  issues : Array[String]
} derive(ToJson)

pub(all) struct TaskFrameReport {
  elapsed_ms : Int64
  root_state : String
  processes : Array[TaskProcess]
  blocker_processes : Array[ProcessInfo]
  issues : Array[String]
} derive(ToJson, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) struct TaskProcess {
  info : ProcessInfo
  finding : String
  waiting_lines : Array[Int]
  requests : Array[Entry]
  blockers : Array[Entry]
  blocker_identities : Array[String]
  files : Array[FileKey]
} derive(ToJson, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) struct TaskReport {
  root_pid : Int
  root_start_ticks : String
  started_at : String
  sample_count : Int
  observed_span_ms : Int64
  max_consecutive_wait_samples : Int
  max_sampled_wait_span_ms : Int64
  frames : Array[TaskFrameReport]
  transitions : Array[TaskTransition]
  next_steps : Array[String]
} derive(ToJson, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) struct TaskTransition {
  at_ms : Int64
  pid : Int
  start_ticks : String
  change : String
  before : String
  after : String
} derive(ToJson, 
@moonbitlang/core/debug.Debug
Debug)

pub(all) struct WaitAssessment {
  status : String
  threshold_samples : Int
  sample_count : Int
  observed_streak : Int
  evidence_gaps : Int
  reason : String
} derive(ToJson)

fn assess_capture(text : String, wait_samples? : Int) -> WaitAssessment raise LockError

fn byte_range(start : String, end : String) -> ByteRange raise LockError

fn file_capture() -> FileCapture

fn file_key(text : String) -> FileKey raise LockError

fn parse(text : String, max_chars? : Int, max_records? : Int, max_depth? : Int) -> Snapshot raise LockError

fn parse_file_capture(text : String) -> FileCapture raise LockError

fn parse_process(stat : String, wchan? : String, wchan_error? : String) -> ProcessInfo raise LockError

fn parse_task_capture(text : String) -> TaskCapture raise LockError

fn task_capture(pid : Int) -> TaskCapture raise LockError