metrics

type AgentStats struct {
	GoroutineCount int     `json:"goroutine_count"`
	HeapAllocBytes uint64  `json:"heap_alloc_bytes"`
	HeapSysBytes   uint64  `json:"heap_sys_bytes"`
	GCPauseTotalNs uint64  `json:"gc_pause_total_ns"`
	GCNumGC        uint32  `json:"gc_num_gc"`
	UptimeSeconds  float64 `json:"uptime_seconds"`
	ReconnectCount int     `json:"reconnect_count"`
}

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

type Collector interface {
	Collect(ctx context.Context) ([]api.MetricPoint, error)
}

type Config struct {
	// Enabled controls whether metrics collection is active.
	// Default: true (set by ApplyDefaults).
	Enabled bool `yaml:"enabled"`

	// CollectInterval is the interval between collection cycles.
	// Must be at least 5s.
	CollectInterval time.Duration `yaml:"collect_interval"`

	// ReportInterval is the interval between reporting to the control plane.
	// Must be at least 10s and >= CollectInterval.
	ReportInterval time.Duration `yaml:"report_interval"`

	// BatchSize is the maximum number of metric points per report batch.
	// Must be > 0. Default: 100.
	BatchSize int `yaml:"batch_size"`

	// LocalEndpoint configures an optional local data-plane endpoint.
	LocalEndpoint api.LocalEndpointConfig `yaml:"local_endpoint"`
}

type IngestClient interface {
	ReportMetrics(ctx context.Context, nodeID string, samples []api.MetricSample) (*api.IngestReceipt, error)
}

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

type LatencyResult struct {
	PeerID  string `json:"peer_id"`
	RTTNano int64  `json:"rtt_nano"`
}

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

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

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

type MetricsReporter interface {
	ReportMetrics(ctx context.Context, nodeID string, batch api.MetricBatch) error
}

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

type PeerLister interface {
	PeerIDs() []string
}

type Pinger interface {
	Ping(ctx context.Context, peerID string) (rttNano int64, err error)
}

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

type ReconnectCounter interface {
	ReconnectCount() int
}

type SecretFetcher interface {
	FetchSecret(ctx context.Context, nodeID, name string, version int) (*api.SecretEnvelope, error)
}

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

type SystemReader interface {
	ReadStats(ctx context.Context) (*SystemStats, error)
}

type SystemStats struct {
	CPUUsagePercent  float64 `json:"cpu_usage_percent"`
	MemoryUsedBytes  uint64  `json:"memory_used_bytes"`
	MemoryTotalBytes uint64  `json:"memory_total_bytes"`
	DiskUsedBytes    uint64  `json:"disk_used_bytes"`
	DiskTotalBytes   uint64  `json:"disk_total_bytes"`
	NetworkRxBytes   uint64  `json:"network_rx_bytes"`
	NetworkTxBytes   uint64  `json:"network_tx_bytes"`
	LoadAvg1         float64 `json:"load_avg_1"`
	LoadAvg5         float64 `json:"load_avg_5"`
	LoadAvg15        float64 `json:"load_avg_15"`
}

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

type TunnelStats struct {
	PeerID             string    `json:"peer_id"`
	LastHandshakeTime  time.Time `json:"last_handshake_time"`
	RxBytes            uint64    `json:"rx_bytes"`
	TxBytes            uint64    `json:"tx_bytes"`
	HandshakeSucceeded bool      `json:"handshake_succeeded"`
	HandshakeStale     bool      `json:"handshake_stale"`
	PacketLossPercent  float64   `json:"packet_loss_percent"`
}

type TunnelStatsReader interface {
	ReadTunnelStats(ctx context.Context) ([]TunnelStats, error)
}