Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 14 of 14 for ReadConfig (0.06 sec)

  1. 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)
  2. 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)
  3. 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)
  4. cmd/bucket-replication.go

    	brs = newBucketResyncStatus(bucket)
    	resyncDirPath := path.Join(bucketMetaPrefix, bucket, replicationDir)
    	data, err := readConfig(GlobalContext, objAPI, pathJoin(resyncDirPath, resyncFileName))
    	if err != nil && err != errConfigNotFound {
    		return brs, err
    	}
    	if len(data) == 0 {
    		// Seems to be empty.
    		return brs, nil
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
Back to top