manager

Documentation

Overview

Package manager contains most of the implementation of the zeropod-manager node daemon. It takes care of loading eBPF programs, providing metrics and monitors the shims for status updates.

Index

• Constants
• Variables
• func AttachRedirectors(ctx context.Context, log *slog.Logger) error
• func NewPodController(ctx context.Context, mgr manager.Manager, log *slog.Logger) error
• func StartSubscribers(ctx context.Context, sc SubscriberConfig, podHandlers ...PodHandler) error
• type Collector
  • func NewCollector() *Collector
  • func (c *Collector) Collect(ch chan<- prometheus.Metric)
  • func (c *Collector) Describe(ch chan<- *prometheus.Desc)
• type PodHandler
• type PodHandlerWithClient
• type PodLabeller
  • func NewPodLabeller(log *slog.Logger) *PodLabeller
  • func (pl *PodLabeller) Handle(ctx context.Context, status *v1.ContainerStatus, pod *corev1.Pod) error
• type PodScaler
  • func NewPodScaler(log *slog.Logger) *PodScaler
  • func (ps *PodScaler) Handle(ctx context.Context, status *v1.ContainerStatus, pod *corev1.Pod) error
• type Redirector
• type SubscriberConfig

Constants

const (
	LabelPodName      = "pod"
	LabelPodNamespace = "namespace"

	MetricsNamespace         = "zeropod"
	MetricCheckpointDuration = "checkpoint_duration_seconds"
	MetricRestoreDuration    = "restore_duration_seconds"
	MetricLastCheckpointTime = "last_checkpoint_time"
	MetricLastRestoreTime    = "last_restore_time"
	MetricRunning            = "running"
)

const (
	CPUAnnotationKey    = "zeropod.ctrox.dev/cpu-requests"
	MemoryAnnotationKey = "zeropod.ctrox.dev/memory-requests"
)

const (
	StatusLabelKeyPrefix = "status.zeropod.ctrox.dev"
)

Variables

var (
	ScaledDownCPU    = resource.MustParse("1m")
	ScaledDownMemory = resource.MustParse("1Ki")
)

Functions

func AttachRedirectors

func AttachRedirectors(ctx context.Context, log *slog.Logger) error

AttachRedirectors scans the zeropod maps path in the bpf file system for directories named after the pid of the sandbox container. It does an initial iteration over all directories and then starts a goroutine which watches for fsevents. When the associated netns of the sandbox container can be found it attaches the redirector BPF programs to the network interfaces of the sandbox. The directories are expected to be created by the zeropod shim on startup.

func NewPodController

func NewPodController(ctx context.Context, mgr manager.Manager, log *slog.Logger) error

func StartSubscribers

func StartSubscribers(ctx context.Context, sc SubscriberConfig, podHandlers ...PodHandler) error

Types

type Collector

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

func NewCollector

func NewCollector() *Collector

func (*Collector) Collect

func (c *Collector) Collect(ch chan<- prometheus.Metric)

func (*Collector) Describe

func (c *Collector) Describe(ch chan<- *prometheus.Desc)

type PodHandler

type PodHandler interface {
	// Handle a status update with the associated pod. Changes made to
	// the pod object will be applied after all handlers have been called.
	// Pod status updates are ignored and won't be applied.
	Handle(context.Context, *v1.ContainerStatus, *corev1.Pod) error
}

type PodHandlerWithClient

type PodHandlerWithClient interface {
	PodHandler
	InjectClient(v1.ShimClient)
}

type PodLabeller

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

func NewPodLabeller

func NewPodLabeller(log *slog.Logger) *PodLabeller

func (*PodLabeller) Handle

func (pl *PodLabeller) Handle(ctx context.Context, status *v1.ContainerStatus, pod *corev1.Pod) error

type PodScaler

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

func NewPodScaler

func NewPodScaler(log *slog.Logger) *PodScaler

func (*PodScaler) Handle

func (ps *PodScaler) Handle(ctx context.Context, status *v1.ContainerStatus, pod *corev1.Pod) error

type Redirector

type Redirector struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type SubscriberConfig

type SubscriberConfig struct {
	Log       *slog.Logger
	Kube      client.Client
	Collector *Collector
}