Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for Cannon (0.15 sec)

  1. cmd/test-utils_test.go

    func preSignV4(req *http.Request, accessKeyID, secretAccessKey string, expires int64) error {
    	// Presign is not needed for anonymous credentials.
    	if accessKeyID == "" || secretAccessKey == "" {
    		return errors.New("Presign cannot be generated without access and secret keys")
    	}
    
    	region := globalSite.Region
    	date := UTCNow()
    	scope := getScope(date, region)
    	credential := fmt.Sprintf("%s/%s", accessKeyID, scope)
    
    	// Set URL query.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  2. cmd/endpoint-ellipses.go

    		setCounts = possibleSetCountsWithSymmetry(setCounts, argPatterns)
    
    		if len(setCounts) == 0 {
    			msg := fmt.Sprintf("No symmetric distribution detected with input endpoints provided %s, drives %d cannot be spread symmetrically by any supported erasure set sizes %d", args, commonSize, setSizes)
    			return nil, config.ErrInvalidNumberOfErasureEndpoints(nil).Msg(msg)
    		}
    
    		// Final set size with all the symmetry accounted for.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 14.7K bytes
    - Viewed (0)
  3. cmd/common-main.go

    	if dir == "" {
    		dir = getDefaultDir()
    	}
    
    	if dir == "" {
    		if !dirSet {
    			return nil, fmt.Errorf("missing option must be provided")
    		}
    		return nil, fmt.Errorf("provided option cannot be empty")
    	}
    
    	// Disallow relative paths, figure out absolute paths.
    	dirAbs, err := filepath.Abs(dir)
    	if err != nil {
    		return nil, err
    	}
    	err = mkdirAllIgnorePerm(dirAbs)
    	if err != nil {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat May 04 00:17:57 GMT 2024
    - 35.8K bytes
    - Viewed (2)
  4. cmd/config-current.go

    			return err
    		}
    	case config.CallhomeSubSys:
    		cfg, err := callhome.LookupConfig(s[config.CallhomeSubSys][config.Default])
    		if err != nil {
    			return err
    		}
    		// callhome cannot be enabled if license is not registered yet, throw an error.
    		if cfg.Enabled() && !globalSubnetConfig.Registered() {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 30.8K bytes
    - Viewed (0)
  5. cmd/format-erasure.go

    		}
    		if len(formatErasure.Erasure.Sets[0]) != setDriveCount {
    			return fmt.Errorf("%s drive is already formatted with %d drives per erasure set. This cannot be changed to %d", disks[i], len(formatErasure.Erasure.Sets[0]), setDriveCount)
    		}
    	}
    	return nil
    }
    
    // Get backend Erasure format in quorum `format.json`.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 15:54:03 GMT 2024
    - 23.2K bytes
    - Viewed (0)
  6. cni/pkg/iptables/iptables.go

    	//
    	// All this is necessary because quite often apps use the same port for healthchecks as they do for reg. traffic, and
    	// we cannot make assumptions there.
    
    	// -A OUTPUT -m owner --socket-exists -p tcp -m set --match-set istio-inpod-probes dst,dst -j SNAT --to-source 169.254.7.127
    	iptablesBuilder.AppendRuleV4(
    Go
    - Registered: Wed May 08 22:53:08 GMT 2024
    - Last Modified: Tue May 07 19:54:50 GMT 2024
    - 19.7K bytes
    - Viewed (0)
  7. cmd/api-errors.go

    	ErrRemoteTargetDenyAddError: {
    		Code:           "XMinioAdminRemoteTargetDenyAdd",
    		Description:    "Cannot add remote target endpoint since this server is in a cluster replication setup",
    		HTTPStatusCode: http.StatusBadRequest,
    	},
    	ErrReplicationDenyEditError: {
    		Code:           "XMinioReplicationDenyEdit",
    		Description:    "Cannot alter local replication config since this server is in a cluster replication setup",
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 91.4K bytes
    - Viewed (7)
  8. cmd/object-api-errors.go

    	case RQInsufficientOnlineDrives:
    		return "InsufficientOnlineDrives"
    	case RQInconsistentMeta:
    		return "InconsistentMeta"
    	default:
    		return "Unknown"
    	}
    }
    
    // InsufficientReadQuorum storage cannot satisfy quorum for read operation.
    type InsufficientReadQuorum struct {
    	Bucket string
    	Object string
    	Err    error
    	Type   RQErrType
    }
    
    func (e InsufficientReadQuorum) Error() string {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 21.3K bytes
    - Viewed (0)
  9. cmd/erasure-object.go

    		for index, nerr := range errs {
    			if nerr != nil {
    				continue
    			}
    			index := index
    			// When we are going to return error, attempt to delete success
    			// on some of the drives, if we cannot we do not have to notify
    			// caller this dangling object will be now scheduled to be removed
    			// via active healing.
    			dg.Go(func() error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  10. cmd/erasure-server-pool.go

    	poolObjIdxMap := map[int][]ObjectToDelete{}
    	origIndexMap := map[int][]int{}
    
    	// Always perform 1/10th of the number of objects per delete
    	concurrent := len(objects) / 10
    	if concurrent <= 10 {
    		// if we cannot get 1/10th then choose the number of
    		// objects as concurrent.
    		concurrent = len(objects)
    	}
    
    	var mu sync.Mutex
    	eg := errgroup.WithNErrs(len(objects)).WithConcurrency(concurrent)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
Back to top