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) error
• func Handler(w http.ResponseWriter, req *http.Request)
• func StartSubscribers(ctx context.Context, podHandlers ...PodHandler) error
• type PodHandler
• type PodLabeller
  • func NewPodLabeller() *PodLabeller
  • func (pl *PodLabeller) Handle(ctx context.Context, status *v1.ContainerStatus, pod *corev1.Pod) error
• type PodScaler
  • func NewPodScaler() *PodScaler
  • func (ps *PodScaler) Handle(ctx context.Context, status *v1.ContainerStatus, pod *corev1.Pod) error
• type Redirector

Constants

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) 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 Handler

func Handler(w http.ResponseWriter, req *http.Request)

func StartSubscribers

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

Types

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 PodLabeller

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

func NewPodLabeller

func NewPodLabeller() *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() *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
}