Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for __construct (0.16 sec)

  1. docs/debugging/xl-meta/main.go

    			if err := rs.ReconstructData(split); err == nil {
    				fmt.Println("Could reconstruct completely")
    				for i, data := range split[:k] {
    					start := i * len(data)
    					copy(mapped[start:], data)
    				}
    				lastValid = size - 1
    				missing = 0
    			} else {
    				fmt.Println("Could NOT reconstruct:", err)
    			}
    		}
    	}
    	if lastValid == 0 {
    		return errors.New("no valid data found")
    	}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 17:56:22 GMT 2024
    - 20.2K bytes
    - Viewed (1)
  2. cmd/update.go

    	// deployment guide for update procedures.
    	if IsKubernetes() {
    		return kubernetesDeploymentDoc
    	}
    
    	// Check if we are docker environment, return docker update command
    	if IsDocker() {
    		// Construct release tag name.
    		return fmt.Sprintf("podman pull quay.io/minio/minio:%s", releaseTag)
    	}
    
    	// For binary only installations, we return link to the latest binary.
    	if runtime.GOOS == "windows" {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Apr 24 04:08:47 GMT 2024
    - 18.7K bytes
    - Viewed (0)
  3. cmd/erasure-object.go

    			if IsErr(errs[i],
    				errFileNotFound,
    				errFileVersionNotFound,
    				errFileCorrupt,
    			) {
    				missingBlocks++
    			}
    		}
    
    		// if missing metadata can be reconstructed, attempt to reconstruct.
    		// additionally do not heal delete markers inline, let them be
    		// healed upon regular heal process.
    		if missingBlocks > 0 && missingBlocks < fi.Erasure.DataBlocks {
    			globalMRFState.addPartialOp(partialOperation{
    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)
  4. cmd/handler-utils.go

    func getResource(path string, host string, domains []string) (string, error) {
    	if len(domains) == 0 {
    		return path, nil
    	}
    
    	// If virtual-host-style is enabled construct the "resource" properly.
    	xhost, err := xnet.ParseHost(host)
    	if err != nil {
    		return "", err
    	}
    
    	for _, domain := range domains {
    		if xhost.Name == minioReservedBucket+"."+domain {
    			continue
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.5K bytes
    - Viewed (3)
  5. cmd/iam-etcd-store.go

    	//  a large number of policies
    	r, err := ies.client.Get(ctx, iamConfigPoliciesPrefix, etcd.WithPrefix())
    	if err != nil {
    		return err
    	}
    
    	// Parse all values to construct the policies data model.
    	for _, kvs := range r.Kvs {
    		if err = ies.getPolicyDocKV(ctx, kvs, m); err != nil && !errors.Is(err, errNoSuchPolicy) {
    			return err
    		}
    	}
    	return nil
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 13.6K bytes
    - Viewed (0)
  6. cmd/test-utils_test.go

    	}
    }
    
    // Uploads an object using DummyDataGen directly via the http
    // handler. Each part in a multipart object is a new DummyDataGen
    // instance (so the part sizes are needed to reconstruct the whole
    // object). When `len(partSizes) == 1`, asMultipart is used to upload
    // the object as multipart with 1 part or as a regular single object.
    //
    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)
  7. cmd/peer-rest-client.go

    	// Use a separate client to avoid recursive calls.
    	healthClient := rest.NewClient(serverURL, globalInternodeTransport, newCachedAuthToken())
    	healthClient.NoMetrics = true
    
    	// Construct a new health function.
    	restClient.HealthCheckFn = func() bool {
    		ctx, cancel := context.WithTimeout(context.Background(), restClient.HealthCheckTimeout)
    		defer cancel()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 25.8K bytes
    - Viewed (0)
  8. cmd/object-api-utils.go

    	}
    	p.Reader = encReader
    	p.sealMD5Fn = sealETagFn(*objEncKey)
    	return p, nil
    }
    
    // NewPutObjReader returns a new PutObjReader. It uses given hash.Reader's
    // MD5Current method to construct md5sum when requested downstream.
    func NewPutObjReader(rawReader *hash.Reader) *PutObjReader {
    	return &PutObjReader{Reader: rawReader, rawReader: rawReader}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
  9. cmd/signature-v4.go

    		return ErrExpiredPresignRequest
    	}
    
    	// Save the date and expires.
    	t := pSignValues.Date
    	expireSeconds := int(pSignValues.Expires / time.Second)
    
    	// Construct new query.
    	query := make(url.Values)
    	clntHashedPayload := req.Form.Get(xhttp.AmzContentSha256)
    	if clntHashedPayload != "" {
    		query.Set(xhttp.AmzContentSha256, hashedPayload)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 19 16:45:54 GMT 2024
    - 12.3K bytes
    - Viewed (0)
  10. internal/bucket/object/lock/lock.go

    		return ObjectLegalHold{XMLNS: "http://s3.amazonaws.com/doc/2006-03-01/", Status: parseLegalHoldStatus(holdStr)}
    	}
    	return ObjectLegalHold{}
    }
    
    // ParseObjectLockLegalHoldHeaders parses request headers to construct ObjectLegalHold
    func ParseObjectLockLegalHoldHeaders(h http.Header) (lhold ObjectLegalHold, err error) {
    	holdStatus, ok := h[AmzObjectLockLegalHold]
    	if ok {
    		lh := parseLegalHoldStatus(holdStatus[0])
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 17.1K bytes
    - Viewed (0)
Back to top