- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for IsNetworkOrHostDown (0.15 sec)
-
internal/event/target/webhook.go
return target.store } func (target *WebhookTarget) isActive() (bool, error) { conn, err := net.DialTimeout("tcp", target.addr, 5*time.Second) if err != nil { if xnet.IsNetworkOrHostDown(err, false) { return false, store.ErrNotConnected } return false, err } defer conn.Close() return true, nil } // Save - saves the events to the store if queuestore is configured,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 8.8K bytes - Viewed (0) -
internal/config/lambda/target/webhook.go
ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second) defer cancel() req, err := http.NewRequestWithContext(ctx, http.MethodHead, target.args.Endpoint.String(), nil) if err != nil { if xnet.IsNetworkOrHostDown(err, false) { return false, errNotConnected } return false, err } tokens := strings.Fields(target.args.AuthToken) switch len(tokens) { case 2:
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Jul 08 21:39:49 UTC 2024 - 6.7K bytes - Viewed (0) -
cmd/admin-server-info.go
if !present { if err := isServerResolvable(endpoint, 5*time.Second); err == nil { network[nodeName] = string(madmin.ItemOnline) } else { if xnet.IsNetworkOrHostDown(err, false) { network[nodeName] = string(madmin.ItemOffline) } else if xnet.IsNetworkOrHostDown(err, true) { network[nodeName] = "connection attempt timedout" } } } } } var memstats runtime.MemStatsRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.9K bytes - Viewed (1)