in store/writer.go [65:75]
func (kw *kustoSpanWriter) Close() error {
kw.logger.Debug("plugin shutdown started")
kw.shutdownWg.Add(kw.workersCount)
kw.shutdown <- struct{}{}
kw.shutdownWg.Wait()
close(kw.spanInput)
kw.logger.Debug("plugin shutdown completed")
return nil
}