RegisterFlagsAndApplyDefaults registers the flags.
(prefix string, f *flag.FlagSet)
| 83 | |
| 84 | // RegisterFlagsAndApplyDefaults registers the flags. |
| 85 | func (cfg *Config) RegisterFlagsAndApplyDefaults(prefix string, f *flag.FlagSet) { |
| 86 | cfg.Ring.RegisterFlagsAndApplyDefaults(prefix, f) |
| 87 | cfg.Processor.RegisterFlagsAndApplyDefaults(prefix, f) |
| 88 | cfg.Registry.RegisterFlagsAndApplyDefaults(prefix, f) |
| 89 | cfg.Storage.RegisterFlagsAndApplyDefaults(prefix, f) |
| 90 | cfg.Ingest.RegisterFlagsAndApplyDefaults(prefix, f) |
| 91 | cfg.IngestConcurrency = 16 |
| 92 | |
| 93 | // setting default for max span age before discarding to 30s |
| 94 | cfg.MetricsIngestionSlack = 30 * time.Second |
| 95 | cfg.OverrideRingKey = generatorRingKey |
| 96 | cfg.RingMode = RingModePartition |
| 97 | cfg.Codec = codecPushBytes |
| 98 | cfg.LimiterType = LimiterTypeSeries |
| 99 | |
| 100 | hostname, err := os.Hostname() |
| 101 | if err != nil { |
| 102 | fmt.Printf("failed to get hostname: %v", err) |
| 103 | os.Exit(1) |
| 104 | } |
| 105 | f.StringVar(&cfg.InstanceID, prefix+".instance-id", hostname, "Instance id.") |
| 106 | f.BoolVar(&cfg.LeaveConsumerGroupOnShutdown, prefix+".leave-consumer-group-on-shutdown", false, "If true, send LeaveGroup to Kafka on shutdown for immediate partition reassignment. Default false; set to true for Deployment rollouts where pod names change on each restart.") |
| 107 | } |
| 108 | |
| 109 | func (cfg *Config) Validate() error { |
| 110 | if cfg.ConsumeFromKafka { |