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, ...) (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, ...) (internal.DeprovisioningOperation, time.Duration, error)
- func (om *DeprovisionOperationManager) RetryOperationOnce(operation internal.DeprovisioningOperation, errorMessage string, ...) (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)
- type DeprovisioningStepProcessed
- type Executor
- type ProvisionOperationManager
- func (om *ProvisionOperationManager) OperationFailed(operation internal.ProvisioningOperation, description string, ...) (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, ...) (internal.ProvisioningOperation, time.Duration, error)
- func (om *ProvisionOperationManager) RetryOperationOnce(operation internal.ProvisioningOperation, errorMessage string, ...) (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)
- type ProvisioningStepProcessed
- type Queue
- type StepProcessed
- 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, ...) (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, ...) (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)
- 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, ...) (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, ...) (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)
- 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, 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, 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, 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)
UpdateOperation updates a given operation and handles conflict situation
type DeprovisioningStepProcessed ¶
type DeprovisioningStepProcessed struct { StepProcessed OldOperation internal.DeprovisioningOperation Operation internal.DeprovisioningOperation }
type ProvisionOperationManager ¶
type ProvisionOperationManager struct {
// contains filtered or unexported fields
}
func NewProvisionOperationManager ¶
func NewProvisionOperationManager(storage storage.Operations) *ProvisionOperationManager
func (*ProvisionOperationManager) OperationFailed ¶
func (om *ProvisionOperationManager) OperationFailed(operation internal.ProvisioningOperation, description string, 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, 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, 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)
UpdateOperation updates a given operation and handles conflict situation
type ProvisioningStepProcessed ¶
type ProvisioningStepProcessed struct { StepProcessed OldOperation internal.ProvisioningOperation Operation internal.ProvisioningOperation }
type StepProcessed ¶
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, 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, 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)
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, 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, 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)
UpdateOperation updates a given operation and handles conflict situation
type UpgradeKymaStepProcessed ¶
type UpgradeKymaStepProcessed struct { StepProcessed OldOperation internal.UpgradeKymaOperation Operation internal.UpgradeKymaOperation }