Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for bonded (0.15 sec)

  1. cmd/test-utils_test.go

    }
    
    // reset the value of the Global server config.
    // set it to `nil`.
    func resetGlobalConfig() {
    	// hold the mutex lock before a new config is assigned.
    	globalServerConfigMu.Lock()
    	// Save the loaded config globally.
    	globalServerConfig = nil
    	globalServerConfigMu.Unlock()
    }
    
    func resetGlobalEndpoints() {
    	globalEndpoints = EndpointServerPools{}
    }
    
    func resetGlobalIsErasure() {
    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/bucket-replication.go

    		}
    		uploadedParts = append(uploadedParts, minio.CompletePart{
    			PartNumber: pInfo.PartNumber,
    			ETag:       pInfo.ETag,
    		})
    	}
    
    	// really big value but its okay on heavily loaded systems. This is just tail end timeout.
    	cctx, ccancel := context.WithTimeout(ctx, 10*time.Minute)
    	defer ccancel()
    	_, err = c.CompleteMultipartUpload(cctx, bucket, object, uploadID, uploadedParts, minio.PutObjectOptions{
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
  3. cmd/config-current.go

    	return readServerConfig(GlobalContext, objAPI, nil)
    }
    
    // loadConfig - loads a new config from disk, overrides params
    // from env if found and valid
    // data is optional. If nil it will be loaded from backend.
    func loadConfig(objAPI ObjectLayer, data []byte) error {
    	bootstrapTraceMsg("load the configuration")
    	srvCfg, err := readServerConfig(GlobalContext, objAPI, data)
    	if err != nil {
    		return err
    	}
    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)
  4. cmd/erasure-server-pool-decom.go

    	}
    }
    
    //go:generate msgp -file $GOFILE -unexported
    type poolMeta struct {
    	Version int          `msg:"v"`
    	Pools   []PoolStatus `msg:"pls"`
    
    	// Value should not be saved when we have not loaded anything yet.
    	dontSave bool `msg:"-"`
    }
    
    // A decommission resumable tells us if decommission is worth
    // resuming upon restart of a cluster.
    func (p *poolMeta) returnResumablePools() []PoolStatus {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 15:18:21 GMT 2024
    - 41.5K bytes
    - Viewed (1)
  5. cmd/sts-handlers.go

    	// because there will be a policy mapping stored on drives whose
    	// filename is this parentUser: therefore, it needs to have only valid
    	// filename characters and needs to have bounded length.
    	{
    		h := sha256.New()
    		h.Write([]byte("openid:" + subFromToken + ":" + issFromToken))
    		bs := h.Sum(nil)
    		cred.ParentUser = base64.RawURLEncoding.EncodeToString(bs)
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 21:31:13 GMT 2024
    - 34.7K bytes
    - Viewed (2)
  6. cmd/data-scanner.go

    	healDeleteDangling   = true
    	healObjectSelectProb = 1024 // Overall probability of a file being scanned; one in n.
    )
    
    var (
    	globalHealConfig heal.Config
    
    	// Sleeper values are updated when config is loaded.
    	scannerSleeper                       = newDynamicSleeper(2, time.Second, true) // Keep defaults same as config defaults
    	scannerCycle                         = uatomic.NewDuration(dataScannerStartDelay)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K bytes
    - Viewed (0)
Back to top