deployitem

func AddControllerToManager ¶

func AddControllerToManager(lsUncachedClient, lsCachedClient client.Client,
	logger logging.Logger,
	lsMgr manager.Manager,
	config config.DeployItemsController,
	deployItemPickupTimeout *lscore.Duration) error

func HasBeenPickedUp ¶

func HasBeenPickedUp(di *lsv1alpha1.DeployItem) bool

func NewController ¶

func NewController(lsUncachedClient, lsCachedClient client.Client,
	logger logging.Logger, scheme *runtime.Scheme, pickupTimeout *lscore.Duration,
	maxNumberOfWorkers int) (reconcile.Reconciler, error)

NewController creates a new deploy item controller that handles timeouts To detect pickup timeouts (when a DeployItem resource is not reconciled by any deployer within a specified timeframe), the controller checks for a timestamp annotation. It is expected that deployers remove the timestamp annotation from deploy items during reconciliation. If the timestamp annotation exists and is older than a specified duration, the controller marks the deploy item as failed. pickupTimeout is a string containing the pickup timeout duration, either as 'none' or as a duration that can be parsed by time.ParseDuration.