Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 82 for joinData (0.17 sec)

  1. cmd/kubeadm/app/cmd/join.go

    }
    
    // compile-time assert that the local data object satisfies the phases data interface.
    var _ phases.JoinData = &joinData{}
    
    // joinData defines all the runtime information used when running the kubeadm join workflow;
    // this data is shared across all the phases that are included in the workflow.
    type joinData struct {
    	cfg                   *kubeadmapi.JoinConfiguration
    	initCfg               *kubeadmapi.InitConfiguration
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 15:33:38 UTC 2024
    - 25.2K bytes
    - Viewed (0)
  2. cmd/kubeadm/app/cmd/join_test.go

    		// Join data passed using config file
    		{
    			name: "Pass with config from file",
    			flags: map[string]string{
    				options.CfgPath: configFilePath,
    			},
    			validate: func(t *testing.T, data *joinData) {
    				validData := &joinData{
    					cfg: &kubeadmapi.JoinConfiguration{
    						TypeMeta: metav1.TypeMeta{Kind: "", APIVersion: ""},
    						NodeRegistration: kubeadmapi.NodeRegistrationOptions{
    							Name:                  "somename",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 12:26:20 UTC 2024
    - 12.7K bytes
    - Viewed (0)
  3. cmd/kubeadm/app/cmd/phases/join/data.go

    	clientcmdapi "k8s.io/client-go/tools/clientcmd/api"
    
    	kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm"
    )
    
    // JoinData is the interface to use for join phases.
    // The "joinData" type from "cmd/join.go" must satisfy this interface.
    type JoinData interface {
    	CertificateKey() string
    	Cfg() *kubeadmapi.JoinConfiguration
    	TLSBootstrapCfg() (*clientcmdapi.Config, error)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 15:33:38 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  4. cmd/kubeadm/app/cmd/phases/join/data_test.go

    	kubeadmapi "k8s.io/kubernetes/cmd/kubeadm/app/apis/kubeadm"
    )
    
    // a package local type for testing purposes.
    type testJoinData struct{}
    
    // testJoinData must satisfy JoinData.
    var _ JoinData = &testJoinData{}
    
    func (j *testJoinData) CertificateKey() string                          { return "" }
    func (j *testJoinData) Cfg() *kubeadmapi.JoinConfiguration              { return nil }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 26 15:51:39 UTC 2023
    - 2K bytes
    - Viewed (0)
  5. cmd/kubeadm/app/cmd/phases/join/controlplaneprepare.go

    		InheritFlags:  getControlPlanePreparePhaseFlags("control-plane"),
    		ArgsValidator: cobra.NoArgs,
    	}
    }
    
    func runControlPlanePrepareControlPlaneSubphase(c workflow.RunData) error {
    	data, ok := c.(JoinData)
    	if !ok {
    		return errors.New("control-plane-prepare phase invoked with an invalid data struct")
    	}
    
    	// Skip if this is not a control plane
    	if data.Cfg().ControlPlane == nil {
    		return nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 12:46:34 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  6. cmd/kubeadm/app/cmd/phases/join/checketcd.go

    func NewCheckEtcdPhase() workflow.Phase {
    	return workflow.Phase{
    		Name:   "check-etcd",
    		Run:    runCheckEtcdPhase,
    		Hidden: true,
    	}
    }
    
    func runCheckEtcdPhase(c workflow.RunData) error {
    	data, ok := c.(JoinData)
    	if !ok {
    		return errors.New("check-etcd phase invoked with an invalid data struct")
    	}
    
    	// Skip if this is not a control plane
    	if data.Cfg().ControlPlane == nil {
    		return nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 02 11:25:47 UTC 2022
    - 1.9K bytes
    - Viewed (0)
  7. cmd/kubeadm/app/cmd/phases/join/controlplanejoin.go

    		Run:           runMarkControlPlanePhase,
    		InheritFlags:  getControlPlaneJoinPhaseFlags("mark-control-plane"),
    		ArgsValidator: cobra.NoArgs,
    	}
    }
    
    func runEtcdPhase(c workflow.RunData) error {
    	data, ok := c.(JoinData)
    	if !ok {
    		return errors.New("control-plane-join phase invoked with an invalid data struct")
    	}
    
    	if data.Cfg().ControlPlane == nil {
    		return nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 03:09:42 UTC 2024
    - 5.7K bytes
    - Viewed (0)
  8. cmd/kubeadm/app/cmd/phases/join/waitcontrolplane.go

    		Short: "EXPERIMENTAL: Wait for the control plane to start",
    		Run:   runWaitControlPlanePhase,
    	}
    	return phase
    }
    
    func runWaitControlPlanePhase(c workflow.RunData) error {
    	data, ok := c.(JoinData)
    	if !ok {
    		return errors.New("wait-control-plane phase invoked with an invalid data struct")
    	}
    
    	if data.Cfg().ControlPlane == nil {
    		return nil
    	}
    
    	initCfg, err := data.InitCfg()
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 16 15:33:38 UTC 2024
    - 2.8K bytes
    - Viewed (0)
  9. cmd/kubeadm/app/cmd/phases/join/kubelet.go

    			options.Patches,
    			options.DryRun,
    		},
    	}
    }
    
    func getKubeletStartJoinData(c workflow.RunData) (*kubeadmapi.JoinConfiguration, *kubeadmapi.InitConfiguration, *clientcmdapi.Config, error) {
    	data, ok := c.(JoinData)
    	if !ok {
    		return nil, nil, nil, errors.New("kubelet-start phase invoked with an invalid data struct")
    	}
    	cfg := data.Cfg()
    	initCfg, err := data.InitCfg()
    	if err != nil {
    		return nil, nil, nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Jun 01 07:10:31 UTC 2024
    - 10.3K bytes
    - Viewed (0)
  10. cmd/kubeadm/app/cmd/phases/join/preflight.go

    			options.TokenDiscoverySkipCAHash,
    			options.CertificateKey,
    			options.DryRun,
    		},
    	}
    }
    
    // runPreflight executes preflight checks logic.
    func runPreflight(c workflow.RunData) error {
    	j, ok := c.(JoinData)
    	if !ok {
    		return errors.New("preflight phase invoked with an invalid data struct")
    	}
    	fmt.Println("[preflight] Running pre-flight checks")
    
    	// Start with general checks
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 03:55:23 UTC 2024
    - 5.3K bytes
    - Viewed (0)
Back to top