Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for IsAbs (0.03 sec)

  1. internal/mountinfo/mountinfo_linux.go

    			return err
    		}
    	}
    	return nil
    }
    
    // CheckCrossDevice - check if given path has any sub-mounts in the input mounts list.
    func (mts mountInfos) checkCrossMounts(path string) error {
    	if !filepath.IsAbs(path) {
    		return fmt.Errorf("Invalid argument, path (%s) is expected to be absolute", path)
    	}
    	var crossMounts mountInfos
    	for _, mount := range mts {
    		// Add a separator to indicate that this is a proper mount-point.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 4.7K bytes
    - Viewed (0)
  2. internal/event/target/webhook.go

    // Validate WebhookArgs fields
    func (w WebhookArgs) Validate() error {
    	if !w.Enable {
    		return nil
    	}
    	if w.Endpoint.IsEmpty() {
    		return errors.New("endpoint empty")
    	}
    	if w.QueueDir != "" {
    		if !filepath.IsAbs(w.QueueDir) {
    			return errors.New("queueDir path should be absolute")
    		}
    	}
    	if w.ClientCert != "" && w.ClientKey == "" || w.ClientCert == "" && w.ClientKey != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  3. internal/event/target/nsq.go

    		return nil
    	}
    
    	if n.NSQDAddress.IsEmpty() {
    		return errors.New("empty nsqdAddress")
    	}
    
    	if n.Topic == "" {
    		return errors.New("empty topic")
    	}
    	if n.QueueDir != "" {
    		if !filepath.IsAbs(n.QueueDir) {
    			return errors.New("queueDir path should be absolute")
    		}
    	}
    
    	return nil
    }
    
    // NSQTarget - NSQ target.
    type NSQTarget struct {
    	initOnce once.Init
    
    	id         event.TargetID
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  4. internal/event/target/mqtt.go

    	if err != nil {
    		return err
    	}
    	switch u.Scheme {
    	case "ws", "wss", "tcp", "ssl", "tls", "tcps":
    	default:
    		return errors.New("unknown protocol in broker address")
    	}
    	if m.QueueDir != "" {
    		if !filepath.IsAbs(m.QueueDir) {
    			return errors.New("queueDir path should be absolute")
    		}
    		if m.QoS == 0 {
    			return errors.New("qos should be set to 1 or 2 if queueDir is set")
    		}
    	}
    
    	return nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 8.2K bytes
    - Viewed (0)
  5. internal/event/target/redis.go

    		if f != event.NamespaceFormat && f != event.AccessFormat {
    			return fmt.Errorf("unrecognized format")
    		}
    	}
    
    	if r.Key == "" {
    		return fmt.Errorf("empty key")
    	}
    
    	if r.QueueDir != "" {
    		if !filepath.IsAbs(r.QueueDir) {
    			return errors.New("queueDir path should be absolute")
    		}
    	}
    
    	return nil
    }
    
    func (r RedisArgs) validateFormat(c redis.Conn) error {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 9.1K bytes
    - Viewed (0)
  6. internal/lock/lock_windows.go

    	// \\?\UNC\server\share paths because the rules for doing so
    	// are less well-specified.
    	if len(path) >= 2 && path[:2] == `\\` {
    		// Don't canonicalize UNC paths.
    		return path
    	}
    	if !filepath.IsAbs(path) {
    		// Relative path
    		return path
    	}
    
    	const prefix = `\\?`
    
    	pathbuf := make([]byte, len(prefix)+len(path)+len(`\`))
    	copy(pathbuf, prefix)
    	n := len(path)
    	r, w := 0, len(prefix)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 18 18:08:15 UTC 2023
    - 7.9K bytes
    - Viewed (0)
Back to top