squad

func CanaryThreshold ¶

func CanaryThreshold(squad carrierv1alpha1.Squad) int32

CanaryThreshold return the replicas of CanaryUpdate

func ComputeHash ¶

func ComputeHash(template *carrierv1alpha1.GameServerTemplateSpec) string

ComputeHash returns a hash value calculated from GameServerTemplateSpec

func ComputePodSpecHash ¶

func ComputePodSpecHash(spec *corev1.PodSpec) string

ComputePodSpecHash return the hash value of the podspec

func EqualGameServerTemplate ¶

func EqualGameServerTemplate(template1, template2 *carrierv1alpha1.GameServerTemplateSpec) bool

EqualGameServerTemplate returns true if two given GameServerTemplateSpec are equal, ignoring some diff in value of Labels

func FilterActiveGameServerSets ¶

func FilterActiveGameServerSets(gsSetList []*carrierv1alpha1.GameServerSet) []*carrierv1alpha1.GameServerSet

FilterActiveGameServerSets returns GameServerSets that have (or at least ought to have) GameServers.

func FilterGameServerSets ¶

func FilterGameServerSets(
	gsSetList []*carrierv1alpha1.GameServerSet,
	filterFn filterGSSet) []*carrierv1alpha1.GameServerSet

FilterGameServerSets returns GameServerSet that are filtered by filterFn (all returned ones should match filterFn).

func FindActiveOrLatest ¶

func FindActiveOrLatest(
	newGSSet *carrierv1alpha1.GameServerSet,
	oldGSSets []*carrierv1alpha1.GameServerSet) *carrierv1alpha1.GameServerSet

FindActiveOrLatest returns the only active or the latest GameServerSet in case there is at most one active GameServerSet. If there are more active GameServerSet, then we should proportionally scale them.

func FindNewGameServerSet ¶

func FindNewGameServerSet(
	squad *carrierv1alpha1.Squad,
	gsSetList []*carrierv1alpha1.GameServerSet) *carrierv1alpha1.GameServerSet

FindNewGameServerSet returns the new GameServerSet this given Squad targets (the one with the same GameServer template).

func FindOldGameServerSets ¶

func FindOldGameServerSets(
	squad *carrierv1alpha1.Squad,
	gsSetList []*carrierv1alpha1.GameServerSet) ([]*carrierv1alpha1.GameServerSet, []*carrierv1alpha1.GameServerSet)

FindOldGameServerSets returns the old GameServerSets targeted by the given Squad, with the given slice of GameServerSets. Note that the first set of old GameServerSets doesn't include the ones with no GameServers, and the second set of old GameServerSets include all old GameServerSets.

func GameServerSetToSquadCondition ¶

func GameServerSetToSquadCondition(cond carrierv1alpha1.GameServerSetCondition) carrierv1alpha1.SquadCondition

GameServerSetToSquadCondition converts a GameServerSet condition into a Squad condition. Useful for promoting GameServerSet failure conditions into Squad.

func GetActualReplicaCountForGameServerSets ¶

func GetActualReplicaCountForGameServerSets(gsSetList []*carrierv1alpha1.GameServerSet) int32

GetActualReplicaCountForGameServerSets returns the sum of actual replicas of the given GameServerSet.

func GetDesiredReplicasAnnotation ¶

func GetDesiredReplicasAnnotation(gsSet *carrierv1alpha1.GameServerSet) (int32, bool)

GetDesiredReplicasAnnotation returns the number of desired replicas

func GetProportion ¶

func GetProportion(
	gsSet *carrierv1alpha1.GameServerSet,
	squad carrierv1alpha1.Squad,
	squadReplicasToAdd,
	squadReplicasAdded int32) int32

GetProportion will estimate the proportion for the provided GameServerSet using 1. the current size of the parent Squad 2. the replica count that needs be added on the GameServerSet of the Squad 3. the total replicas added in the GameServerSet of the Squad so far.

func GetReadyReplicaCountForGameServerSets ¶

func GetReadyReplicaCountForGameServerSets(gsSetList []*carrierv1alpha1.GameServerSet) int32

GetReadyReplicaCountForGameServerSets returns the number of ready GameServers corresponding to the given GameServerSets.

func GetReplicaCountForGameServerSets ¶

func GetReplicaCountForGameServerSets(gsSetList []*carrierv1alpha1.GameServerSet) int32

GetReplicaCountForGameServerSets returns the sum of Replicas of the given GameServerSets.

func GetSquadCondition ¶

func GetSquadCondition(
	status carrierv1alpha1.SquadStatus,
	condType carrierv1alpha1.SquadConditionType) *carrierv1alpha1.SquadCondition

GetSquadCondition returns the condition with the provided type.

func GetUpdateReplicaCountForGameServerSets ¶

func GetUpdateReplicaCountForGameServerSets(gsSetList []*carrierv1alpha1.GameServerSet) int32

GetUpdateReplicaCountForGameServerSets returns the sum of update replicas of the given GameServerSet.

func HasRevisionHistoryLimit ¶

func HasRevisionHistoryLimit(squad *carrierv1alpha1.Squad) bool

HasRevisionHistoryLimit checks if the Squad d is expected to keep a specified number of old GameServerSets

func InplaceThreshold ¶

func InplaceThreshold(squad carrierv1alpha1.Squad) int32

InplaceThreshold return the replicas of InplaceUpdate

func IsCanaryUpdate ¶

func IsCanaryUpdate(squad *carrierv1alpha1.Squad) bool

IsCanaryUpdate returns true if the strategy type is a canary update.

func IsGameServerSetScaling ¶

func IsGameServerSetScaling(gsSet *carrierv1alpha1.GameServerSet, squad *carrierv1alpha1.Squad) bool

IsGameServerSetScaling return true if only scaling GameServerSet

func IsGracefulUpdate ¶

func IsGracefulUpdate(squad *carrierv1alpha1.Squad) bool

IsGracefulUpdate return true if only 'GracefulUpdateAnnotation' is true

func IsInplaceUpdate ¶

func IsInplaceUpdate(squad *carrierv1alpha1.Squad) bool

IsInplaceUpdate returns true if the strategy type is a inplace update

func IsRollingUpdate ¶

func IsRollingUpdate(squad *carrierv1alpha1.Squad) bool

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

func IsSaturated ¶

func IsSaturated(squad *carrierv1alpha1.Squad, gsSet *carrierv1alpha1.GameServerSet) bool

IsSaturated checks if the new GameServerSet is saturated by comparing its size with its Squad size.

func LastRevision ¶

func LastRevision(allGSSets []*carrierv1alpha1.GameServerSet) int64

LastRevision finds the second max revision number in all GameServerSet (the last revision)

func MaxRevision ¶

func MaxRevision(allGSSets []*carrierv1alpha1.GameServerSet) int64

MaxRevision finds the highest revision in the GameServerSet

func MaxSurge ¶

func MaxSurge(squad carrierv1alpha1.Squad) int32

MaxSurge returns the maximum surge GameServers a rolling squad can take.

func MaxUnavailable ¶

func MaxUnavailable(squad carrierv1alpha1.Squad) int32

MaxUnavailable returns the maximum unavailable GameServers a rolling squad can take.

func NewGSSetNewReplicas ¶

func NewGSSetNewReplicas(
	squad *carrierv1alpha1.Squad,
	allGSSets []*carrierv1alpha1.GameServerSet,
	newGSSet *carrierv1alpha1.GameServerSet) (int32, error)

NewGSSetNewReplicas calculates the number of replicas a squad's new GSSet should have. When one of the followings is true, we're rolling out the squad; otherwise, we're scaling it. 1) The new GSSet is saturated: newGSSet's replicas == squad's replicas 2) Max number of GameServers allowed is reached: squad's replicas + maxSurge == all GSSets' replicas

func NewSquadCondition ¶

func NewSquadCondition(
	condType carrierv1alpha1.SquadConditionType,
	status corev1.ConditionStatus,
	reason, message string) *carrierv1alpha1.SquadCondition

NewSquadCondition creates a new squad condition.

func RemoveSquadCondition ¶

func RemoveSquadCondition(status *carrierv1alpha1.SquadStatus, condType carrierv1alpha1.SquadConditionType)

RemoveSquadCondition removes the Squad condition with the provided type.

func ReplicasAnnotationsNeedUpdate ¶

func ReplicasAnnotationsNeedUpdate(gsSet *carrierv1alpha1.GameServerSet, desiredReplicas, maxReplicas int32) bool

ReplicasAnnotationsNeedUpdate return true if ReplicasAnnotations need to be updated

func ResolveFenceposts ¶

func ResolveFenceposts(maxSurge, maxUnavailable *intstrutil.IntOrString, desired int32) (int32, int32, error)

ResolveFenceposts resolves both maxSurge and maxUnavailable. This needs to happen in one step. For example:

2 desired, max unavailable 1%, surge 0% - should scale old(-1), then new(+1), then old(-1), then new(+1) 1 desired, max unavailable 1%, surge 0% - should scale old(-1), then new(+1) 2 desired, max unavailable 25%, surge 1% - should scale new(+1), then old(-1), then new(+1), then old(-1) 1 desired, max unavailable 25%, surge 1% - should scale new(+1), then old(-1) 2 desired, max unavailable 0%, surge 1% - should scale new(+1), then old(-1), then new(+1), then old(-1) 1 desired, max unavailable 0%, surge 1% - should scale new(+1), then old(-1)

func Revision ¶

func Revision(obj runtime.Object) (int64, error)

Revision returns the revision number of the input object.

func SetFromGameServerSetTemplate ¶

func SetFromGameServerSetTemplate(
	squad *carrierv1alpha1.Squad,
	template carrierv1alpha1.GameServerTemplateSpec) *carrierv1alpha1.Squad

SetFromGameServerSetTemplate sets the desired GameServerTemplateSpec from a GameServerSettemplate to the given squad.

func SetGameServerSetInplaceUpdateAnnotations ¶

func SetGameServerSetInplaceUpdateAnnotations(gsSet *carrierv1alpha1.GameServerSet, squad *carrierv1alpha1.Squad)

SetGameServerSetInplaceUpdateAnnotations setting GameServerSet annotations when inplace update

func SetGameServerTemplateHashLabels ¶

func SetGameServerTemplateHashLabels(gsSet *carrierv1alpha1.GameServerSet)

SetGameServerTemplateHashLabels setting pod spec hash to GameServerSet labels

func SetNewGameServerSetAnnotations ¶

func SetNewGameServerSetAnnotations(
	squad *carrierv1alpha1.Squad,
	newGSSet *carrierv1alpha1.GameServerSet,
	newRevision string,
	exists bool,
	revHistoryLimitInChars int) bool

SetNewGameServerSetAnnotations sets new GameServerSet's annotations appropriately by updating its revision and copying required Squad annotations to it; it returns true if GameServerSet's annotation is changed.

func SetReplicasAnnotations ¶

func SetReplicasAnnotations(gsSet *carrierv1alpha1.GameServerSet, desiredReplicas, maxReplicas int32) bool

SetReplicasAnnotations sets the desiredReplicas and maxReplicas into the annotations

func SetScalingAnnotations ¶

func SetScalingAnnotations(gsSet *carrierv1alpha1.GameServerSet) bool

SetScalingAnnotations sets the scaling mark into the annotations

func SetSquadAnnotationsTo ¶

func SetSquadAnnotationsTo(squad *carrierv1alpha1.Squad, rollbackToGSSet *carrierv1alpha1.GameServerSet)

SetSquadAnnotationsTo sets Squad's annotations as given GSSet's annotations. This action should be done if and only if the Squad is rolling back to this rs. Note that apply and revision annotations are not changed.

func SetSquadCondition ¶

func SetSquadCondition(status *carrierv1alpha1.SquadStatus, condition carrierv1alpha1.SquadCondition)

SetSquadCondition updates the squad 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 SetSquadRevision ¶

func SetSquadRevision(squad *carrierv1alpha1.Squad, revision string) bool

SetSquadRevision updates the revision for a squad.

func SquadComplete ¶

func SquadComplete(squad *carrierv1alpha1.Squad, newStatus *carrierv1alpha1.SquadStatus) bool

SquadComplete considers a Squad to be complete once all of its desired replicas are updated , and no old GameServers are running.

func SquadProgressing ¶

func SquadProgressing(squad *carrierv1alpha1.Squad, newStatus *carrierv1alpha1.SquadStatus) bool

SquadProgressing reports progress for a Squad. Progress is estimated by comparing the current with the new status of the Squad that the controller is observing. More specifically, when new GameServers are scaled up or become ready or available, or old GameServers are scaled down, then we consider the Squad is progressing.