controller

Documentation

Index

• func RunBuildConfigChangeController(ctx ControllerContext) (bool, error)
• func RunOriginNamespaceController(ctx ControllerContext) (bool, error)
• func RunServiceAccountPullSecretsController(ctx ControllerContext) (bool, error)
• type BuildControllerConfig
  • func (c *BuildControllerConfig) RunController(ctx ControllerContext) (bool, error)
• type ControllerClientBuilder
• type ControllerContext
  • func (c ControllerContext) IsControllerEnabled(name string) bool
• type DeployerControllerConfig
  • func (c *DeployerControllerConfig) RunController(ctx ControllerContext) (bool, error)
• type DeploymentConfigControllerConfig
  • func (c *DeploymentConfigControllerConfig) RunController(ctx ControllerContext) (bool, error)
• type DeploymentTriggerControllerConfig
  • func (c *DeploymentTriggerControllerConfig) RunController(ctx ControllerContext) (bool, error)
• type ImageImportControllerOptions
  • func (c *ImageImportControllerOptions) RunController(ctx ControllerContext) (bool, error)
• type ImageTriggerControllerConfig
  • func (c *ImageTriggerControllerConfig) RunController(ctx ControllerContext) (bool, error)
• type InitFunc
  • func FromKubeInitFunc(initFn kubecontroller.InitFunc) 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) OpenshiftTemplateClient(name string) (templateclient.Interface, error)
• type ServiceAccountControllerOptions
  • func (c *ServiceAccountControllerOptions) RunController(ctx ControllerContext) (bool, error)
• type ServiceAccountTokenControllerOptions
  • func (c *ServiceAccountTokenControllerOptions) RunController(ctx ControllerContext) (bool, error)
• type ServiceServingCertsControllerOptions
  • func (c *ServiceServingCertsControllerOptions) RunController(ctx ControllerContext) (bool, error)
• type TemplateInstanceControllerConfig
  • func (c *TemplateInstanceControllerConfig) RunController(ctx ControllerContext) (bool, error)

Functions

func RunBuildConfigChangeController

func RunBuildConfigChangeController(ctx ControllerContext) (bool, error)

func RunOriginNamespaceController

func RunOriginNamespaceController(ctx ControllerContext) (bool, error)

func RunServiceAccountPullSecretsController

func RunServiceAccountPullSecretsController(ctx ControllerContext) (bool, error)

Types

type BuildControllerConfig

type BuildControllerConfig struct {
	DockerImage           string
	STIImage              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 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)
}

type ControllerContext

type ControllerContext struct {
	KubeControllerContext kubecontroller.ControllerContext

	// ClientBuilder will provide a client for this controller to use
	ClientBuilder ControllerClientBuilder

	AppInformers      appinformer.SharedInformerFactory
	ImageInformers    imageinformer.SharedInformerFactory
	TemplateInformers templateinformer.SharedInformerFactory

	DeprecatedOpenshiftInformers shared.InformerFactory

	// 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

type DeploymentConfigControllerConfig struct {
	Codec runtime.Codec
}

func (*DeploymentConfigControllerConfig) RunController

func (c *DeploymentConfigControllerConfig) RunController(ctx ControllerContext) (bool, error)

type DeploymentTriggerControllerConfig

type DeploymentTriggerControllerConfig struct {
	Codec runtime.Codec
}

func (*DeploymentTriggerControllerConfig) RunController

func (c *DeploymentTriggerControllerConfig) RunController(ctx ControllerContext) (bool, error)

type ImageImportControllerOptions

type ImageImportControllerOptions struct {
	MaxScheduledImageImportsPerMinute          int
	ScheduledImageImportMinimumIntervalSeconds int
	DisableScheduledImport                     bool
	ResyncPeriod                               time.Duration
}

func (*ImageImportControllerOptions) RunController

func (c *ImageImportControllerOptions) 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 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) OpenshiftTemplateClient

func (b OpenshiftControllerClientBuilder) OpenshiftTemplateClient(name string) (templateclient.Interface, 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

type ServiceServingCertsControllerOptions struct {
	Signer *configapi.CertInfo
}

func (*ServiceServingCertsControllerOptions) RunController

func (c *ServiceServingCertsControllerOptions) RunController(ctx ControllerContext) (bool, error)

type TemplateInstanceControllerConfig

type TemplateInstanceControllerConfig struct {
}

func (*TemplateInstanceControllerConfig) RunController

func (c *TemplateInstanceControllerConfig) RunController(ctx ControllerContext) (bool, error)