podexecutor

Documentation

Index

• type CloudProviderConfig
• type ControlPlaneEnv
• type ControlPlaneMounts
• type ControlPlaneProbeConfs
• type ControlPlaneResources
• type StaticPodConfig
  • func (s *StaticPodConfig) APIServer(ctx context.Context, etcdReady <-chan struct{}, args []string) error
  • func (s *StaticPodConfig) APIServerHandlers(ctx context.Context) (authenticator.Request, http.Handler, error)
  • func (s *StaticPodConfig) Bootstrap(ctx context.Context, nodeConfig *daemonconfig.Node, cfg cmds.Agent) error
  • func (s *StaticPodConfig) CloudControllerManager(ctx context.Context, ccmRBACReady <-chan struct{}, args []string) error
  • func (s *StaticPodConfig) ControllerManager(ctx context.Context, apiReady <-chan struct{}, args []string) error
  • func (s *StaticPodConfig) CurrentETCDOptions() (opts executor.InitialOptions, err error)
  • func (s *StaticPodConfig) ETCD(ctx context.Context, args executor.ETCDConfig, extraArgs []string) error
  • func (s *StaticPodConfig) KubeProxy(ctx context.Context, args []string) error
  • func (s *StaticPodConfig) Kubelet(ctx context.Context, args []string) error
  • func (s *StaticPodConfig) Scheduler(ctx context.Context, apiReady <-chan struct{}, args []string) error

Types

type CloudProviderConfig

type CloudProviderConfig struct {
	Name string
	Path string
}

type ControlPlaneEnv

type ControlPlaneEnv struct {
	KubeAPIServer          []string
	KubeScheduler          []string
	KubeControllerManager  []string
	KubeProxy              []string
	Etcd                   []string
	CloudControllerManager []string
}

type ControlPlaneMounts

type ControlPlaneMounts struct {
	KubeAPIServer          []string
	KubeScheduler          []string
	KubeControllerManager  []string
	KubeProxy              []string
	Etcd                   []string
	CloudControllerManager []string
}

type ControlPlaneProbeConfs

type ControlPlaneProbeConfs struct {
	KubeAPIServer          staticpod.ProbeConfs
	KubeScheduler          staticpod.ProbeConfs
	KubeControllerManager  staticpod.ProbeConfs
	KubeProxy              staticpod.ProbeConfs
	Etcd                   staticpod.ProbeConfs
	CloudControllerManager staticpod.ProbeConfs
}

type ControlPlaneResources

type ControlPlaneResources struct {
	KubeAPIServerCPURequest             string
	KubeAPIServerCPULimit               string
	KubeAPIServerMemoryRequest          string
	KubeAPIServerMemoryLimit            string
	KubeSchedulerCPURequest             string
	KubeSchedulerCPULimit               string
	KubeSchedulerMemoryRequest          string
	KubeSchedulerMemoryLimit            string
	KubeControllerManagerCPURequest     string
	KubeControllerManagerCPULimit       string
	KubeControllerManagerMemoryRequest  string
	KubeControllerManagerMemoryLimit    string
	KubeProxyCPURequest                 string
	KubeProxyCPULimit                   string
	KubeProxyMemoryRequest              string
	KubeProxyMemoryLimit                string
	EtcdCPURequest                      string
	EtcdCPULimit                        string
	EtcdMemoryRequest                   string
	EtcdMemoryLimit                     string
	CloudControllerManagerCPURequest    string
	CloudControllerManagerCPULimit      string
	CloudControllerManagerMemoryRequest string
	CloudControllerManagerMemoryLimit   string
}

type StaticPodConfig

type StaticPodConfig struct {
	ControlPlaneResources
	ControlPlaneProbeConfs
	ControlPlaneEnv
	ControlPlaneMounts
	ManifestsDir    string
	ImagesDir       string
	Resolver        *images.Resolver
	CloudProvider   *CloudProviderConfig
	DataDir         string
	AuditPolicyFile string
	PSAConfigFile   string
	KubeletPath     string
	KubeProxyChan   chan struct{}
	CISMode         bool
	DisableETCD     bool
	IsServer        bool
}

func (*StaticPodConfig) APIServer

func (s *StaticPodConfig) APIServer(ctx context.Context, etcdReady <-chan struct{}, args []string) error

APIServer sets up the apiserver static pod once etcd is available.

func (*StaticPodConfig) APIServerHandlers

func (s *StaticPodConfig) APIServerHandlers(ctx context.Context) (authenticator.Request, http.Handler, error)

APIServerHandlers returning the authenticator and request handler for requests to the apiserver endpoint.

func (*StaticPodConfig) Bootstrap

func (s *StaticPodConfig) Bootstrap(ctx context.Context, nodeConfig *daemonconfig.Node, cfg cmds.Agent) error

Bootstrap prepares the static executor to run components by setting the system default registry and staging the kubelet and containerd binaries. On servers, it also ensures that manifests are copied in to place and in sync with the system configuration.

func (*StaticPodConfig) CloudControllerManager

func (s *StaticPodConfig) CloudControllerManager(ctx context.Context, ccmRBACReady <-chan struct{}, args []string) error

CloudControllerManager starts the cloud-controller-manager static pod, once the cloud controller manager RBAC (and subsequently, the api server) is available.

func (*StaticPodConfig) ControllerManager

func (s *StaticPodConfig) ControllerManager(ctx context.Context, apiReady <-chan struct{}, args []string) error

ControllerManager starts the kube-controller-manager static pod, once the apiserver is available.

func (*StaticPodConfig) CurrentETCDOptions

func (s *StaticPodConfig) CurrentETCDOptions() (opts executor.InitialOptions, err error)

CurrentETCDOptions retrieves the etcd configuration from the static pod definition at etcd.yaml in the manifests directory, if it exists.

func (*StaticPodConfig) ETCD

func (s *StaticPodConfig) ETCD(ctx context.Context, args executor.ETCDConfig, extraArgs []string) error

ETCD starts the etcd static pod.

func (*StaticPodConfig) KubeProxy

func (s *StaticPodConfig) KubeProxy(ctx context.Context, args []string) error

KubeProxy starts Kube Proxy as a static pod.

func (*StaticPodConfig) Kubelet

func (s *StaticPodConfig) Kubelet(ctx context.Context, args []string) error

Kubelet starts the kubelet in a subprocess with watching goroutine.

func (*StaticPodConfig) Scheduler

func (s *StaticPodConfig) Scheduler(ctx context.Context, apiReady <-chan struct{}, args []string) error

Scheduler starts the kube-scheduler static pod, once the apiserver is available.