forked from openshift/origin
/
unidling.go
40 lines (32 loc) · 1.4 KB
/
unidling.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
package controller
import (
"time"
appstypedclient "github.com/openshift/client-go/apps/clientset/versioned/typed/apps/v1"
appsv1client "github.com/openshift/origin/pkg/apps/client/v1"
deployclient "github.com/openshift/origin/pkg/apps/generated/internalclientset/typed/apps/internalversion"
"github.com/openshift/origin/pkg/cmd/server/bootstrappolicy"
unidlingcontroller "github.com/openshift/origin/pkg/unidling/controller"
)
type UnidlingControllerConfig struct {
ResyncPeriod time.Duration
}
func (c *UnidlingControllerConfig) RunController(ctx ControllerContext) (bool, error) {
clientConfig := ctx.ClientBuilder.ConfigOrDie(bootstrappolicy.InfraUnidlingControllerServiceAccountName)
appsClient, err := appstypedclient.NewForConfig(clientConfig)
if err != nil {
return false, err
}
scaleNamespacer := appsv1client.NewDelegatingScaleNamespacer(appsClient,
ctx.ClientBuilder.ClientOrDie(bootstrappolicy.InfraUnidlingControllerServiceAccountName).ExtensionsV1beta1())
coreClient := ctx.ClientBuilder.KubeInternalClientOrDie(bootstrappolicy.InfraUnidlingControllerServiceAccountName).Core()
controller := unidlingcontroller.NewUnidlingController(
scaleNamespacer,
coreClient,
coreClient,
deployclient.NewForConfigOrDie(ctx.ClientBuilder.ConfigOrDie(bootstrappolicy.InfraUnidlingControllerServiceAccountName)),
coreClient,
c.ResyncPeriod,
)
go controller.Run(ctx.Stop)
return true, nil
}