- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 207 for Cfg (1.84 sec)
-
internal/config/ilm/ilm.go
func LookupConfig(kvs config.KVS) (cfg Config, err error) { cfg = Config{ TransitionWorkers: 100, ExpirationWorkers: 100, } if err = config.CheckValidKeys(config.ILMSubSys, kvs, DefaultKVS); err != nil { return cfg, err } tw, err := strconv.Atoi(env.Get(EnvILMTransitionWorkers, kvs.GetWithDefault(transitionWorkers, DefaultKVS))) if err != nil { return cfg, err }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 1.9K bytes - Viewed (0) -
pkg/test/framework/components/cluster/kube/factory.go
cfg, err := validConfig(origCfg) if err != nil { return nil, err } kubeconfigPath := cfg.Meta.String(kubeconfigMetaKey) kubeconfigPath, err = file.NormalizePath(kubeconfigPath) if err != nil { return nil, err } var client istioKube.CLIClient if len(cfg.HTTPProxy) > 0 { proxyURL, err := url.Parse(cfg.HTTPProxy) if err != nil { return nil, err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 2.7K bytes - Viewed (0) -
cmd/admin-handlers-config-kv.go
return } cfg, err := readServerConfig(ctx, objectAPI, nil) if err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } if err = cfg.DelFrom(bytes.NewReader(kvBytes)); err != nil { writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, err), r.URL) return } if err = validateConfig(ctx, cfg, subSys); err != nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.7K bytes - Viewed (0) -
cni/pkg/iptables/iptables_test.go
tt := struct { name string config func(cfg *Config) }{ "default", func(cfg *Config) { cfg.RedirectDNS = true }, } probeSNATipv4 := netip.MustParseAddr("169.254.7.127") probeSNATipv6 := netip.MustParseAddr("e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164") cfg := constructTestConfig() tt.config(cfg) ext := &dep.DependenciesStub{}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 20:16:04 UTC 2024 - 3.7K 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 Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 15.8K bytes - Viewed (0) -
pkg/test/framework/components/environment/kube/kube.go
return clusters, errs } func buildCluster(cfg cluster.Config, allClusters cluster.Map) (cluster.Cluster, error) { cfg, err := validConfig(cfg) if err != nil { return nil, err } return kube.BuildKube(cfg, cluster.NewTopology(cfg, allClusters)) } func validConfig(cfg cluster.Config) (cluster.Config, error) { if cfg.Name == "" { return cfg, fmt.Errorf("empty cluster name") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 5.1K bytes - Viewed (0) -
src/cmd/go/internal/telemetrystats/telemetrystats.go
} telemetry.Inc("go/platform/target/goos:" + cfg.Goos) telemetry.Inc("go/platform/target/goarch:" + cfg.Goarch) switch cfg.Goarch { case "386": telemetry.Inc("go/platform/target/go386:" + cfg.GO386) case "amd64": telemetry.Inc("go/platform/target/goamd64:" + cfg.GOAMD64) case "arm": telemetry.Inc("go/platform/target/goarm:" + cfg.GOARM) case "arm64":
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 21:09:11 UTC 2024 - 1.4K bytes - Viewed (0) -
internal/config/subnet/config.go
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) if err != nil { return cfg, err } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 3.8K bytes - Viewed (0) -
pkg/test/framework/components/echo/deployment/builder.go
func (b *builder) With(i *echo.Instance, cfg echo.Config) Builder { if b.ctx.Settings().SkipWorkloadClassesAsSet().Contains(cfg.WorkloadClass()) { return b } cfg = cfg.DeepCopy() if err := cfg.FillDefaults(b.ctx); err != nil { b.errs = multierror.Append(b.errs, err) return b } shouldSkip := b.ctx.Settings().Skip(cfg.WorkloadClass()) if shouldSkip { return b }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 12K 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: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 17 21:52:29 UTC 2024 - 4.8K bytes - Viewed (0)