(f *flag.FlagSet)
| 38 | } |
| 39 | |
| 40 | func (cfg *Config) RegisterFlags(f *flag.FlagSet) { |
| 41 | f.StringVar(&cfg.FrontendAddress, "querier.frontend-address", "", "Address of query frontend service, in host:port format. If -querier.scheduler-address is set as well, querier will use scheduler instead. Only one of -querier.frontend-address or -querier.scheduler-address can be set. If neither is set, queries are only received via HTTP endpoint.") |
| 42 | |
| 43 | f.DurationVar(&cfg.DNSLookupPeriod, "querier.dns-lookup-period", 10*time.Second, "How often to query DNS for query-frontend or query-scheduler address.") |
| 44 | |
| 45 | f.IntVar(&cfg.Parallelism, "querier.worker-parallelism", 10, "Number of simultaneous queries to process per query-frontend or query-scheduler.") |
| 46 | f.BoolVar(&cfg.MatchMaxConcurrency, "querier.worker-match-max-concurrent", false, "Force worker concurrency to match the -querier.max-concurrent option. Overrides querier.worker-parallelism.") |
| 47 | f.StringVar(&cfg.QuerierID, "querier.id", "", "Querier ID, sent to frontend service to identify requests from the same querier. Defaults to hostname.") |
| 48 | |
| 49 | cfg.GRPCClientConfig.RegisterFlagsWithPrefix("querier.frontend-client", f) |
| 50 | } |
| 51 | |
| 52 | func (cfg *Config) Validate() error { |
| 53 | if cfg.FrontendAddress != "" { |
nothing calls this directly
no test coverage detected