Documentation
¶
Index ¶
- type DeprovisionOperationManager
- func (om *DeprovisionOperationManager) InsertOperation(operation internal.DeprovisioningOperation) (internal.DeprovisioningOperation, time.Duration, error)
- func (om *DeprovisionOperationManager) OperationFailed(operation internal.DeprovisioningOperation, description string, err error, ...) (internal.DeprovisioningOperation, time.Duration, error)
- func (om *DeprovisionOperationManager) OperationSucceeded(operation internal.DeprovisioningOperation, description string, ...) (internal.DeprovisioningOperation, time.Duration, error)
- func (om *DeprovisionOperationManager) RetryOperation(operation internal.DeprovisioningOperation, errorMessage string, err error, ...) (internal.DeprovisioningOperation, time.Duration, error)
- func (om *DeprovisionOperationManager) RetryOperationOnce(operation internal.DeprovisioningOperation, errorMessage string, err error, ...) (internal.DeprovisioningOperation, time.Duration, error)
- func (om *DeprovisionOperationManager) RetryOperationWithoutFail(operation internal.DeprovisioningOperation, description string, ...) (internal.DeprovisioningOperation, time.Duration, error)
- func (om *DeprovisionOperationManager) UpdateOperation(operation internal.DeprovisioningOperation, ...) (internal.DeprovisioningOperation, time.Duration, error)
- type DeprovisioningStepProcessed
- type Executor
- type OperationManager
- func (om *OperationManager) MarkStepAsExcutedButNotCompleted(operation internal.Operation, stepName string, msg string, ...) (internal.Operation, time.Duration, error)
- func (om *OperationManager) OperationCanceled(operation internal.Operation, description string, log logrus.FieldLogger) (internal.Operation, time.Duration, error)
- func (om *OperationManager) OperationFailed(operation internal.Operation, description string, err error, ...) (internal.Operation, time.Duration, error)
- func (om *OperationManager) OperationSucceeded(operation internal.Operation, description string, log logrus.FieldLogger) (internal.Operation, time.Duration, error)
- func (om *OperationManager) RetryOperation(operation internal.Operation, errorMessage string, err error, ...) (internal.Operation, time.Duration, error)
- func (om *OperationManager) RetryOperationOnce(operation internal.Operation, errorMessage string, err error, ...) (internal.Operation, time.Duration, error)
- func (om *OperationManager) RetryOperationWithoutFail(operation internal.Operation, stepName string, description string, ...) (internal.Operation, time.Duration, error)
- func (om *OperationManager) UpdateOperation(operation internal.Operation, update func(operation *internal.Operation), ...) (internal.Operation, time.Duration, error)
- type OperationStepProcessed
- type OperationSucceeded
- type ProvisionOperationManager
- func (om *ProvisionOperationManager) HandleError(operation internal.ProvisioningOperation, err error, log logrus.FieldLogger, ...) (internal.ProvisioningOperation, time.Duration, error)
- func (om *ProvisionOperationManager) OperationFailed(operation internal.ProvisioningOperation, description string, err error, ...) (internal.ProvisioningOperation, time.Duration, error)
- func (om *ProvisionOperationManager) OperationSucceeded(operation internal.ProvisioningOperation, description string, ...) (internal.ProvisioningOperation, time.Duration, error)
- func (om *ProvisionOperationManager) RetryOperation(operation internal.ProvisioningOperation, errorMessage string, err error, ...) (internal.ProvisioningOperation, time.Duration, error)
- func (om *ProvisionOperationManager) RetryOperationOnce(operation internal.ProvisioningOperation, errorMessage string, err error, ...) (internal.ProvisioningOperation, time.Duration, error)
- func (om *ProvisionOperationManager) SimpleUpdateOperation(operation internal.ProvisioningOperation) (internal.ProvisioningOperation, time.Duration)deprecated
- func (om *ProvisionOperationManager) UpdateOperation(operation internal.ProvisioningOperation, ...) (internal.ProvisioningOperation, time.Duration, error)
- type ProvisioningStepProcessed
- type ProvisioningSucceeded
- type Queue
- type StagedManager
- func (m *StagedManager) AddStep(stageName string, step Step, cnd StepCondition) error
- func (m *StagedManager) DefineStages(names []string)
- func (m *StagedManager) Execute(operationID string) (time.Duration, error)
- func (m *StagedManager) GetAllStages() []string
- func (m *StagedManager) SpeedUp(speedFactor int64)
- type Step
- type StepCondition
- type StepProcessed
- type StepWithCondition
- type UpdateOperationManager
- func (om *UpdateOperationManager) OperationFailed(operation internal.UpdatingOperation, description string, err error, ...) (internal.UpdatingOperation, time.Duration, error)
- func (om *UpdateOperationManager) OperationSucceeded(operation internal.UpdatingOperation, description string, ...) (internal.UpdatingOperation, time.Duration, error)
- func (om *UpdateOperationManager) RetryOperation(operation internal.UpdatingOperation, errorMessage string, err error, ...) (internal.UpdatingOperation, time.Duration, error)
- func (om *UpdateOperationManager) RetryOperationWithoutFail(operation internal.UpdatingOperation, description string, ...) (internal.UpdatingOperation, time.Duration, error)
- func (om *UpdateOperationManager) SimpleUpdateOperation(operation internal.UpdatingOperation) (internal.UpdatingOperation, time.Duration)deprecated
- func (om *UpdateOperationManager) UpdateOperation(operation internal.UpdatingOperation, ...) (internal.UpdatingOperation, time.Duration, error)
- type UpdatingStepProcessed
- type UpgradeClusterOperationManager
- func (om *UpgradeClusterOperationManager) OperationCanceled(operation internal.UpgradeClusterOperation, description string, ...) (internal.UpgradeClusterOperation, time.Duration, error)
- func (om *UpgradeClusterOperationManager) OperationFailed(operation internal.UpgradeClusterOperation, description string, err error, ...) (internal.UpgradeClusterOperation, time.Duration, error)
- func (om *UpgradeClusterOperationManager) OperationSucceeded(operation internal.UpgradeClusterOperation, description string, ...) (internal.UpgradeClusterOperation, time.Duration, error)
- func (om *UpgradeClusterOperationManager) RetryOperation(operation internal.UpgradeClusterOperation, errorMessage string, err error, ...) (internal.UpgradeClusterOperation, time.Duration, error)
- func (om *UpgradeClusterOperationManager) RetryOperationWithoutFail(operation internal.UpgradeClusterOperation, description string, ...) (internal.UpgradeClusterOperation, time.Duration, error)
- func (om *UpgradeClusterOperationManager) SimpleUpdateOperation(operation internal.UpgradeClusterOperation) (internal.UpgradeClusterOperation, time.Duration)deprecated
- func (om *UpgradeClusterOperationManager) UpdateOperation(operation internal.UpgradeClusterOperation, ...) (internal.UpgradeClusterOperation, time.Duration, error)
- type UpgradeClusterStepProcessed
- type UpgradeKymaOperationManager
- func (om *UpgradeKymaOperationManager) OperationCanceled(operation internal.UpgradeKymaOperation, description string, ...) (internal.UpgradeKymaOperation, time.Duration, error)
- func (om *UpgradeKymaOperationManager) OperationFailed(operation internal.UpgradeKymaOperation, description string, err error, ...) (internal.UpgradeKymaOperation, time.Duration, error)
- func (om *UpgradeKymaOperationManager) OperationSucceeded(operation internal.UpgradeKymaOperation, description string, ...) (internal.UpgradeKymaOperation, time.Duration, error)
- func (om *UpgradeKymaOperationManager) RetryOperation(operation internal.UpgradeKymaOperation, errorMessage string, err error, ...) (internal.UpgradeKymaOperation, time.Duration, error)
- func (om *UpgradeKymaOperationManager) RetryOperationWithoutFail(operation internal.UpgradeKymaOperation, description string, ...) (internal.UpgradeKymaOperation, time.Duration, error)
- func (om *UpgradeKymaOperationManager) SimpleUpdateOperation(operation internal.UpgradeKymaOperation) (internal.UpgradeKymaOperation, time.Duration)deprecated
- func (om *UpgradeKymaOperationManager) UpdateOperation(operation internal.UpgradeKymaOperation, ...) (internal.UpgradeKymaOperation, time.Duration, error)
- type UpgradeKymaStepProcessed
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DeprovisionOperationManager ¶
type DeprovisionOperationManager struct {
// contains filtered or unexported fields
}
func NewDeprovisionOperationManager ¶
func NewDeprovisionOperationManager(storage storage.Operations) *DeprovisionOperationManager
func (*DeprovisionOperationManager) InsertOperation ¶
func (om *DeprovisionOperationManager) InsertOperation(operation internal.DeprovisioningOperation) (internal.DeprovisioningOperation, time.Duration, error)
InsertOperation stores operation in database
func (*DeprovisionOperationManager) OperationFailed ¶
func (om *DeprovisionOperationManager) OperationFailed(operation internal.DeprovisioningOperation, description string, err error, log logrus.FieldLogger) (internal.DeprovisioningOperation, time.Duration, error)
OperationFailed marks the operation as failed and only repeats it if there is a storage error
func (*DeprovisionOperationManager) OperationSucceeded ¶
func (om *DeprovisionOperationManager) OperationSucceeded(operation internal.DeprovisioningOperation, description string, log logrus.FieldLogger) (internal.DeprovisioningOperation, time.Duration, error)
OperationSucceeded marks the operation as succeeded and only repeats it if there is a storage error
func (*DeprovisionOperationManager) RetryOperation ¶
func (om *DeprovisionOperationManager) RetryOperation(operation internal.DeprovisioningOperation, errorMessage string, err error, retryInterval time.Duration, maxTime time.Duration, log logrus.FieldLogger) (internal.DeprovisioningOperation, time.Duration, error)
RetryOperation retries an operation for at maxTime in retryInterval steps and fails the operation if retrying failed
func (*DeprovisionOperationManager) RetryOperationOnce ¶
func (om *DeprovisionOperationManager) RetryOperationOnce(operation internal.DeprovisioningOperation, errorMessage string, err error, wait time.Duration, log logrus.FieldLogger) (internal.DeprovisioningOperation, time.Duration, error)
RetryOperationOnce retries the operation once and fails the operation when call second time
func (*DeprovisionOperationManager) RetryOperationWithoutFail ¶
func (om *DeprovisionOperationManager) RetryOperationWithoutFail(operation internal.DeprovisioningOperation, description string, retryInterval, maxTime time.Duration, log logrus.FieldLogger) (internal.DeprovisioningOperation, time.Duration, error)
RetryOperationWithoutFail retries an operation for at maxTime in retryInterval steps and omits the operation if retrying failed
func (*DeprovisionOperationManager) UpdateOperation ¶
func (om *DeprovisionOperationManager) UpdateOperation(operation internal.DeprovisioningOperation, overwrite func(operation *internal.DeprovisioningOperation), log logrus.FieldLogger) (internal.DeprovisioningOperation, time.Duration, error)
UpdateOperation updates a given operation and handles conflict situation
type DeprovisioningStepProcessed ¶
type DeprovisioningStepProcessed struct { StepProcessed OldOperation internal.DeprovisioningOperation Operation internal.DeprovisioningOperation }
type OperationManager ¶
type OperationManager struct {
// contains filtered or unexported fields
}
func NewOperationManager ¶
func NewOperationManager(storage storage.Operations) *OperationManager
func (*OperationManager) MarkStepAsExcutedButNotCompleted ¶
func (*OperationManager) OperationCanceled ¶
func (om *OperationManager) OperationCanceled(operation internal.Operation, description string, log logrus.FieldLogger) (internal.Operation, time.Duration, error)
OperationCanceled marks the operation as canceled and returns status of the operation's update
func (*OperationManager) OperationFailed ¶
func (om *OperationManager) OperationFailed(operation internal.Operation, description string, err error, log logrus.FieldLogger) (internal.Operation, time.Duration, error)
OperationFailed marks the operation as failed and returns status of the operation's update
func (*OperationManager) OperationSucceeded ¶
func (om *OperationManager) OperationSucceeded(operation internal.Operation, description string, log logrus.FieldLogger) (internal.Operation, time.Duration, error)
OperationSucceeded marks the operation as succeeded and returns status of the operation's update
func (*OperationManager) RetryOperation ¶
func (om *OperationManager) RetryOperation(operation internal.Operation, errorMessage string, err error, retryInterval time.Duration, maxTime time.Duration, log logrus.FieldLogger) (internal.Operation, time.Duration, error)
RetryOperation checks if operation should be retried or if it's the status should be marked as failed
func (*OperationManager) RetryOperationOnce ¶
func (om *OperationManager) RetryOperationOnce(operation internal.Operation, errorMessage string, err error, wait time.Duration, log logrus.FieldLogger) (internal.Operation, time.Duration, error)
RetryOperationOnce retries the operation once and fails the operation when call second time
func (*OperationManager) RetryOperationWithoutFail ¶
func (om *OperationManager) RetryOperationWithoutFail(operation internal.Operation, stepName string, description string, retryInterval, maxTime time.Duration, log logrus.FieldLogger) (internal.Operation, time.Duration, error)
RetryOperationWithoutFail checks if operation should be retried or updates the status to InProgress, but omits setting the operation to failed if maxTime is reached
func (*OperationManager) UpdateOperation ¶
func (om *OperationManager) UpdateOperation(operation internal.Operation, update func(operation *internal.Operation), log logrus.FieldLogger) (internal.Operation, time.Duration, error)
UpdateOperation updates a given operation and handles conflict situation
type OperationStepProcessed ¶
type OperationStepProcessed struct { StepProcessed OldOperation internal.Operation Operation internal.Operation }
type OperationSucceeded ¶
type ProvisionOperationManager ¶
type ProvisionOperationManager struct {
// contains filtered or unexported fields
}
func NewProvisionOperationManager ¶
func NewProvisionOperationManager(storage storage.Operations) *ProvisionOperationManager
func (*ProvisionOperationManager) HandleError ¶
func (om *ProvisionOperationManager) HandleError(operation internal.ProvisioningOperation, err error, log logrus.FieldLogger, msg string) (internal.ProvisioningOperation, time.Duration, error)
func (*ProvisionOperationManager) OperationFailed ¶
func (om *ProvisionOperationManager) OperationFailed(operation internal.ProvisioningOperation, description string, err error, log logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)
OperationFailed marks the operation as failed and only repeats it if there is a storage error
func (*ProvisionOperationManager) OperationSucceeded ¶
func (om *ProvisionOperationManager) OperationSucceeded(operation internal.ProvisioningOperation, description string, log logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)
OperationSucceeded marks the operation as succeeded and only repeats it if there is a storage error
func (*ProvisionOperationManager) RetryOperation ¶
func (om *ProvisionOperationManager) RetryOperation(operation internal.ProvisioningOperation, errorMessage string, err error, retryInterval time.Duration, maxTime time.Duration, log logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)
RetryOperation retries an operation for at maxTime in retryInterval steps and fails the operation if retrying failed
func (*ProvisionOperationManager) RetryOperationOnce ¶
func (om *ProvisionOperationManager) RetryOperationOnce(operation internal.ProvisioningOperation, errorMessage string, err error, wait time.Duration, log logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)
RetryOperationOnce retries the operation once and fails the operation when call second time
func (*ProvisionOperationManager) SimpleUpdateOperation
deprecated
func (om *ProvisionOperationManager) SimpleUpdateOperation(operation internal.ProvisioningOperation) (internal.ProvisioningOperation, time.Duration)
Deprecated: SimpleUpdateOperation updates a given operation without handling conflicts. Should be used when operation's data mutations are not clear
func (*ProvisionOperationManager) UpdateOperation ¶
func (om *ProvisionOperationManager) UpdateOperation(operation internal.ProvisioningOperation, update func(operation *internal.ProvisioningOperation), log logrus.FieldLogger) (internal.ProvisioningOperation, time.Duration, error)
UpdateOperation updates a given operation and handles conflict situation
type ProvisioningStepProcessed ¶
type ProvisioningStepProcessed struct { StepProcessed Operation internal.ProvisioningOperation }
type ProvisioningSucceeded ¶
type ProvisioningSucceeded struct {
Operation internal.ProvisioningOperation
}
type StagedManager ¶
type StagedManager struct {
// contains filtered or unexported fields
}
func NewStagedManager ¶
func NewStagedManager(storage storage.Operations, pub event.Publisher, operationTimeout time.Duration, logger logrus.FieldLogger) *StagedManager
func (*StagedManager) AddStep ¶
func (m *StagedManager) AddStep(stageName string, step Step, cnd StepCondition) error
func (*StagedManager) DefineStages ¶
func (m *StagedManager) DefineStages(names []string)
func (*StagedManager) Execute ¶
func (m *StagedManager) Execute(operationID string) (time.Duration, error)
func (*StagedManager) GetAllStages ¶
func (m *StagedManager) GetAllStages() []string
func (*StagedManager) SpeedUp ¶
func (m *StagedManager) SpeedUp(speedFactor int64)
SpeedUp changes speedFactor parameter to reduce the sleep time if a step needs a retry. This method should only be used for testing purposes
type StepCondition ¶
type StepProcessed ¶
type StepWithCondition ¶
type StepWithCondition struct { Step // contains filtered or unexported fields }
type UpdateOperationManager ¶
type UpdateOperationManager struct {
// contains filtered or unexported fields
}
func NewUpdateOperationManager ¶
func NewUpdateOperationManager(storage storage.Operations) *UpdateOperationManager
func (*UpdateOperationManager) OperationFailed ¶
func (om *UpdateOperationManager) OperationFailed(operation internal.UpdatingOperation, description string, err error, log logrus.FieldLogger) (internal.UpdatingOperation, time.Duration, error)
OperationFailed marks the operation as failed and only repeats it if there is a storage error
func (*UpdateOperationManager) OperationSucceeded ¶
func (om *UpdateOperationManager) OperationSucceeded(operation internal.UpdatingOperation, description string, log logrus.FieldLogger) (internal.UpdatingOperation, time.Duration, error)
OperationSucceeded marks the operation as succeeded and only repeats it if there is a storage error
func (*UpdateOperationManager) RetryOperation ¶
func (om *UpdateOperationManager) RetryOperation(operation internal.UpdatingOperation, errorMessage string, err error, retryInterval time.Duration, maxTime time.Duration, log logrus.FieldLogger) (internal.UpdatingOperation, time.Duration, error)
RetryOperation retries an operation for at maxTime in retryInterval steps and fails the operation if retrying failed
func (*UpdateOperationManager) RetryOperationWithoutFail ¶
func (om *UpdateOperationManager) RetryOperationWithoutFail(operation internal.UpdatingOperation, description string, retryInterval, maxTime time.Duration, log logrus.FieldLogger) (internal.UpdatingOperation, time.Duration, error)
RetryOperationWithoutFail retries an operation for at maxTime in retryInterval steps and omits the operation if retrying failed
func (*UpdateOperationManager) SimpleUpdateOperation
deprecated
func (om *UpdateOperationManager) SimpleUpdateOperation(operation internal.UpdatingOperation) (internal.UpdatingOperation, time.Duration)
Deprecated: SimpleUpdateOperation updates a given operation without handling conflicts. Should be used when operation's data mutations are not clear
func (*UpdateOperationManager) UpdateOperation ¶
func (om *UpdateOperationManager) UpdateOperation(operation internal.UpdatingOperation, update func(operation *internal.UpdatingOperation), log logrus.FieldLogger) (internal.UpdatingOperation, time.Duration, error)
UpdateOperation updates a given operation
type UpdatingStepProcessed ¶
type UpdatingStepProcessed struct { StepProcessed OldOperation internal.UpdatingOperation Operation internal.UpdatingOperation }
type UpgradeClusterOperationManager ¶
type UpgradeClusterOperationManager struct {
// contains filtered or unexported fields
}
func NewUpgradeClusterOperationManager ¶
func NewUpgradeClusterOperationManager(storage storage.Operations) *UpgradeClusterOperationManager
func (*UpgradeClusterOperationManager) OperationCanceled ¶
func (om *UpgradeClusterOperationManager) OperationCanceled(operation internal.UpgradeClusterOperation, description string, log logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)
OperationSucceeded marks the operation as succeeded and only repeats it if there is a storage error
func (*UpgradeClusterOperationManager) OperationFailed ¶
func (om *UpgradeClusterOperationManager) OperationFailed(operation internal.UpgradeClusterOperation, description string, err error, log logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)
OperationFailed marks the operation as failed and only repeats it if there is a storage error
func (*UpgradeClusterOperationManager) OperationSucceeded ¶
func (om *UpgradeClusterOperationManager) OperationSucceeded(operation internal.UpgradeClusterOperation, description string, log logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)
OperationSucceeded marks the operation as succeeded and only repeats it if there is a storage error
func (*UpgradeClusterOperationManager) RetryOperation ¶
func (om *UpgradeClusterOperationManager) RetryOperation(operation internal.UpgradeClusterOperation, errorMessage string, err error, retryInterval time.Duration, maxTime time.Duration, log logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)
RetryOperation retries an operation for at maxTime in retryInterval steps and fails the operation if retrying failed
func (*UpgradeClusterOperationManager) RetryOperationWithoutFail ¶
func (om *UpgradeClusterOperationManager) RetryOperationWithoutFail(operation internal.UpgradeClusterOperation, description string, retryInterval, maxTime time.Duration, log logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)
RetryOperationWithoutFail retries an operation for at maxTime in retryInterval steps and omits the operation if retrying failed
func (*UpgradeClusterOperationManager) SimpleUpdateOperation
deprecated
func (om *UpgradeClusterOperationManager) SimpleUpdateOperation(operation internal.UpgradeClusterOperation) (internal.UpgradeClusterOperation, time.Duration)
Deprecated: SimpleUpdateOperation updates a given operation without handling conflicts. Should be used when operation's data mutations are not clear
func (*UpgradeClusterOperationManager) UpdateOperation ¶
func (om *UpgradeClusterOperationManager) UpdateOperation(operation internal.UpgradeClusterOperation, update func(operation *internal.UpgradeClusterOperation), log logrus.FieldLogger) (internal.UpgradeClusterOperation, time.Duration, error)
UpdateOperation updates a given operation
type UpgradeClusterStepProcessed ¶
type UpgradeClusterStepProcessed struct { StepProcessed OldOperation internal.UpgradeClusterOperation Operation internal.UpgradeClusterOperation }
type UpgradeKymaOperationManager ¶
type UpgradeKymaOperationManager struct {
// contains filtered or unexported fields
}
func NewUpgradeKymaOperationManager ¶
func NewUpgradeKymaOperationManager(storage storage.Operations) *UpgradeKymaOperationManager
func (*UpgradeKymaOperationManager) OperationCanceled ¶
func (om *UpgradeKymaOperationManager) OperationCanceled(operation internal.UpgradeKymaOperation, description string, log logrus.FieldLogger) (internal.UpgradeKymaOperation, time.Duration, error)
OperationSucceeded marks the operation as succeeded and only repeats it if there is a storage error
func (*UpgradeKymaOperationManager) OperationFailed ¶
func (om *UpgradeKymaOperationManager) OperationFailed(operation internal.UpgradeKymaOperation, description string, err error, log logrus.FieldLogger) (internal.UpgradeKymaOperation, time.Duration, error)
OperationFailed marks the operation as failed and only repeats it if there is a storage error
func (*UpgradeKymaOperationManager) OperationSucceeded ¶
func (om *UpgradeKymaOperationManager) OperationSucceeded(operation internal.UpgradeKymaOperation, description string, log logrus.FieldLogger) (internal.UpgradeKymaOperation, time.Duration, error)
OperationSucceeded marks the operation as succeeded and only repeats it if there is a storage error
func (*UpgradeKymaOperationManager) RetryOperation ¶
func (om *UpgradeKymaOperationManager) RetryOperation(operation internal.UpgradeKymaOperation, errorMessage string, err error, retryInterval time.Duration, maxTime time.Duration, log logrus.FieldLogger) (internal.UpgradeKymaOperation, time.Duration, error)
RetryOperation retries an operation for at maxTime in retryInterval steps and fails the operation if retrying failed
func (*UpgradeKymaOperationManager) RetryOperationWithoutFail ¶
func (om *UpgradeKymaOperationManager) RetryOperationWithoutFail(operation internal.UpgradeKymaOperation, description string, retryInterval, maxTime time.Duration, log logrus.FieldLogger) (internal.UpgradeKymaOperation, time.Duration, error)
RetryOperationWithoutFail retries an operation for at maxTime in retryInterval steps and omits the operation if retrying failed
func (*UpgradeKymaOperationManager) SimpleUpdateOperation
deprecated
func (om *UpgradeKymaOperationManager) SimpleUpdateOperation(operation internal.UpgradeKymaOperation) (internal.UpgradeKymaOperation, time.Duration)
Deprecated: SimpleUpdateOperation updates a given operation without handling conflicts. Should be used when operation's data mutations are not clear
func (*UpgradeKymaOperationManager) UpdateOperation ¶
func (om *UpgradeKymaOperationManager) UpdateOperation(operation internal.UpgradeKymaOperation, update func(operation *internal.UpgradeKymaOperation), log logrus.FieldLogger) (internal.UpgradeKymaOperation, time.Duration, error)
UpdateOperation updates a given operation and handles conflict situation
type UpgradeKymaStepProcessed ¶
type UpgradeKymaStepProcessed struct { StepProcessed OldOperation internal.UpgradeKymaOperation Operation internal.UpgradeKymaOperation }