zeropod

Documentation

Index

• Constants
• func GetNetworkNS(spec *specs.Spec) (string, error)
• func GetPIDNS(spec *specs.Spec) (string, error)
• func GetSpec(bundlePath string) (*specs.Spec, error)
• func ListeningPorts(pid int) ([]uint16, error)
• type Config
  • func NewConfig(ctx context.Context, spec *specs.Spec) (*Config, error)
  • func (cfg Config) IsZeropodContainer() bool
• type Container
  • func New(ctx context.Context, cfg *Config, cr *sync.Mutex, container *runc.Container, ...) (*Container, error)
  • func (c *Container) CancelScaleDown()
  • func (c *Container) ID() string
  • func (c *Container) InitialProcess() process.Process
  • func (c *Container) Process() process.Process
  • func (c *Container) RegisterSetContainer(f func(*runc.Container))
  • func (c *Container) Restore(ctx context.Context) (*runc.Container, process.Process, error)
  • func (c *Container) ScaledDown() bool
  • func (c *Container) ScheduleScaleDown() error
  • func (c *Container) SetScaledDown(scaledDown bool)
  • func (c *Container) Stop(ctx context.Context)
  • func (c *Container) StopActivator(ctx context.Context)

Constants

const (
	NodeLabel                        = "zeropod.ctrox.dev/node"
	PortsAnnotationKey               = "zeropod.ctrox.dev/ports-map"
	ContainerNamesAnnotationKey      = "zeropod.ctrox.dev/container-names"
	ScaleDownDurationAnnotationKey   = "zeropod.ctrox.dev/scaledown-duration"
	DisableCheckpoiningAnnotationKey = "zeropod.ctrox.dev/disable-checkpointing"
	PreDumpAnnotationKey             = "zeropod.ctrox.dev/pre-dump"
	CRIContainerNameAnnotation       = "io.kubernetes.cri.container-name"
	CRIContainerTypeAnnotation       = "io.kubernetes.cri.container-type"
)

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 MetricsSocketPath = "/run/zeropod/s/"

const RuntimeName = "io.containerd.zeropod.v2"

Functions

func GetNetworkNS

func GetNetworkNS(spec *specs.Spec) (string, error)

GetNetworkNS reads the bundle's OCI spec and returns the network NS path of the container.

func GetPIDNS

func GetPIDNS(spec *specs.Spec) (string, error)

GetPIDNS reads the bundle's OCI spec and returns the PID NS path of the container.

func GetSpec

func GetSpec(bundlePath string) (*specs.Spec, error)

func ListeningPorts

func ListeningPorts(pid int) ([]uint16, error)

ListeningPorts finds all ports of the pid that are in listen state of the supplied process. It finds both, ipv4 and ipv6 sockets.

Types

type Config

type Config struct {
	ZeropodContainerNames []string
	Ports                 []uint16
	ScaleDownDuration     time.Duration
	DisableCheckpointing  bool
	PreDump               bool
	ContainerName         string
	ContainerType         string
	PodName               string
	PodNamespace          string
	// contains filtered or unexported fields
}

func NewConfig

func NewConfig(ctx context.Context, spec *specs.Spec) (*Config, error)

NewConfig uses the annotations from the container spec to create a new typed ZeropodConfig config.

func (Config) IsZeropodContainer

func (cfg Config) IsZeropodContainer() bool

type Container

type Container struct {
	*runc.Container
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, cfg *Config, cr *sync.Mutex, container *runc.Container, pt stdio.Platform) (*Container, error)

func (*Container) CancelScaleDown

func (c *Container) CancelScaleDown()

func (*Container) ID

func (c *Container) ID() string

func (*Container) InitialProcess

func (c *Container) InitialProcess() process.Process

func (*Container) Process

func (c *Container) Process() process.Process

func (*Container) RegisterSetContainer

func (c *Container) RegisterSetContainer(f func(*runc.Container))

func (*Container) Restore

func (c *Container) Restore(ctx context.Context) (*runc.Container, process.Process, error)

func (*Container) ScaledDown

func (c *Container) ScaledDown() bool

func (*Container) ScheduleScaleDown

func (c *Container) ScheduleScaleDown() error

func (*Container) SetScaledDown

func (c *Container) SetScaledDown(scaledDown bool)

func (*Container) Stop

func (c *Container) Stop(ctx context.Context)

func (*Container) StopActivator

func (c *Container) StopActivator(ctx context.Context)