Versions in this module Expand all Collapse all v0 v0.0.1 Nov 8, 2023 Changes in this version + type DeprovisionOperationManager struct + func NewDeprovisionOperationManager(storage storage.Operations) *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 struct + OldOperation internal.DeprovisioningOperation + Operation internal.DeprovisioningOperation + type Executor interface + Execute func(operationID string) (time.Duration, error) + type OperationManager struct + func NewOperationManager(storage storage.Operations) *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 struct + OldOperation internal.Operation + Operation internal.Operation + type OperationSucceeded struct + Operation internal.Operation + type ProvisionOperationManager struct + func NewProvisionOperationManager(storage storage.Operations) *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) + func (om *ProvisionOperationManager) UpdateOperation(operation internal.ProvisioningOperation, ...) (internal.ProvisioningOperation, time.Duration, error) + type ProvisioningStepProcessed struct + Operation internal.ProvisioningOperation + type ProvisioningSucceeded struct + Operation internal.ProvisioningOperation + type Queue struct + func NewQueue(executor Executor, log logrus.FieldLogger) *Queue + func (q *Queue) Add(processId string) + func (q *Queue) AddAfter(processId string, duration time.Duration) + func (q *Queue) Run(stop <-chan struct{}, workersAmount int) + func (q *Queue) ShutDown() + func (q *Queue) SpeedUp(speedFactor int64) + type StagedManager struct + func NewStagedManager(storage storage.Operations, pub event.Publisher, ...) *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 StagedManagerConfiguration struct + MaxStepProcessingTime time.Duration + WorkersAmount int + func (c StagedManagerConfiguration) String() string + type Step interface + Name func() string + Run func(operation internal.Operation, logger logrus.FieldLogger) (internal.Operation, time.Duration, error) + type StepCondition func(operation internal.Operation) bool + type StepProcessed struct + Duration time.Duration + Error error + StepName string + When time.Duration + type StepWithCondition struct + type UpdateOperationManager struct + func NewUpdateOperationManager(storage storage.Operations) *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) + func (om *UpdateOperationManager) UpdateOperation(operation internal.UpdatingOperation, ...) (internal.UpdatingOperation, time.Duration, error) + type UpdatingStepProcessed struct + OldOperation internal.UpdatingOperation + Operation internal.UpdatingOperation + type UpgradeClusterOperationManager struct + func NewUpgradeClusterOperationManager(storage storage.Operations) *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) + func (om *UpgradeClusterOperationManager) UpdateOperation(operation internal.UpgradeClusterOperation, ...) (internal.UpgradeClusterOperation, time.Duration, error) + type UpgradeClusterStepProcessed struct + OldOperation internal.UpgradeClusterOperation + Operation internal.UpgradeClusterOperation + type UpgradeKymaOperationManager struct + func NewUpgradeKymaOperationManager(storage storage.Operations) *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) + func (om *UpgradeKymaOperationManager) UpdateOperation(operation internal.UpgradeKymaOperation, ...) (internal.UpgradeKymaOperation, time.Duration, error) + type UpgradeKymaStepProcessed struct + OldOperation internal.UpgradeKymaOperation + Operation internal.UpgradeKymaOperation