execution

Documentation

Index

• func ApplyDeployItemTemplate(di *lsv1alpha1.DeployItem, tmpl lsv1alpha1.DeployItemTemplate)
• type DeployItemClassification
  • func (c *DeployItemClassification) AllSucceeded() bool
  • func (c *DeployItemClassification) GetRunnableItems() []*executionItem
  • func (c *DeployItemClassification) HasFailedItems() bool
  • func (c *DeployItemClassification) HasPendingItems() bool
  • func (c *DeployItemClassification) HasRunnableItems() bool
  • func (c *DeployItemClassification) HasRunningItems() bool
  • func (c *DeployItemClassification) HasSucceededItems() bool
• type Operation
  • func NewOperation(op *operation.Operation, exec *lsv1alpha1.Execution, forceReconcile bool) *Operation
  • func (o *Operation) CollectAndUpdateExportsNew(ctx context.Context) lserrors.LsError
  • func (o *Operation) CreateOrUpdateExportReference(ctx context.Context, values interface{}) error
  • func (o *Operation) ListManagedDeployItems(ctx context.Context, readID read_write_layer.ReadID, ...) ([]*lsv1alpha1.DeployItem, error)
  • func (o *Operation) TriggerDeployItems(ctx context.Context) (*DeployItemClassification, lserrors.LsError)
  • func (o *Operation) TriggerDeployItemsForDelete(ctx context.Context) (*DeployItemClassification, lserrors.LsError)
  • func (o *Operation) UpdateDeployItems(ctx context.Context, deployItemCache *lsv1alpha1.DeployItemCache) lserrors.LsError

Functions

func ApplyDeployItemTemplate

func ApplyDeployItemTemplate(di *lsv1alpha1.DeployItem, tmpl lsv1alpha1.DeployItemTemplate)

ApplyDeployItemTemplate sets and updates the values defined by deploy item template on a deploy item.

Types

type DeployItemClassification

type DeployItemClassification struct {
	// contains filtered or unexported fields
}

DeployItemClassification divides all the deploy items of an execution into the following classes. Every item belongs to exactly one class. - running items: they have the same jobID as the execution, but are unfinished - succeeded items: they have the same jobID as the execution, are finished and succeeded - failed items: they have the same jobID as the execution, are finished and not succeeded (=> failed) - runnableItems: they have an old jobID, which can be updated because there are no pending dependencies - pending items: they have an old jobID, which can not be updated because of pending dependencies

func (*DeployItemClassification) AllSucceeded

func (c *DeployItemClassification) AllSucceeded() bool

func (*DeployItemClassification) GetRunnableItems

func (c *DeployItemClassification) GetRunnableItems() []*executionItem

func (*DeployItemClassification) HasFailedItems

func (c *DeployItemClassification) HasFailedItems() bool

func (*DeployItemClassification) HasPendingItems

func (c *DeployItemClassification) HasPendingItems() bool

func (*DeployItemClassification) HasRunnableItems

func (c *DeployItemClassification) HasRunnableItems() bool

func (*DeployItemClassification) HasRunningItems

func (c *DeployItemClassification) HasRunningItems() bool

func (*DeployItemClassification) HasSucceededItems

func (c *DeployItemClassification) HasSucceededItems() bool

type Operation

type Operation struct {
	*operation.Operation
	// contains filtered or unexported fields
}

Operation contains all execution operations

func NewOperation

func NewOperation(op *operation.Operation, exec *lsv1alpha1.Execution, forceReconcile bool) *Operation

NewOperation creates a new execution operations

func (*Operation) CollectAndUpdateExportsNew

func (o *Operation) CollectAndUpdateExportsNew(ctx context.Context) lserrors.LsError

CollectAndUpdateExportsNew loads all exports of all deployitems and persists them in a data object in the cluster. It also updates the export reference of the execution.

func (*Operation) CreateOrUpdateExportReference

func (o *Operation) CreateOrUpdateExportReference(ctx context.Context, values interface{}) error

CreateOrUpdateExportReference creates or updates a dataobject from a object reference

func (*Operation) ListManagedDeployItems

func (o *Operation) ListManagedDeployItems(ctx context.Context, readID read_write_layer.ReadID,
	deployItemCache *lsv1alpha1.DeployItemCache) ([]*lsv1alpha1.DeployItem, error)

listManagedDeployItems collects all deploy items that are managed by the execution. The managed execution is identified by the managed by label and the ownership.

func (*Operation) TriggerDeployItems

func (o *Operation) TriggerDeployItems(ctx context.Context) (*DeployItemClassification, lserrors.LsError)

func (*Operation) TriggerDeployItemsForDelete

func (o *Operation) TriggerDeployItemsForDelete(ctx context.Context) (*DeployItemClassification, lserrors.LsError)

func (*Operation) UpdateDeployItems

func (o *Operation) UpdateDeployItems(ctx context.Context, deployItemCache *lsv1alpha1.DeployItemCache) lserrors.LsError