util

package
v3.6.119-1+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 20, 2017 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Index

Constants

View Source 
const DeployerPodSuffix = "deploy"

DeployerPodSuffix is the suffix added to pods created from a deployment

Variables

View Source 
var (
	// DeploymentConfigControllerRefKind contains the schema.GroupVersionKind for the
	// deployment config. This is used in the ownerRef and GC client picks the appropriate
	// client to get the deployment config.
	DeploymentConfigControllerRefKind = deployapiv1.SchemeGroupVersion.WithKind("DeploymentConfig")
)

Functions

func ActiveDeployment added in v1.1.1 

func ActiveDeployment(input []*api.ReplicationController) *api.ReplicationController

ActiveDeployment returns the latest complete deployment, or nil if there is no such deployment. The active deployment is not always the same as the latest deployment.

func ActiveDeploymentV1 

func ActiveDeploymentV1(input []*v1.ReplicationController) *v1.ReplicationController

ActiveDeploymentV1 returns the latest complete deployment, or nil if there is no such deployment. The active deployment is not always the same as the latest deployment.

func AnyDeployerPodSelector added in v0.6.2 

func AnyDeployerPodSelector() labels.Selector

AnyDeployerPodSelector returns a label Selector which can be used to find all deployer pods across all deployments, including hook and custom deployer pods.

func CanTransitionPhase added in v1.2.0 

func CanTransitionPhase(current, next deployapi.DeploymentStatus) bool

CanTransitionPhase returns whether it is allowed to go from the current to the next phase.

func ConfigSelector added in v0.5.4 

func ConfigSelector(name string) labels.Selector

ConfigSelector returns a label Selector which can be used to find all deployments for a DeploymentConfig.

TODO: Using the annotation constant for now since the value is correct but we could consider adding a new constant to the public types.

func CopyApiEnvVarToV1EnvVar 

func CopyApiEnvVarToV1EnvVar(in []api.EnvVar) []v1.EnvVar

func CopyApiResourcesToV1Resources 

func CopyApiResourcesToV1Resources(in *api.ResourceRequirements) v1.ResourceRequirements

func DecodeDeploymentConfig added in v0.2.1 

func DecodeDeploymentConfig(controller runtime.Object, decoder runtime.Decoder) (*deployapi.DeploymentConfig, error)

DecodeDeploymentConfig decodes a DeploymentConfig from controller using codec. An error is returned if the controller doesn't contain an encoded config.

func DeployerPodNameFor added in v0.5.2 

func DeployerPodNameFor(obj runtime.Object) string

func DeployerPodNameForDeployment added in v0.3.2 

func DeployerPodNameForDeployment(deployment string) string

DeployerPodNameForDeployment returns the name of a pod for a given deployment

func DeployerPodSelector added in v0.6.2 

func DeployerPodSelector(name string) labels.Selector

DeployerPodSelector returns a label Selector which can be used to find all deployer pods associated with a deployment with name.

func DeploymentConfigDeepCopy added in v1.3.0 

func DeploymentConfigDeepCopy(dc *deployapi.DeploymentConfig) (*deployapi.DeploymentConfig, error)

func DeploymentConfigNameFor added in v0.5.2 

func DeploymentConfigNameFor(obj runtime.Object) string

func DeploymentDeepCopy added in v1.3.0 

func DeploymentDeepCopy(rc *api.ReplicationController) (*api.ReplicationController, error)

func DeploymentDeepCopyV1 

func DeploymentDeepCopyV1(rc *v1.ReplicationController) (*v1.ReplicationController, error)

func DeploymentDesiredReplicas added in v0.5.3 

func DeploymentDesiredReplicas(obj runtime.Object) (int32, bool)

func DeploymentNameFor added in v0.5.2 

func DeploymentNameFor(obj runtime.Object) string

func DeploymentNameForConfigVersion added in v1.0.7 

func DeploymentNameForConfigVersion(name string, version int64) string

DeploymentNameForConfigVersion returns the name of the version-th deployment for the config that has the provided name

func DeploymentReplicas added in v1.1.1 

func DeploymentReplicas(obj runtime.Object) (int32, bool)

func DeploymentStatusFor added in v0.5.2 

func DeploymentStatusFor(obj runtime.Object) deployapi.DeploymentStatus

func DeploymentStatusReasonFor added in v0.5.3 

func DeploymentStatusReasonFor(obj runtime.Object) string

func DeploymentVersionFor added in v0.5.2 

func DeploymentVersionFor(obj runtime.Object) int64

func DeploymentsForCleanup added in v1.3.0 

func DeploymentsForCleanup(configuration *deployapi.DeploymentConfig, deployments []*v1.ReplicationController) []v1.ReplicationController

DeploymentsForCleanup determines which deployments for a configuration are relevant for the revision history limit quota

func EncodeDeploymentConfig added in v0.2.1 

func EncodeDeploymentConfig(config *deployapi.DeploymentConfig, codec runtime.Codec) (string, error)

EncodeDeploymentConfig encodes config as a string using codec.

func EncodedDeploymentConfigFor added in v0.5.2 

func EncodedDeploymentConfigFor(obj runtime.Object) string

func GetAvailableReplicaCountForReplicationControllers 

func GetAvailableReplicaCountForReplicationControllers(replicationControllers []*v1.ReplicationController) int32

GetAvailableReplicaCountForReplicationControllers returns the number of available pods corresponding to the given replication controller.

func GetDeploymentCondition added in v1.4.0 

func GetDeploymentCondition(status deployapi.DeploymentConfigStatus, condType deployapi.DeploymentConditionType) *deployapi.DeploymentCondition

GetDeploymentCondition returns the condition with the provided type.

func GetReadyReplicaCountForReplicationControllers added in v1.5.0 

func GetReadyReplicaCountForReplicationControllers(replicationControllers []*v1.ReplicationController) int32

GetReadyReplicaCountForReplicationControllers returns the number of ready pods corresponding to the given replication controller.

func GetReplicaCountForDeployments added in v1.3.0 

func GetReplicaCountForDeployments(deployments []*v1.ReplicationController) int32

GetReplicaCountForDeployments returns the sum of all replicas for the given deployments.

func GetStatusReplicaCountForDeployments added in v1.3.0 

func GetStatusReplicaCountForDeployments(deployments []*v1.ReplicationController) int32

GetStatusReplicaCountForDeployments returns the sum of the replicas reported in the status of the given deployments.

func HasChangeTrigger added in v1.0.7 

func HasChangeTrigger(config *deployapi.DeploymentConfig) bool

HasChangeTrigger returns whether the provided deployment configuration has a config change trigger or not

func HasImageChangeTrigger added in v1.4.0 

func HasImageChangeTrigger(config *deployapi.DeploymentConfig) bool

HasImageChangeTrigger returns whether the provided deployment configuration has an image change trigger or not.

func HasSynced added in v1.3.0 

func HasSynced(dc *deployapi.DeploymentConfig, generation int64) bool

HasSynced checks if the provided deployment config has been noticed by the deployment config controller.

func IsCompleteDeployment added in v1.4.0 

func IsCompleteDeployment(deployment runtime.Object) bool

IsCompleteDeployment returns true if the passed deployment failed.

func IsDeploymentCancelled added in v0.5.3 

func IsDeploymentCancelled(deployment runtime.Object) bool

func IsFailedDeployment added in v1.3.0 

func IsFailedDeployment(deployment runtime.Object) bool

IsFailedDeployment returns true if the passed deployment failed.

func IsOwnedByConfig added in v1.3.0 

func IsOwnedByConfig(obj metav1.Object) bool

IsOwnedByConfig checks whether the provided replication controller is part of a deployment configuration. TODO: Switch to use owner references once we got those working.

func IsProgressing added in v1.4.0 

func IsProgressing(config *deployapi.DeploymentConfig, newStatus *deployapi.DeploymentConfigStatus) bool

IsProgressing expects a state deployment config and its updated status in order to determine if there is any progress.

func IsRollingConfig added in v1.4.0 

func IsRollingConfig(config *deployapi.DeploymentConfig) bool

IsRollingConfig returns true if the strategy type is a rolling update.

func IsTerminatedDeployment added in v1.0.7 

func IsTerminatedDeployment(deployment runtime.Object) bool

IsTerminatedDeployment returns true if the passed deployment has terminated (either complete or failed).

func LabelForDeployment added in v0.5.1 

func LabelForDeployment(deployment *api.ReplicationController) string

LabelForDeployment builds a string identifier for a Deployment.

func LabelForDeploymentConfig added in v0.5.1 

func LabelForDeploymentConfig(config *deployapi.DeploymentConfig) string

LabelForDeploymentConfig builds a string identifier for a DeploymentConfig.

func LabelForDeploymentV1 

func LabelForDeploymentV1(deployment *v1.ReplicationController) string

LabelForDeployment builds a string identifier for a Deployment.

func LatestDeploymentInfo added in v1.0.7 

func LatestDeploymentInfo(config *deployapi.DeploymentConfig, deployments []*v1.ReplicationController) (bool, *v1.ReplicationController)

LatestDeploymentInfo returns info about the latest deployment for a config, or nil if there is no latest deployment. The latest deployment is not always the same as the active deployment.

func LatestDeploymentNameForConfig added in v0.2.1 

func LatestDeploymentNameForConfig(config *deployapi.DeploymentConfig) string

LatestDeploymentNameForConfig returns a stable identifier for config based on its version.

func MakeDeployment added in v0.2.1 

func MakeDeployment(config *deployapi.DeploymentConfig, codec runtime.Codec) (*api.ReplicationController, error)

MakeDeployment creates a deployment represented as an internal ReplicationController and based on the given DeploymentConfig. The controller replica count will be zero. DEPRECATED: Will be replaced with external version eventually.

func MakeDeploymentV1 

func MakeDeploymentV1(config *deployapi.DeploymentConfig, codec runtime.Codec) (*v1.ReplicationController, error)

MakeDeploymentV1 creates a deployment represented as a ReplicationController and based on the given DeploymentConfig. The controller replica count will be zero.

func MaxSurge added in v1.4.0 

func MaxSurge(config deployapi.DeploymentConfig) int32

MaxSurge returns the maximum surge pods a rolling deployment config can take.

func MaxUnavailable added in v1.4.0 

func MaxUnavailable(config *deployapi.DeploymentConfig) int32

MaxUnavailable returns the maximum unavailable pods a rolling deployment config can take.

func NewControllerRef 

func NewControllerRef(config *deployapi.DeploymentConfig) *metav1.OwnerReference

func NewDeploymentCondition added in v1.4.0 

func NewDeploymentCondition(condType deployapi.DeploymentConditionType, status api.ConditionStatus, reason deployapi.DeploymentConditionReason, message string) *deployapi.DeploymentCondition

NewDeploymentCondition creates a new deployment condition.

func RemoveDeploymentCondition added in v1.4.0 

func RemoveDeploymentCondition(status *deployapi.DeploymentConfigStatus, condType deployapi.DeploymentConditionType)

RemoveDeploymentCondition removes the deployment condition with the provided type.

func SetDeploymentCondition added in v1.4.0 

func SetDeploymentCondition(status *deployapi.DeploymentConfigStatus, condition deployapi.DeploymentCondition)

SetDeploymentCondition updates the deployment to include the provided condition. If the condition that we are about to add already exists and has the same status and reason then we are not going to update.

func WaitForRunningDeployerPod added in v1.3.0 

func WaitForRunningDeployerPod(podClient kcoreclient.PodsGetter, rc *api.ReplicationController, timeout time.Duration) error

WaitForRunningDeployerPod waits a given period of time until the deployer pod for given replication controller is not running.

Types

type ByLatestVersionAsc added in v1.0.7 

type ByLatestVersionAsc []*api.ReplicationController

ByLatestVersionAsc sorts deployments by LatestVersion ascending.

func (ByLatestVersionAsc) Len added in v1.0.7 

func (d ByLatestVersionAsc) Len() int

func (ByLatestVersionAsc) Less added in v1.0.7 

func (d ByLatestVersionAsc) Less(i, j int) bool

func (ByLatestVersionAsc) Swap added in v1.0.7 

func (d ByLatestVersionAsc) Swap(i, j int)

type ByLatestVersionAscV1 

type ByLatestVersionAscV1 []*v1.ReplicationController

func (ByLatestVersionAscV1) Len 

func (d ByLatestVersionAscV1) Len() int

func (ByLatestVersionAscV1) Less 

func (d ByLatestVersionAscV1) Less(i, j int) bool

func (ByLatestVersionAscV1) Swap 

func (d ByLatestVersionAscV1) Swap(i, j int)

type ByLatestVersionDesc added in v1.0.7 

type ByLatestVersionDesc []*api.ReplicationController

ByLatestVersionDesc sorts deployments by LatestVersion descending.

func (ByLatestVersionDesc) Len added in v1.0.7 

func (d ByLatestVersionDesc) Len() int

func (ByLatestVersionDesc) Less added in v1.0.7 

func (d ByLatestVersionDesc) Less(i, j int) bool

func (ByLatestVersionDesc) Swap added in v1.0.7 

func (d ByLatestVersionDesc) Swap(i, j int)

type ByLatestVersionDescV1 

type ByLatestVersionDescV1 []*v1.ReplicationController

ByLatestVersionDescV1 sorts deployments by LatestVersion descending.

func (ByLatestVersionDescV1) Len 

func (d ByLatestVersionDescV1) Len() int

func (ByLatestVersionDescV1) Less 

func (d ByLatestVersionDescV1) Less(i, j int) bool

func (ByLatestVersionDescV1) Swap 

func (d ByLatestVersionDescV1) Swap(i, j int)

type ByMostRecent added in v1.1.1 

type ByMostRecent []*api.ReplicationController

ByMostRecent sorts deployments by most recently created.

func (ByMostRecent) Len added in v1.1.1 

func (s ByMostRecent) Len() int

func (ByMostRecent) Less added in v1.1.1 

func (s ByMostRecent) Less(i, j int) bool

func (ByMostRecent) Swap added in v1.1.1 

func (s ByMostRecent) Swap(i, j int)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.