Documentation ¶
Overview ¶
Package controller contains all the controllers which taken together implement the deployment system's behavior.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChangeStrategy ¶ added in v0.2.1
type ChangeStrategy interface { GenerateDeploymentConfig(namespace, name string) (*deployapi.DeploymentConfig, error) UpdateDeploymentConfig(namespace string, config *deployapi.DeploymentConfig) (*deployapi.DeploymentConfig, error) }
ChangeStrategy knows how to generate and update DeploymentConfigs.
type DeploymentConfigChangeController ¶
type DeploymentConfigChangeController struct { ChangeStrategy ChangeStrategy NextDeploymentConfig func() *deployapi.DeploymentConfig DeploymentStore cache.Store Codec runtime.Codec // Stop is an optional channel that controls when the controller exits Stop <-chan struct{} }
DeploymentConfigChangeController watches for changes to DeploymentConfigs and regenerates them only when detecting a change to the PodTemplate of a DeploymentConfig containing a ConfigChange trigger.
func (*DeploymentConfigChangeController) HandleDeploymentConfig ¶
func (dc *DeploymentConfigChangeController) HandleDeploymentConfig()
HandleDeploymentConfig handles the next DeploymentConfig change that happens.
func (*DeploymentConfigChangeController) Run ¶
func (dc *DeploymentConfigChangeController) Run()
Run watches for config change events.
type DeploymentConfigController ¶
type DeploymentConfigController struct { // DeploymentInterface provides access to Deployments. DeploymentInterface dccDeploymentInterface // NextDeploymentConfig blocks until the next DeploymentConfig is available. NextDeploymentConfig func() *deployapi.DeploymentConfig // Codec is used to encode DeploymentConfigs which are stored on deployments. Codec runtime.Codec // Stop is an optional channel that controls when the controller exits. Stop <-chan struct{} }
DeploymentConfigController is responsible for creating a deployment when a DeploymentConfig is updated with a new LatestVersion. Any deployment created is correlated to a DeploymentConfig by setting the DeploymentConfigLabel on the deployment.
Deployments are represented by ReplicationControllers. The DeploymentConfig used to create the ReplicationController is encoded and stored in an annotation on the ReplicationController.
func (*DeploymentConfigController) HandleDeploymentConfig ¶
func (c *DeploymentConfigController) HandleDeploymentConfig()
Process a single DeploymentConfig event.
func (*DeploymentConfigController) Run ¶
func (c *DeploymentConfigController) Run()
Process DeploymentConfig events one at a time.
type DeploymentContainerCreator ¶ added in v0.2.1
type DeploymentContainerCreator interface {
CreateContainer(*deployapi.DeploymentStrategy) *kapi.Container
}
DeploymentContainerCreator knows how to create a deployment pod's container based on the deployment's strategy.
type DeploymentController ¶ added in v0.2.1
type DeploymentController struct { // ContainerCreator makes the container for the deployment pod based on the strategy. ContainerCreator DeploymentContainerCreator // DeploymentInterface provides access to deployments. DeploymentInterface dcDeploymentInterface // PodInterface provides access to pods. PodInterface dcPodInterface // NextDeployment blocks until the next deployment is available. NextDeployment func() *kapi.ReplicationController // NextPod blocks until the next pod is available. NextPod func() *kapi.Pod // DeploymentStore is a cache of deployments. DeploymentStore cache.Store // Environment is a set of environment which should be injected into all deployment pod // containers, in addition to whatever environment is specified by the ContainerCreator. Environment []kapi.EnvVar // UseLocalImages configures the ImagePullPolicy for containers in the deployment pod. UseLocalImages bool // Codec is used to decode DeploymentConfigs. Codec runtime.Codec // Stop is an optional channel that controls when the controller exits. Stop <-chan struct{} }
DeploymentController performs a deployment by creating a pod which is defined by a strategy. The status of the resulting deployment will follow the status of the corresponding pod.
Deployments are represented by a ReplicationController.
func (*DeploymentController) HandleDeployment ¶ added in v0.2.1
func (dc *DeploymentController) HandleDeployment()
HandleDeployment processes a new deployment and creates a new Pod which implements the specific deployment behavior. The deployment and pod are correlated with annotations. If the pod was successfully created, the deployment's status is transitioned to pending; otherwise, the status is transitioned to failed.
func (*DeploymentController) HandlePod ¶ added in v0.2.1
func (dc *DeploymentController) HandlePod()
HandlePod reconciles a pod's current state with its associated deployment and updates the deployment appropriately.
func (*DeploymentController) Run ¶ added in v0.2.1
func (dc *DeploymentController) Run()
Run begins watching and synchronizing deployment states.
type ImageChangeController ¶
type ImageChangeController struct { DeploymentConfigInterface icDeploymentConfigInterface NextImageRepository func() *imageapi.ImageRepository DeploymentConfigStore cache.Store // Stop is an optional channel that controls when the controller exits Stop <-chan struct{} }
ImageChangeController watches for changes to ImageRepositories and regenerates DeploymentConfigs when a new version of a tag referenced by a DeploymentConfig is available.
func (*ImageChangeController) HandleImageRepo ¶
func (c *ImageChangeController) HandleImageRepo()
HandleImageRepo processes the next ImageRepository event.
func (*ImageChangeController) Run ¶
func (c *ImageChangeController) Run()
Run processes ImageRepository events one by one.