@@ -28,6 +28,7 @@ import (
28
28
networkingv1 "k8s.io/api/networking/v1"
29
29
networkingv1beta1 "k8s.io/api/networking/v1beta1"
30
30
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
31
+ "k8s.io/apimachinery/pkg/runtime"
31
32
testclient "k8s.io/client-go/kubernetes/fake"
32
33
knative "knative.dev/networking/pkg/apis/networking/v1alpha1"
33
34
@@ -56,8 +57,8 @@ func buildLoadBalancerIngressByIP() []apiv1.LoadBalancerIngress {
56
57
}
57
58
}
58
59
59
- func buildSimpleClientSet () * testclient.Clientset {
60
- return testclient . NewSimpleClientset (
60
+ func buildSimpleClientSet (extraObjects ... runtime. Object ) * testclient.Clientset {
61
+ objects := []runtime. Object {
61
62
& apiv1.PodList {Items : []apiv1.Pod {
62
63
{
63
64
ObjectMeta : metav1.ObjectMeta {
@@ -173,8 +174,9 @@ func buildSimpleClientSet() *testclient.Clientset {
173
174
SelfLink : "/api/v1/namespaces/default/endpoints/ingress-controller-leader" ,
174
175
},
175
176
}}},
176
- & networkingv1beta1.IngressList {Items : buildExtensionsIngresses ()},
177
- )
177
+ }
178
+
179
+ return testclient .NewSimpleClientset (append (objects , extraObjects ... )... )
178
180
}
179
181
180
182
func fakeSynFn (interface {}) error {
@@ -285,21 +287,21 @@ func buildStatusSync() statusSync {
285
287
},
286
288
syncQueue : task .NewTaskQueue (fakeSynFn , logrus .New ()),
287
289
Config : Config {
288
- CoreClient : buildSimpleClientSet (),
290
+ CoreClient : buildSimpleClientSet (& networkingv1beta1. IngressList { Items : buildExtensionsIngresses ()} ),
289
291
PublishService : apiv1 .NamespaceDefault + "/" + "foo" ,
290
292
IngressLister : buildIngressLister (),
291
293
IngressAPI : utils .ExtensionsV1beta1 ,
292
294
},
293
295
}
294
296
}
295
297
296
- func TestStatusActions (t * testing.T ) {
298
+ func TestStatusActionsV1beta1 (t * testing.T ) {
297
299
ctx := context .Background ()
298
300
// make sure election can be created
299
301
os .Setenv ("POD_NAME" , "foo1" )
300
302
os .Setenv ("POD_NAMESPACE" , apiv1 .NamespaceDefault )
301
303
c := Config {
302
- CoreClient : buildSimpleClientSet (),
304
+ CoreClient : buildSimpleClientSet (& networkingv1beta1. IngressList { Items : buildExtensionsIngresses ()} ),
303
305
PublishService : apiv1 .NamespaceDefault + "/" + "foo" ,
304
306
IngressLister : buildIngressLister (),
305
307
UpdateStatusOnShutdown : true ,
0 commit comments