- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 82 for scfg (0.03 sec)
-
internal/config/storageclass/storage-class.go
func (sCfg *Config) AvailabilityOptimized() bool { ConfigLock.RLock() defer ConfigLock.RUnlock() if !sCfg.initialized { return true } return sCfg.Optimize == "availability" || sCfg.Optimize == "" } // Update update storage-class with new config func (sCfg *Config) Update(newCfg Config) { ConfigLock.Lock() defer ConfigLock.Unlock() sCfg.RRS = newCfg.RRS
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 12 12:24:04 UTC 2024 - 12.3K bytes - Viewed (0) -
internal/logger/config.go
return cfg, err } case config.AuditWebhookSubSys: cfg = lookupLegacyConfigForSubSys(ctx, config.AuditWebhookSubSys) if cfg, err = lookupAuditWebhookConfig(scfg, cfg); err != nil { return cfg, err } case config.AuditKafkaSubSys: cfg.AuditKafka = make(map[string]kafka.Config) if cfg, err = lookupAuditKafkaConfig(scfg, cfg); err != nil { return cfg, err } } return cfg, nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 20 16:02:50 UTC 2024 - 18.3K bytes - Viewed (0) -
cmd/bootstrap-peer-server.go
continue } envValues[envK] = logger.HashString(env.Get(envK, "")) } scfg := &ServerSystemConfig{NEndpoints: globalEndpoints.NEndpoints(), MinioEnv: envValues, Checksum: binaryChecksum} var cmdLines []string for _, ep := range globalEndpoints { cmdLines = append(cmdLines, ep.CmdLine) } scfg.CmdLines = cmdLines return scfg }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 8.4K bytes - Viewed (0) -
internal/config/api/api.go
if err != nil { return cfg, err } cfg.RequestsMax = requestsMax if requestsMax < 0 { return cfg, errors.New("invalid API max requests value") } clusterDeadline, err := time.ParseDuration(env.Get(EnvAPIClusterDeadline, kvs.GetWithDefault(apiClusterDeadline, DefaultKVS))) if err != nil { return cfg, err } cfg.ClusterDeadline = clusterDeadline
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Aug 16 08:43:49 UTC 2024 - 11.5K bytes - Viewed (0) -
cni/pkg/install/kubeconfig.go
protocol := model.GetOrDefault(cfg.K8sServiceProtocol, "https") cluster := &api.Cluster{ Server: fmt.Sprintf("%s://%s", protocol, net.JoinHostPort(cfg.K8sServiceHost, cfg.K8sServicePort)), } if cfg.SkipTLSVerify { // User explicitly opted into insecure. cluster.InsecureSkipTLSVerify = true } else { caFile := model.GetOrDefault(cfg.KubeCAFile, cfg.K8sServiceAccountPath+"/ca.crt") caContents, err := os.ReadFile(caFile)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 01 18:38:14 UTC 2024 - 4K bytes - Viewed (0) -
cmd/bucket-targets.go
healthCheckDuration: hcDuration, replicateSync: tcfg.ReplicationSync, Bucket: tcfg.TargetBucket, StorageClass: tcfg.StorageClass, disableProxy: tcfg.DisableProxy, ARN: tcfg.Arn, ResetID: tcfg.ResetID, Endpoint: tcfg.Endpoint, Secure: tcfg.Secure, } return tc, nil }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 20.9K bytes - Viewed (0) -
internal/config/identity/openid/openid.go
return nil, err } var res []madmin.IDPListItem for _, cfg := range openIDConfigs { pcfg, ok := r.ProviderCfgs[cfg] if !ok { res = append(res, madmin.IDPListItem{ Type: "openid", Name: cfg, Enabled: false, }) } else { var roleARN string if pcfg.RolePolicy != "" { roleARN = pcfg.roleArn.String() } res = append(res, madmin.IDPListItem{
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 10 20:16:44 UTC 2024 - 16.6K bytes - Viewed (0) -
internal/config/subnet/config.go
} // Update - in-place update with new license and registration information. func (c *Config) Update(ncfg Config, isDevEnv bool) { configLock.Lock() defer configLock.Unlock() c.License = ncfg.License c.APIKey = ncfg.APIKey c.Proxy = ncfg.Proxy c.transport = ncfg.transport c.BaseURL = baseURL if isDevEnv { c.BaseURL = os.Getenv("_MINIO_SUBNET_URL") if c.BaseURL == "" {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3.8K bytes - Viewed (0) -
internal/config/callhome/callhome.go
return c.Frequency } // Update updates new callhome frequency func (c *Config) Update(ncfg Config) { configLock.Lock() defer configLock.Unlock() c.Enable = ncfg.Enable c.Frequency = ncfg.Frequency } // LookupConfig - lookup config and override with valid environment settings if any. func LookupConfig(kvs config.KVS) (cfg Config, err error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 2.6K bytes - Viewed (0) -
cmd/data-scanner.go
done := globalScannerMetrics.time(scannerMetricApplyNonCurrent) defer done() rcfg, _ := globalBucketObjectLockSys.Get(i.bucket) vcfg, _ := globalBucketVersioningSys.Get(i.bucket) versioned := vcfg != nil && vcfg.Versioned(i.objectPath()) objectInfos := make([]ObjectInfo, 0, len(fivs)) if i.lifeCycle == nil { for _, fi := range fivs {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 22 21:10:34 UTC 2024 - 48.4K bytes - Viewed (0)