Function resolveQueueNames

tests/loadtest/tools/queue_benchmark.go:280–311

(inspector *asynq.Inspector, cfg benchmarkConfig)

}

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

	for _, raw := range strings.Split(cfg.queueNames, ",") {
		name := strings.TrimSpace(raw)
		if name != "" {
			names[name] = struct{}{}
		}
	}

	prefixes := configuredPrefixes(cfg)
	if len(prefixes) > 0 {
		all, err := inspector.Queues()
		if err != nil {
			return nil, err
		}
		for _, name := range all {
			for _, prefix := range prefixes {
				if strings.HasPrefix(name, prefix) {
					names[name] = struct{}{}
					break
				}
			}
		}
	}

	resolved := make([]string, 0, len(names))
	for name := range names {
		resolved = append(resolved, name)
	}
	return resolved, nil
}

func configuredPrefixes(cfg benchmarkConfig) []string {
	prefixSet := make(map[string]struct{})