Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for Arun (0.13 sec)

  1. cmd/site-replication.go

    	return concErr{
    		errMap:     errMap,
    		summaryErr: c.toErrorFromErrMap(errMap, actionName),
    	}
    }
    
    // concDo calls actions concurrently. selfActionFn is run for the current
    // cluster and peerActionFn is run for each peer replication cluster.
    func (c *SiteReplicationSys) concDo(selfActionFn func() error, peerActionFn func(deploymentID string, p madmin.PeerInfo) error, actionName string) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 184.2K bytes
    - Viewed (1)
  2. cmd/bucket-replication.go

    	return nil
    }
    
    func (p *ReplicationPool) startResyncRoutine(ctx context.Context, buckets []BucketInfo, objAPI ObjectLayer) {
    	r := rand.New(rand.NewSource(time.Now().UnixNano()))
    	// Run the replication resync in a loop
    	for {
    		if err := p.loadResync(ctx, buckets, objAPI); err == nil {
    			<-ctx.Done()
    			return
    		}
    		duration := time.Duration(r.Float64() * float64(time.Minute))
    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/server_test.go

    	testCases := []*TestSuiteCommon{
    		// Init and run test on ErasureSD backend with signature v4.
    		{serverType: "ErasureSD", signer: signerV4},
    		// Init and run test on ErasureSD backend with signature v2.
    		{serverType: "ErasureSD", signer: signerV2},
    		// Init and run test on ErasureSD backend, with tls enabled.
    		{serverType: "ErasureSD", signer: signerV4, secure: true},
    		// Init and run test on Erasure backend.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 108K bytes
    - Viewed (0)
  4. cmd/metrics-v2.go

    		Name:      total,
    		Help:      "Objects scanned in current self healing run",
    		Type:      gaugeMetric,
    	}
    }
    
    func getHealObjectsHealTotalMD() MetricDescription {
    	return MetricDescription{
    		Namespace: healMetricNamespace,
    		Subsystem: objectsSubsystem,
    		Name:      healTotal,
    		Help:      "Objects healed in current self healing run",
    		Type:      gaugeMetric,
    	}
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
  5. cmd/admin-handlers.go

    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrMethodNotAllowed), r.URL)
    		return
    	}
    
    	vars := mux.Vars(r)
    	updateURL := vars["updateURL"]
    	dryRun := r.Form.Get("dry-run") == "true"
    
    	mode := getMinioMode()
    	if updateURL == "" {
    		updateURL = minioReleaseInfoURL
    		if runtime.GOOS == globalWindowsOSName {
    			updateURL = minioReleaseWindowsInfoURL
    		}
    	}
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  6. cmd/object-handlers_test.go

    	type inputReqRec struct {
    		req     *http.Request
    		rec     *httptest.ResponseRecorder
    		reqType string
    	}
    
    	for i, test := range testCases {
    		// Using sub-tests introduced in Go 1.7.
    		t.Run(fmt.Sprintf("MinIO-%s-Test-%d.", instanceType, i), func(t *testing.T) {
    			// collection of input HTTP request, ResponseRecorder and request type.
    			// Used to make a collection of V4 and V4 HTTP request.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 160K bytes
    - Viewed (0)
Back to top