overwatch

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

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

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

type Overwatch interface {
	// StartMonitoring begins watching an execution.
	StartMonitoring(processID int, provider, model, requestID string) *OverwatchContext

	// StopMonitoring stops watching an execution.
	StopMonitoring(requestID string)

	// GetContext returns the monitoring context for a request.
	GetContext(requestID string) *OverwatchContext

	// WrapReader creates a monitored reader.
	WrapReader(reader io.Reader, ctx *OverwatchContext) *MonitoredReader

	// WrapWriter creates a monitored writer.
	WrapWriter(writer io.Writer, ctx *OverwatchContext) *MonitoredWriter

	// Stop stops all monitoring.
	Stop()
}

type OverwatchContext struct {

	// ProcessID is the OS process ID of the monitored process.
	ProcessID int

	// StartTime is when the process was spawned.
	StartTime time.Time

	// LastOutputTime is the timestamp of the most recent stdout/stderr output.
	// Used for heartbeat detection and silence threshold calculation.
	LastOutputTime time.Time

	// LogBuffer stores recent log lines for diagnostic snapshots.
	LogBuffer *RingBuffer

	// RestartCount tracks how many times this execution has been restarted.
	RestartCount int

	// DiagnosticCount tracks how many diagnostic snapshots have been captured.
	DiagnosticCount int

	// HealingActions records all autonomous interventions taken during this execution.
	HealingActions []types.HealingAction

	// Config holds the Overwatch configuration parameters.
	Config *config.OverwatchConfig

	// Provider is the provider being executed (e.g., "claudecli", "geminicli").
	Provider string

	// Model is the model being used for this execution.
	Model string

	// RequestID uniquely identifies the request that triggered this execution.
	RequestID string

	// IsSilent indicates whether the process is currently in a silent state.
	IsSilent bool

	// SilenceStartTime is when the current silence period began (if IsSilent is true).
	SilenceStartTime time.Time
	// contains filtered or unexported fields
}

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

type SnapshotHandler func(ctx *OverwatchContext, snapshot *types.DiagnosticSnapshot)

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