Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 112 for scfg (0.02 sec)

  1. 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)
  2. 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)
  3. internal/logger/legacy.go

    )
    
    // SetLoggerHTTPAudit - helper for migrating older config to newer KV format.
    func SetLoggerHTTPAudit(scfg config.Config, k string, args http.Config) {
    	if !args.Enabled {
    		// Do not enable audit targets, if not enabled
    		return
    	}
    	scfg[config.AuditWebhookSubSys][k] = config.KVS{
    		config.KV{
    			Key:   config.Enable,
    			Value: config.EnableOn,
    		},
    		config.KV{
    			Key:   Endpoint,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 03 09:47:07 UTC 2023
    - 2K bytes
    - Viewed (0)
  4. internal/config/storageclass/storage-class_test.go

    		{"", 16, 9, 7},
    	}
    	for i, tt := range tests {
    		scfg := Config{
    			Standard: StorageClass{
    				Parity: 8,
    			},
    			RRS: StorageClass{
    				Parity: 2,
    			},
    			initialized: true,
    		}
    		// Set env var for test case 4
    		if i+1 == 4 {
    			scfg.RRS.Parity = 7
    		}
    		// Set env var for test case 5
    		if i+1 == 5 {
    			scfg.Standard.Parity = 6
    		}
    		// Set env var for test case 6
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 15 23:04:20 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top