@@ -103,7 +103,7 @@ def test_deployment_in_namespace(self):
103
103
body = {})
104
104
resp = core_api .delete_namespace (name = "dep" , body = {})
105
105
106
- def test_api_service (self ):
106
+ def test_api_service_with_conflict (self ):
107
107
k8s_client = client .api_client .ApiClient (configuration = self .config )
108
108
k8s_api = utils .create_from_yaml (k8s_client ,
109
109
"kubernetes/e2e_test/test_yaml/api-service.yaml" )
@@ -112,5 +112,85 @@ def test_api_service(self):
112
112
svc = k8s_api .read_api_service (
113
113
name = "v1alpha1.wardle.k8s.io" )
114
114
self .assertIsNotNone (svc )
115
+ svc_conflict = utils .create_from_yaml (k8s_client ,
116
+ "kubernetes/e2e_test/test_yaml/api-service.yaml" )
117
+ self .assertEqual ([], svc_conflict )
115
118
resp = k8s_api .delete_api_service (
116
- name = "v1alpha1.wardle.k8s.io" , body = {})
119
+ name = "v1alpha1.wardle.k8s.io" , body = {})
120
+
121
+ def test_list (self ):
122
+ k8s_client = client .api_client .ApiClient (configuration = self .config )
123
+ k8s_api = utils .create_from_yaml (k8s_client ,
124
+ "kubernetes/e2e_test/test_yaml/list.yaml" )
125
+ svc_api = k8s_api [0 ]
126
+ self .assertEqual ("v1" , svc_api .get_api_resources ().group_version )
127
+ svc = svc_api .read_namespaced_service (name = "list-service-test" ,
128
+ namespace = "default" )
129
+ self .assertIsNotNone (svc )
130
+ ext_api = k8s_api [1 ]
131
+ self .assertEqual ("extensions/v1beta1" ,
132
+ ext_api .get_api_resources ().group_version )
133
+ dep = ext_api .read_namespaced_deployment (name = "list-deployment-test" ,
134
+ namespace = "default" )
135
+ self .assertIsNotNone (dep )
136
+ ext_api .delete_namespaced_deployment (name = "list-deployment-test" ,
137
+ namespace = "default" , body = {})
138
+ svc_api .delete_namespaced_service (name = "list-service-test" ,
139
+ namespace = "default" , body = {})
140
+
141
+ def test_multi_resource (self ):
142
+ k8s_client = client .api_client .ApiClient (configuration = self .config )
143
+ k8s_api = utils .create_from_yaml (k8s_client ,
144
+ "kubernetes/e2e_test/test_yaml/multi-resource-yaml.yaml" )
145
+ svc_api = k8s_api [0 ]
146
+ self .assertEqual ("v1" , svc_api .get_api_resources ().group_version )
147
+ svc = svc_api .read_namespaced_service (name = "mock" ,
148
+ namespace = "default" )
149
+ self .assertIsNotNone (svc )
150
+ ctr_api = k8s_api [1 ]
151
+ self .assertEqual ("v1" , ctr_api .get_api_resources ().group_version )
152
+ ctr = ctr_api .read_namespaced_replication_controller (
153
+ name = "mock" , namespace = "default" )
154
+ self .assertIsNotNone (ctr )
155
+ ctr_api .delete_namespaced_replication_controller (name = "mock" ,
156
+ namespace = "default" , body = {})
157
+ svc_api .delete_namespaced_service (name = "mock" ,
158
+ namespace = "default" , body = {})
159
+
160
+ def test_multi_resource_with_conflict (self ):
161
+ k8s_client = client .api_client .ApiClient (configuration = self .config )
162
+ svc_api = utils .create_from_yaml (k8s_client ,
163
+ "kubernetes/e2e_test/test_yaml/yaml-conflict-first.yaml" )
164
+ self .assertEqual ("v1" , svc_api .get_api_resources ().group_version )
165
+ svc = svc_api .read_namespaced_service (name = "mock-2" ,
166
+ namespace = "default" )
167
+ self .assertIsNotNone (svc )
168
+ ctr_api = utils .create_from_yaml (k8s_client ,
169
+ "kubernetes/e2e_test/test_yaml/yaml-conflict-multi.yaml" )
170
+ self .assertEqual ("v1" , ctr_api .get_api_resources ().group_version )
171
+ ctr = ctr_api .read_namespaced_replication_controller (
172
+ name = "mock-2" , namespace = "default" )
173
+ self .assertIsNotNone (ctr )
174
+ ctr_api .delete_namespaced_replication_controller (name = "mock-2" ,
175
+ namespace = "default" , body = {})
176
+ svc_api .delete_namespaced_service (name = "mock-2" ,
177
+ namespace = "default" , body = {})
178
+
179
+ def test_svc_list_with_conflict_no_kind (self ):
180
+ k8s_client = client .api_client .ApiClient (configuration = self .config )
181
+ svc_apis = utils .create_from_yaml (k8s_client ,
182
+ "kubernetes/e2e_test/test_yaml/multi-resource-svclist.json" )
183
+ svc_api_0 = svc_apis [0 ]
184
+ self .assertEqual ("v1" , svc_api_0 .get_api_resources ().group_version )
185
+ svc_0 = svc_api_0 .read_namespaced_service (name = "mock-3" ,
186
+ namespace = "default" )
187
+ self .assertIsNotNone (svc_0 )
188
+ svc_api_1 = svc_apis [1 ]
189
+ self .assertEqual ("v1" , svc_api_1 .get_api_resources ().group_version )
190
+ svc_1 = svc_api_1 .read_namespaced_service (name = "mock-4" ,
191
+ namespace = "default" )
192
+ self .assertIsNotNone (svc_1 )
193
+ svc_api_0 .delete_namespaced_service (name = "mock-3" ,
194
+ namespace = "default" , body = {})
195
+ svc_api_1 .delete_namespaced_service (name = "mock-4" ,
196
+ namespace = "default" , body = {})
0 commit comments