kubelet

package
v0.11.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 22, 2026 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package kubelet provides the Kubernetes kubelet agent.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Kubelet

type Kubelet struct {
	// contains filtered or unexported fields
}

func NewKubelet

func NewKubelet(nodeName string, s store.Store, logger *slog.Logger) *Kubelet

NewKubelet returns a Kubelet without a CRI connection. It preserves the historical fake reconciliation behaviour and is kept for backward compatibility; new callers should prefer NewKubeletWithCRI.

func NewKubeletWithCRI added in v0.11.0

func NewKubeletWithCRI(ctx context.Context, nodeName string, s store.Store, logger *slog.Logger, criSocket string) (*Kubelet, error)

NewKubeletWithCRI returns a Kubelet that drives a real CRI runtime over the given Unix socket. It dials the runtime, builds the RuntimeService/ImageService clients and stores them on the struct so reconcilePod can issue real RunPodSandbox/CreateContainer/StartContainer calls instead of faking pod status.

func (*Kubelet) Close added in v0.11.0

func (k *Kubelet) Close() error

Close releases the gRPC connection to the CRI runtime, if any. It is safe to call on a Kubelet created via NewKubelet (no CRI).

func (*Kubelet) Run

func (k *Kubelet) Run(ctx context.Context) error

func (*Kubelet) RunningPods

func (k *Kubelet) RunningPods() []*k8s.Pod

Jump to

Keyboard shortcuts

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