kubernetes/pkg/kubelet/cm/cpumanager/cpu_manager.go

type ActivePodsFunc …

type runtimeService …

type policyName …

const cpuManagerStateFileName …

type Manager …

type manager …

var _ …

type sourcesReadyStub …

func (s *sourcesReadyStub) AddSource(source string) { … }

func (s *sourcesReadyStub) AllReady() bool          { … }

// NewManager creates new cpu manager based on provided policy
func NewManager(cpuPolicyName string, cpuPolicyOptions map[string]string, reconcilePeriod time.Duration, machineInfo *cadvisorapi.MachineInfo, specificCPUs cpuset.CPUSet, nodeAllocatableReservation v1.ResourceList, 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) Allocate(p *v1.Pod, c *v1.Container) error { … }

func (m *manager) AddContainer(pod *v1.Pod, container *v1.Container, containerID string) { … }

func (m *manager) RemoveContainer(containerID string) error { … }

func (m *manager) policyRemoveContainerByID(containerID string) error { … }

func (m *manager) policyRemoveContainerByRef(podUID string, containerName string) error { … }

func (m *manager) State() state.Reader { … }

func (m *manager) GetTopologyHints(pod *v1.Pod, container *v1.Container) map[string][]topologymanager.TopologyHint { … }

func (m *manager) GetPodTopologyHints(pod *v1.Pod) map[string][]topologymanager.TopologyHint { … }

func (m *manager) GetAllocatableCPUs() cpuset.CPUSet { … }

func (m *manager) GetAllCPUs() cpuset.CPUSet { … }

type reconciledContainer …

func (m *manager) removeStaleState() { … }

func (m *manager) reconcileState() (success []reconciledContainer, failure []reconciledContainer) { … }

func findContainerIDByName(status *v1.PodStatus, name string) (string, error) { … }

func findContainerStatusByName(status *v1.PodStatus, name string) (*v1.ContainerStatus, error) { … }

func (m *manager) updateContainerCPUSet(ctx context.Context, containerID string, cpus cpuset.CPUSet) error { … }

func (m *manager) GetExclusiveCPUs(podUID, containerName string) cpuset.CPUSet { … }

func (m *manager) GetCPUAffinity(podUID, containerName string) cpuset.CPUSet { … }

func (m *manager) setPodPendingAdmission(pod *v1.Pod) { … }