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 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 (f *FakeCache) FilteredList(filter schedulercache.PodFilter, selector labels.Selector) ([]*v1.Pod, error)
func (*FakeCache) FinishBinding ¶ added in v1.6.0
func (f *FakeCache) FinishBinding(pod *v1.Pod) error
func (*FakeCache) IsAssumedPod ¶ added in v1.9.0
func (f *FakeCache) IsAssumedPod(pod *v1.Pod) (bool, error)
func (*FakeCache) ListPDBs ¶ added in v1.9.0
func (f *FakeCache) ListPDBs(selector labels.Selector) ([]*policy.PodDisruptionBudget, error)
func (*FakeCache) RemoveNode ¶
func (f *FakeCache) RemoveNode(node *v1.Node) error
func (*FakeCache) RemovePDB ¶ added in v1.9.0
func (f *FakeCache) RemovePDB(pdb *policy.PodDisruptionBudget) error
func (*FakeCache) UpdateNode ¶
func (f *FakeCache) UpdateNode(oldNode, newNode *v1.Node) 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
type FakeNodeLister ¶ added in v1.6.0
type FakeNodeLister []*v1.Node
FakeNodeLister implements NodeLister on a []string for test purposes.
type FakePodLister ¶ added in v1.6.0
type FakePodLister []*v1.Pod
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
type FakeServiceLister []*v1.Service
FakeServiceLister implements ServiceLister on []v1.Service for test purposes.
func (FakeServiceLister) GetPodServices ¶ added in v1.6.0
func (f FakeServiceLister) GetPodServices(pod *v1.Pod) (services []*v1.Service, err error)
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 ¶
type PodsToCache []*v1.Pod
PodsToCache is used for testing
func (PodsToCache) List ¶
func (p PodsToCache) List(s labels.Selector) (selected []*v1.Pod, err error)
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