Documentation ¶
Index ¶
- type FakeCache
- func (f *FakeCache) AddNode(node *v1.Node) error
- func (f *FakeCache) AddPDB(pdb *policy.PodDisruptionBudget) error
- func (f *FakeCache) AddPod(pod *v1.Pod) error
- func (f *FakeCache) AssumePod(pod *v1.Pod) error
- func (f *FakeCache) FilteredList(filter schedulercache.PodFilter, selector labels.Selector) ([]*v1.Pod, error)
- func (f *FakeCache) FinishBinding(pod *v1.Pod) error
- func (f *FakeCache) ForgetPod(pod *v1.Pod) error
- func (f *FakeCache) GetPod(pod *v1.Pod) (*v1.Pod, error)
- func (f *FakeCache) IsAssumedPod(pod *v1.Pod) (bool, error)
- func (f *FakeCache) List(s labels.Selector) ([]*v1.Pod, error)
- func (f *FakeCache) ListPDBs(selector labels.Selector) ([]*policy.PodDisruptionBudget, error)
- func (f *FakeCache) RemoveNode(node *v1.Node) error
- func (f *FakeCache) RemovePDB(pdb *policy.PodDisruptionBudget) error
- func (f *FakeCache) RemovePod(pod *v1.Pod) error
- func (f *FakeCache) UpdateNode(oldNode, newNode *v1.Node) error
- func (f *FakeCache) UpdateNodeNameToInfoMap(infoMap map[string]*schedulercache.NodeInfo) error
- func (f *FakeCache) UpdatePDB(oldPDB, newPDB *policy.PodDisruptionBudget) error
- func (f *FakeCache) UpdatePod(oldPod, newPod *v1.Pod) error
- type FakeControllerLister
- type FakeNodeLister
- type FakePersistentVolumeClaimLister
- type FakePodLister
- type FakeReplicaSetLister
- type FakeServiceLister
- type FakeStatefulSetLister
- type PodsToCache
- func (p PodsToCache) AddNode(node *v1.Node) error
- func (p PodsToCache) AddPod(pod *v1.Pod) error
- func (p PodsToCache) AssumePod(pod *v1.Pod) error
- func (p PodsToCache) ForgetPod(pod *v1.Pod) error
- func (p PodsToCache) List(s labels.Selector) (selected []*v1.Pod, err error)
- func (p PodsToCache) RemoveNode(node *v1.Node) error
- func (p PodsToCache) RemovePod(pod *v1.Pod) error
- func (p PodsToCache) UpdateNode(oldNode, newNode *v1.Node) error
- func (p PodsToCache) UpdateNodeNameToInfoMap(infoMap map[string]*schedulercache.NodeInfo) error
- func (p PodsToCache) UpdatePod(oldPod, newPod *v1.Pod) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FakeCache ¶
type FakeCache struct { AssumeFunc func(*v1.Pod) ForgetFunc func(*v1.Pod) IsAssumedPodFunc func(*v1.Pod) bool GetPodFunc func(*v1.Pod) *v1.Pod }
FakeCache is used for testing
func (*FakeCache) AddPDB ¶ added in v1.9.0
func (f *FakeCache) AddPDB(pdb *policy.PodDisruptionBudget) error
func (*FakeCache) FilteredList ¶ added in v1.8.0
func (*FakeCache) FinishBinding ¶ added in v1.6.0
func (*FakeCache) IsAssumedPod ¶ added in v1.9.0
func (*FakeCache) RemovePDB ¶ added in v1.9.0
func (f *FakeCache) RemovePDB(pdb *policy.PodDisruptionBudget) error
func (*FakeCache) UpdateNodeNameToInfoMap ¶ added in v1.4.0
func (f *FakeCache) UpdateNodeNameToInfoMap(infoMap map[string]*schedulercache.NodeInfo) error
type FakeControllerLister ¶ added in v1.6.0
type FakeControllerLister []*v1.ReplicationController
FakeControllerLister implements ControllerLister on []v1.ReplicationController for test purposes.
func (FakeControllerLister) GetPodControllers ¶ added in v1.6.0
func (f FakeControllerLister) GetPodControllers(pod *v1.Pod) (controllers []*v1.ReplicationController, err error)
GetPodControllers gets the ReplicationControllers that have the selector that match the labels on the given pod
func (FakeControllerLister) List ¶ added in v1.6.0
func (f FakeControllerLister) List(labels.Selector) ([]*v1.ReplicationController, error)
List returns []v1.ReplicationController, the list of all ReplicationControllers.
type FakeNodeLister ¶ added in v1.6.0
FakeNodeLister implements NodeLister on a []string for test purposes.
type FakePersistentVolumeClaimLister ¶
type FakePersistentVolumeClaimLister []*v1.PersistentVolumeClaim
FakePersistentVolumeClaimLister implements PersistentVolumeClaimLister on []*v1.PersistentVolumeClaim for test purposes.
func (FakePersistentVolumeClaimLister) List ¶
func (f FakePersistentVolumeClaimLister) List(selector labels.Selector) (ret []*v1.PersistentVolumeClaim, err error)
func (FakePersistentVolumeClaimLister) PersistentVolumeClaims ¶
func (f FakePersistentVolumeClaimLister) PersistentVolumeClaims(namespace string) corelisters.PersistentVolumeClaimNamespaceLister
type FakePodLister ¶ added in v1.6.0
FakePodLister implements PodLister on an []v1.Pods for test purposes.
func (FakePodLister) FilteredList ¶ added in v1.8.0
func (f FakePodLister) FilteredList(podFilter schedulercache.PodFilter, s labels.Selector) (selected []*v1.Pod, err error)
type FakeReplicaSetLister ¶ added in v1.6.0
type FakeReplicaSetLister []*extensions.ReplicaSet
FakeReplicaSetLister implements ControllerLister on []extensions.ReplicaSet for test purposes.
func (FakeReplicaSetLister) GetPodReplicaSets ¶ added in v1.6.0
func (f FakeReplicaSetLister) GetPodReplicaSets(pod *v1.Pod) (rss []*extensions.ReplicaSet, err error)
GetPodReplicaSets gets the ReplicaSets that have the selector that match the labels on the given pod
type FakeServiceLister ¶ added in v1.6.0
FakeServiceLister implements ServiceLister on []v1.Service for test purposes.
func (FakeServiceLister) GetPodServices ¶ added in v1.6.0
GetPodServices gets the services that have the selector that match the labels on the given pod.
type FakeStatefulSetLister ¶ added in v1.6.0
type FakeStatefulSetLister []*apps.StatefulSet
FakeStatefulSetLister implements ControllerLister on []apps.StatefulSet for testing purposes.
func (FakeStatefulSetLister) GetPodStatefulSets ¶ added in v1.6.0
func (f FakeStatefulSetLister) GetPodStatefulSets(pod *v1.Pod) (sss []*apps.StatefulSet, err error)
GetPodStatefulSets gets the StatefulSets that have the selector that match the labels on the given pod.
type PodsToCache ¶
PodsToCache is used for testing
func (PodsToCache) RemoveNode ¶
func (p PodsToCache) RemoveNode(node *v1.Node) error
func (PodsToCache) UpdateNode ¶
func (p PodsToCache) UpdateNode(oldNode, newNode *v1.Node) error
func (PodsToCache) UpdateNodeNameToInfoMap ¶ added in v1.4.0
func (p PodsToCache) UpdateNodeNameToInfoMap(infoMap map[string]*schedulercache.NodeInfo) error