sysmon

type CPUClusterMetric struct {
	// Name is the cluster identifier (e.g., ECPU, PCPU).
	Name string `json:"name"`

	// FrequencyHz is the instantaneous frequency in Hz, if available.
	FrequencyHz float64 `json:"frequency_hz"`
}

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

type CPUMetric struct {
	// CoreID is the zero-based logical core ID.
	CoreID int32 `json:"core_id"`

	// Label is a platform-specific identifier (e.g., ECPU0, PCPU3).
	Label string `json:"label,omitempty"`

	// Cluster is the logical cluster this core belongs to (e.g., ECPU, PCPU).
	Cluster string `json:"cluster,omitempty"`

	// UsagePercent is the CPU usage percentage (0-100).
	UsagePercent float64 `json:"usage_percent"`

	// FrequencyHz is the instantaneous frequency in Hz, if available.
	FrequencyHz float64 `json:"frequency_hz,omitempty"`
}

type Collector interface {
	// Start begins periodic metric collection in the background.
	Start(ctx context.Context) error

	// Stop halts metric collection and releases resources.
	Stop() error

	// Collect performs a single metric collection cycle and returns the sample.
	Collect(ctx context.Context) (*MetricSample, error)

	// Reconfigure updates the collector with new configuration.
	// The collector applies changes without requiring a restart.
	Reconfigure(config *ParsedConfig) error

	// Latest returns the most recent metric sample, or nil if none available.
	Latest() *MetricSample

	// Drain returns all buffered metric samples since the last call.
	Drain() []*MetricSample
}

type CollectorOption func(*DefaultCollector)

type Config struct {
	// Enabled controls whether sysmon collection is active.
	Enabled bool `json:"enabled"`

	// SampleInterval is the duration between metric collections.
	// Supports Go duration strings like "10s", "1m", "500ms".
	SampleInterval string `json:"sample_interval,omitempty"`

	// CollectCPU enables CPU metrics collection.
	CollectCPU bool `json:"collect_cpu"`

	// CollectMemory enables memory metrics collection.
	CollectMemory bool `json:"collect_memory"`

	// CollectDisk enables disk metrics collection.
	CollectDisk bool `json:"collect_disk"`

	// CollectNetwork enables network interface metrics collection.
	CollectNetwork bool `json:"collect_network"`

	// CollectProcesses enables process metrics collection.
	CollectProcesses bool `json:"collect_processes"`

	// DiskPaths specifies which mount points to monitor.
	// If empty, all mounted filesystems are monitored.
	DiskPaths []string `json:"disk_paths,omitempty"`

	// DiskExcludePaths specifies mount points to exclude from collection.
	DiskExcludePaths []string `json:"disk_exclude_paths,omitempty"`

	// Thresholds defines warning/critical thresholds for alerting.
	Thresholds map[string]string `json:"thresholds,omitempty"`
}

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

type DiskMetric struct {
	// MountPoint is the filesystem mount path.
	MountPoint string `json:"mount_point"`

	// UsedBytes is the number of bytes currently in use.
	UsedBytes uint64 `json:"used_bytes"`

	// TotalBytes is the total capacity in bytes.
	TotalBytes uint64 `json:"total_bytes"`
}

type MemoryMetric struct {
	// UsedBytes is the number of bytes currently in use.
	UsedBytes uint64 `json:"used_bytes"`

	// TotalBytes is the total memory capacity in bytes.
	TotalBytes uint64 `json:"total_bytes"`

	// SwapUsedBytes is the swap space currently in use.
	SwapUsedBytes uint64 `json:"swap_used_bytes,omitempty"`

	// SwapTotalBytes is the total swap capacity.
	SwapTotalBytes uint64 `json:"swap_total_bytes,omitempty"`
}

type MetricSample struct {
	// Timestamp is when this sample was collected (RFC3339 format).
	Timestamp string `json:"timestamp"`

	// HostID is the hostname or unique identifier for this host.
	HostID string `json:"host_id"`

	// HostIP is the primary IP address of this host.
	HostIP string `json:"host_ip"`

	// Partition is the optional partition/segment identifier.
	Partition *string `json:"partition,omitempty"`

	// AgentID is the ServiceRadar agent identifier.
	AgentID string `json:"agent_id,omitempty"`

	// CPUs contains per-core CPU metrics.
	CPUs []CPUMetric `json:"cpus"`

	// Clusters contains aggregate CPU cluster metrics (e.g., big.LITTLE).
	Clusters []CPUClusterMetric `json:"clusters,omitempty"`

	// Disks contains per-mount-point disk metrics.
	Disks []DiskMetric `json:"disks"`

	// Memory contains system memory metrics.
	Memory MemoryMetric `json:"memory"`

	// Network contains per-interface network metrics.
	Network []NetworkMetric `json:"network,omitempty"`

	// Processes contains top process metrics.
	Processes []ProcessMetric `json:"processes"`
}

type NetworkMetric struct {
	// Interface is the network interface name.
	Interface string `json:"interface"`

	// BytesSent is the total bytes transmitted.
	BytesSent uint64 `json:"bytes_sent"`

	// BytesRecv is the total bytes received.
	BytesRecv uint64 `json:"bytes_recv"`

	// PacketsSent is the total packets transmitted.
	PacketsSent uint64 `json:"packets_sent"`

	// PacketsRecv is the total packets received.
	PacketsRecv uint64 `json:"packets_recv"`

	// ErrorsIn is the count of receive errors.
	ErrorsIn uint64 `json:"errors_in"`

	// ErrorsOut is the count of transmit errors.
	ErrorsOut uint64 `json:"errors_out"`

	// DropsIn is the count of dropped incoming packets.
	DropsIn uint64 `json:"drops_in"`

	// DropsOut is the count of dropped outgoing packets.
	DropsOut uint64 `json:"drops_out"`
}

type ParsedConfig struct {
	Enabled          bool
	SampleInterval   time.Duration
	CollectCPU       bool
	CollectMemory    bool
	CollectDisk      bool
	CollectNetwork   bool
	CollectProcesses bool
	DiskPaths        []string
	DiskExcludePaths []string
	Thresholds       map[string]string
}

type ProcessMetric struct {
	// PID is the process ID.
	PID uint32 `json:"pid"`

	// Name is the process name.
	Name string `json:"name"`

	// CPUUsage is the CPU usage percentage.
	CPUUsage float32 `json:"cpu_usage"`

	// MemoryUsage is the memory usage in bytes.
	MemoryUsage uint64 `json:"memory_usage"`

	// Status is the process status (e.g., Running, Sleeping).
	Status string `json:"status"`

	// StartTime is when the process started (RFC3339 format).
	StartTime string `json:"start_time"`
}