func()

in store/writer.go [77:84]


func (kw *kustoSpanWriter) ingestWorker() {
	ticker := time.NewTicker(kw.batchTimeout)
	defer ticker.Stop()

	b := &bytes.Buffer{}
	writer := altcsv.NewWriter(b)
	writer.AllQuotes = true
}