const memoryManagerStateFileName …
type ActivePodsFunc …
type runtimeService …
type sourcesReadyStub …
func (s *sourcesReadyStub) AddSource(source string) { … }
func (s *sourcesReadyStub) AllReady() bool { … }
type Manager …
type manager …
var _ …
func NewManager(policyName string, machineInfo *cadvisorapi.MachineInfo, nodeAllocatableReservation v1.ResourceList, reservedMemory []kubeletconfig.MemoryReservation, stateFileDirectory string, affinity topologymanager.Store) (Manager, error) { … }
func (m *manager) Start(activePods ActivePodsFunc, sourcesReady config.SourcesReady, podStatusProvider status.PodStatusProvider, containerRuntime runtimeService, initialContainers containermap.ContainerMap) error { … }
func (m *manager) AddContainer(pod *v1.Pod, container *v1.Container, containerID string) { … }
func (m *manager) GetMemoryNUMANodes(pod *v1.Pod, container *v1.Container) sets.Set[int] { … }
func (m *manager) Allocate(pod *v1.Pod, container *v1.Container) error { … }
func (m *manager) RemoveContainer(containerID string) error { … }
func (m *manager) State() state.Reader { … }
func (m *manager) GetPodTopologyHints(pod *v1.Pod) map[string][]topologymanager.TopologyHint { … }
func (m *manager) GetTopologyHints(pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint { … }
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) { … }
func (m *manager) GetAllocatableMemory() []state.Block { … }
func (m *manager) GetMemory(podUID, containerName string) []state.Block { … }
func (m *manager) setPodPendingAdmission(pod *v1.Pod) { … }