Documentation
¶
Index ¶
- func RunBuildConfigChangeController(ctx ControllerContext) (bool, error)
- func RunControllerServer(servingInfo configapi.HTTPServingInfo, ...) error
- func RunOriginNamespaceController(ctx ControllerContext) (bool, error)
- func RunResourceQuotaManager(ctx ControllerContext) (bool, error)
- func RunServiceAccountPullSecretsController(ctx ControllerContext) (bool, error)
- func RunTemplateInstanceController(ctx ControllerContext) (bool, error)
- type BuildControllerConfig
- type ClusterQuotaReconciliationControllerConfig
- type ControllerClientBuilder
- type ControllerContext
- type DeployerControllerConfig
- type DeploymentConfigControllerConfig
- type DeploymentTriggerControllerConfig
- type ImageImportControllerConfig
- type ImageTriggerControllerConfig
- type IngressIPControllerConfig
- type InitFunc
- type OpenshiftControllerClientBuilder
- func (b OpenshiftControllerClientBuilder) DeprecatedOpenshiftClient(name string) (osclient.Interface, error)
- func (b OpenshiftControllerClientBuilder) DeprecatedOpenshiftClientOrDie(name string) osclient.Interface
- func (b OpenshiftControllerClientBuilder) KubeInternalClient(name string) (kclientsetinternal.Interface, error)
- func (b OpenshiftControllerClientBuilder) KubeInternalClientOrDie(name string) kclientsetinternal.Interface
- func (b OpenshiftControllerClientBuilder) OpenshiftImageClient(name string) (imageclient.Interface, error)
- func (b OpenshiftControllerClientBuilder) OpenshiftImageClientOrDie(name string) imageclient.Interface
- func (b OpenshiftControllerClientBuilder) OpenshiftTemplateClient(name string) (templateclient.Interface, error)
- func (b OpenshiftControllerClientBuilder) OpenshiftTemplateClientOrDie(name string) templateclient.Interface
- type OpenshiftControllerConfig
- type SDNControllerConfig
- type ServiceAccountControllerOptions
- type ServiceAccountTokenControllerOptions
- type ServiceServingCertsControllerOptions
- type UnidlingControllerConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RunBuildConfigChangeController ¶
func RunBuildConfigChangeController(ctx ControllerContext) (bool, error)
func RunControllerServer ¶
func RunControllerServer(servingInfo configapi.HTTPServingInfo, kubeExternal clientgoclientset.Interface) error
TODO make this an actual API server built on the genericapiserver
func RunOriginNamespaceController ¶
func RunOriginNamespaceController(ctx ControllerContext) (bool, error)
func RunResourceQuotaManager ¶
func RunResourceQuotaManager(ctx ControllerContext) (bool, error)
func RunServiceAccountPullSecretsController ¶
func RunServiceAccountPullSecretsController(ctx ControllerContext) (bool, error)
func RunTemplateInstanceController ¶
func RunTemplateInstanceController(ctx ControllerContext) (bool, error)
Types ¶
type BuildControllerConfig ¶
type BuildControllerConfig struct {
DockerImage string
S2IImage string
AdmissionPluginConfig map[string]configapi.AdmissionPluginConfig
Codec runtime.Codec
}
func (*BuildControllerConfig) RunController ¶
func (c *BuildControllerConfig) RunController(ctx ControllerContext) (bool, error)
RunController starts the build sync loop for builds and buildConfig processing.
type ClusterQuotaReconciliationControllerConfig ¶
type ClusterQuotaReconciliationControllerConfig struct {
DefaultResyncPeriod time.Duration
DefaultReplenishmentSyncPeriod time.Duration
}
func (*ClusterQuotaReconciliationControllerConfig) RunController ¶
func (c *ClusterQuotaReconciliationControllerConfig) RunController(ctx ControllerContext) (bool, error)
type ControllerClientBuilder ¶
type ControllerClientBuilder interface {
controller.ControllerClientBuilder
KubeInternalClient(name string) (kclientsetinternal.Interface, error)
KubeInternalClientOrDie(name string) kclientsetinternal.Interface
DeprecatedOpenshiftClient(name string) (osclient.Interface, error)
DeprecatedOpenshiftClientOrDie(name string) osclient.Interface
OpenshiftTemplateClient(name string) (templateclient.Interface, error)
OpenshiftTemplateClientOrDie(name string) templateclient.Interface
OpenshiftImageClient(name string) (imageclient.Interface, error)
OpenshiftImageClientOrDie(name string) imageclient.Interface
}
type ControllerContext ¶
type ControllerContext struct {
KubeControllerContext kubecontroller.ControllerContext
// ClientBuilder will provide a client for this controller to use
ClientBuilder ControllerClientBuilder
ExternalKubeInformers kexternalinformers.SharedInformerFactory
InternalKubeInformers kinternalinformers.SharedInformerFactory
AppInformers appinformer.SharedInformerFactory
BuildInformers buildinformer.SharedInformerFactory
ImageInformers imageinformer.SharedInformerFactory
TemplateInformers templateinformer.SharedInformerFactory
QuotaInformers quotainformer.SharedInformerFactory
AuthorizationInformers authorizationinformer.SharedInformerFactory
SecurityInformers securityinformer.SharedInformerFactory
// Stop is the stop channel
Stop <-chan struct{}
}
func (ControllerContext) IsControllerEnabled ¶
func (c ControllerContext) IsControllerEnabled(name string) bool
TODO wire this up to something that handles the names. The logic is available upstream, we just have to wire to it
type DeployerControllerConfig ¶
type DeployerControllerConfig struct {
ImageName string
ClientEnvVars []kapi.EnvVar
Codec runtime.Codec
}
func (*DeployerControllerConfig) RunController ¶
func (c *DeployerControllerConfig) RunController(ctx ControllerContext) (bool, error)
type DeploymentConfigControllerConfig ¶
func (*DeploymentConfigControllerConfig) RunController ¶
func (c *DeploymentConfigControllerConfig) RunController(ctx ControllerContext) (bool, error)
type DeploymentTriggerControllerConfig ¶
func (*DeploymentTriggerControllerConfig) RunController ¶
func (c *DeploymentTriggerControllerConfig) RunController(ctx ControllerContext) (bool, error)
type ImageImportControllerConfig ¶
type ImageImportControllerConfig struct {
MaxScheduledImageImportsPerMinute int
ScheduledImageImportMinimumIntervalSeconds int
DisableScheduledImport bool
ResyncPeriod time.Duration
}
func (*ImageImportControllerConfig) RunController ¶
func (c *ImageImportControllerConfig) RunController(ctx ControllerContext) (bool, error)
type ImageTriggerControllerConfig ¶
type ImageTriggerControllerConfig struct {
HasBuilderEnabled bool
HasDeploymentsEnabled bool
HasDaemonSetsEnabled bool
HasStatefulSetsEnabled bool
HasCronJobsEnabled bool
}
func (*ImageTriggerControllerConfig) RunController ¶
func (c *ImageTriggerControllerConfig) RunController(ctx ControllerContext) (bool, error)
type IngressIPControllerConfig ¶
type IngressIPControllerConfig struct {
IngressIPNetworkCIDR string
IngressIPSyncPeriod time.Duration
}
func (*IngressIPControllerConfig) RunController ¶
func (c *IngressIPControllerConfig) RunController(ctx ControllerContext) (bool, error)
type InitFunc ¶
type InitFunc func(ctx ControllerContext) (bool, error)
InitFunc is used to launch a particular controller. It may run additional "should I activate checks". Any error returned will cause the controller process to `Fatal` The bool indicates whether the controller was enabled.
func FromKubeInitFunc ¶
func FromKubeInitFunc(initFn kubecontroller.InitFunc) InitFunc
FromKubeInitFunc adapts a kube init func to an openshift one
type OpenshiftControllerClientBuilder ¶
type OpenshiftControllerClientBuilder struct {
controller.ControllerClientBuilder
}
func (OpenshiftControllerClientBuilder) DeprecatedOpenshiftClient ¶
func (b OpenshiftControllerClientBuilder) DeprecatedOpenshiftClient(name string) (osclient.Interface, error)
func (OpenshiftControllerClientBuilder) DeprecatedOpenshiftClientOrDie ¶
func (b OpenshiftControllerClientBuilder) DeprecatedOpenshiftClientOrDie(name string) osclient.Interface
func (OpenshiftControllerClientBuilder) KubeInternalClient ¶
func (b OpenshiftControllerClientBuilder) KubeInternalClient(name string) (kclientsetinternal.Interface, error)
func (OpenshiftControllerClientBuilder) KubeInternalClientOrDie ¶
func (b OpenshiftControllerClientBuilder) KubeInternalClientOrDie(name string) kclientsetinternal.Interface
func (OpenshiftControllerClientBuilder) OpenshiftImageClient ¶
func (b OpenshiftControllerClientBuilder) OpenshiftImageClient(name string) (imageclient.Interface, error)
func (OpenshiftControllerClientBuilder) OpenshiftImageClientOrDie ¶
func (b OpenshiftControllerClientBuilder) OpenshiftImageClientOrDie(name string) imageclient.Interface
func (OpenshiftControllerClientBuilder) OpenshiftTemplateClient ¶
func (b OpenshiftControllerClientBuilder) OpenshiftTemplateClient(name string) (templateclient.Interface, error)
func (OpenshiftControllerClientBuilder) OpenshiftTemplateClientOrDie ¶
func (b OpenshiftControllerClientBuilder) OpenshiftTemplateClientOrDie(name string) templateclient.Interface
type OpenshiftControllerConfig ¶
type OpenshiftControllerConfig struct {
ServiceAccountTokenControllerOptions ServiceAccountTokenControllerOptions
ServiceAccountControllerOptions ServiceAccountControllerOptions
BuildControllerConfig BuildControllerConfig
DeployerControllerConfig DeployerControllerConfig
DeploymentConfigControllerConfig DeploymentConfigControllerConfig
DeploymentTriggerControllerConfig DeploymentTriggerControllerConfig
ImageTriggerControllerConfig ImageTriggerControllerConfig
ImageImportControllerConfig ImageImportControllerConfig
ServiceServingCertsControllerOptions ServiceServingCertsControllerOptions
SDNControllerConfig SDNControllerConfig
UnidlingControllerConfig UnidlingControllerConfig
IngressIPControllerConfig IngressIPControllerConfig
ClusterQuotaReconciliationControllerConfig ClusterQuotaReconciliationControllerConfig
}
OpenshiftControllerConfig is the runtime (non-serializable) config object used to launch the set of openshift (not kube) controllers.
func BuildOpenshiftControllerConfig ¶
func BuildOpenshiftControllerConfig(options configapi.MasterConfig) (*OpenshiftControllerConfig, error)
func (*OpenshiftControllerConfig) GetControllerInitializers ¶
func (c *OpenshiftControllerConfig) GetControllerInitializers() (map[string]InitFunc, error)
func (*OpenshiftControllerConfig) ServiceAccountContentControllerInit ¶
func (c *OpenshiftControllerConfig) ServiceAccountContentControllerInit() InitFunc
NewOpenShiftControllerPreStartInitializers returns list of initializers for controllers that needed to be run before any other controller is started. Typically this has to done for the serviceaccount-token controller as it provides tokens to other controllers.
type SDNControllerConfig ¶
type SDNControllerConfig struct {
NetworkConfig configapi.MasterNetworkConfig
}
func (*SDNControllerConfig) RunController ¶
func (c *SDNControllerConfig) RunController(ctx ControllerContext) (bool, error)
type ServiceAccountControllerOptions ¶
type ServiceAccountControllerOptions struct {
ManagedNames []string
}
func (*ServiceAccountControllerOptions) RunController ¶
func (c *ServiceAccountControllerOptions) RunController(ctx ControllerContext) (bool, error)
type ServiceAccountTokenControllerOptions ¶
type ServiceAccountTokenControllerOptions struct {
RootCA []byte
ServiceServingCA []byte
PrivateKey interface{}
RootClientBuilder controller.SimpleControllerClientBuilder
}
func (*ServiceAccountTokenControllerOptions) RunController ¶
func (c *ServiceAccountTokenControllerOptions) RunController(ctx ControllerContext) (bool, error)
type ServiceServingCertsControllerOptions ¶
func (*ServiceServingCertsControllerOptions) RunController ¶
func (c *ServiceServingCertsControllerOptions) RunController(ctx ControllerContext) (bool, error)
type UnidlingControllerConfig ¶
func (*UnidlingControllerConfig) RunController ¶
func (c *UnidlingControllerConfig) RunController(ctx ControllerContext) (bool, error)