daemon

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

type Ctrl struct {
	Type    CtrlType `json:"type"`
	Version int      `json:"version,omitempty"`
	Session string   `json:"session,omitempty"`
	Cwd     string   `json:"cwd,omitempty"`
	Args    []string `json:"args,omitempty"`
	Prompt  string   `json:"prompt,omitempty"`
	// Line is one stream-json event line (for CtrlData).
	Line string `json:"line,omitempty"`
	// Message is a human-readable detail (for CtrlError / CtrlAck).
	Message string `json:"message,omitempty"`
	// Status is populated on CtrlStatusResult.
	Status *StatusReport `json:"status,omitempty"`
}

type CtrlType string

type ExecLauncherConfig struct {
	// Executable is the zero binary to spawn (defaults to os.Executable()).
	Executable string
	// BaseArgs are prepended before the per-session args (defaults to the headless
	// stream-json exec invocation `exec --output-format stream-json`).
	BaseArgs []string
	// Env is the base environment for workers (defaults to os.Environ()). The
	// re-entrancy markers are always scrubbed from it.
	Env []string
}

type FrameKind uint8

type Launcher func(ctx context.Context, spec WorkerSpec) (WorkerHandle, error)

type Lines interface {
	Next() (line string, ok bool, err error)
}

type Paths struct {
	Socket string
	Lock   string
	Status string
}

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

type PoolOptions struct {
	// Size is the max number of concurrent workers (lease slots). Sessions beyond
	// this queue until a slot frees.
	Size int
	// Launcher spawns a worker. Required.
	Launcher Launcher
	// MaxAttempts caps the total attempts per request (first + retries). When
	// exhausted, Run returns ErrPermanent (mirrors capping consecutive restarts).
	MaxAttempts int
	// KillTimeout bounds graceful termination before SIGKILL-equivalent on drain.
	KillTimeout time.Duration
	// Backoff returns the delay before retry attempt n (1-based crash count).
	// Defaults to BackoffWithJitter; tests inject a deterministic function.
	Backoff func(attempt int) time.Duration
	// TempfailDelay is the cool-off after an ExitTempfail exit. Defaults to 30s.
	TempfailDelay time.Duration
	// Log, when set, receives one line per lifecycle event.
	Log func(string)
}

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

type ServerOptions struct {
	Paths   Paths
	Manager *SessionManager
	Pool    *Pool
	Version int
	Now     func() time.Time
	Log     func(string)
	// contains filtered or unexported fields
}

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

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

type SessionManagerOptions struct {
	Pool      *Pool
	MaxBuffer int // per-session output ring size; 0 => default
	// MaxSessions caps the retained session registry; 0 => default. The oldest
	// FINISHED sessions are evicted once the cap is exceeded.
	MaxSessions int
}

type SessionState string

type SessionStatus struct {
	ID    string `json:"id"`
	State string `json:"state"`
	Lines int    `json:"lines"`
}

type Sink interface {
	Line(line string)
}

type StatusFile struct {
	PID       int       `json:"pid"`
	Socket    string    `json:"socket"`
	Version   int       `json:"version"`
	StartedAt time.Time `json:"startedAt"`
}

type StatusReport struct {
	PID        int             `json:"pid"`
	Version    int             `json:"version"`
	Socket     string          `json:"socket"`
	StartedAt  time.Time       `json:"startedAt"`
	PoolSize   int             `json:"poolSize"`
	Workers    []WorkerStatus  `json:"workers"`
	Sessions   []SessionStatus `json:"sessions"`
	QueueDepth int             `json:"queueDepth"`
}

type WorkerHandle interface {
	Stdout() Lines
	// Wait blocks until the worker exits and returns its process exit code.
	Wait() (int, error)
	// Kill force-terminates the worker (used on drain timeout).
	Kill() error
	Pid() int
}

type WorkerSpec struct {
	Session string
	Cwd     string
	// Args are the per-session exec flags (e.g. --prompt ...), parsed by the CLI
	// and appended after `exec` by the production launcher.
	Args []string
}

type WorkerStatus struct {
	ID                 int    `json:"id"`
	PID                int    `json:"pid"`
	State              string `json:"state"`
	ConsecutiveCrashes int    `json:"consecutiveCrashes"`
	Restarts           int    `json:"restarts"`
	Session            string `json:"session,omitempty"`
}