Function TaskQueueDepthPayloadsFromObserve

internal/api/core/conversions.go:648–662

TaskQueueDepthPayloadsFromObserve converts task queue-depth rows.

(rows []observepkg.TaskQueueDepth)

// TaskQueueDepthPayloadsFromObserve converts task queue-depth rows.
func TaskQueueDepthPayloadsFromObserve(rows []observepkg.TaskQueueDepth) []contract.TaskQueueDepthPayload {
	if len(rows) == 0 {
		return nil
	}
	payloads := make([]contract.TaskQueueDepthPayload, 0, len(rows))
	for _, row := range rows {
		payloads = append(payloads, contract.TaskQueueDepthPayload{
			NetworkChannel:      strings.TrimSpace(row.NetworkChannel),
			Count:               row.Count,
			OldestQueuedAt:      optionalTime(row.OldestQueuedAt),
			OldestQueueAgeMilli: row.OldestQueueAgeMilli,
		})
	}
	return payloads
}

// StuckTaskRunPayloadsFromObserve converts stuck task-run diagnostics.
func StuckTaskRunPayloadsFromObserve(rows []observepkg.StuckTaskRun) []contract.StuckTaskRunPayload {