kubecontroller

May 26, 2023

Changes in this version

+ var ControllersDisabledByDefault = sets.NewString("bootstrapsigner", "tokencleaner")

+ type ClusterRoleAggregationController struct

+ func NewClusterRoleAggregation(clusterRoleInformer rbacinformers.ClusterRoleInformer, ...) *ClusterRoleAggregationController

+ func (c *ClusterRoleAggregationController) Run(ctx context.Context, workers int)

type ControllerContext

+ func (c ControllerContext) IsControllerEnabled(name string) bool

Dec 7, 2022

Changes in this version

+ const ConfigzName

+ const ControllerStartJitter

+ func ContextForChannel(parentCh <-chan struct{}) (context.Context, context.CancelFunc)

+ func GetAvailableResources(clientBuilder clientbuilder.ControllerClientBuilder) (map[schema.GroupVersionResource]bool, error)

+ func NewControllerInitializers() map[string]InitFunc

+ func ResyncPeriod(c *config.CompletedConfig) func() time.Duration

+ func Run(c *config.CompletedConfig, sharedInformers informers.SharedInformerFactory, ...) error

+ func RunKubeControllers(cfg *restclient.Config, sharedInformers informers.SharedInformerFactory, ...) error

+ func StartControllers(ctx context.Context, controllerCtx ControllerContext, ...) error

+ type ControllerContext struct

+ AvailableResources map[schema.GroupVersionResource]bool

+ ClientBuilder clientbuilder.ControllerClientBuilder

+ ComponentConfig kubectrlmgrconfig.KubeControllerManagerConfiguration

+ InformerFactory informers.SharedInformerFactory

+ InformersStarted chan struct{}

+ ObjectOrMetadataInformerFactory informerfactory.InformerFactory

+ RESTMapper *restmapper.DeferredDiscoveryRESTMapper

+ ResyncPeriod func() time.Duration

+ func CreateControllerContext(s *config.CompletedConfig, ...) (ControllerContext, error)

+ type ControllerInitializersFunc func() (initializers map[string]InitFunc)

+ type ControllerLoopMode int

+ const ExternalLoops

+ const IncludeCloudLoops

+ type InitFunc func(ctx context.Context, controllerCtx ControllerContext) (controller controller.Interface, enabled bool, err error)