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 }