1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641264226432644264526462647264826492650265126522653265426552656265726582659266026612662266326642665266626672668266926702671267226732674267526762677267826792680268126822683268426852686268726882689269026912692269326942695269626972698269927002701270227032704270527062707270827092710271127122713271427152716271727182719272027212722272327242725272627272728272927302731273227332734273527362737273827392740274127422743274427452746274727482749275027512752275327542755275627572758275927602761276227632764276527662767276827692770277127722773277427752776277727782779278027812782278327842785278627872788278927902791279227932794279527962797279827992800280128022803280428052806280728082809281028112812281328142815281628172818281928202821282228232824282528262827282828292830283128322833283428352836283728382839284028412842284328442845284628472848284928502851285228532854285528562857285828592860286128622863286428652866286728682869287028712872287328742875287628772878287928802881288228832884288528862887288828892890289128922893289428952896289728982899290029012902290329042905290629072908290929102911291229132914291529162917291829192920292129222923292429252926292729282929293029312932293329342935 |
- /*
- Copyright 2016 The Kubernetes Authors.
- Licensed under the Apache License, Version 2.0 (the "License");
- you may not use this file except in compliance with the License.
- You may obtain a copy of the License at
- http://www.apache.org/licenses/LICENSE-2.0
- Unless required by applicable law or agreed to in writing, software
- distributed under the License is distributed on an "AS IS" BASIS,
- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- See the License for the specific language governing permissions and
- limitations under the License.
- */
- package validation
- import (
- "strconv"
- "strings"
- "testing"
- "github.com/davecgh/go-spew/spew"
- metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
- "k8s.io/apimachinery/pkg/runtime"
- "k8s.io/apimachinery/pkg/util/intstr"
- "k8s.io/apimachinery/pkg/util/validation/field"
- "k8s.io/kubernetes/pkg/apis/apps"
- api "k8s.io/kubernetes/pkg/apis/core"
- )
- func TestValidateStatefulSet(t *testing.T) {
- validLabels := map[string]string{"a": "b"}
- validPodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validLabels,
- },
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "abc", Image: "image", ImagePullPolicy: "IfNotPresent"}},
- },
- },
- }
- invalidLabels := map[string]string{"NoUppercaseOrSpecialCharsLike=Equals": "b"}
- invalidPodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: invalidLabels,
- },
- },
- }
- invalidTime := int64(60)
- invalidPodTemplate2 := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: map[string]string{"foo": "bar"},
- },
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyOnFailure,
- DNSPolicy: api.DNSClusterFirst,
- ActiveDeadlineSeconds: &invalidTime,
- },
- },
- }
- successCases := []apps.StatefulSet{
- {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.ParallelPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.OnDeleteStatefulSetStrategyType},
- },
- },
- {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- Replicas: 3,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{
- Type: apps.RollingUpdateStatefulSetStrategyType,
- RollingUpdate: func() *apps.RollingUpdateStatefulSetStrategy {
- return &apps.RollingUpdateStatefulSetStrategy{Partition: 2}
- }()},
- },
- },
- }
- for i, successCase := range successCases {
- t.Run("success case "+strconv.Itoa(i), func(t *testing.T) {
- if errs := ValidateStatefulSet(&successCase); len(errs) != 0 {
- t.Errorf("expected success: %v", errs)
- }
- })
- }
- errorCases := map[string]apps.StatefulSet{
- "zero-length ID": {
- ObjectMeta: metav1.ObjectMeta{Name: "", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- "missing-namespace": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123"},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- "empty selector": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- "selector_doesnt_match": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: map[string]string{"foo": "bar"}},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- "invalid manifest": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- "negative_replicas": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Replicas: -1,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- "invalid_label": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- Labels: map[string]string{
- "NoUppercaseOrSpecialCharsLike=Equals": "bar",
- },
- },
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- "invalid_label 2": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- Labels: map[string]string{
- "NoUppercaseOrSpecialCharsLike=Equals": "bar",
- },
- },
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Template: invalidPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- "invalid_annotation": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- Annotations: map[string]string{
- "NoUppercaseOrSpecialCharsLike=Equals": "bar",
- },
- },
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- "invalid restart policy 1": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- },
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyOnFailure,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "ctr", Image: "image", ImagePullPolicy: "IfNotPresent"}},
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: validLabels,
- },
- },
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- "invalid restart policy 2": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- },
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyNever,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "ctr", Image: "image", ImagePullPolicy: "IfNotPresent"}},
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: validLabels,
- },
- },
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- "invalid update strategy": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- Replicas: 3,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: "foo"},
- },
- },
- "empty update strategy": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- Replicas: 3,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: ""},
- },
- },
- "invalid rolling update": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- Replicas: 3,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.OnDeleteStatefulSetStrategyType,
- RollingUpdate: func() *apps.RollingUpdateStatefulSetStrategy {
- return &apps.RollingUpdateStatefulSetStrategy{Partition: 1}
- }()},
- },
- },
- "negative parition": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- Replicas: 3,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType,
- RollingUpdate: func() *apps.RollingUpdateStatefulSetStrategy {
- return &apps.RollingUpdateStatefulSetStrategy{Partition: -1}
- }()},
- },
- },
- "empty pod management policy": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: "",
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- Replicas: 3,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- "invalid pod management policy": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: "foo",
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- Replicas: 3,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- "set active deadline seconds": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: "foo",
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: invalidPodTemplate2.Template,
- Replicas: 3,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- }
- for k, v := range errorCases {
- t.Run(k, func(t *testing.T) {
- errs := ValidateStatefulSet(&v)
- if len(errs) == 0 {
- t.Errorf("expected failure for %s", k)
- }
- for i := range errs {
- field := errs[i].Field
- if !strings.HasPrefix(field, "spec.template.") &&
- field != "metadata.name" &&
- field != "metadata.namespace" &&
- field != "spec.selector" &&
- field != "spec.template" &&
- field != "GCEPersistentDisk.ReadOnly" &&
- field != "spec.replicas" &&
- field != "spec.template.labels" &&
- field != "metadata.annotations" &&
- field != "metadata.labels" &&
- field != "status.replicas" &&
- field != "spec.updateStrategy" &&
- field != "spec.updateStrategy.rollingUpdate" &&
- field != "spec.updateStrategy.rollingUpdate.partition" &&
- field != "spec.podManagementPolicy" &&
- field != "spec.template.spec.activeDeadlineSeconds" {
- t.Errorf("%s: missing prefix for: %v", k, errs[i])
- }
- }
- })
- }
- }
- func TestValidateStatefulSetStatus(t *testing.T) {
- observedGenerationMinusOne := int64(-1)
- collisionCountMinusOne := int32(-1)
- tests := []struct {
- name string
- replicas int32
- readyReplicas int32
- currentReplicas int32
- updatedReplicas int32
- observedGeneration *int64
- collisionCount *int32
- expectedErr bool
- }{
- {
- name: "valid status",
- replicas: 3,
- readyReplicas: 3,
- currentReplicas: 2,
- updatedReplicas: 1,
- expectedErr: false,
- },
- {
- name: "invalid replicas",
- replicas: -1,
- readyReplicas: 3,
- currentReplicas: 2,
- updatedReplicas: 1,
- expectedErr: true,
- },
- {
- name: "invalid readyReplicas",
- replicas: 3,
- readyReplicas: -1,
- currentReplicas: 2,
- updatedReplicas: 1,
- expectedErr: true,
- },
- {
- name: "invalid currentReplicas",
- replicas: 3,
- readyReplicas: 3,
- currentReplicas: -1,
- updatedReplicas: 1,
- expectedErr: true,
- },
- {
- name: "invalid updatedReplicas",
- replicas: 3,
- readyReplicas: 3,
- currentReplicas: 2,
- updatedReplicas: -1,
- expectedErr: true,
- },
- {
- name: "invalid observedGeneration",
- replicas: 3,
- readyReplicas: 3,
- currentReplicas: 2,
- updatedReplicas: 1,
- observedGeneration: &observedGenerationMinusOne,
- expectedErr: true,
- },
- {
- name: "invalid collisionCount",
- replicas: 3,
- readyReplicas: 3,
- currentReplicas: 2,
- updatedReplicas: 1,
- collisionCount: &collisionCountMinusOne,
- expectedErr: true,
- },
- {
- name: "readyReplicas greater than replicas",
- replicas: 3,
- readyReplicas: 4,
- currentReplicas: 2,
- updatedReplicas: 1,
- expectedErr: true,
- },
- {
- name: "currentReplicas greater than replicas",
- replicas: 3,
- readyReplicas: 3,
- currentReplicas: 4,
- updatedReplicas: 1,
- expectedErr: true,
- },
- {
- name: "updatedReplicas greater than replicas",
- replicas: 3,
- readyReplicas: 3,
- currentReplicas: 2,
- updatedReplicas: 4,
- expectedErr: true,
- },
- }
- for _, test := range tests {
- t.Run(test.name, func(t *testing.T) {
- status := apps.StatefulSetStatus{
- Replicas: test.replicas,
- ReadyReplicas: test.readyReplicas,
- CurrentReplicas: test.currentReplicas,
- UpdatedReplicas: test.updatedReplicas,
- ObservedGeneration: test.observedGeneration,
- CollisionCount: test.collisionCount,
- }
- errs := ValidateStatefulSetStatus(&status, field.NewPath("status"))
- if hasErr := len(errs) > 0; hasErr != test.expectedErr {
- t.Errorf("%s: expected error: %t, got error: %t\nerrors: %s", test.name, test.expectedErr, hasErr, errs.ToAggregate().Error())
- }
- })
- }
- }
- func TestValidateStatefulSetUpdate(t *testing.T) {
- validLabels := map[string]string{"a": "b"}
- validPodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validLabels,
- },
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "abc", Image: "image", ImagePullPolicy: "IfNotPresent"}},
- },
- },
- }
- addContainersValidTemplate := validPodTemplate.DeepCopy()
- addContainersValidTemplate.Template.Spec.Containers = append(addContainersValidTemplate.Template.Spec.Containers,
- api.Container{Name: "def", Image: "image2", ImagePullPolicy: "IfNotPresent"})
- if len(addContainersValidTemplate.Template.Spec.Containers) != len(validPodTemplate.Template.Spec.Containers)+1 {
- t.Errorf("failure during test setup: template %v should have more containers than template %v", addContainersValidTemplate, validPodTemplate)
- }
- readWriteVolumePodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validLabels,
- },
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "abc", Image: "image", ImagePullPolicy: "IfNotPresent"}},
- Volumes: []api.Volume{{Name: "gcepd", VolumeSource: api.VolumeSource{GCEPersistentDisk: &api.GCEPersistentDiskVolumeSource{PDName: "my-PD", FSType: "ext4", Partition: 1, ReadOnly: false}}}},
- },
- },
- }
- invalidLabels := map[string]string{"NoUppercaseOrSpecialCharsLike=Equals": "b"}
- invalidPodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: invalidLabels,
- },
- },
- }
- type psUpdateTest struct {
- old apps.StatefulSet
- update apps.StatefulSet
- }
- successCases := []psUpdateTest{
- {
- old: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- update: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Replicas: 3,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- },
- {
- old: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- update: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: addContainersValidTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- },
- {
- old: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: addContainersValidTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- update: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- },
- }
- for i, successCase := range successCases {
- t.Run("success case "+strconv.Itoa(i), func(t *testing.T) {
- successCase.old.ObjectMeta.ResourceVersion = "1"
- successCase.update.ObjectMeta.ResourceVersion = "1"
- if errs := ValidateStatefulSetUpdate(&successCase.update, &successCase.old); len(errs) != 0 {
- t.Errorf("expected success: %v", errs)
- }
- })
- }
- errorCases := map[string]psUpdateTest{
- "more than one read/write": {
- old: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- update: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Replicas: 2,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: readWriteVolumePodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- },
- "empty pod creation policy": {
- old: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- update: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- Replicas: 3,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- },
- "invalid pod creation policy": {
- old: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- update: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.PodManagementPolicyType("Other"),
- Replicas: 3,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- },
- "invalid selector": {
- old: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- update: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Replicas: 2,
- Selector: &metav1.LabelSelector{MatchLabels: invalidLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- },
- "invalid pod": {
- old: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- update: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- Replicas: 2,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: invalidPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- },
- "negative replicas": {
- old: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- update: apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- PodManagementPolicy: apps.OrderedReadyPodManagement,
- Replicas: -1,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.StatefulSetUpdateStrategy{Type: apps.RollingUpdateStatefulSetStrategyType},
- },
- },
- },
- }
- for testName, errorCase := range errorCases {
- t.Run(testName, func(t *testing.T) {
- if errs := ValidateStatefulSetUpdate(&errorCase.update, &errorCase.old); len(errs) == 0 {
- t.Errorf("expected failure: %s", testName)
- }
- })
- }
- }
- func TestValidateControllerRevision(t *testing.T) {
- newControllerRevision := func(name, namespace string, data runtime.Object, revision int64) apps.ControllerRevision {
- return apps.ControllerRevision{
- ObjectMeta: metav1.ObjectMeta{
- Name: name,
- Namespace: namespace,
- },
- Data: data,
- Revision: revision,
- }
- }
- ss := apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: map[string]string{"foo": "bar"}},
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: map[string]string{"foo": "bar"},
- },
- },
- },
- }
- var (
- valid = newControllerRevision("validname", "validns", &ss, 0)
- badRevision = newControllerRevision("validname", "validns", &ss, -1)
- emptyName = newControllerRevision("", "validns", &ss, 0)
- invalidName = newControllerRevision("NoUppercaseOrSpecialCharsLike=Equals", "validns", &ss, 0)
- emptyNs = newControllerRevision("validname", "", &ss, 100)
- invalidNs = newControllerRevision("validname", "NoUppercaseOrSpecialCharsLike=Equals", &ss, 100)
- nilData = newControllerRevision("validname", "NoUppercaseOrSpecialCharsLike=Equals", nil, 100)
- )
- tests := map[string]struct {
- history apps.ControllerRevision
- isValid bool
- }{
- "valid": {valid, true},
- "negative revision": {badRevision, false},
- "empty name": {emptyName, false},
- "invalid name": {invalidName, false},
- "empty namespace": {emptyNs, false},
- "invalid namespace": {invalidNs, false},
- "nil data": {nilData, false},
- }
- for name, tc := range tests {
- t.Run(name, func(t *testing.T) {
- errs := ValidateControllerRevision(&tc.history)
- if tc.isValid && len(errs) > 0 {
- t.Errorf("%v: unexpected error: %v", name, errs)
- }
- if !tc.isValid && len(errs) == 0 {
- t.Errorf("%v: unexpected non-error", name)
- }
- })
- }
- }
- func TestValidateControllerRevisionUpdate(t *testing.T) {
- newControllerRevision := func(version, name, namespace string, data runtime.Object, revision int64) apps.ControllerRevision {
- return apps.ControllerRevision{
- ObjectMeta: metav1.ObjectMeta{
- Name: name,
- Namespace: namespace,
- ResourceVersion: version,
- },
- Data: data,
- Revision: revision,
- }
- }
- ss := apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: map[string]string{"foo": "bar"}},
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: map[string]string{"foo": "bar"},
- },
- },
- },
- }
- modifiedss := apps.StatefulSet{
- ObjectMeta: metav1.ObjectMeta{Name: "cdf", Namespace: metav1.NamespaceDefault},
- Spec: apps.StatefulSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: map[string]string{"foo": "bar"}},
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: map[string]string{"foo": "bar"},
- },
- },
- },
- }
- var (
- valid = newControllerRevision("1", "validname", "validns", &ss, 0)
- noVersion = newControllerRevision("", "validname", "validns", &ss, 0)
- changedData = newControllerRevision("1", "validname", "validns", &modifiedss, 0)
- changedRevision = newControllerRevision("1", "validname", "validns", &ss, 1)
- )
- cases := []struct {
- name string
- newHistory apps.ControllerRevision
- oldHistory apps.ControllerRevision
- isValid bool
- }{
- {
- name: "valid",
- newHistory: valid,
- oldHistory: valid,
- isValid: true,
- },
- {
- name: "invalid",
- newHistory: noVersion,
- oldHistory: valid,
- isValid: false,
- },
- {
- name: "changed data",
- newHistory: changedData,
- oldHistory: valid,
- isValid: false,
- },
- {
- name: "changed revision",
- newHistory: changedRevision,
- oldHistory: valid,
- isValid: true,
- },
- }
- for _, tc := range cases {
- t.Run(tc.name, func(t *testing.T) {
- errs := ValidateControllerRevisionUpdate(&tc.newHistory, &tc.oldHistory)
- if tc.isValid && len(errs) > 0 {
- t.Errorf("%v: unexpected error: %v", tc.name, errs)
- }
- if !tc.isValid && len(errs) == 0 {
- t.Errorf("%v: unexpected non-error", tc.name)
- }
- })
- }
- }
- func TestValidateDaemonSetStatusUpdate(t *testing.T) {
- type dsUpdateTest struct {
- old apps.DaemonSet
- update apps.DaemonSet
- }
- successCases := []dsUpdateTest{
- {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 2,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 1,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- },
- }
- for _, successCase := range successCases {
- successCase.old.ObjectMeta.ResourceVersion = "1"
- successCase.update.ObjectMeta.ResourceVersion = "1"
- if errs := ValidateDaemonSetStatusUpdate(&successCase.update, &successCase.old); len(errs) != 0 {
- t.Errorf("expected success: %v", errs)
- }
- }
- errorCases := map[string]dsUpdateTest{
- "negative values": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 2,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: -1,
- NumberMisscheduled: -1,
- DesiredNumberScheduled: -3,
- NumberReady: -1,
- ObservedGeneration: -3,
- UpdatedNumberScheduled: -1,
- NumberAvailable: -1,
- NumberUnavailable: -2,
- },
- },
- },
- "negative CurrentNumberScheduled": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 2,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: -1,
- NumberMisscheduled: 1,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- },
- "negative NumberMisscheduled": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 2,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: -1,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- },
- "negative DesiredNumberScheduled": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 2,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 1,
- DesiredNumberScheduled: -3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- },
- "negative NumberReady": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 2,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 1,
- DesiredNumberScheduled: 3,
- NumberReady: -1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- },
- "negative ObservedGeneration": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 2,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 1,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: -3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- },
- "negative UpdatedNumberScheduled": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 2,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 1,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: -1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- },
- "negative NumberAvailable": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 2,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 1,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: -1,
- NumberUnavailable: 2,
- },
- },
- },
- "negative NumberUnavailable": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 2,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: 2,
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- ResourceVersion: "10",
- },
- Status: apps.DaemonSetStatus{
- CurrentNumberScheduled: 1,
- NumberMisscheduled: 1,
- DesiredNumberScheduled: 3,
- NumberReady: 1,
- ObservedGeneration: 3,
- UpdatedNumberScheduled: 1,
- NumberAvailable: 1,
- NumberUnavailable: -2,
- },
- },
- },
- }
- for testName, errorCase := range errorCases {
- if errs := ValidateDaemonSetStatusUpdate(&errorCase.update, &errorCase.old); len(errs) == 0 {
- t.Errorf("expected failure: %s", testName)
- }
- }
- }
- func TestValidateDaemonSetUpdate(t *testing.T) {
- validSelector := map[string]string{"a": "b"}
- validSelector2 := map[string]string{"c": "d"}
- invalidSelector := map[string]string{"NoUppercaseOrSpecialCharsLike=Equals": "b"}
- validPodSpecAbc := api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "abc", Image: "image", ImagePullPolicy: "IfNotPresent", TerminationMessagePolicy: api.TerminationMessageReadFile}},
- }
- validPodSpecDef := api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "def", Image: "image", ImagePullPolicy: "IfNotPresent", TerminationMessagePolicy: api.TerminationMessageReadFile}},
- }
- validPodSpecNodeSelector := api.PodSpec{
- NodeSelector: validSelector,
- NodeName: "xyz",
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "abc", Image: "image", ImagePullPolicy: "IfNotPresent", TerminationMessagePolicy: api.TerminationMessageReadFile}},
- }
- validPodSpecVolume := api.PodSpec{
- Volumes: []api.Volume{{Name: "gcepd", VolumeSource: api.VolumeSource{GCEPersistentDisk: &api.GCEPersistentDiskVolumeSource{PDName: "my-PD", FSType: "ext4", Partition: 1, ReadOnly: false}}}},
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "abc", Image: "image", ImagePullPolicy: "IfNotPresent", TerminationMessagePolicy: api.TerminationMessageReadFile}},
- }
- validPodTemplateAbc := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validSelector,
- },
- Spec: validPodSpecAbc,
- },
- }
- validPodTemplateAbcSemanticallyEqual := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validSelector,
- },
- Spec: validPodSpecAbc,
- },
- }
- validPodTemplateAbcSemanticallyEqual.Template.Spec.ImagePullSecrets = []api.LocalObjectReference{}
- validPodTemplateNodeSelector := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validSelector,
- },
- Spec: validPodSpecNodeSelector,
- },
- }
- validPodTemplateAbc2 := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validSelector2,
- },
- Spec: validPodSpecAbc,
- },
- }
- validPodTemplateDef := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validSelector2,
- },
- Spec: validPodSpecDef,
- },
- }
- invalidPodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- // no containers specified
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: validSelector,
- },
- },
- }
- readWriteVolumePodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validSelector,
- },
- Spec: validPodSpecVolume,
- },
- }
- type dsUpdateTest struct {
- old apps.DaemonSet
- update apps.DaemonSet
- expectedErrNum int
- }
- successCases := map[string]dsUpdateTest{
- "no change": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 1,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 1,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- },
- "change template and selector": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 2,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector2},
- TemplateGeneration: 3,
- Template: validPodTemplateAbc2.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- },
- "change template": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 3,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 4,
- Template: validPodTemplateNodeSelector.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- },
- "change container image name": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 1,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector2},
- TemplateGeneration: 2,
- Template: validPodTemplateDef.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- },
- "change update strategy": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 4,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 4,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.RollingUpdateDaemonSetStrategyType,
- RollingUpdate: &apps.RollingUpdateDaemonSet{
- MaxUnavailable: intstr.FromInt(1),
- },
- },
- },
- },
- },
- "unchanged templateGeneration upon semantically equal template update": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 4,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 4,
- Template: validPodTemplateAbcSemanticallyEqual.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.RollingUpdateDaemonSetStrategyType,
- RollingUpdate: &apps.RollingUpdateDaemonSet{
- MaxUnavailable: intstr.FromInt(1),
- },
- },
- },
- },
- },
- }
- for testName, successCase := range successCases {
- // ResourceVersion is required for updates.
- successCase.old.ObjectMeta.ResourceVersion = "1"
- successCase.update.ObjectMeta.ResourceVersion = "2"
- // Check test setup
- if successCase.expectedErrNum > 0 {
- t.Errorf("%q has incorrect test setup with expectedErrNum %d, expected no error", testName, successCase.expectedErrNum)
- }
- if len(successCase.old.ObjectMeta.ResourceVersion) == 0 || len(successCase.update.ObjectMeta.ResourceVersion) == 0 {
- t.Errorf("%q has incorrect test setup with no resource version set", testName)
- }
- if errs := ValidateDaemonSetUpdate(&successCase.update, &successCase.old); len(errs) != 0 {
- t.Errorf("%q expected no error, but got: %v", testName, errs)
- }
- }
- errorCases := map[string]dsUpdateTest{
- "change daemon name": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 1,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 1,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- expectedErrNum: 1,
- },
- "invalid selector": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 1,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: invalidSelector},
- TemplateGeneration: 1,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- expectedErrNum: 1,
- },
- "invalid pod": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 1,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 2,
- Template: invalidPodTemplate.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- expectedErrNum: 1,
- },
- "invalid read-write volume": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 1,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 2,
- Template: readWriteVolumePodTemplate.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- expectedErrNum: 1,
- },
- "invalid update strategy": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 1,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: 1,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: "Random",
- },
- },
- },
- expectedErrNum: 1,
- },
- "negative templateGeneration": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: -1,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- TemplateGeneration: -1,
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- expectedErrNum: 1,
- },
- "decreased templateGeneration": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- TemplateGeneration: 2,
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- TemplateGeneration: 1,
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- expectedErrNum: 1,
- },
- "unchanged templateGeneration upon template update": {
- old: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- TemplateGeneration: 2,
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- Template: validPodTemplateAbc.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- update: apps.DaemonSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- TemplateGeneration: 2,
- Selector: &metav1.LabelSelector{MatchLabels: validSelector2},
- Template: validPodTemplateAbc2.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- expectedErrNum: 1,
- },
- }
- for testName, errorCase := range errorCases {
- // ResourceVersion is required for updates.
- errorCase.old.ObjectMeta.ResourceVersion = "1"
- errorCase.update.ObjectMeta.ResourceVersion = "2"
- // Check test setup
- if errorCase.expectedErrNum <= 0 {
- t.Errorf("%q has incorrect test setup with expectedErrNum %d, expected at least one error", testName, errorCase.expectedErrNum)
- }
- if len(errorCase.old.ObjectMeta.ResourceVersion) == 0 || len(errorCase.update.ObjectMeta.ResourceVersion) == 0 {
- t.Errorf("%q has incorrect test setup with no resource version set", testName)
- }
- // Run the tests
- if errs := ValidateDaemonSetUpdate(&errorCase.update, &errorCase.old); len(errs) != errorCase.expectedErrNum {
- t.Errorf("%q expected %d errors, but got %d error: %v", testName, errorCase.expectedErrNum, len(errs), errs)
- } else {
- t.Logf("(PASS) %q got errors %v", testName, errs)
- }
- }
- }
- func TestValidateDaemonSet(t *testing.T) {
- validSelector := map[string]string{"a": "b"}
- validPodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validSelector,
- },
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "abc", Image: "image", ImagePullPolicy: "IfNotPresent", TerminationMessagePolicy: api.TerminationMessageReadFile}},
- },
- },
- }
- invalidSelector := map[string]string{"NoUppercaseOrSpecialCharsLike=Equals": "b"}
- invalidPodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: invalidSelector,
- },
- },
- }
- successCases := []apps.DaemonSet{
- {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- Template: validPodTemplate.Template,
- UpdateStrategy: apps.DaemonSetUpdateStrategy{
- Type: apps.OnDeleteDaemonSetStrategyType,
- },
- },
- },
- }
- for _, successCase := range successCases {
- if errs := ValidateDaemonSet(&successCase); len(errs) != 0 {
- t.Errorf("expected success: %v", errs)
- }
- }
- errorCases := map[string]apps.DaemonSet{
- "zero-length ID": {
- ObjectMeta: metav1.ObjectMeta{Name: "", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- Template: validPodTemplate.Template,
- },
- },
- "missing-namespace": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123"},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- Template: validPodTemplate.Template,
- },
- },
- "nil selector": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Template: validPodTemplate.Template,
- },
- },
- "empty selector": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{},
- Template: validPodTemplate.Template,
- },
- },
- "selector_doesnt_match": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: map[string]string{"foo": "bar"}},
- Template: validPodTemplate.Template,
- },
- },
- "invalid template": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- },
- },
- "invalid_label": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- Labels: map[string]string{
- "NoUppercaseOrSpecialCharsLike=Equals": "bar",
- },
- },
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- Template: validPodTemplate.Template,
- },
- },
- "invalid_label 2": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- Labels: map[string]string{
- "NoUppercaseOrSpecialCharsLike=Equals": "bar",
- },
- },
- Spec: apps.DaemonSetSpec{
- Template: invalidPodTemplate.Template,
- },
- },
- "invalid_annotation": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- Annotations: map[string]string{
- "NoUppercaseOrSpecialCharsLike=Equals": "bar",
- },
- },
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- Template: validPodTemplate.Template,
- },
- },
- "invalid restart policy 1": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- },
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyOnFailure,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "ctr", Image: "image", ImagePullPolicy: "IfNotPresent", TerminationMessagePolicy: api.TerminationMessageReadFile}},
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: validSelector,
- },
- },
- },
- },
- "invalid restart policy 2": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- },
- Spec: apps.DaemonSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validSelector},
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyNever,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "ctr", Image: "image", ImagePullPolicy: "IfNotPresent", TerminationMessagePolicy: api.TerminationMessageReadFile}},
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: validSelector,
- },
- },
- },
- },
- }
- for k, v := range errorCases {
- errs := ValidateDaemonSet(&v)
- if len(errs) == 0 {
- t.Errorf("expected failure for %s", k)
- }
- for i := range errs {
- field := errs[i].Field
- if !strings.HasPrefix(field, "spec.template.") &&
- !strings.HasPrefix(field, "spec.updateStrategy") &&
- field != "metadata.name" &&
- field != "metadata.namespace" &&
- field != "spec.selector" &&
- field != "spec.template" &&
- field != "GCEPersistentDisk.ReadOnly" &&
- field != "spec.template.labels" &&
- field != "metadata.annotations" &&
- field != "metadata.labels" {
- t.Errorf("%s: missing prefix for: %v", k, errs[i])
- }
- }
- }
- }
- func validDeployment() *apps.Deployment {
- return &apps.Deployment{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- },
- Spec: apps.DeploymentSpec{
- Selector: &metav1.LabelSelector{
- MatchLabels: map[string]string{
- "name": "abc",
- },
- },
- Strategy: apps.DeploymentStrategy{
- Type: apps.RollingUpdateDeploymentStrategyType,
- RollingUpdate: &apps.RollingUpdateDeployment{
- MaxSurge: intstr.FromInt(1),
- MaxUnavailable: intstr.FromInt(1),
- },
- },
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc",
- Namespace: metav1.NamespaceDefault,
- Labels: map[string]string{
- "name": "abc",
- },
- },
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSDefault,
- Containers: []api.Container{
- {
- Name: "nginx",
- Image: "image",
- ImagePullPolicy: api.PullNever,
- TerminationMessagePolicy: api.TerminationMessageReadFile,
- },
- },
- },
- },
- RollbackTo: &apps.RollbackConfig{
- Revision: 1,
- },
- },
- }
- }
- func TestValidateDeployment(t *testing.T) {
- successCases := []*apps.Deployment{
- validDeployment(),
- }
- for _, successCase := range successCases {
- if errs := ValidateDeployment(successCase); len(errs) != 0 {
- t.Errorf("expected success: %v", errs)
- }
- }
- errorCases := map[string]*apps.Deployment{}
- errorCases["metadata.name: Required value"] = &apps.Deployment{
- ObjectMeta: metav1.ObjectMeta{
- Namespace: metav1.NamespaceDefault,
- },
- }
- // selector should match the labels in pod template.
- invalidSelectorDeployment := validDeployment()
- invalidSelectorDeployment.Spec.Selector = &metav1.LabelSelector{
- MatchLabels: map[string]string{
- "name": "def",
- },
- }
- errorCases["`selector` does not match template `labels`"] = invalidSelectorDeployment
- // RestartPolicy should be always.
- invalidRestartPolicyDeployment := validDeployment()
- invalidRestartPolicyDeployment.Spec.Template.Spec.RestartPolicy = api.RestartPolicyNever
- errorCases["Unsupported value: \"Never\""] = invalidRestartPolicyDeployment
- // must have valid strategy type
- invalidStrategyDeployment := validDeployment()
- invalidStrategyDeployment.Spec.Strategy.Type = apps.DeploymentStrategyType("randomType")
- errorCases[`supported values: "Recreate", "RollingUpdate"`] = invalidStrategyDeployment
- // rollingUpdate should be nil for recreate.
- invalidRecreateDeployment := validDeployment()
- invalidRecreateDeployment.Spec.Strategy = apps.DeploymentStrategy{
- Type: apps.RecreateDeploymentStrategyType,
- RollingUpdate: &apps.RollingUpdateDeployment{},
- }
- errorCases["may not be specified when strategy `type` is 'Recreate'"] = invalidRecreateDeployment
- // MaxSurge should be in the form of 20%.
- invalidMaxSurgeDeployment := validDeployment()
- invalidMaxSurgeDeployment.Spec.Strategy = apps.DeploymentStrategy{
- Type: apps.RollingUpdateDeploymentStrategyType,
- RollingUpdate: &apps.RollingUpdateDeployment{
- MaxSurge: intstr.FromString("20Percent"),
- },
- }
- errorCases["a valid percent string must be"] = invalidMaxSurgeDeployment
- // MaxSurge and MaxUnavailable cannot both be zero.
- invalidRollingUpdateDeployment := validDeployment()
- invalidRollingUpdateDeployment.Spec.Strategy = apps.DeploymentStrategy{
- Type: apps.RollingUpdateDeploymentStrategyType,
- RollingUpdate: &apps.RollingUpdateDeployment{
- MaxSurge: intstr.FromString("0%"),
- MaxUnavailable: intstr.FromInt(0),
- },
- }
- errorCases["may not be 0 when `maxSurge` is 0"] = invalidRollingUpdateDeployment
- // MaxUnavailable should not be more than 100%.
- invalidMaxUnavailableDeployment := validDeployment()
- invalidMaxUnavailableDeployment.Spec.Strategy = apps.DeploymentStrategy{
- Type: apps.RollingUpdateDeploymentStrategyType,
- RollingUpdate: &apps.RollingUpdateDeployment{
- MaxUnavailable: intstr.FromString("110%"),
- },
- }
- errorCases["must not be greater than 100%"] = invalidMaxUnavailableDeployment
- // Rollback.Revision must be non-negative
- invalidRollbackRevisionDeployment := validDeployment()
- invalidRollbackRevisionDeployment.Spec.RollbackTo.Revision = -3
- errorCases["must be greater than or equal to 0"] = invalidRollbackRevisionDeployment
- // ProgressDeadlineSeconds should be greater than MinReadySeconds
- invalidProgressDeadlineDeployment := validDeployment()
- seconds := int32(600)
- invalidProgressDeadlineDeployment.Spec.ProgressDeadlineSeconds = &seconds
- invalidProgressDeadlineDeployment.Spec.MinReadySeconds = seconds
- errorCases["must be greater than minReadySeconds"] = invalidProgressDeadlineDeployment
- for k, v := range errorCases {
- errs := ValidateDeployment(v)
- if len(errs) == 0 {
- t.Errorf("[%s] expected failure", k)
- } else if !strings.Contains(errs[0].Error(), k) {
- t.Errorf("unexpected error: %q, expected: %q", errs[0].Error(), k)
- }
- }
- }
- func TestValidateDeploymentStatus(t *testing.T) {
- collisionCount := int32(-3)
- tests := []struct {
- name string
- replicas int32
- updatedReplicas int32
- readyReplicas int32
- availableReplicas int32
- observedGeneration int64
- collisionCount *int32
- expectedErr bool
- }{
- {
- name: "valid status",
- replicas: 3,
- updatedReplicas: 3,
- readyReplicas: 2,
- availableReplicas: 1,
- observedGeneration: 2,
- expectedErr: false,
- },
- {
- name: "invalid replicas",
- replicas: -1,
- updatedReplicas: 2,
- readyReplicas: 2,
- availableReplicas: 1,
- observedGeneration: 2,
- expectedErr: true,
- },
- {
- name: "invalid updatedReplicas",
- replicas: 2,
- updatedReplicas: -1,
- readyReplicas: 2,
- availableReplicas: 1,
- observedGeneration: 2,
- expectedErr: true,
- },
- {
- name: "invalid readyReplicas",
- replicas: 3,
- readyReplicas: -1,
- availableReplicas: 1,
- observedGeneration: 2,
- expectedErr: true,
- },
- {
- name: "invalid availableReplicas",
- replicas: 3,
- readyReplicas: 3,
- availableReplicas: -1,
- observedGeneration: 2,
- expectedErr: true,
- },
- {
- name: "invalid observedGeneration",
- replicas: 3,
- readyReplicas: 3,
- availableReplicas: 3,
- observedGeneration: -1,
- expectedErr: true,
- },
- {
- name: "updatedReplicas greater than replicas",
- replicas: 3,
- updatedReplicas: 4,
- readyReplicas: 3,
- availableReplicas: 3,
- observedGeneration: 1,
- expectedErr: true,
- },
- {
- name: "readyReplicas greater than replicas",
- replicas: 3,
- readyReplicas: 4,
- availableReplicas: 3,
- observedGeneration: 1,
- expectedErr: true,
- },
- {
- name: "availableReplicas greater than replicas",
- replicas: 3,
- readyReplicas: 3,
- availableReplicas: 4,
- observedGeneration: 1,
- expectedErr: true,
- },
- {
- name: "availableReplicas greater than readyReplicas",
- replicas: 3,
- readyReplicas: 2,
- availableReplicas: 3,
- observedGeneration: 1,
- expectedErr: true,
- },
- {
- name: "invalid collisionCount",
- replicas: 3,
- observedGeneration: 1,
- collisionCount: &collisionCount,
- expectedErr: true,
- },
- }
- for _, test := range tests {
- status := apps.DeploymentStatus{
- Replicas: test.replicas,
- UpdatedReplicas: test.updatedReplicas,
- ReadyReplicas: test.readyReplicas,
- AvailableReplicas: test.availableReplicas,
- ObservedGeneration: test.observedGeneration,
- CollisionCount: test.collisionCount,
- }
- errs := ValidateDeploymentStatus(&status, field.NewPath("status"))
- if hasErr := len(errs) > 0; hasErr != test.expectedErr {
- errString := spew.Sprintf("%#v", errs)
- t.Errorf("%s: expected error: %t, got error: %t\nerrors: %s", test.name, test.expectedErr, hasErr, errString)
- }
- }
- }
- func TestValidateDeploymentStatusUpdate(t *testing.T) {
- collisionCount := int32(1)
- otherCollisionCount := int32(2)
- tests := []struct {
- name string
- from, to apps.DeploymentStatus
- expectedErr bool
- }{
- {
- name: "increase: valid update",
- from: apps.DeploymentStatus{
- CollisionCount: nil,
- },
- to: apps.DeploymentStatus{
- CollisionCount: &collisionCount,
- },
- expectedErr: false,
- },
- {
- name: "stable: valid update",
- from: apps.DeploymentStatus{
- CollisionCount: &collisionCount,
- },
- to: apps.DeploymentStatus{
- CollisionCount: &collisionCount,
- },
- expectedErr: false,
- },
- {
- name: "unset: invalid update",
- from: apps.DeploymentStatus{
- CollisionCount: &collisionCount,
- },
- to: apps.DeploymentStatus{
- CollisionCount: nil,
- },
- expectedErr: true,
- },
- {
- name: "decrease: invalid update",
- from: apps.DeploymentStatus{
- CollisionCount: &otherCollisionCount,
- },
- to: apps.DeploymentStatus{
- CollisionCount: &collisionCount,
- },
- expectedErr: true,
- },
- }
- for _, test := range tests {
- meta := metav1.ObjectMeta{Name: "foo", Namespace: metav1.NamespaceDefault, ResourceVersion: "1"}
- from := &apps.Deployment{
- ObjectMeta: meta,
- Status: test.from,
- }
- to := &apps.Deployment{
- ObjectMeta: meta,
- Status: test.to,
- }
- errs := ValidateDeploymentStatusUpdate(to, from)
- if hasErr := len(errs) > 0; hasErr != test.expectedErr {
- errString := spew.Sprintf("%#v", errs)
- t.Errorf("%s: expected error: %t, got error: %t\nerrors: %s", test.name, test.expectedErr, hasErr, errString)
- }
- }
- }
- func validDeploymentRollback() *apps.DeploymentRollback {
- return &apps.DeploymentRollback{
- Name: "abc",
- UpdatedAnnotations: map[string]string{
- "created-by": "abc",
- },
- RollbackTo: apps.RollbackConfig{
- Revision: 1,
- },
- }
- }
- func TestValidateDeploymentRollback(t *testing.T) {
- noAnnotation := validDeploymentRollback()
- noAnnotation.UpdatedAnnotations = nil
- successCases := []*apps.DeploymentRollback{
- validDeploymentRollback(),
- noAnnotation,
- }
- for _, successCase := range successCases {
- if errs := ValidateDeploymentRollback(successCase); len(errs) != 0 {
- t.Errorf("expected success: %v", errs)
- }
- }
- errorCases := map[string]*apps.DeploymentRollback{}
- invalidNoName := validDeploymentRollback()
- invalidNoName.Name = ""
- errorCases["name: Required value"] = invalidNoName
- for k, v := range errorCases {
- errs := ValidateDeploymentRollback(v)
- if len(errs) == 0 {
- t.Errorf("[%s] expected failure", k)
- } else if !strings.Contains(errs[0].Error(), k) {
- t.Errorf("unexpected error: %q, expected: %q", errs[0].Error(), k)
- }
- }
- }
- func TestValidateReplicaSetStatus(t *testing.T) {
- tests := []struct {
- name string
- replicas int32
- fullyLabeledReplicas int32
- readyReplicas int32
- availableReplicas int32
- observedGeneration int64
- expectedErr bool
- }{
- {
- name: "valid status",
- replicas: 3,
- fullyLabeledReplicas: 3,
- readyReplicas: 2,
- availableReplicas: 1,
- observedGeneration: 2,
- expectedErr: false,
- },
- {
- name: "invalid replicas",
- replicas: -1,
- fullyLabeledReplicas: 3,
- readyReplicas: 2,
- availableReplicas: 1,
- observedGeneration: 2,
- expectedErr: true,
- },
- {
- name: "invalid fullyLabeledReplicas",
- replicas: 3,
- fullyLabeledReplicas: -1,
- readyReplicas: 2,
- availableReplicas: 1,
- observedGeneration: 2,
- expectedErr: true,
- },
- {
- name: "invalid readyReplicas",
- replicas: 3,
- fullyLabeledReplicas: 3,
- readyReplicas: -1,
- availableReplicas: 1,
- observedGeneration: 2,
- expectedErr: true,
- },
- {
- name: "invalid availableReplicas",
- replicas: 3,
- fullyLabeledReplicas: 3,
- readyReplicas: 3,
- availableReplicas: -1,
- observedGeneration: 2,
- expectedErr: true,
- },
- {
- name: "invalid observedGeneration",
- replicas: 3,
- fullyLabeledReplicas: 3,
- readyReplicas: 3,
- availableReplicas: 3,
- observedGeneration: -1,
- expectedErr: true,
- },
- {
- name: "fullyLabeledReplicas greater than replicas",
- replicas: 3,
- fullyLabeledReplicas: 4,
- readyReplicas: 3,
- availableReplicas: 3,
- observedGeneration: 1,
- expectedErr: true,
- },
- {
- name: "readyReplicas greater than replicas",
- replicas: 3,
- fullyLabeledReplicas: 3,
- readyReplicas: 4,
- availableReplicas: 3,
- observedGeneration: 1,
- expectedErr: true,
- },
- {
- name: "availableReplicas greater than replicas",
- replicas: 3,
- fullyLabeledReplicas: 3,
- readyReplicas: 3,
- availableReplicas: 4,
- observedGeneration: 1,
- expectedErr: true,
- },
- {
- name: "availableReplicas greater than readyReplicas",
- replicas: 3,
- fullyLabeledReplicas: 3,
- readyReplicas: 2,
- availableReplicas: 3,
- observedGeneration: 1,
- expectedErr: true,
- },
- }
- for _, test := range tests {
- status := apps.ReplicaSetStatus{
- Replicas: test.replicas,
- FullyLabeledReplicas: test.fullyLabeledReplicas,
- ReadyReplicas: test.readyReplicas,
- AvailableReplicas: test.availableReplicas,
- ObservedGeneration: test.observedGeneration,
- }
- if hasErr := len(ValidateReplicaSetStatus(status, field.NewPath("status"))) > 0; hasErr != test.expectedErr {
- t.Errorf("%s: expected error: %t, got error: %t", test.name, test.expectedErr, hasErr)
- }
- }
- }
- func TestValidateReplicaSetStatusUpdate(t *testing.T) {
- validLabels := map[string]string{"a": "b"}
- validPodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validLabels,
- },
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "abc", Image: "image", ImagePullPolicy: "IfNotPresent", TerminationMessagePolicy: api.TerminationMessageReadFile}},
- },
- },
- }
- type rcUpdateTest struct {
- old apps.ReplicaSet
- update apps.ReplicaSet
- }
- successCases := []rcUpdateTest{
- {
- old: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- Status: apps.ReplicaSetStatus{
- Replicas: 2,
- },
- },
- update: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Replicas: 3,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- Status: apps.ReplicaSetStatus{
- Replicas: 4,
- },
- },
- },
- }
- for _, successCase := range successCases {
- successCase.old.ObjectMeta.ResourceVersion = "1"
- successCase.update.ObjectMeta.ResourceVersion = "1"
- if errs := ValidateReplicaSetStatusUpdate(&successCase.update, &successCase.old); len(errs) != 0 {
- t.Errorf("expected success: %v", errs)
- }
- }
- errorCases := map[string]rcUpdateTest{
- "negative replicas": {
- old: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- Status: apps.ReplicaSetStatus{
- Replicas: 3,
- },
- },
- update: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Replicas: 2,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- Status: apps.ReplicaSetStatus{
- Replicas: -3,
- },
- },
- },
- }
- for testName, errorCase := range errorCases {
- if errs := ValidateReplicaSetStatusUpdate(&errorCase.update, &errorCase.old); len(errs) == 0 {
- t.Errorf("expected failure: %s", testName)
- }
- }
- }
- func TestValidateReplicaSetUpdate(t *testing.T) {
- validLabels := map[string]string{"a": "b"}
- validPodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validLabels,
- },
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "abc", Image: "image", ImagePullPolicy: "IfNotPresent", TerminationMessagePolicy: api.TerminationMessageReadFile}},
- },
- },
- }
- readWriteVolumePodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validLabels,
- },
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "abc", Image: "image", ImagePullPolicy: "IfNotPresent", TerminationMessagePolicy: api.TerminationMessageReadFile}},
- Volumes: []api.Volume{{Name: "gcepd", VolumeSource: api.VolumeSource{GCEPersistentDisk: &api.GCEPersistentDiskVolumeSource{PDName: "my-PD", FSType: "ext4", Partition: 1, ReadOnly: false}}}},
- },
- },
- }
- invalidLabels := map[string]string{"NoUppercaseOrSpecialCharsLike=Equals": "b"}
- invalidPodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: invalidLabels,
- },
- },
- }
- type rcUpdateTest struct {
- old apps.ReplicaSet
- update apps.ReplicaSet
- }
- successCases := []rcUpdateTest{
- {
- old: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- update: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Replicas: 3,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- },
- {
- old: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- update: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Replicas: 1,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: readWriteVolumePodTemplate.Template,
- },
- },
- },
- }
- for _, successCase := range successCases {
- successCase.old.ObjectMeta.ResourceVersion = "1"
- successCase.update.ObjectMeta.ResourceVersion = "1"
- if errs := ValidateReplicaSetUpdate(&successCase.update, &successCase.old); len(errs) != 0 {
- t.Errorf("expected success: %v", errs)
- }
- }
- errorCases := map[string]rcUpdateTest{
- "more than one read/write": {
- old: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- update: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Replicas: 2,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: readWriteVolumePodTemplate.Template,
- },
- },
- },
- "invalid selector": {
- old: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- update: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Replicas: 2,
- Selector: &metav1.LabelSelector{MatchLabels: invalidLabels},
- Template: validPodTemplate.Template,
- },
- },
- },
- "invalid pod": {
- old: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- update: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Replicas: 2,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: invalidPodTemplate.Template,
- },
- },
- },
- "negative replicas": {
- old: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- update: apps.ReplicaSet{
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Replicas: -1,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- },
- }
- for testName, errorCase := range errorCases {
- if errs := ValidateReplicaSetUpdate(&errorCase.update, &errorCase.old); len(errs) == 0 {
- t.Errorf("expected failure: %s", testName)
- }
- }
- }
- func TestValidateReplicaSet(t *testing.T) {
- validLabels := map[string]string{"a": "b"}
- validPodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validLabels,
- },
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "abc", Image: "image", ImagePullPolicy: "IfNotPresent", TerminationMessagePolicy: api.TerminationMessageReadFile}},
- },
- },
- }
- readWriteVolumePodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- ObjectMeta: metav1.ObjectMeta{
- Labels: validLabels,
- },
- Spec: api.PodSpec{
- Volumes: []api.Volume{{Name: "gcepd", VolumeSource: api.VolumeSource{GCEPersistentDisk: &api.GCEPersistentDiskVolumeSource{PDName: "my-PD", FSType: "ext4", Partition: 1, ReadOnly: false}}}},
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "abc", Image: "image", ImagePullPolicy: "IfNotPresent", TerminationMessagePolicy: api.TerminationMessageReadFile}},
- },
- },
- }
- invalidLabels := map[string]string{"NoUppercaseOrSpecialCharsLike=Equals": "b"}
- invalidPodTemplate := api.PodTemplate{
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyAlways,
- DNSPolicy: api.DNSClusterFirst,
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: invalidLabels,
- },
- },
- }
- successCases := []apps.ReplicaSet{
- {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Replicas: 1,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: readWriteVolumePodTemplate.Template,
- },
- },
- }
- for _, successCase := range successCases {
- if errs := ValidateReplicaSet(&successCase); len(errs) != 0 {
- t.Errorf("expected success: %v", errs)
- }
- }
- errorCases := map[string]apps.ReplicaSet{
- "zero-length ID": {
- ObjectMeta: metav1.ObjectMeta{Name: "", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- "missing-namespace": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc-123"},
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- "empty selector": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Template: validPodTemplate.Template,
- },
- },
- "selector_doesnt_match": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: map[string]string{"foo": "bar"}},
- Template: validPodTemplate.Template,
- },
- },
- "invalid manifest": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- },
- },
- "read-write persistent disk with > 1 pod": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc"},
- Spec: apps.ReplicaSetSpec{
- Replicas: 2,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: readWriteVolumePodTemplate.Template,
- },
- },
- "negative_replicas": {
- ObjectMeta: metav1.ObjectMeta{Name: "abc", Namespace: metav1.NamespaceDefault},
- Spec: apps.ReplicaSetSpec{
- Replicas: -1,
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- },
- },
- "invalid_label": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- Labels: map[string]string{
- "NoUppercaseOrSpecialCharsLike=Equals": "bar",
- },
- },
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- "invalid_label 2": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- Labels: map[string]string{
- "NoUppercaseOrSpecialCharsLike=Equals": "bar",
- },
- },
- Spec: apps.ReplicaSetSpec{
- Template: invalidPodTemplate.Template,
- },
- },
- "invalid_annotation": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- Annotations: map[string]string{
- "NoUppercaseOrSpecialCharsLike=Equals": "bar",
- },
- },
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: validPodTemplate.Template,
- },
- },
- "invalid restart policy 1": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- },
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyOnFailure,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "ctr", Image: "image", ImagePullPolicy: "IfNotPresent", TerminationMessagePolicy: api.TerminationMessageReadFile}},
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: validLabels,
- },
- },
- },
- },
- "invalid restart policy 2": {
- ObjectMeta: metav1.ObjectMeta{
- Name: "abc-123",
- Namespace: metav1.NamespaceDefault,
- },
- Spec: apps.ReplicaSetSpec{
- Selector: &metav1.LabelSelector{MatchLabels: validLabels},
- Template: api.PodTemplateSpec{
- Spec: api.PodSpec{
- RestartPolicy: api.RestartPolicyNever,
- DNSPolicy: api.DNSClusterFirst,
- Containers: []api.Container{{Name: "ctr", Image: "image", ImagePullPolicy: "IfNotPresent", TerminationMessagePolicy: api.TerminationMessageReadFile}},
- },
- ObjectMeta: metav1.ObjectMeta{
- Labels: validLabels,
- },
- },
- },
- },
- }
- for k, v := range errorCases {
- errs := ValidateReplicaSet(&v)
- if len(errs) == 0 {
- t.Errorf("expected failure for %s", k)
- }
- for i := range errs {
- field := errs[i].Field
- if !strings.HasPrefix(field, "spec.template.") &&
- field != "metadata.name" &&
- field != "metadata.namespace" &&
- field != "spec.selector" &&
- field != "spec.template" &&
- field != "GCEPersistentDisk.ReadOnly" &&
- field != "spec.replicas" &&
- field != "spec.template.labels" &&
- field != "metadata.annotations" &&
- field != "metadata.labels" &&
- field != "status.replicas" {
- t.Errorf("%s: missing prefix for: %v", k, errs[i])
- }
- }
- }
- }
|