unitstatusstore

Documentation

Index

• Constants
• func NewCache(handler handler.CacheHandler) commonstores.CommonStore
• func NewSnapshot(handler handler.CacheHandler) commonstores.CommonStore
• type UnitStatusStore
  • func (s *UnitStatusStore) AddPod(pod *v1.Pod) error
  • func (s *UnitStatusStore) AddPodGroup(podGroup *schedulingv1a1.PodGroup) error
  • func (s *UnitStatusStore) AssumePod(podInfo *framework.CachePodInfo) error
  • func (s *UnitStatusStore) ForgetPod(podInfo *framework.CachePodInfo) error
  • func (s *UnitStatusStore) GetUnitSchedulingStatus(unitKey string) unitstatus.SchedulingStatus
  • func (s *UnitStatusStore) GetUnitStatus(unitKey string) unitstatus.UnitStatus
  • func (c *UnitStatusStore) Name() commonstores.StoreName
  • func (s *UnitStatusStore) RemovePod(pod *v1.Pod) error
  • func (s *UnitStatusStore) RemovePodGroup(podGroup *schedulingv1a1.PodGroup) error
  • func (s *UnitStatusStore) SetUnitSchedulingStatus(unitKey string, status unitstatus.SchedulingStatus)
  • func (s *UnitStatusStore) UpdatePod(oldPod *v1.Pod, newPod *v1.Pod) error
  • func (s *UnitStatusStore) UpdatePodGroup(oldPodGroup, newPodGroup *schedulingv1a1.PodGroup) error
  • func (s *UnitStatusStore) UpdateSnapshot(_ commonstores.CommonStore) error

Constants

const Name commonstores.StoreName = "UnitStatusStore"

Functions

func NewCache

func NewCache(handler handler.CacheHandler) commonstores.CommonStore

func NewSnapshot

func NewSnapshot(handler handler.CacheHandler) commonstores.CommonStore

Types

type UnitStatusStore

type UnitStatusStore struct {
	commonstores.BaseStore

	Store *unitstatus.UnitStatusMap // Only be used in Cache.
	// contains filtered or unexported fields
}

func (*UnitStatusStore) AddPod

func (s *UnitStatusStore) AddPod(pod *v1.Pod) error

func (*UnitStatusStore) AddPodGroup

func (s *UnitStatusStore) AddPodGroup(podGroup *schedulingv1a1.PodGroup) error

func (*UnitStatusStore) AssumePod

func (s *UnitStatusStore) AssumePod(podInfo *framework.CachePodInfo) error

func (*UnitStatusStore) ForgetPod

func (s *UnitStatusStore) ForgetPod(podInfo *framework.CachePodInfo) error

func (*UnitStatusStore) GetUnitSchedulingStatus

func (s *UnitStatusStore) GetUnitSchedulingStatus(unitKey string) unitstatus.SchedulingStatus

func (*UnitStatusStore) GetUnitStatus

func (s *UnitStatusStore) GetUnitStatus(unitKey string) unitstatus.UnitStatus

func (*UnitStatusStore) Name

func (c *UnitStatusStore) Name() commonstores.StoreName

func (*UnitStatusStore) RemovePod

func (s *UnitStatusStore) RemovePod(pod *v1.Pod) error

func (*UnitStatusStore) RemovePodGroup

func (s *UnitStatusStore) RemovePodGroup(podGroup *schedulingv1a1.PodGroup) error

func (*UnitStatusStore) SetUnitSchedulingStatus

func (s *UnitStatusStore) SetUnitSchedulingStatus(unitKey string, status unitstatus.SchedulingStatus)

func (*UnitStatusStore) UpdatePod

func (s *UnitStatusStore) UpdatePod(oldPod *v1.Pod, newPod *v1.Pod) error

func (*UnitStatusStore) UpdatePodGroup

func (s *UnitStatusStore) UpdatePodGroup(oldPodGroup, newPodGroup *schedulingv1a1.PodGroup) error

func (*UnitStatusStore) UpdateSnapshot

func (s *UnitStatusStore) UpdateSnapshot(_ commonstores.CommonStore) error