type deviceAllocateInfo … type resourceAllocateInfo … type containerDevices … type podDevices … // NewPodDevices is a function that returns object of podDevices type with its own guard // RWMutex and a map where key is a pod UID and value contains // container devices information of type containerDevices. func newPodDevices() *podDevices { … } func (pdev *podDevices) pods() sets.Set[string] { … } func (pdev *podDevices) size() int { … } func (pdev *podDevices) hasPod(podUID string) bool { … } func (pdev *podDevices) insert(podUID, contName, resource string, devices checkpoint.DevicesPerNUMA, resp *pluginapi.ContainerAllocateResponse) { … } func (pdev *podDevices) delete(pods []string) { … } // Returns list of device Ids allocated to the given pod for the given resource. // Returns nil if we don't have cached state for the given <podUID, resource>. func (pdev *podDevices) podDevices(podUID, resource string) sets.Set[string] { … } // Returns list of device Ids allocated to the given container for the given resource. // Returns nil if we don't have cached state for the given <podUID, contName, resource>. func (pdev *podDevices) containerDevices(podUID, contName, resource string) sets.Set[string] { … } // Populates allocatedResources with the device resources allocated to the specified <podUID, contName>. func (pdev *podDevices) addContainerAllocatedResources(podUID, contName string, allocatedResources map[string]sets.Set[string]) { … } // Removes the device resources allocated to the specified <podUID, contName> from allocatedResources. func (pdev *podDevices) removeContainerAllocatedResources(podUID, contName string, allocatedResources map[string]sets.Set[string]) { … } // Returns all devices allocated to the pods being tracked, keyed by resourceName. func (pdev *podDevices) devices() map[string]sets.Set[string] { … } // Returns podUID and containerName for a device func (pdev *podDevices) getPodAndContainerForDevice(deviceID string) (string, string) { … } // Turns podDevices to checkpointData. func (pdev *podDevices) toCheckpointData() []checkpoint.PodDevicesEntry { … } // Populates podDevices from the passed in checkpointData. func (pdev *podDevices) fromCheckpointData(data []checkpoint.PodDevicesEntry) { … } // Returns combined container runtime settings to consume the container's allocated devices. func (pdev *podDevices) deviceRunContainerOptions(podUID, contName string) *DeviceRunContainerOptions { … } // getCDIDeviceInfo returns CDI devices from an allocate response func getCDIDeviceInfo(resp *pluginapi.ContainerAllocateResponse, knownCDIDevices sets.Set[string]) []kubecontainer.CDIDevice { … } // getContainerDevices returns the devices assigned to the provided container for all ResourceNames func (pdev *podDevices) getContainerDevices(podUID, contName string) ResourceDeviceInstances { … } type DeviceInstances … type ResourceDeviceInstances … // NewResourceDeviceInstances returns a new ResourceDeviceInstances func NewResourceDeviceInstances() ResourceDeviceInstances { … } // Clone returns a clone of ResourceDeviceInstances func (rdev ResourceDeviceInstances) Clone() ResourceDeviceInstances { … } // Filter takes a condition set expressed as map[string]sets.Set[string] and returns a new // ResourceDeviceInstances with only the devices matching the condition set. func (rdev ResourceDeviceInstances) Filter(cond map[string]sets.Set[string]) ResourceDeviceInstances { … }
Codebase Browser
kubernetes