monitor

type ExitInfo ¶

type ExitInfo struct {
	Code      int
	Signal    string
	Timestamp time.Time
	Error     error
}

ExitInfo contains information about process exit

type HealthCheck ¶

type HealthCheck struct {
	Endpoint  string
	Status    HealthStatus
	Latency   time.Duration
	Error     error
	Timestamp time.Time
}

HealthCheck represents a health check result

type HealthMonitor ¶

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

HealthMonitor monitors the health of the core service

func NewHealthMonitor(endpoint string, logger *zap.SugaredLogger, stateMachine *state.Machine) *HealthMonitor

func (hm *HealthMonitor) GetLastCheck() time.Time

func (hm *HealthMonitor) GetLastError() error

func (hm *HealthMonitor) GetStatus() HealthStatus

func (hm *HealthMonitor) IsHealthy() bool

func (hm *HealthMonitor) IsReady() bool

func (hm *HealthMonitor) IsStarting() bool

func (hm *HealthMonitor) ResultsChannel() <-chan HealthCheck

func (hm *HealthMonitor) SetCheckInterval(interval time.Duration)

func (hm *HealthMonitor) SetReadinessTimeout(timeout time.Duration)

func (hm *HealthMonitor) SetTimeout(timeout time.Duration)

func (hm *HealthMonitor) Start()

func (hm *HealthMonitor) Stop()

func (hm *HealthMonitor) WaitForReady() error

type HealthStatus ¶

type HealthStatus string

HealthStatus represents the health status of the core service

const (
	HealthStatusUnknown     HealthStatus = "unknown"
	HealthStatusStarting    HealthStatus = "starting"
	HealthStatusHealthy     HealthStatus = "healthy"
	HealthStatusUnhealthy   HealthStatus = "unhealthy"
	HealthStatusUnavailable HealthStatus = "unavailable"
)

type ProcessConfig ¶

type ProcessConfig struct {
	Binary        string
	Args          []string
	Env           []string
	WorkingDir    string
	StartTimeout  time.Duration
	CaptureOutput bool
}

ProcessConfig contains configuration for process monitoring

type ProcessEvent ¶

type ProcessEvent struct {
	Type      ProcessEventType
	Data      map[string]interface{}
	Error     error
	Timestamp time.Time
}

ProcessEvent represents events from the process monitor

type ProcessEventType ¶

type ProcessEventType string

const (
	ProcessEventStarted ProcessEventType = "started"
	ProcessEventExited  ProcessEventType = "exited"
	ProcessEventError   ProcessEventType = "error"
	ProcessEventOutput  ProcessEventType = "output"
)

type ProcessMonitor ¶

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

ProcessMonitor monitors a subprocess and reports its status

func NewProcessMonitor(config *ProcessConfig, logger *zap.SugaredLogger, stateMachine *state.Machine) *ProcessMonitor

func (pm *ProcessMonitor) EventChannel() <-chan ProcessEvent

func (pm *ProcessMonitor) GetExitInfo() *ExitInfo

func (pm *ProcessMonitor) GetOutput() (stdout, stderr string)

func (pm *ProcessMonitor) GetPID() int

func (pm *ProcessMonitor) GetStatus() ProcessStatus

func (pm *ProcessMonitor) Shutdown()

func (pm *ProcessMonitor) Start() error

func (pm *ProcessMonitor) Stop() error

type ProcessStatus ¶

type ProcessStatus string

ProcessStatus represents the status of a monitored process

const (
	ProcessStatusStopped  ProcessStatus = "stopped"
	ProcessStatusStarting ProcessStatus = "starting"
	ProcessStatusRunning  ProcessStatus = "running"
	ProcessStatusFailed   ProcessStatus = "failed"
	ProcessStatusCrashed  ProcessStatus = "crashed"
)