Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 29 for laking (7.56 sec)

  1. cmd/mrf.go

    				}
    				if wildcard.Match("tmp-old/*", u.object) {
    					continue
    				}
    			}
    
    			now := time.Now()
    			if now.Sub(u.queued) < time.Second {
    				// let recently failed networks to reconnect
    				// making MRF wait for 1s before retrying,
    				// i.e 4 reconnect attempts.
    				time.Sleep(time.Second)
    			}
    
    			// wait on timer per heal
    			wait := healSleeper.Timer(context.Background())
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 3.2K bytes
    - Viewed (0)
  2. update-credits.sh

          "You" (or "Your") shall mean an individual or Legal Entity
          exercising permissions granted by this License.
    
          "Source" form shall mean the preferred form for making modifications,
          including but not limited to software source code, documentation
          source, and configuration files.
    
          "Object" form shall mean any form resulting from mechanical
    Shell Script
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Aug 11 05:08:38 GMT 2023
    - 11.4K bytes
    - Viewed (0)
  3. helm/minio/README.md

    ```bash
    helm install --name my-release --set persistence.size=1Ti minio/minio
    ```
    
    The above command deploys MinIO server with a 1Ti backing persistent volume.
    
    Alternately, you can provide a YAML file that specifies parameter values while installing the chart. For example,
    
    ```bash
    helm install --name my-release -f values.yaml minio/minio
    ```
    
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed Jan 24 07:27:57 GMT 2024
    - 10.9K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    			return true
    		}
    
    		goOffline := func(err error, spent time.Duration) {
    			if p.health.status.CompareAndSwap(diskHealthOK, diskHealthFaulty) {
    				storageLogAlwaysIf(ctx, fmt.Errorf("node(%s): taking drive %s offline: %v", globalLocalNodeName, p.storage.String(), err))
    				p.health.waiting.Add(1)
    				go p.monitorDiskStatus(spent, fn)
    			}
    		}
    
    		// Offset checks a bit.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  5. cmd/erasure-object_test.go

    	_, err = obj.PutObject(ctx, bucket, object, mustGetPutObjReader(t, bytes.NewReader([]byte("abcd")), int64(len("abcd")), "", ""), opts)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Remove one more disk to 'lose' quorum, by taking 2 more drives offline.
    	erasureDisks = xl.getDisks()
    	z.serverPools[0].erasureDisksMu.Lock()
    	xl.getDisks = func() []StorageAPI {
    		erasureDisks[7] = nil
    		erasureDisks[8] = nil
    		return erasureDisks
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Jan 30 20:43:25 GMT 2024
    - 36.8K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    	object = encodeDirObject(object)
    
    	if z.SinglePool() {
    		return z.serverPools[0].GetObjectInfo(ctx, bucket, object, opts)
    	}
    
    	if !opts.NoLock {
    		opts.NoLock = true // avoid taking locks at lower levels for multi-pool setups.
    
    		// Lock the object before reading.
    		lk := z.NewNSLock(bucket, object)
    		lkctx, err := lk.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    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)
  7. cmd/server_test.go

    	response, err = s.client.Do(request)
    	c.Assert(err, nil)
    	// assert the status code of the response.
    	c.Assert(response.StatusCode, http.StatusOK)
    
    	// constructing http request to delete the bucket.
    	// making an attempt to delete an non-empty bucket.
    	// expected to fail.
    	request, err = newTestSignedRequest(http.MethodDelete, getDeleteBucketURL(s.endPoint, bucketName),
    		0, nil, s.accessKey, s.secretKey, s.signer)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  8. internal/handlers/proxy.go

    		s := strings.Index(fwd, ", ")
    		if s == -1 {
    			s = len(fwd)
    		}
    		addr = fwd[:s]
    	} else if fwd := r.Header.Get(xRealIP); fwd != "" {
    		// X-Real-IP should only contain one IP address (the client making the
    		// request).
    		addr = fwd
    	} else if fwd := r.Header.Get(forwarded); fwd != "" {
    		// match should contain at least two elements if the protocol was
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Dec 22 00:56:55 GMT 2023
    - 5.1K bytes
    - Viewed (0)
  9. cmd/bucket-object-lock.go

    			return r, err
    		}
    		return r, err
    	}
    	return config.ToRetention(), nil
    }
    
    // enforceRetentionForDeletion checks if it is appropriate to remove an
    // object according to locking configuration when this is lifecycle/ bucket quota asking.
    func enforceRetentionForDeletion(ctx context.Context, objInfo ObjectInfo) (locked bool) {
    	if objInfo.DeleteMarker {
    		return false
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 13.2K bytes
    - Viewed (0)
  10. cmd/admin-handlers-config-kv.go

    		return
    	}
    
    	writeSuccessResponseHeadersOnly(w)
    }
    
    // GetConfigHandler - GET /minio/admin/v3/config
    //
    // This endpoint is mainly for exporting and backing up the configuration.
    // Secrets are not redacted.
    func (a adminAPIHandlers) GetConfigHandler(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.7K bytes
    - Viewed (0)
Back to top