process

package
v0.0.0-...-6d4a0cd Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 30, 2020 License: Apache-2.0, Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

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) (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 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 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{})

Source Files

View all Source files

Directories

Path Synopsis
automock
automock
input
input/automock

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.