Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 14 for ReadConfig (0.19 sec)

  1. cmd/config.go

    				RestoreID:  strings.TrimSuffix(path.Base(obj.Name), kvPrefix),
    				CreateTime: obj.ModTime, // ModTime is createTime for config history entries.
    			}
    			if withData {
    				data, err := readConfig(ctx, objAPI, obj.Name)
    				if err != nil {
    					// ignore history file if not readable.
    					continue
    				}
    
    				data, err = decryptData(data, obj.Name)
    				if err != nil {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Aug 23 10:07:06 GMT 2023
    - 6K bytes
    - Viewed (0)
  2. cmd/data-usage.go

    		},
    	)
    
    	return prefixUsageCache.Get()
    }
    
    func loadDataUsageFromBackend(ctx context.Context, objAPI ObjectLayer) (DataUsageInfo, error) {
    	buf, err := readConfig(ctx, objAPI, dataUsageObjNamePath)
    	if err != nil {
    		buf, err = readConfig(ctx, objAPI, dataUsageObjNamePath+".bkp")
    		if err != nil {
    			if errors.Is(err, errConfigNotFound) {
    				return DataUsageInfo{}, nil
    			}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 5.6K bytes
    - Viewed (0)
  3. 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
    		}
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Oct 18 18:05:24 GMT 2023
    - 5.4K bytes
    - Viewed (0)
  4. cmd/config-common.go

    	buf, err := io.ReadAll(r)
    	if err != nil {
    		return nil, ObjectInfo{}, err
    	}
    	if len(buf) == 0 {
    		return nil, ObjectInfo{}, errConfigNotFound
    	}
    	return buf, r.ObjInfo, nil
    }
    
    func readConfig(ctx context.Context, store objectIO, configFile string) ([]byte, error) {
    	buf, _, err := readConfigWithMetadata(ctx, store, configFile, ObjectOptions{})
    	return buf, err
    }
    
    type objectDeleter interface {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Sep 18 17:00:54 GMT 2023
    - 3.1K bytes
    - Viewed (0)
  5. 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
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 15.7K bytes
    - Viewed (0)
  6. 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 {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 12.7K bytes
    - Viewed (0)
  7. 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() {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sat Mar 02 05:11:03 GMT 2024
    - 37.3K bytes
    - Viewed (0)
  8. 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]) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 16.5K bytes
    - Viewed (0)
  9. 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, fmt.Errorf("tierConfigInit: no data")
    	}
    
    	// Read header
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Wed Apr 17 05:09:58 GMT 2024
    - 15.5K bytes
    - Viewed (0)
  10. cmd/batch-handlers.go

    	case job.Expire != nil:
    		version = batchExpireVersionV1
    		format = batchExpireFormat
    	default:
    		return errors.New("no supported batch job request specified")
    	}
    	data, err := readConfig(ctx, api, getJobReportPath(job))
    	if err != nil {
    		if errors.Is(err, errConfigNotFound) || isErrObjectNotFound(err) {
    			ri.Version = int(version)
    			switch {
    			case job.Replicate != nil:
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 08 14:11:38 GMT 2024
    - 55.2K bytes
    - Viewed (0)
Back to top