Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for gosave (0.05 seconds)

  1. cmd/bucket-replication.go

    	// For each bucket name, store the last timestamp of the
    	// successful save of replication status in the backend disks.
    	lastResyncStatusSave := make(map[string]time.Time)
    
    	for {
    		select {
    		case <-resyncTimer.C:
    			s.RLock()
    			for bucket, brs := range s.statusMap {
    				var updt bool
    				// Save the replication status if one resync to any bucket target is still not finished
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  2. cmd/site-replication.go

    	}
    
    	// we can now save the cluster replication configuration state.
    	if err = c.saveToDisk(ctx, state); err != nil {
    		return madmin.ReplicateEditStatus{
    			Status:    madmin.ReplicateAddStatusPartial,
    			ErrDetail: fmt.Sprintf("unable to save cluster-replication state on local: %v", err),
    		}, nil
    	}
    
    	if peer.DeploymentID != "" {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 184.8K bytes
    - Click Count (1)
  3. cmd/admin-handlers.go

    		adminLogIf(ctx, err)
    	}
    
    	// save the format.json as part of inspect by default
    	if volume != minioMetaBucket || file != formatConfigFile {
    		err = o.GetRawData(ctx, minioMetaBucket, formatConfigFile, rawDataFn)
    	}
    	if !errors.Is(err, errFileNotFound) {
    		adminLogIf(ctx, err)
    	}
    
    	scheme := "https"
    	if !globalIsTLS {
    		scheme = "http"
    	}
    
    	// save MinIO start script to inspect command
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  4. cmd/object-handlers.go

    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(s3Err), r.URL)
    			return errors.New(errorCodes.ToAPIErr(s3Err).Code)
    		}
    		metadata := map[string]string{
    			xhttp.AmzStorageClass: sc, // save same storage-class as incoming stream.
    		}
    
    		actualSize := size
    		var idxCb func() []byte
    		if isCompressible(r.Header, object) && size > minCompressibleSize {
    			// Storing the compression metadata.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 120.6K bytes
    - Click Count (0)
  5. cmd/object-handlers_test.go

    			secretKey:          credentials.SecretKey,
    			shouldPass:         false,
    			fault:              tooBigDecodedLength,
    		},
    		// Test case - 12
    		// Set custom content encoding should succeed and save the encoding properly.
    		{
    			bucketName:         bucketName,
    			objectName:         objectName,
    			data:               bytesData,
    			dataLen:            len(bytesData),
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 163.1K bytes
    - Click Count (0)
Back to Top