From 572719872dd1c9f9c4b828ac1df2ea7b3bd3e31f Mon Sep 17 00:00:00 2001 From: Ashish Kumar Sinha Date: Wed, 7 Nov 2018 01:08:54 +0530 Subject: [PATCH] Event Notification for ElasticSearch (#6764) Using access format for Event Notification for Elastic Search --- pkg/event/target/elasticsearch.go | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/pkg/event/target/elasticsearch.go b/pkg/event/target/elasticsearch.go index 638946766..2722de5da 100644 --- a/pkg/event/target/elasticsearch.go +++ b/pkg/event/target/elasticsearch.go @@ -22,7 +22,6 @@ import ( "fmt" "net/url" "strings" - "time" "github.com/minio/minio/pkg/event" xnet "github.com/minio/minio/pkg/net" @@ -85,13 +84,7 @@ func (target *ElasticsearchTarget) Send(eventData event.Event) (err error) { } add := func() error { - eventTime, err := time.Parse(event.AMZTimeFormat, eventData.EventTime) - if err != nil { - return err - } - - eventTimeMS := fmt.Sprintf("%d", eventTime.UnixNano()/1000000) - _, err = target.client.Index().Index(target.args.Index).Type("event").Timestamp(eventTimeMS).BodyJson(map[string]interface{}{"Records": []event.Event{eventData}}).Do(context.Background()) + _, err = target.client.Index().Index(target.args.Index).Type("event").BodyJson(map[string]interface{}{"Records": []event.Event{eventData}}).Do(context.Background()) return err }