(_ context.Context)
| 281 | } |
| 282 | |
| 283 | func (g *Generator) CheckReady(_ context.Context) error { |
| 284 | if g.cfg.ConsumeFromKafka && g.kafkaClient == nil { |
| 285 | return fmt.Errorf("metrics-generator check ready failed: kafka client not initialized") |
| 286 | } |
| 287 | |
| 288 | return nil |
| 289 | } |
| 290 | |
| 291 | // ExtractNoGenerateMetrics checks for presence of context keys that indicate no |
| 292 | // span-derived metrics should be generated for the request. If any such context |