Method PushSpans

modules/generator/processor/hostinfo/processor.go:52–67

(_ context.Context, req *tempopb.PushSpansRequest)

}

func (p *Processor) PushSpans(_ context.Context, req *tempopb.PushSpansRequest) {
	for i := range req.Batches {
		resourceSpans := req.Batches[i]
		if hostID, hostSource := p.findHostIdentifier(resourceSpans); hostID != "" && hostSource != "" {
			builder := p.registry.NewInfoMetricLabelBuilder()
			builder.Add(hostIdentifierAttr, hostID)
			builder.Add(hostSourceAttr, hostSource)
			labels, validUTF8 := builder.CloseAndBuildLabels()
			if !validUTF8 {
				p.invalidUTF8Counter.Inc()
				continue
			}
			p.gauge.Set(labels, 1)
		}
	}
}

func (p *Processor) Shutdown(_ context.Context) {}