- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 421 for Cfg (1.16 sec)
-
pkg/scheduler/profile/profile.go
m := make(Map) v := cfgValidator{m: m} for _, cfg := range cfgs { p, err := newProfile(ctx, cfg, r, recorderFact, opts...) if err != nil { return nil, fmt.Errorf("creating profile for scheduler name %s: %v", cfg.SchedulerName, err) } if err := v.validate(cfg, p); err != nil { return nil, err } m[cfg.SchedulerName] = p } return m, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 06 01:11:19 UTC 2024 - 4K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFileHandleImpl.java
this.cfg = cfg; this.fileId = fid; this.initialSize = initialSize; this.fid = 0; this.unc = unc; this.flags = flags; this.access = access; this.attrs = attrs; this.options = options; this.tree = tree.acquire(); this.tree_num = tree.getTreeId(); if ( cfg.isTraceResourceUsage() ) {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 8.6K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/phases/util.go
// unless it's already set to a value different from the default. func SetKubernetesVersion(cfg *kubeadmapiv1.ClusterConfiguration) { if cfg.KubernetesVersion != kubeadmapiv1.DefaultKubernetesVersion && cfg.KubernetesVersion != "" { return } cfg.KubernetesVersion = version.Get().String()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 14:17:32 UTC 2023 - 1.1K bytes - Viewed (0) -
cni/pkg/iptables/iptables_unspecified.go
import ( "errors" ) func AddInpodMarkIPRule(cfg *Config) error { return errors.New("not implemented on this platform") } func DelInpodMarkIPRule(cfg *Config) error { return errors.New("not implemented on this platform") } func AddLoopbackRoutes(cfg *Config) error { return errors.New("not implemented on this platform") } func DelLoopbackRoutes(cfg *Config) error {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jan 26 20:34:28 UTC 2024 - 1K bytes - Viewed (0) -
cluster/images/etcd/migrate/migrate_client.go
} return e.runEtcdctlCommand(version, "snapshot", "restore", snapshotFile, "--data-dir", e.cfg.dataDirectory, "--name", e.cfg.name, "--initial-advertise-peer-urls", e.cfg.peerAdvertiseUrls, "--initial-cluster", e.cfg.initialCluster, ) } // Migrate upgrades a 'etcd2' storage version data directory to a 'etcd3' storage version // data directory.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 15 13:53:06 UTC 2021 - 6.6K bytes - Viewed (0) -
cmd/kubeadm/app/componentconfigs/kubelet_unix_test.go
tests := []struct { name string cfg *kubeletconfig.KubeletConfiguration isServiceActiveFunc func(string) (bool, error) expected *kubeletconfig.KubeletConfiguration }{ { name: "the resolver config should not be mutated when it was set already even if systemd-resolved is active", cfg: &kubeletconfig.KubeletConfiguration{ ResolverConfig: ptr.To(fooResolverConfig),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 25 10:26:46 UTC 2024 - 2.5K bytes - Viewed (0) -
tools/istio-clean-iptables/pkg/cmd/cleanup.go
// Remove the old DNS UDP rules if cfg.RedirectDNS { ownerGroupsFilter := types.ParseInterceptFilter(cfg.OwnerGroupsInclude, cfg.OwnerGroupsExclude) common.HandleDNSUDP(common.DeleteOps, builder.NewIptablesRuleBuilder(nil), ext, iptV, ipt6V, cfg.ProxyUID, cfg.ProxyGID, cfg.DNSServersV4, cfg.DNSServersV6, cfg.CaptureAllDNS, ownerGroupsFilter) } } func (c *IptablesCleaner) Run() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 15:51:15 UTC 2024 - 5.1K bytes - Viewed (0) -
internal/config/compress/compress.go
if kvs.Empty() { return cfg, nil } return cfg, err } if !cfg.Enabled { return cfg, nil } allowEnc := env.Get(EnvCompressAllowEncryption, kvs.Get(AllowEncrypted)) if allowEnc == "" { allowEnc = env.Get(EnvCompressAllowEncryptionLegacy, "") } cfg.AllowEncrypted, err = config.ParseBool(allowEnc) 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 - 5K bytes - Viewed (0) -
pkg/istio-agent/health/health_check.go
lastStateUnhealthy ) func fillInDefaults(cfg *v1alpha3.ReadinessProbe, ipAddresses []string) *v1alpha3.ReadinessProbe { cfg = cfg.DeepCopy() // Thresholds have a minimum of 1 cfg.FailureThreshold = orDefault(cfg.FailureThreshold, 1) cfg.SuccessThreshold = orDefault(cfg.SuccessThreshold, 1) // InitialDelaySeconds allows zero, no default needed cfg.TimeoutSeconds = orDefault(cfg.TimeoutSeconds, 1)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jul 21 03:06:44 UTC 2021 - 5.7K bytes - Viewed (0) -
cmd/kubeadm/app/apis/kubeadm/types_test.go
) func TestClusterConfigurationEncryptionAlgorithmType(t *testing.T) { tests := []struct { name string cfg *ClusterConfiguration expectedResult EncryptionAlgorithmType }{ { name: "feature gate is set to true, return ECDSA-P256", cfg: &ClusterConfiguration{ FeatureGates: map[string]bool{ features.PublicKeysECDSA: true, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 09:39:24 UTC 2024 - 1.9K bytes - Viewed (0)