- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for readConfig (0.05 sec)
-
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 {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.9K bytes - Viewed (0) -
cmd/admin-handlers-config-kv.go
result.Cfg, err = readServerConfig(ctx, objectAPI, nil) if err != nil { return result, err } result.Dynamic, err = result.Cfg.ReadConfig(bytes.NewReader(kvBytes)) if err != nil { return result, err } result.SubSys, _, _, err = config.GetSubSys(string(kvBytes)) if err != nil { return result, err }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 15.8K bytes - Viewed (1) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 5.4K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 15.6K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.5K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 18.2K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 63.5K bytes - Viewed (0) -
internal/config/config.go
return nil, err } ids[tgt] = true } if err := scanner.Err(); err != nil { return nil, err } return ids, err } // 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 37.7K bytes - Viewed (0) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 42.2K bytes - Viewed (1) -
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 Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 184.8K bytes - Viewed (1)