progressive

Documentation

Index

• func IsNumaflowChildReady(upgradingObjectStatus *kubernetes.GenericStatus) bool
• func ProcessResource(ctx context.Context, rolloutObject ctlrcommon.RolloutObject, ...) (bool, bool, time.Duration, error)

Functions

func IsNumaflowChildReady

func IsNumaflowChildReady(upgradingObjectStatus *kubernetes.GenericStatus) bool

func ProcessResource

func ProcessResource(
	ctx context.Context,
	rolloutObject ctlrcommon.RolloutObject,
	liveRolloutObject ctlrcommon.RolloutObject,
	existingPromotedChild *unstructured.Unstructured,
	promotedDifference bool,
	controller progressiveController,
	c client.Client,
) (bool, bool, time.Duration, error)

return: - whether we're done - whether we just created a new child - duration indicating the requeue delay for the controller to use for next reconciliation - error if any