func podDisruptionBudgetIsReady()

in gke-deploy/core/resource/ready.go [283:314]

• 28 lines of code
• 10 McCabe index (conditional complexity)

func podDisruptionBudgetIsReady(ctx context.Context, obj *Object) (bool, error) {
	generation, ok, err := unstructured.NestedInt64(obj.Object, "metadata", "generation")
	if err != nil {
		return false, fmt.Errorf("failed to get metadata.generation field: %v", err)
	}
	if !ok {
		return false, nil
	}

	observedGeneration, ok, err := unstructured.NestedInt64(obj.Object, "status", "observedGeneration")
	if err != nil {
		return false, fmt.Errorf("failed to get status.observedGeneration field: %v", err)
	}
	if !ok || observedGeneration != generation {
		return false, nil
	}

	desiredHealthy, ok, err := unstructured.NestedInt64(obj.Object, "status", "desiredHealthy")
	if err != nil {
		return false, fmt.Errorf("failed to get status.desiredHealthy field: %v", err)
	}

	currentHealthy, ok, err := unstructured.NestedInt64(obj.Object, "status", "currentHealthy")
	if err != nil {
		return false, fmt.Errorf("failed to get status.currentHealthy field: %v", err)
	}
	if !ok || currentHealthy < desiredHealthy {
		return false, nil
	}

	return true, nil
}