process

Documentation

Index

• type DeprovisionOperationManager
  • 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) (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, error)
• type DeprovisioningStepProcessed
• type Executor
• type ProvisionOperationManager
  • func NewProvisionOperationManager(storage storage.Operations) *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) UpdateOperation(operation internal.ProvisioningOperation) (internal.ProvisioningOperation, time.Duration)
• type ProvisioningStepProcessed
• type Queue
  • func NewQueue(executor Executor) *Queue
  • func (q *Queue) Add(processId string)
  • func (q *Queue) Run(stop <-chan struct{})
• type StepProcessed

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) (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) (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) (internal.DeprovisioningOperation, time.Duration, error)

UpdateOperation updates a given operation

type DeprovisioningStepProcessed

type DeprovisioningStepProcessed struct {
	StepProcessed
	OldOperation internal.DeprovisioningOperation
	Operation    internal.DeprovisioningOperation
}

type Executor

type Executor interface {
	Execute(operationID string) (time.Duration, error)
}

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) (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) (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) UpdateOperation

func (om *ProvisionOperationManager) UpdateOperation(operation internal.ProvisioningOperation) (internal.ProvisioningOperation, time.Duration)

UpdateOperation updates a given operation

type ProvisioningStepProcessed

type ProvisioningStepProcessed struct {
	StepProcessed
	OldOperation internal.ProvisioningOperation
	Operation    internal.ProvisioningOperation
}

type Queue

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

func NewQueue

func NewQueue(executor Executor) *Queue

func (*Queue) Add

func (q *Queue) Add(processId string)

func (*Queue) Run

func (q *Queue) Run(stop <-chan struct{})

type StepProcessed

type StepProcessed struct {
	StepName string
	Duration time.Duration
	When     time.Duration
	Error    error
}