func()

in pkg/esoutput/esoutput.go [213:220]


func (o *Output) Stop() error {
	o.logger.Debug("Elasticsearch: stopping writing")
	o.periodicFlusher.Stop()
	if err := o.bulkIndexer.Close(context.Background()); err != nil {
		log.Fatalf("Elasticsearch: Could not close bulk indexer: %s", err)
	}
	return nil
}