- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 762 for Cfg (0.02 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
cmd/kubeadm/app/images/images_test.go
var tests = []struct { expected string cfg *kubeadmapi.ClusterConfiguration }{ { cfg: &kubeadmapi.ClusterConfiguration{ ImageRepository: "real.repo", KubernetesVersion: testversion, Etcd: kubeadmapi.Etcd{ Local: &kubeadmapi.LocalEtcd{}, }, }, expected: "real.repo/etcd:" + testEtcdVer.String(), }, { cfg: &kubeadmapi.ClusterConfiguration{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 06:33:37 UTC 2023 - 8.9K bytes - Viewed (0) -
pkg/test/framework/components/echo/kube/instance.go
ctx: ctx, cluster: cfg.Cluster, } // Deploy echo to the cluster c.deployment, err = newDeployment(ctx, cfg) if err != nil { return nil, err } // Create the manager for echo workloads for this instance. c.workloadMgr, err = newWorkloadManager(ctx, cfg, c.deployment) if err != nil { return nil, err } // Now that we have the successfully created the workload manager, track this resource so
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 16 18:55:23 UTC 2023 - 9K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/init/certs_test.go
type testCertsData struct { testInitData cfg *kubeadmapi.InitConfiguration } func (t *testCertsData) Cfg() *kubeadmapi.InitConfiguration { return t.cfg } func (t *testCertsData) ExternalCA() bool { return false } func (t *testCertsData) CertificateDir() string { return t.cfg.CertificatesDir } func (t *testCertsData) CertificateWriteDir() string { return t.cfg.CertificatesDir }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 17 14:40:46 UTC 2021 - 2.1K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
pods kclient.Client[*corev1.Pod] queue controllers.Queue cfg config.RepairConfig events kclient.EventRecorder repairedPods map[types.NamespacedName]types.UID } func NewRepairController(client kube.Client, cfg config.RepairConfig) (*Controller, error) { c := &Controller{ cfg: cfg, client: client, events: kclient.NewEventRecorder(client, "cni-repair"),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0)