Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for IsNetworkOrHostDown (0.15 sec)

  1. 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)
  2. 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)
  3. 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.MemStats
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (1)
Back to top