mirror of
https://github.com/minio/minio.git
synced 2025-11-10 05:59:43 -05:00
Check for connection errors during event transit in elasticsearch and webhook (#8273)
This commit is contained in:
committed by
Harshavardhana
parent
0e1408844b
commit
dc0dce9beb
@@ -171,6 +171,9 @@ func (target *ElasticsearchTarget) Send(eventKey string) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if err := target.send(eventData); err != nil {
|
if err := target.send(eventData); err != nil {
|
||||||
|
if xnet.IsNetworkOrHostDown(err) {
|
||||||
|
return errNotConnected
|
||||||
|
}
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -155,6 +155,9 @@ func (target *WebhookTarget) Send(eventKey string) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if err := target.send(eventData); err != nil {
|
if err := target.send(eventData); err != nil {
|
||||||
|
if xnet.IsNetworkOrHostDown(err) {
|
||||||
|
return errNotConnected
|
||||||
|
}
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user