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) {}