@@ -10,7 +10,9 @@ import (
10
10
"github.com/stretchr/testify/require"
11
11
appsv1 "k8s.io/api/apps/v1"
12
12
extv1beta1 "k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1"
13
+ metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
13
14
"k8s.io/apimachinery/pkg/labels"
15
+ "k8s.io/apimachinery/pkg/selection"
14
16
"k8s.io/apimachinery/pkg/util/wait"
15
17
16
18
"github.com/operator-framework/operator-lifecycle-manager/pkg/api/apis/operators/v1alpha1"
@@ -77,6 +79,26 @@ func TestCatalogLoadingBetweenRestarts(t *testing.T) {
77
79
t .Logf ("Catalog source sucessfully loaded after rescale" )
78
80
}
79
81
82
+ func TestDefaultCatalogLoading (t * testing.T ) {
83
+ defer cleaner .NotifyTestComplete (t , true )
84
+ c := newKubeClient (t )
85
+ crc := newCRClient (t )
86
+
87
+ catalogSource , err := fetchCatalogSource (t , crc , "rh-operators" , operatorNamespace , catalogSourceRegistryPodSynced )
88
+ require .NoError (t , err )
89
+ requirement , err := labels .NewRequirement ("olm.catalogSource" , selection .Equals , []string {catalogSource .GetName ()})
90
+ require .NoError (t , err )
91
+ selector := labels .NewSelector ().Add (* requirement ).String ()
92
+ pods , err := c .KubernetesInterface ().CoreV1 ().Pods (operatorNamespace ).List (metav1.ListOptions {LabelSelector : selector })
93
+ require .NoError (t , err )
94
+ for _ , p := range pods .Items {
95
+ for _ , s := range p .Status .ContainerStatuses {
96
+ require .True (t , s .Ready )
97
+ require .Zero (t , s .RestartCount )
98
+ }
99
+ }
100
+ }
101
+
80
102
func getOperatorDeployment (c operatorclient.ClientInterface , namespace string , operatorLabels labels.Set ) (* appsv1.Deployment , error ) {
81
103
deployments , err := c .ListDeploymentsWithLabels (namespace , operatorLabels )
82
104
if err != nil || deployments == nil || len (deployments .Items ) != 1 {
0 commit comments