1 package mapper
2
3 import (
4 "fmt"
5
6 metastatus "edge-infra.dev/pkg/k8s/meta/status"
7
8 metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
9 )
10
11 const (
12 Provisioning = "Provisioning"
13 SyncingError = "SyncingError"
14 ProvisioningError = "ProvisioningError"
15 BucketError = "BucketError"
16 )
17
18 func isResourceReady(conditions []metav1.Condition, conditionReason string) (bool, string, string) {
19 for _, condition := range conditions {
20 if condition.Type == metastatus.ReadyCondition {
21 ok := condition.Status == metav1.ConditionTrue && condition.Reason == conditionReason
22 message := fmt.Sprintf("%s: %s", condition.Reason, condition.Message)
23 return ok, condition.Reason, message
24 }
25 }
26 return false, "", "ready condition not found"
27 }
28
View as plain text