const memoryManagerStateFileName … type ActivePodsFunc … type runtimeService … type sourcesReadyStub … func (s *sourcesReadyStub) AddSource(source string) { … } func (s *sourcesReadyStub) AllReady() bool { … } type Manager … type manager … var _ … // NewManager returns new instance of the memory manager func NewManager(policyName string, machineInfo *cadvisorapi.MachineInfo, nodeAllocatableReservation v1.ResourceList, reservedMemory []kubeletconfig.MemoryReservation, stateFileDirectory string, affinity topologymanager.Store) (Manager, error) { … } // Start starts the memory manager under the kubelet and calls policy start func (m *manager) Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady, podStatusProvider status.PodStatusProvider, containerRuntime runtimeService, initialContainers containermap.ContainerMap) error { … } // AddContainer saves the value of requested memory for the guaranteed pod under the state and set memory affinity according to the topolgy manager func (m *manager) AddContainer(pod *v1.Pod, container *v1.Container, containerID string) { … } // GetMemoryNUMANodes provides NUMA nodes that used to allocate the container memory func (m *manager) GetMemoryNUMANodes(pod *v1.Pod, container *v1.Container) sets.Set[int] { … } // Allocate is called to pre-allocate memory resources during Pod admission. func (m *manager) Allocate(pod *v1.Pod, container *v1.Container) error { … } // RemoveContainer removes the container from the state func (m *manager) RemoveContainer(containerID string) error { … } // State returns the state of the manager func (m *manager) State() state.Reader { … } // GetPodTopologyHints returns the topology hints for the topology manager func (m *manager) GetPodTopologyHints(pod *v1.Pod) map[string][]topologymanager.TopologyHint { … } // GetTopologyHints returns the topology hints for the topology manager func (m *manager) GetTopologyHints(pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint { … } // TODO: move the method to the upper level, to re-use it under the CPU and memory managers func (m *manager) removeStaleState() { … } func (m *manager) policyRemoveContainerByRef(podUID string, containerName string) { … } func getTotalMemoryTypeReserved(machineInfo *cadvisorapi.MachineInfo, reservedMemory []kubeletconfig.MemoryReservation) (map[v1.ResourceName]resource.Quantity, error) { … } func validateReservedMemory(machineInfo *cadvisorapi.MachineInfo, nodeAllocatableReservation v1.ResourceList, reservedMemory []kubeletconfig.MemoryReservation) error { … } func convertReserved(machineInfo *cadvisorapi.MachineInfo, reservedMemory []kubeletconfig.MemoryReservation) (systemReservedMemory, error) { … } func getSystemReservedMemory(machineInfo *cadvisorapi.MachineInfo, nodeAllocatableReservation v1.ResourceList, reservedMemory []kubeletconfig.MemoryReservation) (systemReservedMemory, error) { … } // GetAllocatableMemory returns the amount of allocatable memory for each NUMA node func (m *manager) GetAllocatableMemory() []state.Block { … } // GetMemory returns the memory allocated by a container from NUMA nodes func (m *manager) GetMemory(podUID, containerName string) []state.Block { … } func (m *manager) setPodPendingAdmission(pod *v1.Pod) { … }
Codebase Browser
kubernetes