func()

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
}