Function
New
(cfg Config, reg registry.Registry, logger log.Logger, invalidUTF8Counter prometheus.Counter)
Source from the content-addressed store, hash-verified
| 69 | func (p *Processor) Shutdown(_ context.Context) {} |
| 70 | |
| 71 | func New(cfg Config, reg registry.Registry, logger log.Logger, invalidUTF8Counter prometheus.Counter) (*Processor, error) { |
| 72 | p := &Processor{ |
| 73 | Cfg: cfg, |
| 74 | logger: logger, |
| 75 | registry: reg, |
| 76 | metricName: cfg.MetricName, |
| 77 | gauge: reg.NewGauge(cfg.MetricName), |
| 78 | invalidUTF8Counter: invalidUTF8Counter, |
| 79 | } |
| 80 | return p, nil |
| 81 | } |