- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for ReadConfig (0.19 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 {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Aug 23 10:07:06 GMT 2023 - 6K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)