We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent fa6893f commit e91329eCopy full SHA for e91329e
cmd/cortex/main.go
@@ -125,18 +125,15 @@ func main() {
125
}
126
defer ring.Stop()
127
setupDistributor(cfg.distributorConfig, chunkStore, cfg.logSuccess)
128
- if err != nil {
129
- log.Fatalf("Error initializing distributor: %v", err)
130
- }
131
case modeIngester:
132
registration, err := ring.RegisterIngester(consul, cfg.listenPort, cfg.numTokens)
133
- prometheus.MustRegister(registration)
134
if err != nil {
135
// This only happens for errors in configuration & set-up, not for
136
// network errors.
137
log.Fatalf("Could not register ingester: %v", err)
138
139
defer registration.Unregister()
+ prometheus.MustRegister(registration)
140
ing := setupIngester(chunkStore, cfg.ingesterConfig, cfg.logSuccess)
141
defer ing.Stop()
142
default:
0 commit comments