Function TestUpdatePod

pkg/scheduler/eventhandlers_test.go:885–1035

(t *testing.T)

}

func TestUpdatePod(t *testing.T) {
	pod := st.MakePod().Name("pod1").Namespace("ns1").UID("pod1").SchedulerName("supported-scheduler").Obj()
	updatedPod := st.MakePod().Name("pod1").Namespace("ns1").UID("pod1").Labels(map[string]string{"foo": "bar"}).ResourceVersion("2").SchedulerName("supported-scheduler").Obj()

	podWithDeletionTimestamp := st.MakePod().Name("pod1").Namespace("ns1").UID("pod1").Terminating().ResourceVersion("2").SchedulerName("supported-scheduler").Obj()

	otherPod := st.MakePod().Name("pod1").Namespace("ns1").UID("pod1").SchedulerName("other-scheduler").Obj()
	updatedOtherPod := st.MakePod().Name("pod1").Namespace("ns1").UID("pod1").Labels(map[string]string{"foo": "bar"}).ResourceVersion("2").SchedulerName("other-scheduler").Obj()

	scheduledPod := st.MakePod().Name("pod1").Namespace("ns1").UID("pod1").Node("node1").SchedulerName("supported-scheduler").Obj()
	updatedScheduledPod := st.MakePod().Name("pod1").Namespace("ns1").UID("pod1").Labels(map[string]string{"foo": "bar"}).ResourceVersion("2").Node("node1").SchedulerName("supported-scheduler").Obj()

	otherScheduledPod := st.MakePod().Name("pod1").Namespace("ns1").UID("pod1").Node("node1").SchedulerName("other-scheduler").Obj()
	updatedOtherScheduledPod := st.MakePod().Name("pod1").Namespace("ns1").UID("pod1").Labels(map[string]string{"foo": "bar"}).ResourceVersion("2").Node("node1").SchedulerName("other-scheduler").Obj()

	scheduledPodOtherNode := st.MakePod().Name("pod1").Namespace("ns1").UID("pod1").Node("node2").SchedulerName("supported-scheduler").Obj()

	tests := []struct {
		name          string
		oldPod        *v1.Pod
		assumedPod    *v1.Pod
		newPod        *v1.Pod
		expectInQueue *v1.Pod
		expectInCache *v1.Pod
	}{
		{
			name:          "update unscheduled pod",
			oldPod:        pod,
			newPod:        updatedPod,
			expectInQueue: updatedPod,
		},
		{
			name:   "update unscheduled pod with other scheduler name",
			oldPod: otherPod,
			newPod: updatedOtherPod,
		},
		{
			name:          "update assumed pod",
			oldPod:        pod,
			assumedPod:    scheduledPod,
			newPod:        updatedPod,
			expectInCache: scheduledPod,
		},
		{
			name:          "update scheduled pod",
			oldPod:        scheduledPod,
			newPod:        updatedScheduledPod,
			expectInCache: updatedScheduledPod,
		},
		{
			name:          "update scheduled pod with other scheduler name",
			oldPod:        otherScheduledPod,
			newPod:        updatedOtherScheduledPod,
			expectInCache: updatedOtherScheduledPod,
		},
		{
			name:          "bind unscheduled pod",
			oldPod:        pod,