process

Oct 14, 2025

Changes in this version

+ type Config struct

+ Command []string

+ Env map[string]string

+ OutputHandler OutputHandler

+ ReadyCheck ReadyChecker

+ ReadyTimeout time.Duration

+ WorkDir string

+ type LogBuffer struct

+ func NewLogBuffer(capacity int) *LogBuffer

+ func (lb *LogBuffer) Append(entry LogEntry)

+ func (lb *LogBuffer) Clear()

+ func (lb *LogBuffer) Close() error

+ func (lb *LogBuffer) GetAllFromFile() ([]string, error)

+ func (lb *LogBuffer) GetByStream(stream string, n int) []LogEntry

+ func (lb *LogBuffer) GetLogFilePath() string

+ func (lb *LogBuffer) GetRecent(n int) []LogEntry

+ func (lb *LogBuffer) GetSince(since time.Time) []LogEntry

+ func (lb *LogBuffer) GetStats() LogStats

+ func (lb *LogBuffer) ToJSON(n int) ([]byte, error)

+ type LogCaptureConfig struct

+ BufferSize int

+ Enabled bool

+ func DefaultLogCaptureConfig() LogCaptureConfig

+ type LogEntry struct

+ Line string

+ PID int

+ Stream string

+ Timestamp time.Time

+ type LogStats struct

+ BufferFull bool

+ BufferedLines int

+ Capacity int

+ TotalLines int

+ type Manager struct

+ func NewManager(cfg Config, log *logger.Logger) (*Manager, error)

+ func (m *Manager) GetCommand() []string

+ func (m *Manager) GetPID() int

+ func (m *Manager) GetState() ProcessState

+ func (m *Manager) GetUptime() time.Duration

+ func (m *Manager) GetWorkDir() string

+ func (m *Manager) IsRunning() bool

+ func (m *Manager) Start(ctx context.Context) error

+ func (m *Manager) Stop() error

+ type ManagerWithLogs struct

+ func NewManagerWithLogs(cfg Config, logCfg LogCaptureConfig, log *logger.Logger) (*ManagerWithLogs, error)

+ func (m *ManagerWithLogs) AddErrorLog(message string)

+ func (m *ManagerWithLogs) ClearLogs()

+ func (m *ManagerWithLogs) CloseLogFile() error

+ func (m *ManagerWithLogs) GetAllLogsFromFile() ([]string, error)

+ func (m *ManagerWithLogs) GetLogFilePath() string

+ func (m *ManagerWithLogs) GetLogStats() LogStats

+ func (m *ManagerWithLogs) GetLogsByStream(stream string, n int) []LogEntry

+ func (m *ManagerWithLogs) GetLogsJSON(n int) ([]byte, error)

+ func (m *ManagerWithLogs) GetLogsSince(since time.Time) []LogEntry

+ func (m *ManagerWithLogs) GetRecentLogs(n int) []LogEntry

+ func (m *ManagerWithLogs) StreamLogs(ctx context.Context) <-chan LogEntry

+ type OutputHandler func(stream string, line string)

+ type ProcessState string

+ const StateFailed

+ const StateInitializing

+ const StateRunning

+ const StateStarting

+ const StateStopped

+ type ReadyChecker func(ctx context.Context) error