- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 762 for Cfg (0.02 sec)
-
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) -
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/echo/kube/workload_manager.go
var grpcInstancePort int var tls *echoCommon.TLSSettings if cfg.IsProxylessGRPC() { grpcInstancePort = grpcMagicPort } if grpcInstancePort == 0 { if grpcPort, found := cfg.Ports.ForProtocol(protocol.GRPC); found { if grpcPort.TLS { tls = cfg.TLSSettings } grpcInstancePort = grpcPort.WorkloadPort } } if grpcInstancePort == 0 { return nil, errors.New("unable to find GRPC command port") }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 6.4K bytes - Viewed (0) -
pilot/pkg/config/memory/store.go
if !exists { ns = map[string]any{} cr.data[kind][cfg.Namespace] = ns } _, exists = ns[cfg.Name] if !exists { tnow := time.Now() if cfg.ResourceVersion == "" { cfg.ResourceVersion = tnow.String() } // Set the creation timestamp, if not provided. if cfg.CreationTimestamp.IsZero() { cfg.CreationTimestamp = tnow } ns[cfg.Name] = cfg
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Dec 26 01:14:27 UTC 2023 - 6.3K 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) -
cluster/images/etcd/migrate/migrate_server.go
fmt.Sprintf("%s/etcd-%s", r.cfg.binPath, version), "--name", r.cfg.name, "--initial-cluster", r.cfg.initialCluster, "--debug", "--data-dir", r.cfg.dataDirectory, "--listen-client-urls", r.cfg.clientListenUrls, "--advertise-client-urls", fmt.Sprintf("http://127.0.0.1:%d", r.cfg.port), "--listen-peer-urls", r.cfg.peerListenUrls, "--initial-advertise-peer-urls", r.cfg.peerAdvertiseUrls, )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 30 16:29:59 UTC 2022 - 3.8K bytes - Viewed (0) -
pilot/pkg/model/status/helper.go
} func DeleteConfigCondition(cfg config.Config, condition string) config.Config { c, ok := cfg.Status.(*v1alpha1.IstioStatus) if !ok { return cfg } if GetCondition(c.Conditions, condition) == nil { return cfg } cfg = cfg.DeepCopy() status := cfg.Status.(*v1alpha1.IstioStatus) status.Conditions = deleteCondition(status.Conditions, condition) return cfg }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jun 21 15:06:10 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/apis/flowcontrol/v1beta1/defaults.go
} // SetDefaults_FlowSchema sets default values for flow schema func SetDefaults_QueuingConfiguration(cfg *v1beta1.QueuingConfiguration) { if cfg.HandSize == 0 { cfg.HandSize = PriorityLevelConfigurationDefaultHandSize } if cfg.Queues == 0 { cfg.Queues = PriorityLevelConfigurationDefaultQueues } if cfg.QueueLengthLimit == 0 { cfg.QueueLengthLimit = PriorityLevelConfigurationDefaultQueueLengthLimit }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 00:47:58 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/config/analysis/local/context.go
} for id, store := range i.stores { cfg := store.Get(colschema.GroupVersionKind(), name.Name.String(), name.Namespace.String()) if cfg == nil { continue } result, err := cfgToInstance(*cfg, col, colschema, id) if err != nil { log.Errorf("failed converting found config %s %s/%s to instance: %s, ", cfg.Meta.GroupVersionKind.Kind, cfg.Meta.Namespace, cfg.Meta.Namespace, err) return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 6.3K bytes - Viewed (0) -
pkg/test/framework/components/echo/util/traffic/generator.go
} // Can never happen, but the compiler doesn't know that Fatal terminates return Result{} } func fillInDefaults(cfg *Config) { if cfg.Interval == 0 { cfg.Interval = defaultInterval } if cfg.StopTimeout == 0 { cfg.StopTimeout = defaultTimeout } if cfg.Options.Check == nil { cfg.Options.Check = check.OK() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 12 22:50:35 UTC 2022 - 3.1K bytes - Viewed (0)