 Documentation
      ¶
      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)