toolruntime

type BootReconcileReport struct {
	Checked   int
	Recovered int
	Stale     int
}

type Handle struct {
	// contains filtered or unexported fields
}

type InterruptFunc func(context.Context, ProcessRecord) error

type InterruptReport struct {
	Matched     int
	Signaled    int
	Stale       int
	Unavailable int
}

type InterruptScope struct {
	ProcessID     string
	SessionID     string
	TurnID        string
	ToolCallID    string
	TerminalID    string
	ExtensionName string
	HookName      string
	Source        ProcessSource
	Reason        string
}

type Interrupter interface {
	InterruptProcess(ctx context.Context, record ProcessRecord) error
}

type MemoryStore struct {
	// contains filtered or unexported fields
}

type Option func(*Registry)

type ProcessCheckpoint struct {
	Owner          *ProcessOwner
	PID            *int
	ProcessGroupID *int
	StartedAt      *time.Time
	State          ProcessState
	Error          string
	UpdatedAt      time.Time
}

type ProcessCompletion struct {
	ExitCode *int
	Err      error
	Error    string
}

type ProcessOwner struct {
	SessionID     string
	TurnID        string
	ToolCallID    string
	TerminalID    string
	ExtensionName string
	HookName      string
	SandboxID     string
}

type ProcessQuery struct {
	IDs    []string
	States []ProcessState
	Scope  InterruptScope
	Limit  int
}

type ProcessRecord struct {
	ID             string
	Source         ProcessSource
	Owner          ProcessOwner
	PID            int
	ProcessGroupID int
	Command        string
	Args           []string
	Cwd            string
	StartedAt      time.Time
	StartedByPID   int
	State          ProcessState
	ExitCode       *int
	Error          string
	CreatedAt      time.Time
	UpdatedAt      time.Time
	CompletedAt    *time.Time
}

type ProcessSource string

type ProcessState string

type ProcessStateUpdate struct {
	ID          string
	State       ProcessState
	ExitCode    *int
	Error       string
	UpdatedAt   time.Time
	CompletedAt *time.Time
}

type RegisterConfig struct {
	ID             string
	Source         ProcessSource
	Owner          ProcessOwner
	PID            int
	ProcessGroupID int
	Command        string
	Args           []string
	Cwd            string
	StartedAt      time.Time
	Interrupt      InterruptFunc
}

type Registry struct {
	// contains filtered or unexported fields
}

type Store interface {
	UpsertProcessRecord(ctx context.Context, record ProcessRecord) error
	UpdateProcessRecordState(ctx context.Context, update ProcessStateUpdate) error
	ListProcessRecords(ctx context.Context, query ProcessQuery) ([]ProcessRecord, error)
}

type Verifier func(pid int, startedAt time.Time) bool