- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 330 for Cfg (1.6 sec)
-
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) -
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) -
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) -
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) -
tools/istio-iptables/pkg/capture/run_test.go
cfg.ProxyGID = "1,2" cfg.ProxyUID = "3,4" cfg.DNSServersV4 = []string{"127.0.0.53"} }, }, { "tproxy", func(cfg *config.Config) { cfg.InboundInterceptionMode = constants.TPROXY cfg.InboundPortsInclude = "*" cfg.OutboundIPRangesExclude = "1.1.0.0/16" cfg.OutboundIPRangesInclude = "9.9.0.0/16" cfg.DryRun = true cfg.RedirectDNS = true cfg.DNSServersV4 = []string{"127.0.0.53"}
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 22:24:38 UTC 2024 - 8.1K 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) -
test/fixedbugs/issue59709.dir/bresource.go
name string initializer Initializer[T] cfg ResConfig value T } func Should[T any](r *Resource[T], e error) bool { return r.cfg.ShouldRetry(e) } type ResConfig struct { ShouldRetry func(error) bool TearDown func() } type Initializer[T any] func(*int) (T, error) func New[T any](name string, f Initializer[T], cfg ResConfig) *Resource[T] {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 05 21:04:28 UTC 2023 - 643 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)