package deployment

import "k8s.io/kubernetes/pkg/util/deployment"

Index ¶

• func CloneAndAddLabel(labels map[string]string, labelKey string, labelValue uint32) map[string]string
• func GetAvailablePodsForRCs(c client.Interface, rcs []*api.ReplicationController, minReadySeconds int) (int, error)
• func GetNewRC(deployment extensions.Deployment, c client.Interface) (*api.ReplicationController, error)
• func GetNewRCFromList(deployment extensions.Deployment, c client.Interface, getRcList func(string, api.ListOptions) ([]api.ReplicationController, error)) (*api.ReplicationController, error)
• func GetNewRCTemplate(deployment extensions.Deployment) api.PodTemplateSpec
• func GetOldRCs(deployment extensions.Deployment, c client.Interface) ([]*api.ReplicationController, error)
• func GetOldRCsFromLists(deployment extensions.Deployment, c client.Interface, getPodList func(string, api.ListOptions) (*api.PodList, error), getRcList func(string, api.ListOptions) ([]api.ReplicationController, error)) ([]*api.ReplicationController, error)
• func GetPodTemplateSpecHash(template api.PodTemplateSpec) uint32
• func GetReplicaCountForRCs(replicationControllers []*api.ReplicationController) int

Functions ¶

func CloneAndAddLabel ¶

func CloneAndAddLabel(labels map[string]string, labelKey string, labelValue uint32) map[string]string

Clones the given map and returns a new map with the given key and value added. Returns the given map, if labelKey is empty.

func GetAvailablePodsForRCs ¶

func GetAvailablePodsForRCs(c client.Interface, rcs []*api.ReplicationController, minReadySeconds int) (int, error)

Returns the number of available pods corresponding to the given RCs.

func GetNewRC ¶

func GetNewRC(deployment extensions.Deployment, c client.Interface) (*api.ReplicationController, error)

GetNewRC returns an RC that matches the intent of the given deployment; get RCList from client interface. Returns nil if the new RC doesnt exist yet.

func GetNewRCFromList ¶

func GetNewRCFromList(deployment extensions.Deployment, c client.Interface, getRcList func(string, api.ListOptions) ([]api.ReplicationController, error)) (*api.ReplicationController, error)

GetNewRCFromList returns an RC that matches the intent of the given deployment; get RCList with the input function. Returns nil if the new RC doesnt exist yet.

func GetNewRCTemplate ¶

func GetNewRCTemplate(deployment extensions.Deployment) api.PodTemplateSpec

Returns the desired PodTemplateSpec for the new RC corresponding to the given RC.

func GetOldRCs ¶

func GetOldRCs(deployment extensions.Deployment, c client.Interface) ([]*api.ReplicationController, error)

GetOldRCs returns the old RCs targeted by the given Deployment; get PodList and RCList from client interface.

func GetOldRCsFromLists ¶

func GetOldRCsFromLists(deployment extensions.Deployment, c client.Interface, getPodList func(string, api.ListOptions) (*api.PodList, error), getRcList func(string, api.ListOptions) ([]api.ReplicationController, error)) ([]*api.ReplicationController, error)

GetOldRCsFromLists returns the old RCs targeted by the given Deployment; get PodList and RCList with input functions.

func GetPodTemplateSpecHash ¶

func GetPodTemplateSpecHash(template api.PodTemplateSpec) uint32

func GetReplicaCountForRCs ¶

func GetReplicaCountForRCs(replicationControllers []*api.ReplicationController) int

Returns the sum of Replicas of the given replication controllers.

Source Files ¶

deployment.go