metrics

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

type DispatcherSnapshot struct {
	// CollectedAt is the time the snapshot was taken.
	CollectedAt time.Time

	// ClaimedCount is the number of issues currently claimed by agents.
	ClaimedCount int
	// TotalRouted is the total issues routed since dispatcher start.
	TotalRouted int64
	// TotalRequeued is the total issues that failed and were requeued.
	TotalRequeued int64
	// TotalEventsProcessed is the total events processed since dispatcher start.
	TotalEventsProcessed int64
	// AvgPollLatency is the rolling average time between poll cycle completions.
	// Zero if no cycles have completed.
	AvgPollLatency time.Duration
	// LastPollAt is the time the last poll cycle completed.
	LastPollAt time.Time
}

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

type PoolSnapshot struct {
	// CollectedAt is the time the snapshot was taken.
	CollectedAt time.Time

	// TotalWorkers is the total worker goroutines configured.
	TotalWorkers int
	// ActiveWorkers is the number of workers currently processing a task.
	ActiveWorkers int
	// IdleWorkers is the number of workers currently idle (TotalWorkers - ActiveWorkers).
	IdleWorkers int
	// QueueDepth is the number of tasks waiting in the queue.
	QueueDepth int
	// TasksCompleted is the total tasks completed successfully since pool start.
	TasksCompleted int64
	// TasksFailed is the total tasks that failed since pool start.
	TasksFailed int64

	// AvgTaskDuration is the rolling average task duration over the last N completed tasks.
	// Zero if no tasks have completed.
	AvgTaskDuration time.Duration
	// P95TaskDuration is the approximate P95 task duration over the last N tasks.
	// Zero if fewer than 20 tasks have completed.
	P95TaskDuration time.Duration
}

type SystemCollector struct{}

type SystemSnapshot struct {
	// CollectedAt is the time the snapshot was taken.
	CollectedAt time.Time

	// Goroutines is the goroutine count from runtime.NumGoroutine().
	Goroutines int

	// HeapAllocBytes is bytes of allocated heap objects.
	HeapAllocBytes uint64
	// SysBytesTotal is total OS memory obtained by the Go runtime.
	SysBytesTotal uint64
	// GCCycles is the number of GC cycles since program start.
	GCCycles uint32
	// GCPauseTotalNs is total time in GC stop-the-world pauses.
	GCPauseTotalNs uint64
	// NextGCBytes is the target heap size for the next GC cycle.
	NextGCBytes uint64
}

type TaskResult string