/
unidling.go
34 lines (28 loc) · 1.18 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
package controller
import (
"time"
osclient "github.com/openshift/origin/pkg/client"
"github.com/openshift/origin/pkg/cmd/server/bootstrappolicy"
deployclient "github.com/openshift/origin/pkg/deploy/generated/internalclientset/typed/apps/internalversion"
unidlingcontroller "github.com/openshift/origin/pkg/unidling/controller"
)
type UnidlingControllerConfig struct {
ResyncPeriod time.Duration
}
func (c *UnidlingControllerConfig) RunController(ctx ControllerContext) (bool, error) {
scaleNamespacer := osclient.NewDelegatingScaleNamespacer(
ctx.ClientBuilder.DeprecatedOpenshiftClientOrDie(bootstrappolicy.InfraUnidlingControllerServiceAccountName),
ctx.ClientBuilder.ClientOrDie(bootstrappolicy.InfraUnidlingControllerServiceAccountName).Extensions(),
)
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
}