pdbstore

Documentation

Index

• Constants
• func NewCache(handler commoncache.CacheHandler) commonstore.Store
• func NewPDBItemImpl(pdb *policy.PodDisruptionBudget) *pdbItemImpl
• func NewSnapshot(handler commoncache.CacheHandler) commonstore.Store
• type OwnerItemImpl
  • func (o *OwnerItemImpl) AddPDB(key string)
  • func (o *OwnerItemImpl) Clone() framework.OwnerItem
  • func (o *OwnerItemImpl) GetGeneration() int64
  • func (o *OwnerItemImpl) GetOwnerLabels() map[string]string
  • func (o *OwnerItemImpl) GetPDBUpdated() bool
  • func (o *OwnerItemImpl) GetRelatedPDBs() []string
  • func (o *OwnerItemImpl) RemovePDB(key string)
  • func (o *OwnerItemImpl) Replace(item framework.OwnerItem)
  • func (o *OwnerItemImpl) SetGeneration(generation int64)
  • func (o *OwnerItemImpl) SetPDBUpdated()
• type PdbStore
  • func (s *PdbStore) AddOwner(ownerType, ownerKey string, ownerLabels map[string]string) error
  • func (s *PdbStore) AddPDB(pdb *policy.PodDisruptionBudget) error
  • func (s *PdbStore) DeleteOwner(ownerType, ownerKey string) error
  • func (s *PdbStore) DeletePDB(pdb *policy.PodDisruptionBudget) error
  • func (s *PdbStore) GetOwnerLabels(ownerType, ownerKey string) map[string]string
  • func (s *PdbStore) GetOwnersForPDB(key, ownerType string) []string
  • func (s *PdbStore) GetPDBItemList() []framework.PDBItem
  • func (s *PdbStore) GetPDBsForOwner(ownerType, ownerKey string) (bool, bool, []string)
  • func (c *PdbStore) Name() commonstore.StoreName
  • func (s *PdbStore) SetPDBUpdated(ownerType, ownerKey string)
  • func (c *PdbStore) UpdateOwner(ownerType, key string, oldLabels, newLabels map[string]string) error
  • func (s *PdbStore) UpdatePDB(oldPdb, newPdb *policy.PodDisruptionBudget) error
  • func (s *PdbStore) UpdateSnapshot(store commonstore.Store) error
• type StoreHandle

Constants

const Name commonstore.StoreName = "PdbStore"

Functions

func NewCache

func NewCache(handler commoncache.CacheHandler) commonstore.Store

func NewPDBItemImpl

func NewPDBItemImpl(pdb *policy.PodDisruptionBudget) *pdbItemImpl

func NewSnapshot

func NewSnapshot(handler commoncache.CacheHandler) commonstore.Store

Types

type OwnerItemImpl

type OwnerItemImpl struct {
	Pdbs framework.GenerationStringSet
	// contains filtered or unexported fields
}

func (*OwnerItemImpl) AddPDB

func (o *OwnerItemImpl) AddPDB(key string)

func (*OwnerItemImpl) Clone

func (o *OwnerItemImpl) Clone() framework.OwnerItem

func (*OwnerItemImpl) GetGeneration

func (o *OwnerItemImpl) GetGeneration() int64

func (*OwnerItemImpl) GetOwnerLabels

func (o *OwnerItemImpl) GetOwnerLabels() map[string]string

func (*OwnerItemImpl) GetPDBUpdated

func (o *OwnerItemImpl) GetPDBUpdated() bool

func (*OwnerItemImpl) GetRelatedPDBs

func (o *OwnerItemImpl) GetRelatedPDBs() []string

func (*OwnerItemImpl) RemovePDB

func (o *OwnerItemImpl) RemovePDB(key string)

func (*OwnerItemImpl) Replace

func (o *OwnerItemImpl) Replace(item framework.OwnerItem)

func (*OwnerItemImpl) SetGeneration

func (o *OwnerItemImpl) SetGeneration(generation int64)

func (*OwnerItemImpl) SetPDBUpdated

func (o *OwnerItemImpl) SetPDBUpdated()

type PdbStore

type PdbStore struct {
	commonstore.BaseStore

	// key is replicaset namespace/name
	ReplicaSets generationstore.Store
	// key is daemonset namespace/name
	DaemonSets generationstore.Store
	// key is pdb namespace/name
	Pdbs generationstore.Store
	// contains filtered or unexported fields
}

PdbStore is used to cache pdb and pdb selectors Operation of this struct is not thread-safe, should ensure thread-safe by callers.

func (*PdbStore) AddOwner

func (s *PdbStore) AddOwner(ownerType, ownerKey string, ownerLabels map[string]string) error

func (*PdbStore) AddPDB

func (s *PdbStore) AddPDB(pdb *policy.PodDisruptionBudget) error

func (*PdbStore) DeleteOwner

func (s *PdbStore) DeleteOwner(ownerType, ownerKey string) error

func (*PdbStore) DeletePDB

func (s *PdbStore) DeletePDB(pdb *policy.PodDisruptionBudget) error

func (*PdbStore) GetOwnerLabels

func (s *PdbStore) GetOwnerLabels(ownerType, ownerKey string) map[string]string

func (*PdbStore) GetOwnersForPDB

func (s *PdbStore) GetOwnersForPDB(key, ownerType string) []string

func (*PdbStore) GetPDBItemList

func (s *PdbStore) GetPDBItemList() []framework.PDBItem

func (*PdbStore) GetPDBsForOwner

func (s *PdbStore) GetPDBsForOwner(ownerType, ownerKey string) (bool, bool, []string)

func (*PdbStore) Name

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

func (*PdbStore) SetPDBUpdated

func (s *PdbStore) SetPDBUpdated(ownerType, ownerKey string)

func (*PdbStore) UpdateOwner

func (c *PdbStore) UpdateOwner(ownerType, key string, oldLabels, newLabels map[string]string) error

func (*PdbStore) UpdatePDB

func (s *PdbStore) UpdatePDB(oldPdb, newPdb *policy.PodDisruptionBudget) error

func (*PdbStore) UpdateSnapshot

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

type StoreHandle

type StoreHandle interface {
	GetPDBItemList() []framework.PDBItem
	GetPDBsForOwner(ownerType, ownerKey string) (bool, bool, []string)
	GetOwnerLabels(ownerType, ownerKey string) map[string]string
}