- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 138 for ekvs (0.25 sec)
-
internal/config/notify/parse.go
}, } ) // GetNotifyES - returns a map of registered notification 'elasticsearch' targets func GetNotifyES(esKVS map[string]config.KVS, transport *http.Transport) (map[string]target.ElasticsearchArgs, error) { esTargets := make(map[string]target.ElasticsearchArgs) for k, kv := range config.Merge(esKVS, target.EnvElasticEnable, DefaultESKVS) { enableEnv := target.EnvElasticEnable if k != config.Default {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 46.4K bytes - Viewed (0) -
cmd/kubeadm/app/util/env.go
} envs = append(envs, envVar) } } return envs } // MergeKubeadmEnvVars merges values of environment variable slices. // The values defined in later slices overwrite values in previous ones. func MergeKubeadmEnvVars(envList ...[]kubeadmapi.EnvVar) []v1.EnvVar { m := make(map[string]v1.EnvVar) merged := []v1.EnvVar{} for _, envs := range envList { for _, env := range envs {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Sep 12 09:09:19 UTC 2023 - 1.7K bytes - Viewed (0) -
cmd/config.go
} srvCfg, err := readConfigWithoutMigrate(GlobalContext, objAPI) if err != nil { return err } bootstrapTraceMsg("lookup the configuration") // Override any values from ENVs. lookupConfigs(srvCfg, objAPI) // hold the mutex lock before a new config is assigned. globalServerConfigMu.Lock() globalServerConfig = srvCfg globalServerConfigMu.Unlock() return nil
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Wed Aug 23 10:07:06 UTC 2023 - 6K bytes - Viewed (0) -
internal/config/identity/plugin/config.go
shutdownCtx context.Context serviceMetrics *metrics } // Enabled returns if AuthNPlugin is enabled. func Enabled(kvs config.KVS) bool { return kvs.Get(URL) != "" } // LookupConfig lookup AuthNPlugin from config, override with any ENVs. func LookupConfig(kv config.KVS, transport *http.Transport, closeRespFn func(io.ReadCloser), serverRegion string) (Args, error) { args := Args{}
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 13.3K bytes - Viewed (0) -
ci/official/any.sh
# # 3. DO THE SAME WITH A LOCAL CACHE OR RBE: # export TF_ANY_EXTRA_ENV=ci/official/envs/public_cache,ci/official/envs/disk_cache # ... # ./any.sh # or # export TF_ANY_EXTRA_ENV=ci/official/envs/local_rbe # ./any.sh # ... set -euxo pipefail cd "$(dirname "$0")/../../" # tensorflow/ # Any request that includes "nightly_upload" should just use the
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Feb 01 03:21:19 UTC 2024 - 2.1K bytes - Viewed (0) -
cmd/config-current.go
} for k, v := range notify.DefaultNotificationKVS { kvs[k] = v } for k, v := range lambda.DefaultLambdaKVS { kvs[k] = v } 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{
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu May 30 08:14:58 UTC 2024 - 30.8K 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":
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.5K bytes - Viewed (0) -
src/runtime/security_unix.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 15:41:45 UTC 2024 - 866 bytes - Viewed (0) -
src/internal/trace/internal/oldtrace/parser_test.go
} } } func TestBuckets(t *testing.T) { var evs Events const N = eventsBucketSize*3 + 123 for i := 0; i < N; i++ { evs.append(Event{Ts: Timestamp(i)}) } if n := len(evs.buckets); n != 4 { t.Fatalf("got %d buckets, want %d", n, 4) } if n := evs.Len(); n != N { t.Fatalf("got %d events, want %d", n, N) } var n int evs.All()(func(ev *Event) bool { n++ return true })
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 3.4K 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 }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.8K bytes - Viewed (0)