Method Add

plugins/processors/streamingprocessor.go:31–36

(m telegraf.Metric, acc telegraf.Accumulator)

}

func (sp *streamingProcessor) Add(m telegraf.Metric, acc telegraf.Accumulator) error {
	for _, m := range sp.processor.Apply(m) {
		acc.AddMetric(m)
	}
	return nil
}

func (*streamingProcessor) Stop() {
}