conversion_test.go 23 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653
  1. /*
  2. Copyright 2017 The Kubernetes Authors.
  3. Licensed under the Apache License, Version 2.0 (the "License");
  4. you may not use this file except in compliance with the License.
  5. You may obtain a copy of the License at
  6. http://www.apache.org/licenses/LICENSE-2.0
  7. Unless required by applicable law or agreed to in writing, software
  8. distributed under the License is distributed on an "AS IS" BASIS,
  9. WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  10. See the License for the specific language governing permissions and
  11. limitations under the License.
  12. */
  13. package v1beta2_test
  14. import (
  15. "testing"
  16. "k8s.io/api/apps/v1beta2"
  17. "k8s.io/api/core/v1"
  18. "k8s.io/apimachinery/pkg/util/intstr"
  19. "k8s.io/kubernetes/pkg/api/legacyscheme"
  20. "k8s.io/kubernetes/pkg/apis/apps"
  21. "k8s.io/kubernetes/pkg/apis/autoscaling"
  22. api "k8s.io/kubernetes/pkg/apis/core"
  23. apiequality "k8s.io/apimachinery/pkg/api/equality"
  24. metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
  25. utilpointer "k8s.io/utils/pointer"
  26. )
  27. func TestV1beta2StatefulSetSpecConversion(t *testing.T) {
  28. replicas := utilpointer.Int32Ptr(2)
  29. selector := &metav1.LabelSelector{MatchLabels: map[string]string{"foo": "bar"}}
  30. v1beta2Template := v1.PodTemplateSpec{
  31. ObjectMeta: metav1.ObjectMeta{Name: "foo"},
  32. Spec: v1.PodSpec{
  33. RestartPolicy: v1.RestartPolicy("bar"),
  34. SecurityContext: new(v1.PodSecurityContext),
  35. },
  36. }
  37. apiTemplate := api.PodTemplateSpec{
  38. ObjectMeta: metav1.ObjectMeta{Name: "foo"},
  39. Spec: api.PodSpec{
  40. RestartPolicy: api.RestartPolicy("bar"),
  41. SecurityContext: new(api.PodSecurityContext),
  42. },
  43. }
  44. testcases := map[string]struct {
  45. stsSpec1 *apps.StatefulSetSpec
  46. stsSepc2 *v1beta2.StatefulSetSpec
  47. }{
  48. "StatefulSetSpec Conversion 1": {
  49. stsSpec1: &apps.StatefulSetSpec{
  50. Replicas: *replicas,
  51. Template: apiTemplate,
  52. },
  53. stsSepc2: &v1beta2.StatefulSetSpec{
  54. Replicas: replicas,
  55. Template: v1beta2Template,
  56. },
  57. },
  58. "StatefulSetSpec Conversion 2": {
  59. stsSpec1: &apps.StatefulSetSpec{
  60. Replicas: *replicas,
  61. Selector: selector,
  62. Template: apiTemplate,
  63. ServiceName: "foo",
  64. PodManagementPolicy: apps.PodManagementPolicyType("bar"),
  65. },
  66. stsSepc2: &v1beta2.StatefulSetSpec{
  67. Replicas: replicas,
  68. Selector: selector,
  69. Template: v1beta2Template,
  70. ServiceName: "foo",
  71. PodManagementPolicy: v1beta2.PodManagementPolicyType("bar"),
  72. },
  73. },
  74. }
  75. for k, tc := range testcases {
  76. // apps -> v1beta2
  77. internal1 := &v1beta2.StatefulSetSpec{}
  78. if err := legacyscheme.Scheme.Convert(tc.stsSpec1, internal1, nil); err != nil {
  79. t.Errorf("%q - %q: unexpected error: %v", k, "from extensions to v1beta2", err)
  80. }
  81. if !apiequality.Semantic.DeepEqual(internal1, tc.stsSepc2) {
  82. t.Errorf("%q - %q: expected\n\t%#v, got \n\t%#v", k, "from extensions to v1beta2", tc.stsSepc2, internal1)
  83. }
  84. // v1beta2 -> apps
  85. internal2 := &apps.StatefulSetSpec{}
  86. if err := legacyscheme.Scheme.Convert(tc.stsSepc2, internal2, nil); err != nil {
  87. t.Errorf("%q - %q: unexpected error: %v", k, "from v1beta2 to extensions", err)
  88. }
  89. if !apiequality.Semantic.DeepEqual(internal2, tc.stsSpec1) {
  90. t.Errorf("%q- %q: expected\n\t%#v, got \n\t%#v", k, "from v1beta2 to extensions", tc.stsSpec1, internal2)
  91. }
  92. }
  93. }
  94. func TestV1beta2StatefulSetUpdateStrategyConversion(t *testing.T) {
  95. partition := utilpointer.Int32Ptr(2)
  96. v1beta2rollingUpdate := new(v1beta2.RollingUpdateStatefulSetStrategy)
  97. v1beta2rollingUpdate.Partition = partition
  98. appsrollingUpdate := new(apps.RollingUpdateStatefulSetStrategy)
  99. appsrollingUpdate.Partition = *partition
  100. testcases := map[string]struct {
  101. stsUpdateStrategy1 *apps.StatefulSetUpdateStrategy
  102. stsUpdateStrategy2 *v1beta2.StatefulSetUpdateStrategy
  103. }{
  104. "StatefulSetUpdateStrategy Conversion 1": {
  105. stsUpdateStrategy1: &apps.StatefulSetUpdateStrategy{Type: apps.StatefulSetUpdateStrategyType("foo")},
  106. stsUpdateStrategy2: &v1beta2.StatefulSetUpdateStrategy{Type: v1beta2.StatefulSetUpdateStrategyType("foo")},
  107. },
  108. "StatefulSetUpdateStrategy Conversion 2": {
  109. stsUpdateStrategy1: &apps.StatefulSetUpdateStrategy{
  110. Type: apps.StatefulSetUpdateStrategyType("foo"),
  111. RollingUpdate: appsrollingUpdate,
  112. },
  113. stsUpdateStrategy2: &v1beta2.StatefulSetUpdateStrategy{
  114. Type: v1beta2.StatefulSetUpdateStrategyType("foo"),
  115. RollingUpdate: v1beta2rollingUpdate,
  116. },
  117. },
  118. }
  119. for k, tc := range testcases {
  120. // apps -> v1beta2
  121. internal1 := &v1beta2.StatefulSetUpdateStrategy{}
  122. if err := legacyscheme.Scheme.Convert(tc.stsUpdateStrategy1, internal1, nil); err != nil {
  123. t.Errorf("%q - %q: unexpected error: %v", "apps -> v1beta2", k, err)
  124. }
  125. if !apiequality.Semantic.DeepEqual(internal1, tc.stsUpdateStrategy2) {
  126. t.Errorf("%q - %q: expected\n\t%#v, got \n\t%#v", "apps -> v1beta2", k, tc.stsUpdateStrategy2, internal1)
  127. }
  128. // v1beta2 -> apps
  129. internal2 := &apps.StatefulSetUpdateStrategy{}
  130. if err := legacyscheme.Scheme.Convert(tc.stsUpdateStrategy2, internal2, nil); err != nil {
  131. t.Errorf("%q - %q: unexpected error: %v", "v1beta2 -> apps", k, err)
  132. }
  133. if !apiequality.Semantic.DeepEqual(internal2, tc.stsUpdateStrategy1) {
  134. t.Errorf("%q - %q: expected\n\t%#v, got \n\t%#v", "v1beta2 -> apps", k, tc.stsUpdateStrategy1, internal2)
  135. }
  136. }
  137. }
  138. func TestV1beta2RollingUpdateDaemonSetConversion(t *testing.T) {
  139. intorstr := intstr.FromInt(1)
  140. testcases := map[string]struct {
  141. rollingUpdateDs1 *apps.RollingUpdateDaemonSet
  142. rollingUpdateDs2 *v1beta2.RollingUpdateDaemonSet
  143. }{
  144. "RollingUpdateDaemonSet Conversion 2": {
  145. rollingUpdateDs1: &apps.RollingUpdateDaemonSet{MaxUnavailable: intorstr},
  146. rollingUpdateDs2: &v1beta2.RollingUpdateDaemonSet{MaxUnavailable: &intorstr},
  147. },
  148. }
  149. for k, tc := range testcases {
  150. // extensions -> v1beta2
  151. internal1 := &v1beta2.RollingUpdateDaemonSet{}
  152. if err := legacyscheme.Scheme.Convert(tc.rollingUpdateDs1, internal1, nil); err != nil {
  153. t.Errorf("%q - %q: unexpected error: %v", k, "from extensions to v1beta2", err)
  154. }
  155. if !apiequality.Semantic.DeepEqual(internal1, tc.rollingUpdateDs2) {
  156. t.Errorf("%q - %q: expected\n\t%#v, got \n\t%#v", k, "from extensions to v1beta2", tc.rollingUpdateDs2, internal1)
  157. }
  158. // v1beta2 -> extensions
  159. internal2 := &apps.RollingUpdateDaemonSet{}
  160. if err := legacyscheme.Scheme.Convert(tc.rollingUpdateDs2, internal2, nil); err != nil {
  161. t.Errorf("%q - %q: unexpected error: %v", k, "from v1beta2 to extensions", err)
  162. }
  163. if !apiequality.Semantic.DeepEqual(internal2, tc.rollingUpdateDs1) {
  164. t.Errorf("%q - %q: expected\n\t%#v, got \n\t%#v", k, "from v1beta2 to extensions", tc.rollingUpdateDs1, internal2)
  165. }
  166. }
  167. }
  168. func TestV1beta2StatefulSetStatusConversion(t *testing.T) {
  169. observedGeneration := new(int64)
  170. *observedGeneration = 2
  171. collisionCount := new(int32)
  172. *collisionCount = 1
  173. testcases := map[string]struct {
  174. stsStatus1 *apps.StatefulSetStatus
  175. stsStatus2 *v1beta2.StatefulSetStatus
  176. }{
  177. "StatefulSetStatus Conversion 1": {
  178. stsStatus1: &apps.StatefulSetStatus{
  179. Replicas: int32(3),
  180. ReadyReplicas: int32(1),
  181. CurrentReplicas: int32(3),
  182. UpdatedReplicas: int32(3),
  183. CurrentRevision: "12345",
  184. UpdateRevision: "23456",
  185. ObservedGeneration: observedGeneration,
  186. },
  187. stsStatus2: &v1beta2.StatefulSetStatus{
  188. Replicas: int32(3),
  189. ReadyReplicas: int32(1),
  190. CurrentReplicas: int32(3),
  191. UpdatedReplicas: int32(3),
  192. CurrentRevision: "12345",
  193. UpdateRevision: "23456",
  194. ObservedGeneration: *observedGeneration,
  195. },
  196. },
  197. "StatefulSetStatus Conversion 2": {
  198. stsStatus1: &apps.StatefulSetStatus{
  199. ObservedGeneration: observedGeneration,
  200. Replicas: int32(3),
  201. ReadyReplicas: int32(1),
  202. CurrentReplicas: int32(3),
  203. UpdatedReplicas: int32(3),
  204. CurrentRevision: "12345",
  205. UpdateRevision: "23456",
  206. CollisionCount: collisionCount,
  207. },
  208. stsStatus2: &v1beta2.StatefulSetStatus{
  209. ObservedGeneration: *observedGeneration,
  210. Replicas: int32(3),
  211. ReadyReplicas: int32(1),
  212. CurrentReplicas: int32(3),
  213. UpdatedReplicas: int32(3),
  214. CurrentRevision: "12345",
  215. UpdateRevision: "23456",
  216. CollisionCount: collisionCount,
  217. },
  218. },
  219. }
  220. for k, tc := range testcases {
  221. // apps -> v1beta2
  222. internal1 := &v1beta2.StatefulSetStatus{}
  223. if err := legacyscheme.Scheme.Convert(tc.stsStatus1, internal1, nil); err != nil {
  224. t.Errorf("%q - %q: unexpected error: %v", k, "from apps to v1beta2", err)
  225. }
  226. if !apiequality.Semantic.DeepEqual(internal1, tc.stsStatus2) {
  227. t.Errorf("%q - %q: expected\n\t%#v, got \n\t%#v", k, "from apps to v1beta2", tc.stsStatus2, internal1)
  228. }
  229. // v1beta2 -> apps
  230. internal2 := &apps.StatefulSetStatus{}
  231. if err := legacyscheme.Scheme.Convert(tc.stsStatus2, internal2, nil); err != nil {
  232. t.Errorf("%q - %q: unexpected error: %v", k, "from v1beta2 to apps", err)
  233. }
  234. if !apiequality.Semantic.DeepEqual(internal2, tc.stsStatus1) {
  235. t.Errorf("%q - %q: expected\n\t%#v, got \n\t%#v", k, "from v1beta2 to apps", tc.stsStatus1, internal2)
  236. }
  237. }
  238. }
  239. func TestV1beta2DeploymentConversion(t *testing.T) {
  240. replica := utilpointer.Int32Ptr(2)
  241. rollbackTo := new(apps.RollbackConfig)
  242. rollbackTo.Revision = int64(2)
  243. testcases := map[string]struct {
  244. deployment1 *apps.Deployment
  245. deployment2 *v1beta2.Deployment
  246. }{
  247. "Deployment Conversion 1": {
  248. deployment1: &apps.Deployment{
  249. Spec: apps.DeploymentSpec{
  250. Replicas: *replica,
  251. RollbackTo: rollbackTo,
  252. Template: api.PodTemplateSpec{
  253. Spec: api.PodSpec{
  254. SecurityContext: new(api.PodSecurityContext),
  255. },
  256. },
  257. },
  258. },
  259. deployment2: &v1beta2.Deployment{
  260. ObjectMeta: metav1.ObjectMeta{
  261. Annotations: map[string]string{v1beta2.DeprecatedRollbackTo: "2"},
  262. },
  263. Spec: v1beta2.DeploymentSpec{
  264. Replicas: replica,
  265. Template: v1.PodTemplateSpec{
  266. Spec: v1.PodSpec{
  267. SecurityContext: new(v1.PodSecurityContext),
  268. },
  269. },
  270. },
  271. },
  272. },
  273. "Deployment Conversion 2": {
  274. deployment1: &apps.Deployment{
  275. Spec: apps.DeploymentSpec{
  276. Replicas: *replica,
  277. Template: api.PodTemplateSpec{
  278. Spec: api.PodSpec{
  279. SecurityContext: new(api.PodSecurityContext),
  280. },
  281. },
  282. },
  283. },
  284. deployment2: &v1beta2.Deployment{
  285. Spec: v1beta2.DeploymentSpec{
  286. Replicas: replica,
  287. Template: v1.PodTemplateSpec{
  288. Spec: v1.PodSpec{
  289. SecurityContext: new(v1.PodSecurityContext),
  290. },
  291. },
  292. },
  293. },
  294. },
  295. }
  296. for k, tc := range testcases {
  297. // extensions -> v1beta2
  298. internal1 := &v1beta2.Deployment{}
  299. if err := legacyscheme.Scheme.Convert(tc.deployment1, internal1, nil); err != nil {
  300. t.Errorf("%q - %q: unexpected error: %v", k, "from extensions to v1beta2", err)
  301. }
  302. if !apiequality.Semantic.DeepEqual(internal1, tc.deployment2) {
  303. t.Errorf("%q - %q: expected\n\t%#v, got \n\t%#v", k, "from extensions to v1beta2", tc.deployment2, internal1)
  304. }
  305. // v1beta2 -> extensions
  306. internal2 := &apps.Deployment{}
  307. if err := legacyscheme.Scheme.Convert(tc.deployment2, internal2, nil); err != nil {
  308. t.Errorf("%q - %q: unexpected error: %v", k, "from v1beta2 to extensions", err)
  309. }
  310. if !apiequality.Semantic.DeepEqual(internal2, tc.deployment1) {
  311. t.Errorf("%q - %q: expected\n\t%#v, got \n\t%#v", k, "from v1beta2 to extensions", tc.deployment1, internal2)
  312. }
  313. }
  314. }
  315. func TestV1beta2ScaleStatusConversion(t *testing.T) {
  316. matchLabels := map[string]string{"foo": "bar"}
  317. selector1 := &metav1.LabelSelector{MatchLabels: matchLabels}
  318. labelsSelector1, _ := metav1.LabelSelectorAsSelector(selector1)
  319. matchExpressions := []metav1.LabelSelectorRequirement{
  320. {Key: "foo", Operator: metav1.LabelSelectorOpIn, Values: []string{"foo"}},
  321. }
  322. selector2 := &metav1.LabelSelector{MatchLabels: matchLabels, MatchExpressions: matchExpressions}
  323. labelsSelector2, _ := metav1.LabelSelectorAsSelector(selector2)
  324. testcases := map[string]struct {
  325. scaleStatus1 *autoscaling.ScaleStatus
  326. scaleStatus2 *v1beta2.ScaleStatus
  327. }{
  328. "ScaleStatus Conversion 1": {
  329. scaleStatus1: &autoscaling.ScaleStatus{Replicas: 2},
  330. scaleStatus2: &v1beta2.ScaleStatus{Replicas: 2},
  331. },
  332. "ScaleStatus Conversion 2": {
  333. scaleStatus1: &autoscaling.ScaleStatus{Replicas: 2, Selector: labelsSelector1.String()},
  334. scaleStatus2: &v1beta2.ScaleStatus{Replicas: 2, Selector: matchLabels, TargetSelector: labelsSelector1.String()},
  335. },
  336. "ScaleStatus Conversion 3": {
  337. scaleStatus1: &autoscaling.ScaleStatus{Replicas: 2, Selector: labelsSelector2.String()},
  338. scaleStatus2: &v1beta2.ScaleStatus{Replicas: 2, Selector: map[string]string{}, TargetSelector: labelsSelector2.String()},
  339. },
  340. }
  341. for k, tc := range testcases {
  342. // autoscaling -> v1beta2
  343. internal1 := &v1beta2.ScaleStatus{}
  344. if err := legacyscheme.Scheme.Convert(tc.scaleStatus1, internal1, nil); err != nil {
  345. t.Errorf("%q - %q: unexpected error: %v", k, "autoscaling -> v1beta2", err)
  346. }
  347. if !apiequality.Semantic.DeepEqual(internal1, tc.scaleStatus2) {
  348. t.Errorf("%q - %q: expected\n\t%#v, got \n\t%#v", k, "autoscaling -> v1beta2", tc.scaleStatus2, internal1)
  349. }
  350. // v1beta2 -> autoscaling
  351. internal2 := &autoscaling.ScaleStatus{}
  352. if err := legacyscheme.Scheme.Convert(tc.scaleStatus2, internal2, nil); err != nil {
  353. t.Errorf("%q - %q: unexpected error: %v", k, "v1beta2 -> autoscaling", err)
  354. }
  355. if !apiequality.Semantic.DeepEqual(internal2, tc.scaleStatus1) {
  356. t.Errorf("%q - %q: expected\n\t%+v, got \n\t%+v", k, "v1beta2 -> autoscaling", tc.scaleStatus1, internal2)
  357. }
  358. }
  359. }
  360. func TestV1beta2DeploymentSpecConversion(t *testing.T) {
  361. replica := utilpointer.Int32Ptr(2)
  362. revisionHistoryLimit := utilpointer.Int32Ptr(2)
  363. progressDeadlineSeconds := utilpointer.Int32Ptr(2)
  364. testcases := map[string]struct {
  365. deploymentSpec1 *apps.DeploymentSpec
  366. deploymentSpec2 *v1beta2.DeploymentSpec
  367. }{
  368. "DeploymentSpec Conversion 1": {
  369. deploymentSpec1: &apps.DeploymentSpec{
  370. Replicas: *replica,
  371. Template: api.PodTemplateSpec{
  372. Spec: api.PodSpec{
  373. SecurityContext: new(api.PodSecurityContext),
  374. },
  375. },
  376. },
  377. deploymentSpec2: &v1beta2.DeploymentSpec{
  378. Replicas: replica,
  379. Template: v1.PodTemplateSpec{
  380. Spec: v1.PodSpec{
  381. SecurityContext: new(v1.PodSecurityContext),
  382. },
  383. },
  384. },
  385. },
  386. "DeploymentSpec Conversion 2": {
  387. deploymentSpec1: &apps.DeploymentSpec{
  388. Replicas: *replica,
  389. RevisionHistoryLimit: revisionHistoryLimit,
  390. MinReadySeconds: 2,
  391. Paused: true,
  392. Template: api.PodTemplateSpec{
  393. Spec: api.PodSpec{
  394. SecurityContext: new(api.PodSecurityContext),
  395. },
  396. },
  397. },
  398. deploymentSpec2: &v1beta2.DeploymentSpec{
  399. Replicas: replica,
  400. RevisionHistoryLimit: revisionHistoryLimit,
  401. MinReadySeconds: 2,
  402. Paused: true,
  403. Template: v1.PodTemplateSpec{
  404. Spec: v1.PodSpec{
  405. SecurityContext: new(v1.PodSecurityContext),
  406. },
  407. },
  408. },
  409. },
  410. "DeploymentSpec Conversion 3": {
  411. deploymentSpec1: &apps.DeploymentSpec{
  412. Replicas: *replica,
  413. ProgressDeadlineSeconds: progressDeadlineSeconds,
  414. Template: api.PodTemplateSpec{
  415. Spec: api.PodSpec{
  416. SecurityContext: new(api.PodSecurityContext),
  417. },
  418. },
  419. },
  420. deploymentSpec2: &v1beta2.DeploymentSpec{
  421. Replicas: replica,
  422. ProgressDeadlineSeconds: progressDeadlineSeconds,
  423. Template: v1.PodTemplateSpec{
  424. Spec: v1.PodSpec{
  425. SecurityContext: new(v1.PodSecurityContext),
  426. },
  427. },
  428. },
  429. },
  430. }
  431. // extensions -> v1beta2
  432. for k, tc := range testcases {
  433. internal := &v1beta2.DeploymentSpec{}
  434. if err := legacyscheme.Scheme.Convert(tc.deploymentSpec1, internal, nil); err != nil {
  435. t.Errorf("%q - %q: unexpected error: %v", "extensions -> v1beta2", k, err)
  436. }
  437. if !apiequality.Semantic.DeepEqual(internal, tc.deploymentSpec2) {
  438. t.Errorf("%q - %q: expected\n\t%+v, got \n\t%+v", "extensions -> v1beta2", k, tc.deploymentSpec2, internal)
  439. }
  440. }
  441. // v1beta2 -> extensions
  442. for k, tc := range testcases {
  443. internal := &apps.DeploymentSpec{}
  444. if err := legacyscheme.Scheme.Convert(tc.deploymentSpec2, internal, nil); err != nil {
  445. t.Errorf("%q - %q: unexpected error: %v", "v1beta2 -> extensions", k, err)
  446. }
  447. if !apiequality.Semantic.DeepEqual(internal, tc.deploymentSpec1) {
  448. t.Errorf("%q - %q: expected\n\t%+v, got \n\t%+v", "v1beta2 -> extensions", k, tc.deploymentSpec1, internal)
  449. }
  450. }
  451. }
  452. func TestV1beta2DeploymentStrategyConversion(t *testing.T) {
  453. maxUnavailable := intstr.FromInt(2)
  454. maxSurge := intstr.FromInt(2)
  455. extensionsRollingUpdate := apps.RollingUpdateDeployment{MaxUnavailable: maxUnavailable, MaxSurge: maxSurge}
  456. v1beta2RollingUpdate := v1beta2.RollingUpdateDeployment{MaxUnavailable: &maxUnavailable, MaxSurge: &maxSurge}
  457. testcases := map[string]struct {
  458. deploymentStrategy1 *apps.DeploymentStrategy
  459. deploymentStrategy2 *v1beta2.DeploymentStrategy
  460. }{
  461. "DeploymentStrategy Conversion 1": {
  462. deploymentStrategy1: &apps.DeploymentStrategy{Type: apps.DeploymentStrategyType("foo")},
  463. deploymentStrategy2: &v1beta2.DeploymentStrategy{Type: v1beta2.DeploymentStrategyType("foo")},
  464. },
  465. "DeploymentStrategy Conversion 2": {
  466. deploymentStrategy1: &apps.DeploymentStrategy{Type: apps.DeploymentStrategyType("foo"), RollingUpdate: &extensionsRollingUpdate},
  467. deploymentStrategy2: &v1beta2.DeploymentStrategy{Type: v1beta2.DeploymentStrategyType("foo"), RollingUpdate: &v1beta2RollingUpdate},
  468. },
  469. }
  470. for k, tc := range testcases {
  471. // extensions -> v1beta2
  472. internal1 := &v1beta2.DeploymentStrategy{}
  473. if err := legacyscheme.Scheme.Convert(tc.deploymentStrategy1, internal1, nil); err != nil {
  474. t.Errorf("%q - %q: unexpected error: %v", k, "extensions -> v1beta2", err)
  475. }
  476. if !apiequality.Semantic.DeepEqual(internal1, tc.deploymentStrategy2) {
  477. t.Errorf("%q - %q: expected\n\t%#v, got \n\t%#v", k, "extensions -> v1beta2", tc.deploymentStrategy2, internal1)
  478. }
  479. // v1beta2 -> extensions
  480. internal2 := &apps.DeploymentStrategy{}
  481. if err := legacyscheme.Scheme.Convert(tc.deploymentStrategy2, internal2, nil); err != nil {
  482. t.Errorf("%q - %q: unexpected error: %v", k, "v1beta2 -> extensions", err)
  483. }
  484. if !apiequality.Semantic.DeepEqual(internal2, tc.deploymentStrategy1) {
  485. t.Errorf("%q - %q: expected\n\t%#v, got \n\t%#v", k, "v1beta2 -> extensions", tc.deploymentStrategy1, internal2)
  486. }
  487. }
  488. }
  489. func TestV1beta2RollingUpdateDeploymentConversion(t *testing.T) {
  490. nilIntStr := intstr.IntOrString{}
  491. maxUnavailable := intstr.FromInt(2)
  492. maxSurge := intstr.FromInt(2)
  493. testcases := map[string]struct {
  494. rollingUpdateDeployment1 *apps.RollingUpdateDeployment
  495. rollingUpdateDeployment2 *v1beta2.RollingUpdateDeployment
  496. }{
  497. "RollingUpdateDeployment Conversion 1": {
  498. rollingUpdateDeployment1: &apps.RollingUpdateDeployment{},
  499. rollingUpdateDeployment2: &v1beta2.RollingUpdateDeployment{MaxUnavailable: &nilIntStr, MaxSurge: &nilIntStr},
  500. },
  501. "RollingUpdateDeployment Conversion 2": {
  502. rollingUpdateDeployment1: &apps.RollingUpdateDeployment{MaxUnavailable: maxUnavailable},
  503. rollingUpdateDeployment2: &v1beta2.RollingUpdateDeployment{MaxUnavailable: &maxUnavailable, MaxSurge: &nilIntStr},
  504. },
  505. "RollingUpdateDeployment Conversion 3": {
  506. rollingUpdateDeployment1: &apps.RollingUpdateDeployment{MaxSurge: maxSurge},
  507. rollingUpdateDeployment2: &v1beta2.RollingUpdateDeployment{MaxSurge: &maxSurge, MaxUnavailable: &nilIntStr},
  508. },
  509. "RollingUpdateDeployment Conversion 4": {
  510. rollingUpdateDeployment1: &apps.RollingUpdateDeployment{MaxUnavailable: maxUnavailable, MaxSurge: maxSurge},
  511. rollingUpdateDeployment2: &v1beta2.RollingUpdateDeployment{MaxUnavailable: &maxUnavailable, MaxSurge: &maxSurge},
  512. },
  513. }
  514. for k, tc := range testcases {
  515. // extensions -> v1beta2
  516. internal1 := &v1beta2.RollingUpdateDeployment{}
  517. if err := legacyscheme.Scheme.Convert(tc.rollingUpdateDeployment1, internal1, nil); err != nil {
  518. t.Errorf("%q - %q: unexpected error: %v", k, "extensions -> v1beta2", err)
  519. }
  520. if !apiequality.Semantic.DeepEqual(internal1, tc.rollingUpdateDeployment2) {
  521. t.Errorf("%q - %q: expected\n\t%#v, got \n\t%#v", k, "extensions -> v1beta2", tc.rollingUpdateDeployment2, internal1)
  522. }
  523. // v1beta2 -> extensions
  524. internal2 := &apps.RollingUpdateDeployment{}
  525. if err := legacyscheme.Scheme.Convert(tc.rollingUpdateDeployment2, internal2, nil); err != nil {
  526. t.Errorf("%q - %q: unexpected error: %v", k, "v1beta2 -> extensions", err)
  527. }
  528. if !apiequality.Semantic.DeepEqual(internal2, tc.rollingUpdateDeployment1) {
  529. t.Errorf("%q - %q: expected\n\t%#v, got \n\t%#v", k, "v1beta2 -> extensions", tc.rollingUpdateDeployment1, internal2)
  530. }
  531. }
  532. }
  533. func TestV1beta2ReplicaSetSpecConversion(t *testing.T) {
  534. replicas := new(int32)
  535. *replicas = 2
  536. matchExpressions := []metav1.LabelSelectorRequirement{
  537. {Key: "foo", Operator: metav1.LabelSelectorOpIn, Values: []string{"foo"}},
  538. }
  539. matchLabels := map[string]string{"foo": "bar"}
  540. selector := &metav1.LabelSelector{MatchLabels: matchLabels, MatchExpressions: matchExpressions}
  541. testcases := map[string]struct {
  542. replicaset1 *apps.ReplicaSetSpec
  543. replicaset2 *v1beta2.ReplicaSetSpec
  544. }{
  545. "ReplicaSetSpec Conversion 1": {
  546. replicaset1: &apps.ReplicaSetSpec{
  547. Replicas: *replicas,
  548. MinReadySeconds: 2,
  549. Template: api.PodTemplateSpec{
  550. Spec: api.PodSpec{
  551. SecurityContext: new(api.PodSecurityContext),
  552. },
  553. },
  554. },
  555. replicaset2: &v1beta2.ReplicaSetSpec{
  556. Replicas: replicas,
  557. MinReadySeconds: 2,
  558. Template: v1.PodTemplateSpec{
  559. Spec: v1.PodSpec{
  560. SecurityContext: new(v1.PodSecurityContext),
  561. },
  562. },
  563. },
  564. },
  565. "ReplicaSetSpec Conversion 2": {
  566. replicaset1: &apps.ReplicaSetSpec{
  567. Replicas: *replicas,
  568. Selector: selector,
  569. Template: api.PodTemplateSpec{
  570. Spec: api.PodSpec{
  571. SecurityContext: new(api.PodSecurityContext),
  572. },
  573. },
  574. },
  575. replicaset2: &v1beta2.ReplicaSetSpec{
  576. Replicas: replicas,
  577. Selector: selector,
  578. Template: v1.PodTemplateSpec{
  579. Spec: v1.PodSpec{
  580. SecurityContext: new(v1.PodSecurityContext),
  581. },
  582. },
  583. },
  584. },
  585. }
  586. for k, tc := range testcases {
  587. // extensions -> v1beta2
  588. internal1 := &v1beta2.ReplicaSetSpec{}
  589. if err := legacyscheme.Scheme.Convert(tc.replicaset1, internal1, nil); err != nil {
  590. t.Errorf("%q - %q: unexpected error: %v", k, "extensions -> v1beta2", err)
  591. }
  592. if !apiequality.Semantic.DeepEqual(internal1, tc.replicaset2) {
  593. t.Errorf("%q - %q: expected\n\t%+v, got \n\t%+v", k, "extensions -> v1beta2", tc.replicaset2, internal1)
  594. }
  595. // v1beta2 -> extensions
  596. internal2 := &apps.ReplicaSetSpec{}
  597. if err := legacyscheme.Scheme.Convert(tc.replicaset2, internal2, nil); err != nil {
  598. t.Errorf("%q - %q: unexpected error: %v", k, "v1beta2 -> extensions", err)
  599. }
  600. if !apiequality.Semantic.DeepEqual(internal2, tc.replicaset1) {
  601. t.Errorf("%q - %q: expected\n\t%+v, got \n\t%+v", k, "v1beta2 -> extensions", tc.replicaset1, internal2)
  602. }
  603. }
  604. }