stats

type AgentFilter struct {
	Role    string
	Tool    string
	Runtime string
	Agent   []string
}

type AgentMetric struct {
	Time           time.Time `json:"time"`
	AgentName      string    `json:"agent_name"`
	Role           string    `json:"role"`
	Tool           string    `json:"tool"`
	Runtime        string    `json:"runtime"`
	State          string    `json:"state"`
	CPUPercent     float64   `json:"cpu_percent"`
	MemUsedBytes   int64     `json:"mem_used_bytes"`
	MemLimitBytes  int64     `json:"mem_limit_bytes"`
	MemPercent     float64   `json:"mem_percent"`
	NetRxBytes     int64     `json:"net_rx_bytes"`
	NetTxBytes     int64     `json:"net_tx_bytes"`
	DiskReadBytes  int64     `json:"disk_read_bytes"`
	DiskWriteBytes int64     `json:"disk_write_bytes"`
}

type AgentMetrics struct {
	// Per-agent stats
	AgentStats []AgentStat `json:"agent_stats"`

	// Counts
	TotalAgents  int `json:"total_agents"`
	ActiveAgents int `json:"active_agents"`
	Coordinators int `json:"coordinators"`
	Workers      int `json:"workers"`

	// By state
	Idle    int `json:"idle"`
	Working int `json:"working"`
	Done    int `json:"done"`
	Stuck   int `json:"stuck"`
	Error   int `json:"error"`
	Stopped int `json:"stopped"`
}

type AgentStat struct {
	Name   string        `json:"name"`
	Role   string        `json:"role"`
	State  string        `json:"state"`
	Uptime time.Duration `json:"uptime"`
}

type AgentSummary struct {
	// Token and cost totals (over period)
	Models []ModelCostBreakdown `json:"models,omitempty"`

	AgentName string `json:"agent_name"`
	Role      string `json:"role"`
	Tool      string `json:"tool"`
	Runtime   string `json:"runtime"`
	State     string `json:"state"`

	// Resource metrics (latest sample)
	CPU    CPUSummary    `json:"cpu"`
	Memory MemorySummary `json:"memory"`
	Disk   DiskSummary   `json:"disk"`
	Net    NetSummary    `json:"network"`

	Tokens TokenSummary `json:"tokens"`
	Cost   CostSummary  `json:"cost"`
}

type CPUSummary struct {
	AvgPercent float64 `json:"avg_percent"`
	MaxPercent float64 `json:"max_percent"`
}

type ChannelFilter struct {
	Channel []string
}

type ChannelMetric struct {
	Time          time.Time `json:"time"`
	ChannelName   string    `json:"channel_name"`
	MessageCount  int64     `json:"message_count"`
	MemberCount   int       `json:"member_count"`
	ReactionCount int64     `json:"reaction_count"`
}

type CostSummary struct {
	TotalUSD float64 `json:"total_usd"`
}

type DefaultTmuxProcRunner struct{}

type DiskSummary struct {
	ReadBytes  int64 `json:"read_bytes"`
	WriteBytes int64 `json:"write_bytes"`
}

type MemorySummary struct {
	AvgBytes   int64   `json:"avg_bytes"`
	MaxBytes   int64   `json:"max_bytes"`
	AvgPercent float64 `json:"avg_percent"`
}

type ModelCostBreakdown struct {
	Model        string  `json:"model"`
	CostUSD      float64 `json:"cost_usd"`
	InputTokens  int64   `json:"input_tokens"`
	OutputTokens int64   `json:"output_tokens"`
}

type NetSummary struct {
	RxBytes int64 `json:"rx_bytes"`
	TxBytes int64 `json:"tx_bytes"`
}

type Stats struct {
	CollectedAt time.Time `json:"collected_at"`

	WorkspacePath string       `json:"workspace_path"`
	Agents        AgentMetrics `json:"agents"`
	// contains filtered or unexported fields
}

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

type SystemMetric struct {
	Time           time.Time `json:"time"`
	SystemName     string    `json:"system_name"`
	CPUPercent     float64   `json:"cpu_percent"`
	MemUsedBytes   int64     `json:"mem_used_bytes"`
	MemLimitBytes  int64     `json:"mem_limit_bytes"`
	MemPercent     float64   `json:"mem_percent"`
	NetRxBytes     int64     `json:"net_rx_bytes"`
	NetTxBytes     int64     `json:"net_tx_bytes"`
	DiskReadBytes  int64     `json:"disk_read_bytes"`
	DiskWriteBytes int64     `json:"disk_write_bytes"`
}

type TimeRange struct {
	From     time.Time
	To       time.Time
	Interval string // e.g. "5m", "1h" — converted to Postgres interval via PGInterval()
}

type TmuxProcRunner interface {
	// PanePIDs returns the pane PIDs for the given tmux session. The
	// session name is resolved by the caller (e.g. `bc-<hash>-<agent>`).
	// Returns an empty slice (and nil error) when the session does not
	// exist — callers treat that as "agent not running, record 0".
	PanePIDs(ctx context.Context, session string) ([]int, error)
	// ListSessions returns the list of live tmux session names. Used to
	// resolve the workspace-hashed session name from a bare agent name.
	ListSessions(ctx context.Context) ([]string, error)
	// Children returns the direct child PIDs of the given PID.
	Children(ctx context.Context, pid int) ([]int, error)
	// PSStats returns the (%cpu, rssBytes) pair for each supplied PID.
	// Missing PIDs are silently skipped (they may have exited between
	// the walk and the ps call).
	PSStats(ctx context.Context, pids []int) (cpuPercent float64, rssBytes int64, err error)
}

type TmuxSample struct {
	CPUPercent float64
	MemBytes   int64
	// PIDsWalked is the count of descendant PIDs included in the sum;
	// useful for debug logging and tests.
	PIDsWalked int
}

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

type TokenMetric struct {
	Time         time.Time `json:"time"`
	AgentName    string    `json:"agent_name"`
	Model        string    `json:"model"`
	InputTokens  int64     `json:"input_tokens"`
	OutputTokens int64     `json:"output_tokens"`
	CacheRead    int64     `json:"cache_read"`
	CacheCreate  int64     `json:"cache_create"`
	CostUSD      float64   `json:"cost_usd"`
}

type TokenSummary struct {
	Input       int64 `json:"input"`
	Output      int64 `json:"output"`
	CacheRead   int64 `json:"cache_read"`
	CacheCreate int64 `json:"cache_create"`
}