Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for saveConfig (0.49 sec)

  1. cmd/data-scanner.go

    	if globalIsErasureSD {
    		return
    	}
    
    	b, err := json.Marshal(info)
    	if err != nil {
    		bugLogIf(ctx, err)
    		return
    	}
    	// Get last healing information
    	err = saveConfig(ctx, objAPI, backgroundHealInfoPath, b)
    	if err != nil {
    		internalLogIf(ctx, err)
    	}
    }
    
    // runDataScanner will start a data scanner.
    // The function will block until the context is canceled.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 45.5K bytes
    - Viewed (0)
  2. cmd/bucket-metadata.go

    	// Marshal the bucket metadata
    	data, err := b.MarshalMsg(data)
    	if err != nil {
    		return err
    	}
    
    	configFile := path.Join(bucketMetaPrefix, b.Name, bucketMetadataFile)
    	return saveConfig(ctx, api, configFile, data)
    }
    
    // migrate config for remote targets by encrypting data if currently unencrypted and kms is configured.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 16 14:27:42 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  3. cmd/iam-object-store.go

    	}
    	if GlobalKMS != nil {
    		data, err = config.EncryptBytes(GlobalKMS, data, kms.Context{
    			minioMetaBucket: path.Join(minioMetaBucket, objPath),
    		})
    		if err != nil {
    			return err
    		}
    	}
    	return saveConfig(ctx, iamOS.objAPI, objPath, data)
    }
    
    func decryptData(data []byte, objPath string) ([]byte, error) {
    	if utf8.Valid(data) {
    		return data, nil
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  4. cmd/data-usage-cache.go

    	}
    
    	save := func(name string, timeout time.Duration) error {
    		// Abandon if more than a minute, so we don't hold up scanner.
    		ctx, cancel := context.WithTimeout(ctx, timeout)
    		defer cancel()
    
    		return saveConfig(ctx, store, pathJoin(bucketMetaPrefix, name), buf.Bytes())
    	}
    	defer save(name+".bkp", 5*time.Second) // Keep a backup as well
    
    	// drive timeout by default is 2 minutes, we do not need to wait longer.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-decom.go

    	buf, err := p.MarshalMsg(data)
    	if err != nil {
    		return err
    	}
    
    	// Saves on all pools to make sure decommissioning of first pool is allowed.
    	for i, eset := range pools {
    		if err = saveConfig(ctx, eset, poolMetaName, buf); err != nil {
    			if !errors.Is(err, context.Canceled) {
    				storageLogIf(ctx, fmt.Errorf("saving pool.bin for pool index %d failed with: %v", i, err))
    			}
    			return err
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 42.1K bytes
    - Viewed (1)
  6. cmd/erasure-healing_test.go

    	if err != nil {
    		t.Fatalf("Failed to complete multipart upload - got: %v", err)
    	}
    
    	cfgFile := pathJoin(bucketMetaPrefix, bucket, ".test.bin")
    	if err = saveConfig(ctx, objLayer, cfgFile, data); err != nil {
    		t.Fatal(err)
    	}
    
    	hopts := madmin.HealOpts{
    		DryRun:   false,
    		Remove:   true,
    		ScanMode: madmin.HealNormalScan,
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 48.5K bytes
    - Viewed (0)
Back to top