From dc0dce9beb608c965cd7ca19297498bf645adf6c Mon Sep 17 00:00:00 2001 From: Praveen raj Mani Date: Thu, 19 Sep 2019 20:53:43 +0530 Subject: [PATCH] Check for connection errors during event transit in elasticsearch and webhook (#8273) --- pkg/event/target/elasticsearch.go | 3 +++ pkg/event/target/webhook.go | 3 +++ 2 files changed, 6 insertions(+) diff --git a/pkg/event/target/elasticsearch.go b/pkg/event/target/elasticsearch.go index 6723589b3..64d533163 100644 --- a/pkg/event/target/elasticsearch.go +++ b/pkg/event/target/elasticsearch.go @@ -171,6 +171,9 @@ func (target *ElasticsearchTarget) Send(eventKey string) error { } if err := target.send(eventData); err != nil { + if xnet.IsNetworkOrHostDown(err) { + return errNotConnected + } return err } diff --git a/pkg/event/target/webhook.go b/pkg/event/target/webhook.go index 118fd4a7a..ab185312a 100644 --- a/pkg/event/target/webhook.go +++ b/pkg/event/target/webhook.go @@ -155,6 +155,9 @@ func (target *WebhookTarget) Send(eventKey string) error { } if err := target.send(eventData); err != nil { + if xnet.IsNetworkOrHostDown(err) { + return errNotConnected + } return err }