github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-22 11:21:47 +00:00
Code Issues Projects Releases Wiki Activity

expose controller initializers

Browse Source
This commit is contained in:
deads2k 2017-05-08 14:16:05 -04:00
parent 843c40e32e
commit b7161a02b2
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
cmd/kube-controller-manager/app/controllermanager.go
View File

@ -177,7 +177,7 @@ func Run(s *options.CMServer) error {
clientBuilder = rootClientBuilder clientBuilder = rootClientBuilder
} }
err := StartControllers(newControllerInitializers(), s, rootClientBuilder, clientBuilder, stop) err := StartControllers(NewControllerInitializers(), s, rootClientBuilder, clientBuilder, stop)
glog.Fatalf("error running controllers: %v", err) glog.Fatalf("error running controllers: %v", err)
panic("unreachable") panic("unreachable")
} }
@ -272,7 +272,7 @@ func IsControllerEnabled(name string, disabledByDefaultControllers sets.String,
type InitFunc func(ctx ControllerContext) (bool, error) type InitFunc func(ctx ControllerContext) (bool, error)
func KnownControllers() []string { func KnownControllers() []string {
ret := sets.StringKeySet(newControllerInitializers()) ret := sets.StringKeySet(NewControllerInitializers())
ret.Insert( ret.Insert(
saTokenControllerName, saTokenControllerName,
@ -292,7 +292,9 @@ var ControllersDisabledByDefault = sets.NewString(
"tokencleaner", "tokencleaner",
) )
func newControllerInitializers() map[string]InitFunc { // NewControllerInitializers is a public map of named controller groups (you can start more than one in an init func)
// paired to their InitFunc. This allows for structured downstream composition and subdivision.
func NewControllerInitializers() map[string]InitFunc {
controllers := map[string]InitFunc{} controllers := map[string]InitFunc{}
controllers["endpoint"] = startEndpointController controllers["endpoint"] = startEndpointController
controllers["replicationcontroller"] = startReplicationController controllers["replicationcontroller"] = startReplicationController
@ -319,7 +321,8 @@ func newControllerInitializers() map[string]InitFunc {
// TODO: In general, any controller checking this needs to be dynamic so // TODO: In general, any controller checking this needs to be dynamic so
// users don't have to restart their controller manager if they change the apiserver. // users don't have to restart their controller manager if they change the apiserver.
func getAvailableResources(clientBuilder controller.ControllerClientBuilder) (map[schema.GroupVersionResource]bool, error) { // Until we get there, the structure here needs to be exposed for the construction of a proper ControllerContext.
func GetAvailableResources(clientBuilder controller.ControllerClientBuilder) (map[schema.GroupVersionResource]bool, error) {
var discoveryClient discovery.DiscoveryInterface var discoveryClient discovery.DiscoveryInterface
// If apiserver is not running we should wait for some time and fail only then. This is particularly // If apiserver is not running we should wait for some time and fail only then. This is particularly
@ -410,7 +413,7 @@ func StartControllers(controllers map[string]InitFunc, s *options.CMServer, root
glog.Warningf("%q is disabled", saTokenControllerName) glog.Warningf("%q is disabled", saTokenControllerName)
} }
availableResources, err := getAvailableResources(clientBuilder) availableResources, err := GetAvailableResources(clientBuilder)
if err != nil { if err != nil {
return err return err
} }