movementstore

Documentation

Index

• Constants
• func NewCacheMovementStore(handler commoncache.CacheHandler) commonstore.Store
• func NewSnapshotMovementStore(handler commoncache.CacheHandler) commonstore.Store
• type MovementStore
  • func (s *MovementStore) AddMovement(movement *schedulingv1a1.Movement) error
  • func (s *MovementStore) AddPod(pod *v1.Pod) error
  • func (s *MovementStore) AssumePod(podInfo *framework.CachePodInfo) error
  • func (s *MovementStore) DeleteMovement(movement *schedulingv1a1.Movement) error
  • func (s *MovementStore) DeletePod(pod *v1.Pod) error
  • func (s *MovementStore) ForgetPod(podInfo *framework.CachePodInfo) error
  • func (s *MovementStore) GetAvailableSuggestionTimesForNodes(ownerKey string) map[string]int64
  • func (s *MovementStore) GetDeletedPodsFromMovement(movementName string) sets.String
  • func (s *MovementStore) GetSuggestedMovementAndNodes(ownerKey string) map[string][]*framework.MovementDetailOnNode
  • func (c *MovementStore) Name() commonstore.StoreName
  • func (s *MovementStore) UpdateMovement(oldMovement, newMovement *schedulingv1a1.Movement) error
  • func (s *MovementStore) UpdatePod(oldPod, newPod *v1.Pod) error
  • func (s *MovementStore) UpdateSnapshot(store commonstore.Store) error
• type StoreHandle

Constants

const Name commonstore.StoreName = "MovementStore"

Functions

func NewCacheMovementStore

func NewCacheMovementStore(handler commoncache.CacheHandler) commonstore.Store

func NewSnapshotMovementStore

func NewSnapshotMovementStore(handler commoncache.CacheHandler) commonstore.Store

Types

type MovementStore

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

func (*MovementStore) AddMovement

func (s *MovementStore) AddMovement(movement *schedulingv1a1.Movement) error

func (*MovementStore) AddPod

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

func (*MovementStore) AssumePod

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

func (*MovementStore) DeleteMovement

func (s *MovementStore) DeleteMovement(movement *schedulingv1a1.Movement) error

func (*MovementStore) DeletePod

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

func (*MovementStore) ForgetPod

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

func (*MovementStore) GetAvailableSuggestionTimesForNodes

func (s *MovementStore) GetAvailableSuggestionTimesForNodes(ownerKey string) map[string]int64

func (*MovementStore) GetDeletedPodsFromMovement

func (s *MovementStore) GetDeletedPodsFromMovement(movementName string) sets.String

func (*MovementStore) GetSuggestedMovementAndNodes

func (s *MovementStore) GetSuggestedMovementAndNodes(ownerKey string) map[string][]*framework.MovementDetailOnNode

func (*MovementStore) Name

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

func (*MovementStore) UpdateMovement

func (s *MovementStore) UpdateMovement(oldMovement, newMovement *schedulingv1a1.Movement) error

func (*MovementStore) UpdatePod

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

func (*MovementStore) UpdateSnapshot

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

type StoreHandle

type StoreHandle interface {
	GetAvailableSuggestionTimesForNodes(ownerKey string) map[string]int64
	GetSuggestedMovementAndNodes(ownerKey string) map[string][]*framework.MovementDetailOnNode
	GetDeletedPodsFromMovement(movementName string) sets.String
}