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) AddNode ¶
func (f *FakeCache) AddNode(node *v1.Node) error
AddNode is a fake method for testing.
func (*FakeCache) AddPDB ¶
func (f *FakeCache) AddPDB(pdb *policy.PodDisruptionBudget) error
AddPDB is a fake method for testing.
func (*FakeCache) AddPod ¶
func (f *FakeCache) AddPod(pod *v1.Pod) error
AddPod is a fake method for testing.
func (*FakeCache) AssumePod ¶
func (f *FakeCache) AssumePod(pod *v1.Pod) error
AssumePod is a fake method for testing.
func (*FakeCache) FilteredList ¶
func (f *FakeCache) FilteredList(filter schedulercache.PodFilter, selector labels.Selector) ([]*v1.Pod, error)
FilteredList is a fake method for testing.
func (*FakeCache) FinishBinding ¶
func (f *FakeCache) FinishBinding(pod *v1.Pod) error
FinishBinding is a fake method for testing.
func (*FakeCache) ForgetPod ¶
func (f *FakeCache) ForgetPod(pod *v1.Pod) error
ForgetPod is a fake method for testing.
func (*FakeCache) GetPod ¶
func (f *FakeCache) GetPod(pod *v1.Pod) (*v1.Pod, error)
GetPod is a fake method for testing.
func (*FakeCache) IsAssumedPod ¶
func (f *FakeCache) IsAssumedPod(pod *v1.Pod) (bool, error)
IsAssumedPod is a fake method for testing.
func (*FakeCache) List ¶
func (f *FakeCache) List(s labels.Selector) ([]*v1.Pod, error)
List is a fake method for testing.
func (*FakeCache) ListPDBs ¶
func (f *FakeCache) ListPDBs(selector labels.Selector) ([]*policy.PodDisruptionBudget, error)
ListPDBs is a fake method for testing.
func (*FakeCache) RemoveNode ¶
func (f *FakeCache) RemoveNode(node *v1.Node) error
RemoveNode is a fake method for testing.
func (*FakeCache) RemovePDB ¶
func (f *FakeCache) RemovePDB(pdb *policy.PodDisruptionBudget) error
RemovePDB is a fake method for testing.
func (*FakeCache) RemovePod ¶
func (f *FakeCache) RemovePod(pod *v1.Pod) error
RemovePod is a fake method for testing.
func (*FakeCache) UpdateNode ¶
func (f *FakeCache) UpdateNode(oldNode, newNode *v1.Node) error
UpdateNode is a fake method for testing.
func (*FakeCache) UpdateNodeNameToInfoMap ¶
func (f *FakeCache) UpdateNodeNameToInfoMap(infoMap map[string]*schedulercache.NodeInfo) error
UpdateNodeNameToInfoMap is a fake method for testing.
type FakeControllerLister ¶
type FakeControllerLister []*v1.ReplicationController
FakeControllerLister implements ControllerLister on []v1.ReplicationController for test purposes.
func (FakeControllerLister) GetPodControllers ¶
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 ¶
type FakeNodeLister []*v1.Node
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)
List returns not implemented error.
func (FakePersistentVolumeClaimLister) PersistentVolumeClaims ¶
func (f FakePersistentVolumeClaimLister) PersistentVolumeClaims(namespace string) corelisters.PersistentVolumeClaimNamespaceLister
PersistentVolumeClaims returns a FakePersistentVolumeClaimLister object.
type FakePodLister ¶
type FakePodLister []*v1.Pod
FakePodLister implements PodLister on an []v1.Pods for test purposes.
func (FakePodLister) FilteredList ¶
func (f FakePodLister) FilteredList(podFilter schedulercache.PodFilter, s labels.Selector) (selected []*v1.Pod, err error)
FilteredList returns pods matching a pod filter and a label selector.
type FakeReplicaSetLister ¶
type FakeReplicaSetLister []*extensions.ReplicaSet
FakeReplicaSetLister implements ControllerLister on []extensions.ReplicaSet for test purposes.
func (FakeReplicaSetLister) GetPodReplicaSets ¶
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 ¶
type FakeServiceLister []*v1.Service
FakeServiceLister implements ServiceLister on []v1.Service for test purposes.
func (FakeServiceLister) GetPodServices ¶
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 ¶
type FakeStatefulSetLister []*apps.StatefulSet
FakeStatefulSetLister implements ControllerLister on []apps.StatefulSet for testing purposes.
func (FakeStatefulSetLister) GetPodStatefulSets ¶
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) AssumePod ¶
func (p PodsToCache) AssumePod(pod *v1.Pod) error
AssumePod returns nil.
func (PodsToCache) ForgetPod ¶
func (p PodsToCache) ForgetPod(pod *v1.Pod) error
ForgetPod returns nil.
func (PodsToCache) List ¶
func (p PodsToCache) List(s labels.Selector) (selected []*v1.Pod, err error)
List returns pods matching the label selector.
func (PodsToCache) RemoveNode ¶
func (p PodsToCache) RemoveNode(node *v1.Node) error
RemoveNode returns nil.
func (PodsToCache) RemovePod ¶
func (p PodsToCache) RemovePod(pod *v1.Pod) error
RemovePod returns nil.
func (PodsToCache) UpdateNode ¶
func (p PodsToCache) UpdateNode(oldNode, newNode *v1.Node) error
UpdateNode returns nil.
func (PodsToCache) UpdateNodeNameToInfoMap ¶
func (p PodsToCache) UpdateNodeNameToInfoMap(infoMap map[string]*schedulercache.NodeInfo) error
UpdateNodeNameToInfoMap returns nil.