Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

add auto pod upgrade controller for daemoset #970

Merged
merged 11 commits into from
Sep 27, 2022
Merged

add auto pod upgrade controller for daemoset #970

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
808c9c6
add auto pod upgrade controller for daemoset
xavier-hou Aug 26, 2022
d740058
add unit tests for util
xavier-hou Aug 30, 2022
855e47f
remove node workqueue
xavier-hou Sep 2, 2022
79abddc
add maxUnavailable limitation
xavier-hou Sep 6, 2022
b31933e
add unit tests case
xavier-hou Sep 7, 2022
22e2fef
fix upper case
xavier-hou Sep 7, 2022
16979d8
add unit tests for k8s utils
xavier-hou Sep 9, 2022
6055449
add node ready check for ota strategy
xavier-hou Sep 12, 2022
be73044
use pod condition to specify upgradability
xavier-hou Sep 15, 2022
c2c44ee
add code comments
xavier-hou Sep 20, 2022
b1d4411
remove node ready check for ota strategy
xavier-hou Sep 26, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion cmd/yurt-controller-manager/app/controllermanager.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -305,7 +305,7 @@ func NewControllerInitializers() map[string]InitFunc {
controllers := map[string]InitFunc{}
controllers["nodelifecycle"] = startNodeLifecycleController
controllers["yurtcsrapprover"] = startYurtCSRApproverController

controllers["daemonpodupdater"] = startDaemonPodUpdaterController
return controllers
}

Expand Down
14 changes: 14 additions & 0 deletions cmd/yurt-controller-manager/app/core.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,7 @@ import (
"time"

"github.com/openyurtio/openyurt/pkg/controller/certificates"
daemonpodupdater "github.com/openyurtio/openyurt/pkg/controller/daemonpodupdater"
lifecyclecontroller "github.com/openyurtio/openyurt/pkg/controller/nodelifecycle"
)

Expand Down Expand Up @@ -65,3 +66,16 @@ func startYurtCSRApproverController(ctx ControllerContext) (http.Handler, bool,

return nil, true, nil
}

func startDaemonPodUpdaterController(ctx ControllerContext) (http.Handler, bool, error) {
daemonPodUpdaterCtrl := daemonpodupdater.NewController(
ctx.ClientBuilder.ClientOrDie("daemonPodUpdater-controller"),
ctx.InformerFactory.Apps().V1().DaemonSets(),
ctx.InformerFactory.Core().V1().Nodes(),
ctx.InformerFactory.Core().V1().Pods(),
)

go daemonPodUpdaterCtrl.Run(2, ctx.Stop)

return nil, true, nil
}
1 change: 1 addition & 0 deletions go.mod
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -7,6 +7,7 @@ require (
github.com/Masterminds/semver/v3 v3.1.1
github.com/Microsoft/go-winio v0.4.15
github.com/aliyun/alibaba-cloud-sdk-go v1.61.579
github.com/davecgh/go-spew v1.1.1
github.com/daviddengcn/go-colortext v1.0.0
github.com/dgrijalva/jwt-go v3.2.0+incompatible
github.com/emicklei/go-restful v2.12.0+incompatible // indirect
Expand Down
Loading