1
1
package catalog
2
2
3
3
import (
4
+ "encoding/json"
4
5
"errors"
5
6
"fmt"
6
7
"testing"
7
8
"time"
8
- "encoding/json"
9
9
10
10
"github.com/ghodss/yaml"
11
11
"github.com/sirupsen/logrus"
12
12
"github.com/stretchr/testify/require"
13
+ appsv1 "k8s.io/api/apps/v1"
13
14
corev1 "k8s.io/api/core/v1"
15
+ rbacv1 "k8s.io/api/rbac/v1"
14
16
"k8s.io/apiextensions-apiserver/pkg/apis/apiextensions/v1beta1"
15
17
apiextensionsfake "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset/fake"
16
18
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -20,8 +22,6 @@ import (
20
22
k8sfake "k8s.io/client-go/kubernetes/fake"
21
23
"k8s.io/client-go/tools/cache"
22
24
apiregistrationfake "k8s.io/kube-aggregator/pkg/client/clientset_generated/clientset/fake"
23
- appsv1 "k8s.io/api/apps/v1"
24
- rbacv1 "k8s.io/api/rbac/v1"
25
25
26
26
"github.com/operator-framework/operator-lifecycle-manager/pkg/api/apis/operators/v1alpha1"
27
27
"github.com/operator-framework/operator-lifecycle-manager/pkg/api/client/clientset/versioned/fake"
@@ -119,51 +119,51 @@ func TestTransitionInstallPlan(t *testing.T) {
119
119
func TestExecutePlan (t * testing.T ) {
120
120
namespace := "ns"
121
121
122
- tests := []struct {
122
+ tests := []struct {
123
123
testName string
124
- in * v1alpha1.InstallPlan
125
- want []runtime.Object
126
- err error
124
+ in * v1alpha1.InstallPlan
125
+ want []runtime.Object
126
+ err error
127
127
}{
128
128
{
129
129
testName : "NoSteps" ,
130
- in : installPlan ("p" , namespace , v1alpha1 .InstallPlanPhaseInstalling ),
131
- want : []runtime.Object {},
132
- err : nil ,
130
+ in : installPlan ("p" , namespace , v1alpha1 .InstallPlanPhaseInstalling ),
131
+ want : []runtime.Object {},
132
+ err : nil ,
133
133
},
134
134
{
135
135
testName : "MultipleSteps" ,
136
136
in : withSteps (installPlan ("p" , namespace , v1alpha1 .InstallPlanPhaseInstalling , "csv" ),
137
137
[]* v1alpha1.Step {
138
138
& v1alpha1.Step {
139
139
Resource : v1alpha1.StepResource {
140
- CatalogSource : "catalog" ,
140
+ CatalogSource : "catalog" ,
141
141
CatalogSourceNamespace : namespace ,
142
- Group : "" ,
143
- Version : "v1" ,
144
- Kind : "Service" ,
145
- Name : "service" ,
146
- Manifest : toManifest (service ("service" , namespace )),
142
+ Group : "" ,
143
+ Version : "v1" ,
144
+ Kind : "Service" ,
145
+ Name : "service" ,
146
+ Manifest : toManifest (service ("service" , namespace )),
147
147
},
148
148
Status : v1alpha1 .StepStatusUnknown ,
149
149
},
150
150
& v1alpha1.Step {
151
151
Resource : v1alpha1.StepResource {
152
- CatalogSource : "catalog" ,
152
+ CatalogSource : "catalog" ,
153
153
CatalogSourceNamespace : namespace ,
154
- Group : "operators.coreos.com" ,
155
- Version : "v1alpha1" ,
156
- Kind : "ClusterServiceVersion" ,
157
- Name : "csv" ,
158
- Manifest : toManifest (csv ("csv" , namespace , nil , nil )),
154
+ Group : "operators.coreos.com" ,
155
+ Version : "v1alpha1" ,
156
+ Kind : "ClusterServiceVersion" ,
157
+ Name : "csv" ,
158
+ Manifest : toManifest (csv ("csv" , namespace , nil , nil )),
159
159
},
160
160
Status : v1alpha1 .StepStatusUnknown ,
161
161
},
162
162
},
163
163
),
164
164
want : []runtime.Object {service ("service" , namespace ), csv ("csv" , namespace , nil , nil )},
165
- err : nil ,
166
- },
165
+ err : nil ,
166
+ },
167
167
}
168
168
169
169
for _ , tt := range tests {
@@ -538,15 +538,15 @@ func NewFakeOperator(clientObjs []runtime.Object, k8sObjs []runtime.Object, extO
538
538
func installPlan (name , namespace string , phase v1alpha1.InstallPlanPhase , names ... string ) * v1alpha1.InstallPlan {
539
539
return & v1alpha1.InstallPlan {
540
540
ObjectMeta : metav1.ObjectMeta {
541
- Name : name ,
541
+ Name : name ,
542
542
Namespace : namespace ,
543
543
},
544
544
Spec : v1alpha1.InstallPlanSpec {
545
545
ClusterServiceVersionNames : names ,
546
546
},
547
547
Status : v1alpha1.InstallPlanStatus {
548
548
Phase : phase ,
549
- Plan : []* v1alpha1.Step {},
549
+ Plan : []* v1alpha1.Step {},
550
550
},
551
551
}
552
552
}
@@ -575,7 +575,7 @@ func csv(name, namespace string, owned, required []string) *v1alpha1.ClusterServ
575
575
576
576
return & v1alpha1.ClusterServiceVersion {
577
577
ObjectMeta : metav1.ObjectMeta {
578
- Name : name ,
578
+ Name : name ,
579
579
Namespace : namespace ,
580
580
},
581
581
Spec : v1alpha1.ClusterServiceVersionSpec {
@@ -605,7 +605,7 @@ func crd(name string) v1beta1.CustomResourceDefinition {
605
605
func service (name , namespace string ) * corev1.Service {
606
606
return & corev1.Service {
607
607
ObjectMeta : metav1.ObjectMeta {
608
- Name : name ,
608
+ Name : name ,
609
609
Namespace : namespace ,
610
610
},
611
611
}
@@ -614,4 +614,4 @@ func service(name, namespace string) *corev1.Service {
614
614
func toManifest (obj runtime.Object ) string {
615
615
raw , _ := json .Marshal (obj )
616
616
return string (raw )
617
- }
617
+ }
0 commit comments