- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 43 for KVS (0.14 sec)
-
internal/config/callhome/callhome.go
func LookupConfig(kvs config.KVS) (cfg Config, err error) { if err = config.CheckValidKeys(config.CallhomeSubSys, kvs, DefaultKVS); err != nil { return cfg, err } cfg.Enable = env.Get(config.EnvMinIOCallhomeEnable, kvs.GetWithDefault(Enable, DefaultKVS)) == config.EnableOn cfg.Frequency, err = time.ParseDuration(env.Get(config.EnvMinIOCallhomeFrequency, kvs.GetWithDefault(Frequency, DefaultKVS)))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 2.6K bytes - Viewed (0) -
internal/config/etcd/etcd.go
} // Enabled returns if etcd is enabled. func Enabled(kvs config.KVS) bool { endpoints := kvs.Get(Endpoints) return endpoints != "" } // LookupConfig - Initialize new etcd config. func LookupConfig(kvs config.KVS, rootCAs *x509.CertPool) (Config, error) { cfg := Config{} if err := config.CheckValidKeys(config.EtcdSubSys, kvs, DefaultKVS); err != nil { return cfg, err }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Sep 04 19:57:37 GMT 2023 - 4.8K bytes - Viewed (0) -
internal/s3select/sql/jsonpath.go
} switch { case p[0].Key != nil: key := p[0].Key.keyString() switch kvs := v.(type) { case jstream.KVS: for _, kv := range kvs { if kv.Key == key { return jsonpathEval(p[1:], kv.Value) } } // Key not found - return nil result return Missing{}, false, nil case simdjson.Object: elem := kvs.FindKey(key, nil) if elem == nil { // Key not found - return nil result
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 3.4K bytes - Viewed (0) -
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)))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 5.8K bytes - Viewed (0) -
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{}
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Sep 14 21:50:16 GMT 2023 - 5.2K bytes - Viewed (1) -
internal/config/config.go
} return s.String() } // KVS - is a shorthand for some wrapper functions // to operate on list of key values. type KVS []KV // Empty - return if kv is empty func (kvs KVS) Empty() bool { return len(kvs) == 0 } // Clone - returns a copy of the KVS func (kvs KVS) Clone() KVS { return append(make(KVS, 0, len(kvs)), kvs...) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Mar 02 05:11:03 GMT 2024 - 37.3K bytes - Viewed (0) -
internal/config/batch/batch.go
func LookupConfig(kvs config.KVS) (cfg Config, err error) { if err = config.CheckValidKeys(config.BatchSubSys, kvs, DefaultKVS); err != nil { return cfg, err } cfg.ReplicationWorkersWait = 0 cfg.KeyRotationWorkersWait = 0 cfg.ExpirationWorkersWait = 0 rduration, err := time.ParseDuration(env.Get(EnvReplicationWorkersWait, kvs.GetWithDefault(ReplicationWorkersWait, DefaultKVS)))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Dec 06 09:09:22 GMT 2023 - 4.7K bytes - Viewed (0) -
internal/config/scanner/scanner.go
// has not been changed from its "default" value, if it has been changed honor new settings. if kvs.GetWithDefault(Speed, DefaultKVS) == "default" { if kvs.Get(Delay) != "" && kvs.Get(MaxWait) != "" { if err = lookupDeprecatedScannerConfig(kvs, &cfg); err != nil { return cfg, err } } } switch speed := env.Get(EnvSpeed, kvs.GetWithDefault(Speed, DefaultKVS)); speed { case "fastest":
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 01:10:30 GMT 2024 - 5.5K bytes - Viewed (0) -
internal/s3select/json/preader.go
// order) kvs = mv.Value.(jstream.KVS) } else { // To be AWS S3 compatible Select for JSON needs to // output non-object JSON as single column value // i.e. a map with `_1` as key and value as the // non-object. kvs = jstream.KVS{jstream.KV{Key: "_1", Value: mv.Value}} } all = append(all, kvs) } // We don't need the input any more.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Mar 05 04:57:35 GMT 2023 - 6.4K bytes - Viewed (0) -
internal/logger/legacy.go
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, Value: args.Endpoint.String(), }, config.KV{ Key: AuthToken, Value: args.AuthToken,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Aug 03 09:47:07 GMT 2023 - 2K bytes - Viewed (1)