process

Dec 22, 2025

Changes in this version

type ManagerConfig

+ PIDTracker PIDTracker

+ type PIDTracker interface

+ Add func(id string, pid int, pgid int, projectPath string) error

+ Remove func(id string, projectPath string) error

Dec 19, 2025

Changes in this version

type ProcessManager

+ func (pm *ProcessManager) StopByProjectPath(ctx context.Context, projectPath string) ([]string, error)

Dec 18, 2025

Changes in this version

type ManagedProcess

+ Env []string

type ProcessConfig

+ Env []string

type ProcessManager

+ func (pm *ProcessManager) StopAll(ctx context.Context) error

Dec 15, 2025

Changes in this version

+ const CTRL_BREAK_EVENT — windows/amd64

+ const CTRL_C_EVENT — windows/amd64

+ func CleanupJobObject(pid int)

+ func SetupJobObject(cmd *exec.Cmd) error

Dec 15, 2025

Changes in this version

+ const DefaultBufferSize

+ var ErrInvalidState = errors.New("invalid process state for operation")

+ var ErrProcessExists = errors.New("process already exists")

+ var ErrProcessNotFound = errors.New("process not found")

+ var ErrShuttingDown = errors.New("process manager is shutting down")

+ type ManagedProcess struct

+ Args []string

+ Command string

+ ID string

+ Labels map[string]string

+ ProjectPath string

+ func NewManagedProcess(cfg ProcessConfig) *ManagedProcess

+ func (p *ManagedProcess) Cancel()

+ func (p *ManagedProcess) CombinedOutput() ([]byte, bool)

+ func (p *ManagedProcess) CompareAndSwapState(expected, new ProcessState) bool

+ func (p *ManagedProcess) Done() <-chan struct{}

+ func (p *ManagedProcess) EndTime() *time.Time

+ func (p *ManagedProcess) ExitCode() int

+ func (p *ManagedProcess) IsDone() bool

+ func (p *ManagedProcess) IsRunning() bool

+ func (p *ManagedProcess) PID() int

+ func (p *ManagedProcess) Runtime() time.Duration

+ func (p *ManagedProcess) SetState(s ProcessState)

+ func (p *ManagedProcess) StartTime() *time.Time

+ func (p *ManagedProcess) State() ProcessState

+ func (p *ManagedProcess) Stderr() ([]byte, bool)

+ func (p *ManagedProcess) Stdout() ([]byte, bool)

+ func (p *ManagedProcess) Summary() string

+ type ManagerConfig struct

+ DefaultTimeout time.Duration

+ GracefulTimeout time.Duration

+ HealthCheckPeriod time.Duration

+ MaxOutputBuffer int

+ func DefaultManagerConfig() ManagerConfig

+ type ProcessConfig struct

+ Args []string

+ BufferSize int

+ Command string

+ ID string

+ Labels map[string]string

+ ProjectPath string

+ Timeout time.Duration

+ type ProcessManager struct

+ func NewProcessManager(config ManagerConfig) *ProcessManager

+ func (pm *ProcessManager) ActiveCount() int64

+ func (pm *ProcessManager) Config() ManagerConfig

+ func (pm *ProcessManager) Get(id string) (*ManagedProcess, error)

+ func (pm *ProcessManager) GetByPID(pid int) *ManagedProcess

+ func (pm *ProcessManager) GetByPath(id, projectPath string) (*ManagedProcess, error)

+ func (pm *ProcessManager) IncrementFailed()

+ func (pm *ProcessManager) IsManagedPID(pid int) bool

+ func (pm *ProcessManager) IsShuttingDown() bool

+ func (pm *ProcessManager) KillProcessByPort(ctx context.Context, port int) ([]int, error)

+ func (pm *ProcessManager) List() []*ManagedProcess

+ func (pm *ProcessManager) ListByLabel(key, value string) []*ManagedProcess

+ func (pm *ProcessManager) Register(proc *ManagedProcess) error

+ func (pm *ProcessManager) Remove(id string) bool

+ func (pm *ProcessManager) RemoveByPath(id, projectPath string) bool

+ func (pm *ProcessManager) Restart(ctx context.Context, id string) (*ManagedProcess, error)

+ func (pm *ProcessManager) RunSync(ctx context.Context, cfg ProcessConfig) (int, error)

+ func (pm *ProcessManager) Shutdown(ctx context.Context) error

+ func (pm *ProcessManager) Start(ctx context.Context, proc *ManagedProcess) error

+ func (pm *ProcessManager) StartCommand(ctx context.Context, cfg ProcessConfig) (*ManagedProcess, error)

+ func (pm *ProcessManager) StartOrReuse(ctx context.Context, cfg ProcessConfig) (*StartOrReuseResult, error)

+ func (pm *ProcessManager) Stop(ctx context.Context, id string) error

+ func (pm *ProcessManager) StopProcess(ctx context.Context, proc *ManagedProcess) error

+ func (pm *ProcessManager) TotalFailed() int64

+ func (pm *ProcessManager) TotalStarted() int64

+ type ProcessState uint32

+ const StateFailed

+ const StatePending

+ const StateRunning

+ const StateStarting

+ const StateStopped

+ const StateStopping

+ func (s ProcessState) String() string

+ type RingBuffer struct

+ func NewRingBuffer(capacity int) *RingBuffer

+ func (rb *RingBuffer) Cap() int

+ func (rb *RingBuffer) Len() int

+ func (rb *RingBuffer) Reset()

+ func (rb *RingBuffer) Snapshot() (data []byte, truncated bool)

+ func (rb *RingBuffer) Truncated() bool

+ func (rb *RingBuffer) Write(p []byte) (n int, err error)

+ type StartOrReuseResult struct

+ Cleaned bool

+ PortError string

+ PortRetried bool

+ PortsCleared []int

+ Process *ManagedProcess

+ Reused bool