reservationstore

Documentation

Index

• Constants
• func NewCache(handler commoncache.CacheHandler) commonstore.Store
• func NewSnapshot(handler commoncache.CacheHandler) commonstore.Store
• type ReservationStore
  • func (r *ReservationStore) AddDeployment(deploy *appsv1.Deployment) error
  • func (s *ReservationStore) AddReservation(res *schedulingv1a1.Reservation) error
  • func (s *ReservationStore) AssumePod(podInfo *framework.CachePodInfo) error
  • func (s *ReservationStore) CleanupExpiredAssumedPodReservation(now time.Time)
  • func (r *ReservationStore) DeleteDeployment(deploy *appsv1.Deployment) error
  • func (s *ReservationStore) DeletePod(pod *v1.Pod) error
  • func (s *ReservationStore) DeleteReservation(res *schedulingv1a1.Reservation) error
  • func (s *ReservationStore) ForgetPod(podInfo *framework.CachePodInfo) error
  • func (s *ReservationStore) GetAvailableNodes(placeholder string) ([]string, error)
  • func (s *ReservationStore) GetAvailableNodesAndPlaceholders(placeholder string) (framework.ReservationPlaceholdersOfNodes, error)
  • func (c *ReservationStore) Name() commonstore.StoreName
  • func (s *ReservationStore) PeriodWorker(mu *sync.RWMutex)
  • func (r *ReservationStore) UpdateDeployment(oldDeploy, newDeploy *appsv1.Deployment) error
  • func (s *ReservationStore) UpdatePod(oldPod, newPod *v1.Pod) error
  • func (s *ReservationStore) UpdateReservation(oldRes, newRes *schedulingv1a1.Reservation) error
  • func (s *ReservationStore) UpdateSnapshot(store commonstore.Store) error
• type StoreHandle

Constants

const Name commonstore.StoreName = "ReservationStore"

Functions

func NewCache

func NewCache(handler commoncache.CacheHandler) commonstore.Store

func NewSnapshot

func NewSnapshot(handler commoncache.CacheHandler) commonstore.Store

Types

type ReservationStore

type ReservationStore struct {
	commonstore.BaseStore
	// contains filtered or unexported fields
}

func (*ReservationStore) AddDeployment

func (r *ReservationStore) AddDeployment(deploy *appsv1.Deployment) error

func (*ReservationStore) AddReservation

func (s *ReservationStore) AddReservation(res *schedulingv1a1.Reservation) error

func (*ReservationStore) AssumePod

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

func (*ReservationStore) CleanupExpiredAssumedPodReservation

func (s *ReservationStore) CleanupExpiredAssumedPodReservation(now time.Time)

func (*ReservationStore) DeleteDeployment

func (r *ReservationStore) DeleteDeployment(deploy *appsv1.Deployment) error

func (*ReservationStore) DeletePod

func (s *ReservationStore) DeletePod(pod *v1.Pod) error

func (*ReservationStore) DeleteReservation

func (s *ReservationStore) DeleteReservation(res *schedulingv1a1.Reservation) error

func (*ReservationStore) ForgetPod

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

func (*ReservationStore) GetAvailableNodes

func (s *ReservationStore) GetAvailableNodes(placeholder string) ([]string, error)

func (*ReservationStore) GetAvailableNodesAndPlaceholders

func (s *ReservationStore) GetAvailableNodesAndPlaceholders(placeholder string) (framework.ReservationPlaceholdersOfNodes, error)

func (*ReservationStore) Name

func (c *ReservationStore) Name() commonstore.StoreName

func (*ReservationStore) PeriodWorker

func (s *ReservationStore) PeriodWorker(mu *sync.RWMutex)

func (*ReservationStore) UpdateDeployment

func (r *ReservationStore) UpdateDeployment(oldDeploy, newDeploy *appsv1.Deployment) error

func (*ReservationStore) UpdatePod

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

func (*ReservationStore) UpdateReservation

func (s *ReservationStore) UpdateReservation(oldRes, newRes *schedulingv1a1.Reservation) error

func (*ReservationStore) UpdateSnapshot

func (s *ReservationStore) UpdateSnapshot(store commonstore.Store) error

type StoreHandle

type StoreHandle interface {
	GetAvailableNodesAndPlaceholders(placeholder string) (framework.ReservationPlaceholdersOfNodes, error)
}