package checkpoint

import "k8s.io/kubernetes/pkg/kubelet/cm/devicemanager/checkpoint"

Index ¶

• type Data
• func (cp *Data) GetData() ([]PodDevicesEntry, map[string][]string)
• func (cp *Data) MarshalCheckpoint() ([]byte, error)
• func (cp *Data) UnmarshalCheckpoint(blob []byte) error
• func (cp *Data) VerifyChecksum() error
• type DeviceManagerCheckpoint
• func New(devEntries []PodDevicesEntry, devices map[string][]string) DeviceManagerCheckpoint
• type DevicesPerNUMA
• func NewDevicesPerNUMA() DevicesPerNUMA
• func (dev DevicesPerNUMA) Devices() sets.Set[string]
• type PodDevicesEntry

Types ¶

type Data ¶

type Data struct {
	Data     checkpointData
	Checksum checksum.Checksum
}

Data holds checkpoint data and its checksum

func (*Data) GetData ¶

func (cp *Data) GetData() ([]PodDevicesEntry, map[string][]string)

GetData returns device entries and registered devices in the *most recent* checkpoint format, *not* in the original format stored on disk.

func (*Data) MarshalCheckpoint ¶

func (cp *Data) MarshalCheckpoint() ([]byte, error)

MarshalCheckpoint returns marshalled data

func (*Data) UnmarshalCheckpoint ¶

func (cp *Data) UnmarshalCheckpoint(blob []byte) error

UnmarshalCheckpoint returns unmarshalled data

func (*Data) VerifyChecksum ¶

func (cp *Data) VerifyChecksum() error

VerifyChecksum verifies that passed checksum is same as calculated checksum

type DeviceManagerCheckpoint ¶

type DeviceManagerCheckpoint interface {
	checkpointmanager.Checkpoint
	GetData() ([]PodDevicesEntry, map[string][]string)
}

DeviceManagerCheckpoint defines the operations to retrieve pod devices

func New ¶

func New(devEntries []PodDevicesEntry, devices map[string][]string) DeviceManagerCheckpoint

New returns an instance of Checkpoint - must be an alias for the most recent version

type DevicesPerNUMA ¶

type DevicesPerNUMA map[int64][]string

DevicesPerNUMA represents device ids obtained from device plugin per NUMA node id

func NewDevicesPerNUMA ¶

func NewDevicesPerNUMA() DevicesPerNUMA

NewDevicesPerNUMA is a function that creates DevicesPerNUMA map

func (DevicesPerNUMA) Devices ¶

func (dev DevicesPerNUMA) Devices() sets.Set[string]

Devices is a function that returns all device ids for all NUMA nodes and represent it as sets.Set[string]

type PodDevicesEntry ¶

type PodDevicesEntry struct {
	PodUID        string
	ContainerName string
	ResourceName  string
	DeviceIDs     DevicesPerNUMA
	AllocResp     []byte
}

PodDevicesEntry connects pod information to devices

Source Files ¶

checkpoint.go