Function takeSnapshot

tests/loadtest/tools/queue_benchmark.go:244–278

(inspector *asynq.Inspector, cfg benchmarkConfig)

}

func takeSnapshot(inspector *asynq.Inspector, cfg benchmarkConfig) (snapshot, error) {
	queueNames, err := resolveQueueNames(inspector, cfg)
	if err != nil {
		return snapshot{}, err
	}

	sort.Strings(queueNames)

	snap := snapshot{
		timestamp:  time.Now().UTC(),
		queueNames: queueNames,
	}

	for _, name := range queueNames {
		info, err := inspector.GetQueueInfo(name)
		if err != nil {
			return snapshot{}, fmt.Errorf("queue %s: %w", name, err)
		}

		snap.pending += info.Pending
		snap.active += info.Active
		snap.scheduled += info.Scheduled
		snap.retry += info.Retry
		snap.aggregating += info.Aggregating
		snap.archived += info.Archived
		snap.size += info.Size
		snap.processedTotal += info.ProcessedTotal
		snap.failedTotal += info.FailedTotal
		if latencyMs := float64(info.Latency.Milliseconds()); latencyMs > snap.latencyMs {
			snap.latencyMs = latencyMs
		}
	}

	return snap, nil
}

func resolveQueueNames(inspector *asynq.Inspector, cfg benchmarkConfig) ([]string, error) {
	names := make(map[string]struct{})