Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 161 for podutil (0.11 sec)

  1. pkg/kubelet/kubelet_node_status.go

    	cloudproviderapi "k8s.io/cloud-provider/api"
    	nodeutil "k8s.io/component-helpers/node/util"
    	"k8s.io/klog/v2"
    	kubeletapis "k8s.io/kubelet/pkg/apis"
    	v1helper "k8s.io/kubernetes/pkg/apis/core/v1/helper"
    	"k8s.io/kubernetes/pkg/kubelet/events"
    	"k8s.io/kubernetes/pkg/kubelet/nodestatus"
    	taintutil "k8s.io/kubernetes/pkg/util/taints"
    	volutil "k8s.io/kubernetes/pkg/volume/util"
    )
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 31.1K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/phases/certs/certlist.go

    	certDir := kubeadmConfig.CertificatesDir
    	name := cert.BaseName
    	if pkiutil.CSROrKeyExist(certDir, name) {
    		return errors.Errorf("%s: key or CSR %s/%s", errExist, certDir, name)
    	}
    	cfg, err := cert.GetConfig(kubeadmConfig)
    	if err != nil {
    		return err
    	}
    	csr, key, err := pkiutil.NewCSRAndKey(cfg)
    	if err != nil {
    		return err
    	}
    	err = pkiutil.WriteKey(certDir, name, key)
    	if err != nil {
    		return err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 16:01:49 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/phases/certs/certs.go

    	key, err := pkiutil.NewPrivateKey(keyType)
    	if err != nil {
    		return err
    	}
    
    	// Write .key and .pub files to disk
    	fmt.Printf("[certs] Generating %q key and public key\n", kubeadmconstants.ServiceAccountKeyBaseName)
    
    	if err := pkiutil.WriteKey(certsDir, kubeadmconstants.ServiceAccountKeyBaseName, key); err != nil {
    		return err
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Dec 05 10:17:14 UTC 2023
    - 19.4K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/cmd/upgrade/apply.go

    	allowRCUpgrades, ok := cmdutil.ValueFromFlagsOrConfig(flagSet, options.AllowRCUpgrades, upgradeCfg.Apply.AllowRCUpgrades, &flags.allowRCUpgrades).(*bool)
    	if ok {
    		flags.allowRCUpgrades = *allowRCUpgrades
    	} else {
    		return cmdutil.TypeMismatchErr("allowRCUpgrades", "bool")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 03:55:23 UTC 2024
    - 11.6K bytes
    - Viewed (0)
  5. cmd/kubeadm/app/cmd/token.go

    			}
    
    			if err := bto.ApplyTo(cfg); err != nil {
    				return err
    			}
    
    			klog.V(1).Infoln("[token] getting Clientsets from kubeconfig file")
    			kubeConfigFile = cmdutil.GetKubeConfigPath(kubeConfigFile)
    			client, err := cmdutil.GetClientSet(kubeConfigFile, dryRun)
    			if err != nil {
    				return err
    			}
    
    			return RunCreateToken(out, client, cfgPath, cfg, printJoinCommand, certificateKey, kubeConfigFile)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 23 05:47:48 UTC 2024
    - 15.9K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/phases/certs/renewal/manager_test.go

    	certtestutil "k8s.io/kubernetes/cmd/kubeadm/app/util/certs"
    	"k8s.io/kubernetes/cmd/kubeadm/app/util/pkiutil"
    	testutil "k8s.io/kubernetes/cmd/kubeadm/test"
    )
    
    var (
    	testCACertCfg = &pkiutil.CertConfig{
    		Config: certutil.Config{CommonName: "kubernetes"},
    	}
    
    	testCACert, testCAKey, _ = pkiutil.NewCertificateAuthority(testCACertCfg)
    
    	testCertOrganization = []string{"sig-cluster-lifecycle"}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 16:01:49 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  7. cmd/kubeadm/app/cmd/reset.go

    		cfg:                   initCfg,
    		resetCfg:              resetCfg,
    		dryRun:                cmdutil.ValueFromFlagsOrConfig(cmd.Flags(), options.DryRun, resetCfg.DryRun, opts.externalcfg.DryRun).(bool),
    		forceReset:            cmdutil.ValueFromFlagsOrConfig(cmd.Flags(), options.ForceReset, resetCfg.Force, opts.externalcfg.Force).(bool),
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Oct 17 12:26:58 UTC 2023
    - 11.4K bytes
    - Viewed (0)
  8. cmd/kubeadm/app/cmd/upgrade/common.go

    	ok := false
    	if upgradeApply {
    		printConfigCfg = upgradeCfg.Apply.PrintConfig
    		ignoreErrCfg = upgradeCfg.Apply.IgnorePreflightErrors
    		isDryRun, ok = cmdutil.ValueFromFlagsOrConfig(flagSet, options.DryRun, upgradeCfg.Apply.DryRun, &dryRun).(*bool)
    		if !ok {
    			return nil, nil, nil, nil, cmdutil.TypeMismatchErr("dryRun", "bool")
    		}
    	}
    
    	client, err := getClient(flags.kubeConfigPath, *isDryRun)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 16 08:34:39 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  9. cmd/kubeadm/app/cmd/upgrade/plan.go

    	// flags are respected while keeping the configuration file not changed.
    	allowRCUpgrades, ok := cmdutil.ValueFromFlagsOrConfig(flagSet, options.AllowRCUpgrades, upgradeCfg.Plan.AllowRCUpgrades, &flags.allowRCUpgrades).(*bool)
    	if !ok {
    		return cmdutil.TypeMismatchErr("allowRCUpgrades", "bool")
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Mar 03 03:03:29 UTC 2024
    - 14.9K bytes
    - Viewed (0)
  10. cmd/kubeadm/app/phases/certs/renewal/manager.go

    			return err
    		}
    	}
    	cfg := &pkiutil.CertConfig{
    		Config:              certConfig,
    		EncryptionAlgorithm: rm.cfg.EncryptionAlgorithmType(),
    	}
    
    	// generates the CSR request and save it
    	csr, key, err := pkiutil.NewCSRAndKey(cfg)
    	if err != nil {
    		return errors.Wrapf(err, "failure while generating %s CSR and key", name)
    	}
    	if err := pkiutil.WriteKey(outdir, name, key); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 01 16:01:49 UTC 2024
    - 15K bytes
    - Viewed (0)
Back to top