add .Close() method to interface and all implementations.

2023-11-05 10:39:41 -03:00
parent 8c0fd4c760
commit 03517317f8
5 changed files with 17 additions and 0 deletions
--- a/elasticsearch/elasticsearch.go
+++ b/elasticsearch/elasticsearch.go
@@ -55,6 +55,8 @@ type ElasticsearchStorage struct {
 	bi esutil.BulkIndexer
 }

+func (ess *ElasticsearchStorage) Close() {}
+
 func (ess *ElasticsearchStorage) Init() error {
 	if ess.IndexName == "" {
 		ess.IndexName = "events"