Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 21 - 30 of 51 for kvs (0.1 seconds)

  1. internal/config/subnet/config.go

    // LookupConfig - lookup config and override with valid environment settings if any.
    func LookupConfig(kvs config.KVS, transport http.RoundTripper) (cfg Config, err error) {
    	if err = config.CheckValidKeys(config.SubnetSubSys, kvs, DefaultKVS); err != nil {
    		return cfg, err
    	}
    
    	var proxyURL *xnet.URL
    	proxy := env.Get(config.EnvMinIOSubnetProxy, kvs.Get(config.Proxy))
    	if len(proxy) > 0 {
    		proxyURL, err = xnet.ParseHTTPURL(proxy)
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Feb 18 16:25:55 GMT 2025
    - 3.9K bytes
    - Click Count (0)
  2. internal/config/browser/browser.go

    		return cfg, err
    	}
    
    	hstsIncludeSubdomains := env.Get(EnvBrowserHSTSIncludeSubdomains, kvs.GetWithDefault(browserHSTSIncludeSubdomains, DefaultKVS)) == config.EnableOn
    	hstsPreload := env.Get(EnvBrowserHSTSPreload, kvs.Get(browserHSTSPreload)) == config.EnableOn
    
    	hstsSeconds, err := strconv.Atoi(env.Get(EnvBrowserHSTSSeconds, kvs.GetWithDefault(browserHSTSSeconds, DefaultKVS)))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jun 21 00:58:58 GMT 2024
    - 5.9K bytes
    - Click Count (0)
  3. internal/s3select/json/record.go

    func (r *Record) Clone(dst sql.Record) sql.Record {
    	other, ok := dst.(*Record)
    	if !ok {
    		other = &Record{}
    	}
    	if len(other.KVS) > 0 {
    		other.KVS = other.KVS[:0]
    	}
    	other.KVS = append(other.KVS, r.KVS...)
    	return other
    }
    
    // Set - sets the value for a column name.
    func (r *Record) Set(name string, value *sql.Value) (sql.Record, error) {
    	var v any
    	if b, ok := value.ToBool(); ok {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.2K bytes
    - Click Count (0)
  4. internal/config/help.go

    	// Indicates if sub-sys supports multiple targets.
    	MultipleTargets bool `json:"multipleTargets"`
    }
    
    // HelpKVS - implement order of keys help messages.
    type HelpKVS []HelpKV
    
    // Lookup - lookup a key from help kvs.
    func (hkvs HelpKVS) Lookup(key string) (HelpKV, bool) {
    	for _, hkv := range hkvs {
    		if hkv.Key == key {
    			return hkv, true
    		}
    	}
    	return HelpKV{}, false
    }
    
    // DefaultComment used across all sub-systems.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Jun 23 14:45:27 GMT 2023
    - 2.8K bytes
    - Click Count (0)
  5. internal/config/storageclass/storage-class.go

    func LookupConfig(kvs config.KVS, setDriveCount int) (cfg Config, err error) {
    	cfg = Config{}
    
    	deprecatedKeys := []string{
    		"dma",
    	}
    
    	if err = config.CheckValidKeys(config.StorageClassSubSys, kvs, DefaultKVS, deprecatedKeys...); err != nil {
    		return Config{}, err
    	}
    
    	ssc := env.Get(StandardEnv, kvs.Get(ClassStandard))
    	rrsc := env.Get(RRSEnv, kvs.Get(ClassRRS))
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.3K bytes
    - Click Count (0)
  6. cmd/config-current.go

    		config.BrowserSubSys:        browser.DefaultKVS,
    	}
    	maps.Copy(kvs, notify.DefaultNotificationKVS)
    	maps.Copy(kvs, lambda.DefaultLambdaKVS)
    	if globalIsErasure {
    		kvs[config.StorageClassSubSys] = storageclass.DefaultKVS
    		kvs[config.HealSubSys] = heal.DefaultKVS
    	}
    	config.RegisterDefaultKVS(kvs)
    
    	// Captures help for each sub-system
    	helpSubSys := config.HelpKVS{
    		config.HelpKV{
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 28.5K bytes
    - Click Count (0)
  7. cmd/postpolicyform.go

    			// This is a JSON object type (that preserves key order)
    			kvs, ok := mv.Value.(jstream.KVS)
    			if ok {
    				for _, kv := range kvs {
    					if sset.Contains(kv.Key) {
    						// Reject duplicate conditions or expiration.
    						return nil, fmt.Errorf("input policy has multiple %s, please fix your client code", kv.Key)
    					}
    					sset.Add(kv.Key)
    				}
    			}
    			e.Encode(kvs)
    		}
    	}
    	return &buf, d.Err()
    }
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Oct 23 15:10:12 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  8. internal/config/identity/openid/openid.go

    	// remove this since we have removed support for this already.
    	for k := range s[config.IdentityOpenIDSubSys] {
    		for _, dk := range deprecatedKeys {
    			kvs := s[config.IdentityOpenIDSubSys][k]
    			kvs.Delete(dk)
    			s[config.IdentityOpenIDSubSys][k] = kvs
    		}
    	}
    
    	if err := s.CheckValidKeys(config.IdentityOpenIDSubSys, deprecatedKeys); err != nil {
    		return c, err
    	}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 17.3K bytes
    - Click Count (0)
  9. internal/config/legacy.go

    // SetRegion - One time migration code needed, for migrating from older config to new for server Region.
    func SetRegion(c Config, name string) {
    	if name == "" {
    		return
    	}
    	c[RegionSubSys][Default] = KVS{
    		KV{
    			Key:   RegionName,
    			Value: name,
    		},
    	}
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Mon Dec 19 20:27:06 GMT 2022
    - 1.1K bytes
    - Click Count (0)
  10. internal/config/policy/opa/config.go

    type Opa struct {
    	args   Args
    	client *http.Client
    }
    
    // Enabled returns if opa is enabled.
    func Enabled(kvs config.KVS) bool {
    	return kvs.Get(URL) != ""
    }
    
    // LookupConfig lookup Opa from config, override with any ENVs.
    func LookupConfig(kv config.KVS, transport *http.Transport, closeRespFn func(io.ReadCloser)) (Args, error) {
    	args := Args{}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.3K bytes
    - Click Count (0)
Back to Top