Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for readConfig (0.09 sec)

  1. cmd/admin-handlers-config-kv.go

    	result.Cfg, err = readServerConfig(ctx, objectAPI, nil)
    	if err != nil {
    		return
    	}
    
    	result.Dynamic, err = result.Cfg.ReadConfig(bytes.NewReader(kvBytes))
    	if err != nil {
    		return
    	}
    
    	result.SubSys, _, _, err = config.GetSubSys(string(kvBytes))
    	if err != nil {
    		return
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  2. cmd/config-migrate.go

    	}
    	if osIsPermission(err) {
    		logger.Info("Older config found but is not readable %s, proceeding to read config from other places", err)
    	}
    	if osIsNotExist(err) || osIsPermission(err) || len(data) == 0 {
    		data, err = readConfig(GlobalContext, objAPI, configFile)
    		if err != nil {
    			// when config.json is not found, then we freshly initialize.
    			if errors.Is(err, errConfigNotFound) {
    				return newServerCfg()
    			}
    			return nil, err
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 5.4K bytes
    - Viewed (0)
  3. cmd/admin-handlers-idp-config.go

    	}
    
    	cfg, err := readServerConfig(ctx, objectAPI, nil)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	dynamic, err := cfg.ReadConfig(strings.NewReader(cfgData))
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL)
    		return
    	}
    
    	// IDP config is not dynamic. Sanity check.
    	if dynamic {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  4. cmd/tier.go

    func loadTierConfig(ctx context.Context, objAPI ObjectLayer) (*TierConfigMgr, error) {
    	if objAPI == nil {
    		return nil, errServerNotInitialized
    	}
    
    	data, err := readConfig(ctx, objAPI, tierConfigPath)
    	if err != nil {
    		return nil, err
    	}
    
    	if len(data) <= 4 {
    		return nil, errors.New("tierConfigInit: no data")
    	}
    
    	// Read header
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:44:05 UTC 2024
    - 15.7K bytes
    - Viewed (0)
  5. cmd/bucket-metadata.go

    		return BucketMetadata{}, errInvalidArgument
    	}
    	b := newBucketMetadata(name)
    	configFile := path.Join(bucketMetaPrefix, name, bucketMetadataFile)
    	data, err := readConfig(ctx, api, configFile)
    	if err != nil {
    		return b, err
    	}
    	if len(data) <= 4 {
    		return b, fmt.Errorf("loadBucketMetadata: no data")
    	}
    	// Read header
    	switch binary.LittleEndian.Uint16(data[0:2]) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  6. cmd/data-scanner.go

    }
    
    func readBackgroundHealInfo(ctx context.Context, objAPI ObjectLayer) backgroundHealInfo {
    	if globalIsErasureSD {
    		return backgroundHealInfo{}
    	}
    
    	// Get last healing information
    	buf, err := readConfig(ctx, objAPI, backgroundHealInfoPath)
    	if err != nil {
    		if !errors.Is(err, errConfigNotFound) {
    			internalLogOnceIf(ctx, err, backgroundHealInfoPath)
    		}
    		return backgroundHealInfo{}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 21:10:34 UTC 2024
    - 48.4K bytes
    - Viewed (0)
  7. cmd/batch-handlers.go

    	case batchExpireName:
    		version = batchExpireVersionV1
    		format = batchExpireFormat
    	default:
    		return errors.New("no supported batch job request specified")
    	}
    
    	data, err := readConfig(ctx, api, path)
    	if err != nil {
    		if errors.Is(err, errConfigNotFound) || isErrObjectNotFound(err) {
    			return errNoSuchJob
    		}
    		return err
    	}
    	if len(data) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  8. internal/config/config.go

    			return nil, err
    		}
    		ids[tgt] = true
    	}
    	if err := scanner.Err(); err != nil {
    		return nil, err
    	}
    	return
    }
    
    // ReadConfig - read content from input and write into c.
    // Returns whether all parameters were dynamic.
    func (c Config) ReadConfig(r io.Reader) (dynOnly bool, err error) {
    	var n int
    	scanner := bufio.NewScanner(r)
    	dynOnly = true
    	for scanner.Scan() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  9. cmd/erasure-server-pool-decom.go

    	if !update {
    		update = len(specifiedPools) != len(rememberedPools)
    	}
    
    	return update, nil
    }
    
    func (p *poolMeta) load(ctx context.Context, pool *erasureSets, pools []*erasureSets) error {
    	data, err := readConfig(ctx, pool, poolMetaName)
    	if err != nil {
    		if errors.Is(err, errConfigNotFound) || isErrObjectNotFound(err) {
    			return nil
    		}
    		return err
    	}
    	if len(data) == 0 {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
  10. cmd/site-replication.go

    	if c.enabled {
    		logger.Info("Cluster replication initialized")
    	}
    	return nil
    }
    
    func (c *SiteReplicationSys) loadFromDisk(ctx context.Context, objAPI ObjectLayer) error {
    	buf, err := readConfig(ctx, objAPI, getSRStateFilePath())
    	if err != nil {
    		if errors.Is(err, errConfigNotFound) {
    			c.Lock()
    			defer c.Unlock()
    			c.state = srState{}
    			c.enabled = false
    		}
    		return err
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 185.1K bytes
    - Viewed (0)
Back to top