Search Options

Results per page
Sort
Preferred Languages
Advance

Results 161 - 170 of 2,448 for error_ (0.15 sec)

  1. internal/event/target/nsq.go

    }
    
    // Validate NSQArgs fields
    func (n NSQArgs) Validate() error {
    	if !n.Enable {
    		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
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 7.1K bytes
    - Viewed (0)
  2. internal/auth/credentials.go

    	reservedChars = "=,"
    )
    
    // Common errors generated for access and secret key validation.
    var (
    	ErrInvalidAccessKeyLength   = fmt.Errorf("access key length should be between %d and %d", accessKeyMinLen, accessKeyMaxLen)
    	ErrInvalidSecretKeyLength   = fmt.Errorf("secret key length should be between %d and %d", secretKeyMinLen, secretKeyMaxLen)
    	ErrNoAccessKeyWithSecretKey = fmt.Errorf("access key must be specified if secret key is specified")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue May 28 17:14:16 UTC 2024
    - 12K bytes
    - Viewed (0)
  3. internal/etag/etag.go

    		if strict && len(etag) != 16 { // AWS S3 ETags are always 128 bit long
    			return nil, fmt.Errorf("etag: invalid length %d", len(etag))
    		}
    		return ETag(etag), nil
    	}
    
    	prefix, suffix := s[:n], s[n:]
    	if len(prefix) != 32 {
    		return nil, fmt.Errorf("etag: invalid prefix length %d", len(prefix))
    	}
    	if len(suffix) <= 1 {
    		return nil, errors.New("etag: suffix is not a part number")
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Mar 10 21:09:36 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. internal/disk/stat_linux_32bit.go

    		Ffree:  s.Ffree,
    		FSType: getFSType(s.Type),
    	}
    	// Check for overflows.
    	// https://github.com/minio/minio/issues/8035
    	// XFS can show wrong values at times error out
    	// in such scenarios.
    	if info.Free > info.Total {
    		return info, fmt.Errorf("detected free space (%d) > total drive space (%d), fs corruption at (%s). please run 'fsck'", info.Free, info.Total, path)
    	}
    	info.Used = info.Total - info.Free
    	return info, nil
    }
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  5. internal/disk/stat_netbsd.go

    	if info.Free > info.Total {
    		return info, fmt.Errorf("detected free space (%d) > total drive space (%d), fs corruption at (%s). please run 'fsck'", info.Free, info.Total, path)
    	}
    	info.Used = info.Total - info.Free
    	return info, nil
    }
    
    // GetDriveStats returns IO stats of the drive by its major:minor
    func GetDriveStats(major, minor uint32) (iostats IOStats, err error) {
    	return IOStats{}, errors.New("operation unsupported")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  6. internal/config/identity/openid/jwks.go

    	E   string `json:"e,omitempty"`
    	K   string `json:"k,omitempty"`
    }
    
    var (
    	errMalformedJWKRSAKey = errors.New("malformed JWK RSA key")
    	errMalformedJWKECKey  = errors.New("malformed JWK EC key")
    )
    
    // DecodePublicKey - decodes JSON Web Key (JWK) as public key
    func (key *JWKS) DecodePublicKey() (crypto.PublicKey, error) {
    	switch key.Kty {
    	case "RSA":
    		if key.N == "" || key.E == "" {
    			return nil, errMalformedJWKRSAKey
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Apr 02 23:02:35 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  7. internal/event/target/kafka.go

    // Validate KafkaArgs fields
    func (k KafkaArgs) Validate() error {
    	if !k.Enable {
    		return nil
    	}
    	if len(k.Brokers) == 0 {
    		return errors.New("no broker address found")
    	}
    	for _, b := range k.Brokers {
    		if _, err := xnet.ParseHost(b.String()); err != nil {
    			return err
    		}
    	}
    	if k.QueueDir != "" {
    		if !filepath.IsAbs(k.QueueDir) {
    			return errors.New("queueDir path should be absolute")
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 13.6K bytes
    - Viewed (0)
  8. docs/sts/web-identity.go

    		clnt, err := minio.New(u.Host, opts)
    		if err != nil {
    			log.Println(fmt.Errorf("Error while initializing Minio client, %s", err))
    			http.Error(w, err.Error(), http.StatusBadRequest)
    			return
    		}
    		buckets, err := clnt.ListBuckets(r.Context())
    		if err != nil {
    			log.Println(fmt.Errorf("Error while listing buckets, %s", err))
    			http.Error(w, err.Error(), http.StatusBadRequest)
    			return
    		}
    		creds, _ := sts.Get()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 19 09:13:33 UTC 2023
    - 7.8K bytes
    - Viewed (0)
  9. istioctl/pkg/tag/generate.go

    	if err != nil {
    		return "", err
    	}
    	if len(revWebhooks) == 0 {
    		return "", fmt.Errorf("cannot modify tag: cannot find MutatingWebhookConfiguration with revision %q", opts.Revision)
    	}
    	if len(revWebhooks) > 1 {
    		return "", fmt.Errorf("cannot modify tag: found multiple canonical webhooks with revision %q", opts.Revision)
    	}
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  10. internal/disk/stat_bsd.go

    	if info.Free > info.Total {
    		return info, fmt.Errorf("detected free space (%d) > total drive space (%d), fs corruption at (%s). please run 'fsck'", info.Free, info.Total, path)
    	}
    	info.Used = info.Total - info.Free
    	return info, nil
    }
    
    // GetDriveStats returns IO stats of the drive by its major:minor
    func GetDriveStats(major, minor uint32) (iostats IOStats, err error) {
    	return IOStats{}, errors.New("operation unsupported")
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Feb 26 19:34:50 UTC 2024
    - 1.7K bytes
    - Viewed (0)
Back to top