deletedmarkerstore

Documentation

Index

• Constants
• func NewCacheDeletedMarkerStore(handler commoncache.CacheHandler) commonstore.Store
• func NewSnapshotDeletedMarkerStore(handler commoncache.CacheHandler) commonstore.Store
• type DeletedMarkerStore
  • func (dms *DeletedMarkerStore) AddPod(pod *v1.Pod) error
  • func (dms *DeletedMarkerStore) CleanupPodDeletionMarker(mu *sync.RWMutex, now time.Time)
  • func (dms *DeletedMarkerStore) DeletePod(pod *v1.Pod) error
  • func (dms *DeletedMarkerStore) IsPodMarkedToDelete(pod *v1.Pod) (bool, error)
  • func (dms *DeletedMarkerStore) MarkPodToDelete(pod, preemptor *v1.Pod) error
  • func (dms *DeletedMarkerStore) Name() commonstore.StoreName
  • func (dms *DeletedMarkerStore) PeriodWorker(mu *sync.RWMutex)
  • func (dms *DeletedMarkerStore) RemoveDeletePodMarker(pod, preemptor *v1.Pod) error
  • func (dms *DeletedMarkerStore) RemoveDeletePodMarkerByKey(podKey, preemptorKey string) error
  • func (dms *DeletedMarkerStore) UpdatePod(oldPod *v1.Pod, newPod *v1.Pod) error
  • func (dms *DeletedMarkerStore) UpdateSnapshot(_ commonstore.Store) error

Constants

const Name commonstore.StoreName = "DeletedMarkerStore"

const PodMarkerExpirationPeriod = 600 * time.Second

Functions

func NewCacheDeletedMarkerStore

func NewCacheDeletedMarkerStore(handler commoncache.CacheHandler) commonstore.Store

func NewSnapshotDeletedMarkerStore

func NewSnapshotDeletedMarkerStore(handler commoncache.CacheHandler) commonstore.Store

Types

type DeletedMarkerStore

type DeletedMarkerStore struct {
	commonstore.BaseStore

	Store map[string]*markInfo
	// contains filtered or unexported fields
}

func (*DeletedMarkerStore) AddPod

func (dms *DeletedMarkerStore) AddPod(pod *v1.Pod) error

func (*DeletedMarkerStore) CleanupPodDeletionMarker

func (dms *DeletedMarkerStore) CleanupPodDeletionMarker(mu *sync.RWMutex, now time.Time)

func (*DeletedMarkerStore) DeletePod

func (dms *DeletedMarkerStore) DeletePod(pod *v1.Pod) error

func (*DeletedMarkerStore) IsPodMarkedToDelete

func (dms *DeletedMarkerStore) IsPodMarkedToDelete(pod *v1.Pod) (bool, error)

func (*DeletedMarkerStore) MarkPodToDelete

func (dms *DeletedMarkerStore) MarkPodToDelete(pod, preemptor *v1.Pod) error

func (*DeletedMarkerStore) Name

func (dms *DeletedMarkerStore) Name() commonstore.StoreName

func (*DeletedMarkerStore) PeriodWorker

func (dms *DeletedMarkerStore) PeriodWorker(mu *sync.RWMutex)

func (*DeletedMarkerStore) RemoveDeletePodMarker

func (dms *DeletedMarkerStore) RemoveDeletePodMarker(pod, preemptor *v1.Pod) error

func (*DeletedMarkerStore) RemoveDeletePodMarkerByKey

func (dms *DeletedMarkerStore) RemoveDeletePodMarkerByKey(podKey, preemptorKey string) error

func (*DeletedMarkerStore) UpdatePod

func (dms *DeletedMarkerStore) UpdatePod(oldPod *v1.Pod, newPod *v1.Pod) error

func (*DeletedMarkerStore) UpdateSnapshot

func (dms *DeletedMarkerStore) UpdateSnapshot(_ commonstore.Store) error