[Feature] Pod Scheduled condition (#1152)

Author: ajanikow

CHANGELOG.md

@@ -14,6 +14,7 @@
 - (Bugfix) Fix Go routine leak
 - (Feature) Extend Pod Security context
 - (Improvement) Update DeploymentReplicationStatus on configuration error
+- (Feature) Pod Scheduled condition
 
 ## [1.2.19](https://github.com/arangodb/kube-arangodb/tree/1.2.19) (2022-10-05)
 - (Bugfix) Prevent changes when UID is wrong

pkg/apis/deployment/v1/conditions.go

@@ -41,6 +41,8 @@ const (
 	ConditionTypeStarted ConditionType = "Started"
 	// ConditionTypeReachable indicates that the member is reachable.
 	ConditionTypeReachable ConditionType = "Reachable"
+	// ConditionTypeScheduled indicates that the member primary pod is scheduled.
+	ConditionTypeScheduled ConditionType = "Scheduled"
 	// ConditionTypeServing indicates that the member core services are running.
 	ConditionTypeServing ConditionType = "Serving"
 	// ConditionTypeActive indicates that the member server container started.

pkg/apis/deployment/v2alpha1/conditions.go

@@ -41,6 +41,8 @@ const (
 	ConditionTypeStarted ConditionType = "Started"
 	// ConditionTypeReachable indicates that the member is reachable.
 	ConditionTypeReachable ConditionType = "Reachable"
+	// ConditionTypeScheduled indicates that the member primary pod is scheduled.
+	ConditionTypeScheduled ConditionType = "Scheduled"
 	// ConditionTypeServing indicates that the member core services are running.
 	ConditionTypeServing ConditionType = "Serving"
 	// ConditionTypeActive indicates that the member server container started.

pkg/deployment/member/phase_updates.go

@@ -84,6 +84,7 @@ func removeMemberConditionsMapFunc(m *api.MemberStatus) {
 	m.Conditions.Remove(api.ConditionTypeReady)
 	m.Conditions.Remove(api.ConditionTypeActive)
 	m.Conditions.Remove(api.ConditionTypeStarted)
+	m.Conditions.Remove(api.ConditionTypeScheduled)
 	m.Conditions.Remove(api.ConditionTypeReachable)
 	m.Conditions.Remove(api.ConditionTypeServing)
 	m.Conditions.Remove(api.ConditionTypeTerminated)

pkg/deployment/resources/pod_inspector.go

@@ -360,12 +360,19 @@ func (r *Resources) InspectPods(ctx context.Context, cachedStatus inspectorInter
 			}
 		}
 
-		if k8sutil.IsPodNotScheduledFor(pod, podScheduleTimeout) {
-			// Pod cannot be scheduled for to long
-			log.Str("pod-name", pod.GetName()).Debug("Pod scheduling timeout")
-			podNamesWithScheduleTimeout = append(podNamesWithScheduleTimeout, pod.GetName())
-		} else if !k8sutil.IsPodScheduled(pod) {
-			unscheduledPodNames = append(unscheduledPodNames, pod.GetName())
+		if k8sutil.IsPodScheduled(pod) {
+			if memberStatus.Conditions.Update(api.ConditionTypeScheduled, true, "Pod is scheduled", "") {
+				updateMemberStatusNeeded = true
+				nextInterval = nextInterval.ReduceTo(recheckSoonPodInspectorInterval)
+			}
+		} else {
+			if k8sutil.IsPodNotScheduledFor(pod, podScheduleTimeout) {
+				// Pod cannot be scheduled for to long
+				log.Str("pod-name", pod.GetName()).Debug("Pod scheduling timeout")
+				podNamesWithScheduleTimeout = append(podNamesWithScheduleTimeout, pod.GetName())
+			} else {
+				unscheduledPodNames = append(unscheduledPodNames, pod.GetName())
+			}
 		}
 
 		if k8sutil.IsPodMarkedForDeletion(pod) {