manager

Documentation

Index

• Constants
• Variables
• func AttachRedirectors(ctx context.Context) error
• func Handler(w http.ResponseWriter, req *http.Request)
• func StartSubscribers(ctx context.Context, handlers ...StatusHandler) error
• type PodScaler
  • func NewPodScaler() (*PodScaler, error)
  • func (ps *PodScaler) Handle(ctx context.Context, status *v1.ContainerStatus) error
• type Redirector
• type StatusHandler

Constants

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

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, handlers ...StatusHandler) error

Types

type PodScaler

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

func NewPodScaler

func NewPodScaler() (*PodScaler, error)

func (*PodScaler) Handle

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

type Redirector

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

type StatusHandler

type StatusHandler interface {
	Handle(context.Context, *v1.ContainerStatus) error
}