deployerpod

type DeployerPodController ¶

type DeployerPodController struct {
	// contains filtered or unexported fields
}

DeployerPodController keeps a deployment's status in sync with the deployer pod handling the deployment.

Use the DeployerPodControllerFactory to create this controller.

func (c *DeployerPodController) Handle(pod *kapi.Pod) error

type DeployerPodControllerFactory ¶

type DeployerPodControllerFactory struct {
	// KubeClient is a Kubernetes client.
	KubeClient kclient.Interface
}

DeployerPodControllerFactory can create a DeployerPodController which gets pods from a queue populated from a watch of all pods filtered by a cache of deployments associated with pods.

func (factory *DeployerPodControllerFactory) Create() controller.RunnableController