podexecutor

package

v1.26.3-rke2r1-build20... Latest Latest Go to latest Published: Mar 17, 2023 License: Apache-2.0 Imports: 27 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rancher/rke2

Documentation ¶

Rendered for

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

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.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL