orchestration

func ComputeHash ¶

func ComputeHash(template *orchestrationv1alpha1.RoleSetTemplateSpec, collisionCount *int32) string

ComputeHash returns a hash value calculated from stormService template and a collisionCount to avoid hash collision. The hash will be safe encoded to avoid bad words.

func DeepCopyMap ¶

func DeepCopyMap(source map[string]string) map[string]string

func FilterOutCondition ¶

func FilterOutCondition(conditions []orchestrationv1alpha1.Condition, condType orchestrationv1alpha1.ConditionType) []orchestrationv1alpha1.Condition

FilterOutCondition returns a new slice of stormService conditions without conditions with the provided type.

func GetCondition ¶

func GetCondition(conditions orchestrationv1alpha1.Conditions, condType orchestrationv1alpha1.ConditionType) *orchestrationv1alpha1.Condition

GetCondition returns the condition with the provided type.

func IsRoleSetReady ¶

func IsRoleSetReady(rs *orchestrationv1alpha1.RoleSet) bool

func MinInt ¶

func MinInt(a, b int) int

func MinInt32 ¶

func MinInt32(a, b int32) int32

func NewCondition ¶

func NewCondition(condType orchestrationv1alpha1.ConditionType, status v1.ConditionStatus, reason, message string) *orchestrationv1alpha1.Condition

NewCondition creates a new stormService condition.

func Patch ¶

func Patch(ctx context.Context, cli client.Client, obj client.Object, patch client.Patch) error

Patch object with retry. Original object would change.

func SlowStartBatch ¶

func SlowStartBatch(count int, initialBatchSize int, fn func(int) error) (int, error)

func UpdateStatus ¶

func UpdateStatus(ctx context.Context, scheme *runtime.Scheme, cli client.Client, obj client.Object) error

func ValidateControllerRef ¶

func ValidateControllerRef(controllerRef *metav1.OwnerReference) error